add spring boot

Author: kimmking

04fx/springboot01/pom.xml

@@ -0,0 +1,70 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter-parent</artifactId>
+ <version>2.0.9.RELEASE</version>
+ <relativePath/> <!-- lookup parent from repository -->
+ </parent>
+ <groupId>io.kimmking</groupId>
+ <artifactId>springboot01</artifactId>
+ <version>0.0.1-SNAPSHOT</version>
+ <name>springboot01</name>
+ <description>Demo project for Spring Boot</description>
+
+ <properties>
+ <java.version>1.8</java.version>
+ </properties>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter</artifactId>
+ </dependency>
+
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter-activemq</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter-web</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.activemq</groupId>
+ <artifactId>activemq-pool</artifactId>
+ <version>5.15.0</version>
+ </dependency>
+
+
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter-data-mongodb</artifactId>
+ </dependency>
+
+
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter-test</artifactId>
+ <scope>test</scope>
+ <exclusions>
+ <exclusion>
+ <groupId>org.junit.vintage</groupId>
+ <artifactId>junit-vintage-engine</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-maven-plugin</artifactId>
+ </plugin>
+ </plugins>
+ </build>
+
+</project>

04fx/springboot01/src/main/java/io/kimmking/springboot01/Springboot01Application.java

@@ -0,0 +1,18 @@
+packageio.kimmking.springboot01;
+
+importorg.springframework.boot.SpringApplication;
+importorg.springframework.boot.autoconfigure.EnableAutoConfiguration;
+importorg.springframework.boot.autoconfigure.SpringBootApplication;
+importorg.springframework.data.mongodb.repository.config.EnableMongoRepositories;
+importorg.springframework.jms.annotation.EnableJms;
+
+@SpringBootApplication
+@EnableJms//启动消息队列
+@EnableMongoRepositories
+publicclassSpringboot01Application{
+
+publicstaticvoidmain(String[] args){
+SpringApplication.run(Springboot01Application.class, args);
+ }
+
+}

04fx/springboot01/src/main/java/io/kimmking/springboot01/jms/BeanConfig.java

@@ -0,0 +1,73 @@
+packageio.kimmking.springboot01.jms;
+
+importorg.apache.activemq.ActiveMQConnectionFactory;
+importorg.apache.activemq.command.ActiveMQQueue;
+importorg.apache.activemq.command.ActiveMQTopic;
+importorg.springframework.beans.factory.annotation.Value;
+importorg.springframework.context.annotation.Bean;
+importorg.springframework.context.annotation.Configuration;
+importorg.springframework.jms.config.JmsListenerContainerFactory;
+importorg.springframework.jms.config.SimpleJmsListenerContainerFactory;
+importorg.springframework.jms.core.JmsMessagingTemplate;
+
+importjavax.jms.ConnectionFactory;
+importjavax.jms.Queue;
+importjavax.jms.Topic;
+
+@Configuration
+publicclassBeanConfig{
+
+@Value("${spring.activemq.broker-url}")
+privateStringbrokerUrl;
+
+@Value("${spring.activemq.user}")
+privateStringusername;
+
+@Value("${spring.activemq.topic-name}")
+privateStringpassword;
+
+@Value("${spring.activemq.queue-name}")
+privateStringqueueName;
+
+@Value("${spring.activemq.topic-name}")
+privateStringtopicName;
+
+@Bean(name = "queue")
+publicQueuequeue(){
+returnnewActiveMQQueue(queueName);
+ }
+
+@Bean(name = "topic")
+publicTopictopic(){
+returnnewActiveMQTopic(topicName);
+ }
+
+@Bean
+publicConnectionFactoryconnectionFactory(){
+returnnewActiveMQConnectionFactory(username, password, brokerUrl);
+ }
+
+@Bean
+publicJmsMessagingTemplatejmsMessageTemplate(){
+returnnewJmsMessagingTemplate(connectionFactory());
+ }
+
+// 在Queue模式中，对消息的监听需要对containerFactory进行配置
+@Bean("queueListener")
+publicJmsListenerContainerFactory<?> queueJmsListenerContainerFactory(ConnectionFactoryconnectionFactory){
+SimpleJmsListenerContainerFactoryfactory = newSimpleJmsListenerContainerFactory();
+factory.setConnectionFactory(connectionFactory);
+factory.setPubSubDomain(false);
+returnfactory;
+ }
+
+//在Topic模式中，对消息的监听需要对containerFactory进行配置
+@Bean("topicListener")
+publicJmsListenerContainerFactory<?> topicJmsListenerContainerFactory(ConnectionFactoryconnectionFactory){
+SimpleJmsListenerContainerFactoryfactory = newSimpleJmsListenerContainerFactory();
+factory.setConnectionFactory(connectionFactory);
+factory.setPubSubDomain(true);
+returnfactory;
+ }
+}
+

04fx/springboot01/src/main/java/io/kimmking/springboot01/jms/ProducerController.java

@@ -0,0 +1,44 @@
+packageio.kimmking.springboot01.jms;
+
+importorg.springframework.beans.factory.annotation.Autowired;
+importorg.springframework.jms.core.JmsMessagingTemplate;
+importorg.springframework.web.bind.annotation.PostMapping;
+importorg.springframework.web.bind.annotation.RequestBody;
+importorg.springframework.web.bind.annotation.RestController;
+importjavax.jms.Destination;
+importjavax.jms.Queue;
+importjavax.jms.Topic;
+
+@RestController
+publicclassProducerController
+{
+@Autowired
+privateJmsMessagingTemplatejmsMessagingTemplate;
+
+@Autowired
+privateQueuequeue;
+
+@Autowired
+privateTopictopic;
+
+
+// curl http://localhost:8080/queue/test -X POST -d "testququuquqq"
+@PostMapping("/queue/test")
+publicStringsendQueue(@RequestBodyStringstr){
+this.sendMessage(this.queue, str);
+return"success";
+ }
+
+
+//curl http://localhost:8080/topic/test -X POST -d "testtopiccccc"
+@PostMapping("/topic/test")
+publicStringsendTopic(@RequestBodyStringstr){
+this.sendMessage(this.topic, str);
+return"success";
+ }
+
+// 发送消息，destination是发送到的队列，message是待发送的消息
+privatevoidsendMessage(Destinationdestination, finalStringmessage){
+jmsMessagingTemplate.convertAndSend(destination, message);
+ }
+}

04fx/springboot01/src/main/java/io/kimmking/springboot01/jms/QueueConsumerListener.java

@@ -0,0 +1,13 @@
+packageio.kimmking.springboot01.jms;
+
+importorg.springframework.jms.annotation.JmsListener;
+importorg.springframework.stereotype.Component;
+
+@Component
+publicclassQueueConsumerListener{
+//queue模式的消费者
+@JmsListener(destination = "${spring.activemq.queue-name}", containerFactory = "queueListener")
+publicvoidreadActiveQueue(Stringmessage){
+System.out.println("queue接受到：" + message);
+ }
+}

04fx/springboot01/src/main/java/io/kimmking/springboot01/jms/TopicConsumerListener.java

@@ -0,0 +1,13 @@
+packageio.kimmking.springboot01.jms;
+
+importorg.springframework.jms.annotation.JmsListener;
+importorg.springframework.stereotype.Component;
+
+@Component
+publicclassTopicConsumerListener{
+//topic模式的消费者
+@JmsListener(destination = "${spring.activemq.topic-name}", containerFactory = "topicListener")
+publicvoidreadActiveQueue(Stringmessage){
+System.out.println("topic接受到：" + message);
+ }
+}

04fx/springboot01/src/main/java/io/kimmking/springboot01/mongo/MongoController.java

@@ -0,0 +1,46 @@
+packageio.kimmking.springboot01.mongo;
+
+importorg.springframework.beans.factory.annotation.Autowired;
+importorg.springframework.boot.SpringApplication;
+importorg.springframework.boot.autoconfigure.EnableAutoConfiguration;
+importorg.springframework.data.mongodb.core.MongoTemplate;
+importorg.springframework.data.mongodb.core.query.Criteria;
+importorg.springframework.data.mongodb.core.query.Query;
+importorg.springframework.stereotype.Controller;
+importorg.springframework.web.bind.annotation.RequestMapping;
+importorg.springframework.web.bind.annotation.ResponseBody;
+
+importjava.util.List;
+
+@Controller
+@EnableAutoConfiguration
+publicclassMongoController{
+
+@Autowired
+MongoTemplatemongoTemplate;
+
+@RequestMapping("/mongo/list")
+@ResponseBody
+List<User> mongo(){
+//Query query = new Query();
+//query.addCriteria(Criteria.where("name").is("kk"));
+//String name = mongotemplate.findOne(query, User.class).getName();
+returnmongoTemplate.findAll(User.class);
+ }
+
+@RequestMapping("/mongo/test")
+@ResponseBody
+Stringtest(){
+//Query query = new Query();
+//query.addCriteria(Criteria.where("name").is("kk"));
+//String name = mongotemplate.findOne(query, User.class).getName();
+Useruser = newUser();
+user.setId(newLong(System.currentTimeMillis()).toString());
+user.setName("KK" + System.currentTimeMillis() % 1000);
+user.setAge("33");
+mongoTemplate.insert(user);
+return"test ok";
+ }
+
+
+}

04fx/springboot01/src/main/java/io/kimmking/springboot01/mongo/User.java

@@ -0,0 +1,85 @@
+packageio.kimmking.springboot01.mongo;
+
+importorg.springframework.data.annotation.Id;
+importorg.springframework.data.mongodb.core.mapping.Document;
+importorg.springframework.data.mongodb.core.mapping.Field;
+
+@Document(collection = "user")
+publicclassUser{
+
+@Id
+privateStringid;
+@Field("username")
+privateStringusername;
+privateStringpassword;
+privateStringregisterTime;
+privateStringphone;
+privateStringname;
+privateStringsex;
+privateStringage;
+
+publicStringgetId(){
+returnid;
+ }
+
+publicvoidsetId(Stringid){
+this.id = id;
+ }
+
+publicStringgetUsername(){
+returnusername;
+ }
+
+publicvoidsetUsername(Stringusername){
+this.username = username;
+ }
+
+publicStringgetPassword(){
+returnpassword;
+ }
+
+publicvoidsetPassword(Stringpassword){
+this.password = password;
+ }
+
+publicStringgetRegisterTime(){
+returnregisterTime;
+ }
+
+publicvoidsetRegisterTime(StringregisterTime){
+this.registerTime = registerTime;
+ }
+
+publicStringgetPhone(){
+returnphone;
+ }
+
+publicvoidsetPhone(Stringphone){
+this.phone = phone;
+ }
+
+publicStringgetName(){
+returnname;
+ }
+
+publicvoidsetName(Stringname){
+this.name = name;
+ }
+
+publicStringgetSex(){
+returnsex;
+ }
+
+publicvoidsetSex(Stringsex){
+this.sex = sex;
+ }
+
+publicStringgetAge(){
+returnage;
+ }
+
+publicvoidsetAge(Stringage){
+this.age = age;
+ }
+
+}