.gitignore

@@ -1,24 +1,30 @@
-# ---> Java
-# Compiled class file
-*.class
+.mvn/
+target/
+!**/src/main/**
+!**/src/test/**
 
-# Log file
-*.log
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
 
-# BlueJ files
-*.ctxt
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
 
-# Mobile Tools for Java (J2ME)
-.mtj.tmp/
-
-# Package Files #
-*.jar
-*.war
-*.ear
-*.zip
-*.tar.gz
-*.rar
-
-# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
-hs_err_pid*
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
 
+### VS Code ###
+.vscode/

README.md

@@ -1,3 +1,18 @@
-# spring-boot-starter-activemq-demo
+这是一个仅使用spring-boot-starter-activemq的演示示例
+
+使用spring-boot-starter-activemq后变得对于mq消息的生产和消费非常简易，具体请看想应的示例代码。
+
+与http://gitea.vcarecity.com/ewsq/Spring-boot-starter-activeMQ-JmsMessagingTemplate不同的是，这里面演示了怎么去获取配置文件中的相应信息来配置连接。
+
+
+
+knife4j-spring-boot-starter 是用来生成API文档的，启动后访问API的地址是：
+
+http://127.0.0.1:9090/doc.html
+
+
+
+这里也演示了使用SpringBoot自带的quartz去做定时任务。
+
+
 
-spring-boot-starter-activemq-demo

http/ProducerController.http

@@ -0,0 +1,25 @@
+### queue
+POST http://{{host}}/api/mq/queue/test
+Content-Type: application/json
+
+{
+  "tableName": "queue",
+  "stamp_start": "2020-11-01 14:58:23",
+  "stamp_end": "2020-11-01 15:58:23",
+  "offset": 0,
+  "limit": 10
+}
+
+### topic
+POST http://{{host}}/api/mq/topic/test
+Content-Type: application/json
+
+{
+  "tableName": "topic",
+  "stamp_start": "2020-11-01 14:58:23",
+  "stamp_end": "2020-11-01 15:58:23",
+  "offset": 0,
+  "limit": 10
+}
+
+

http/http-client.env.json

@@ -0,0 +1,12 @@
+{
+  "dev": {
+    "host": "127.0.0.1:9090",
+    "limit": "20",
+    "offset": "0"
+  },
+  "production": {
+    "host": "127.0.0.1:9090",
+    "limit": "20",
+    "offset": "0"
+  }
+}

pom.xml

@@ -0,0 +1,213 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.vcarecity</groupId>
+    <artifactId>spring-boot-starter-activemq-demo</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+
+    <distributionManagement>
+        <repository>
+            <id>nexus-releases</id>
+            <name>Nexus Release Repository</name>
+            <url>http://maven.vcarecity.com/nexus/content/repositories/releases/</url>
+        </repository>
+        <snapshotRepository>
+            <id>nexus-snapshots</id>
+            <name>Nexus Snapshot Repository</name>
+            <url>http://maven.vcarecity.com/nexus/content/repositories/snapshots/</url>
+        </snapshotRepository>
+    </distributionManagement>
+
+
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.2.1.RELEASE</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+
+    <properties>
+        <java.version>1.8</java.version>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <junit.version>4.13.1</junit.version>
+    </properties>
+
+    <dependencies>
+
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>${junit.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.11</version>
+        </dependency>
+        <!-- quartz -->
+        <dependency>
+            <groupId>org.quartz-scheduler</groupId>
+            <artifactId>quartz</artifactId>
+        </dependency>
+        <!-- Spring Boot Starter -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+
+        <!-- Spring Boot Starter Activemq (JMS) -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-activemq</artifactId>
+        </dependency>
+
+        <!-- Spring Boot Starter Test -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>com.github.xiaoymin</groupId>
+            <artifactId>knife4j-spring-boot-starter</artifactId>
+            <!--在引用时请在maven中央仓库搜索最新版本号 -->
+            <version>2.0.3</version>
+        </dependency>
+
+        <!-- xk-time 是时间转换，计算，格式化，解析，日历和cron表达式等的工具，使用Java8，线程安全，简单易用，多达70几种常用日期格式化模板，支持Java8时间类和Date，轻量级，无第三方依赖 -->
+        <!-- https://www.oschina.net/news/119438/xk-time-2-2-0-released -->
+        <dependency>
+            <groupId>com.github.xkzhangsan</groupId>
+            <artifactId>xk-time</artifactId>
+            <version>2.2.0</version>
+        </dependency>
+
+    </dependencies>
+
+    <build>
+        <finalName>${project.artifactId}</finalName>
+        <plugins>
+            <!-- java编译插件 -->
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.2</version>
+                <configuration>
+                    <source>8</source>
+                    <target>8</target>
+                    <encoding>UTF-8</encoding>
+                </configuration>
+            </plugin>
+            <!--添加配置跳过测试-->
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-surefire-plugin</artifactId>
+                <version>2.22.1</version>
+                <configuration>
+                    <skipTests>true</skipTests>
+                </configuration>
+            </plugin>
+            <!--添加配置跳过测试-->
+
+            <!--Copy resource -->
+            <plugin>
+                <artifactId>maven-resources-plugin</artifactId>
+                <version>2.7</version>
+
+                <configuration>
+                    <encoding>UTF-8</encoding>
+                </configuration>
+
+                <executions>
+                    <execution>
+                        <id>copy-resource</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>copy-resources</goal>
+                        </goals>
+                        <configuration>
+                            <outputDirectory>${project.build.directory}/config</outputDirectory>
+                            <resources>
+                                <resource>
+                                    <directory>${project.basedir}/src/main/resources</directory>
+                                </resource>
+                            </resources>
+                        </configuration>
+                    </execution>
+                    <execution>
+                        <id>copy-sh</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>copy-resources</goal>
+                        </goals>
+                        <configuration>
+                            <outputDirectory>${project.build.directory}</outputDirectory>
+                            <resources>
+                                <resource>
+                                    <directory>${project.basedir}/sh</directory>
+                                </resource>
+                            </resources>
+                        </configuration>
+                    </execution>
+                    <execution>
+                        <id>copy-md</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>copy-resources</goal>
+                        </goals>
+                        <configuration>
+                            <outputDirectory>${project.build.directory}</outputDirectory>
+                            <resources>
+                                <resource>
+                                    <directory>${project.basedir}/md</directory>
+                                </resource>
+                            </resources>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-dependency-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>copy-dependencies</goal>
+                        </goals>
+                        <configuration>
+                            <outputDirectory>${project.build.directory}/libs</outputDirectory>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-jar-plugin</artifactId>
+                <version>2.4</version>
+                <configuration>
+                    <archive>
+                        <manifest>
+                            <addClasspath>true</addClasspath>
+                            <classpathPrefix>libs/</classpathPrefix>
+                            <mainClass>com.vcarecity.AppRun</mainClass>
+                        </manifest>
+                    </archive>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

src/main/java/com/vcarecity/AppRun.java

@@ -0,0 +1,23 @@
+package com.vcarecity;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.jms.annotation.EnableJms;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author Zheng Jie
+ * @date 2018/11/15 9:20:19
+ */
+@EnableAsync
+@RestController
+@SpringBootApplication
+@EnableTransactionManagement
+@EnableJms    //启动消息队列
+public class AppRun {
+    public static void main(String[] args) {
+        SpringApplication.run(AppRun.class, args);
+    }
+}

src/main/java/com/vcarecity/mq/config/ActiveMQConfig.java

@@ -0,0 +1,71 @@
+package com.vcarecity.mq.config;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.command.ActiveMQQueue;
+import org.apache.activemq.command.ActiveMQTopic;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.jms.config.JmsListenerContainerFactory;
+import org.springframework.jms.config.SimpleJmsListenerContainerFactory;
+import org.springframework.jms.core.JmsMessagingTemplate;
+
+import javax.jms.ConnectionFactory;
+import javax.jms.Queue;
+import javax.jms.Topic;
+
+@Configuration
+public class ActiveMQConfig {
+
+    @Value("${spring.activemq.broker-url}")
+    private String brokerUrl;
+
+    @Value("${spring.activemq.user}")
+    private String username;
+
+    @Value("${spring.activemq.topic-name}")
+    private String password;
+
+    @Value("${spring.activemq.queue-name}")
+    private String queueName;
+
+    @Value("${spring.activemq.topic-name}")
+    private String topicName;
+
+    @Bean(name = "queue")
+    public Queue queue() {
+        return new ActiveMQQueue(queueName);
+    }
+
+    @Bean(name = "topic")
+    public Topic topic() {
+        return new ActiveMQTopic(topicName);
+    }
+
+    @Bean
+    public ConnectionFactory connectionFactory() {
+        return new ActiveMQConnectionFactory(username, password, brokerUrl);
+    }
+
+    @Bean
+    public JmsMessagingTemplate jmsMessageTemplate() {
+        return new JmsMessagingTemplate(connectionFactory());
+    }
+
+    // 在Queue模式中，对消息的监听需要对containerFactory进行配置
+    @Bean("queueListener")
+    public JmsListenerContainerFactory<?> queueJmsListenerContainerFactory(ConnectionFactory connectionFactory) {
+        SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory();
+        factory.setConnectionFactory(connectionFactory);
+        factory.setPubSubDomain(false);
+        return factory;
+    }
+    //在Topic模式中，对消息的监听需要对containerFactory进行配置
+    @Bean("topicListener")
+    public JmsListenerContainerFactory<?> topicJmsListenerContainerFactory(ConnectionFactory connectionFactory) {
+        SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory();
+        factory.setConnectionFactory(connectionFactory);
+        factory.setPubSubDomain(true);
+        return factory;
+    }
+}

src/main/java/com/vcarecity/mq/consumer/QueueConsumerListener.java

@@ -0,0 +1,14 @@
+package com.vcarecity.mq.consumer;
+
+import org.springframework.jms.annotation.JmsListener;
+import org.springframework.stereotype.Component;
+
+@Component
+public class QueueConsumerListener
+{
+    //queue模式的消费者
+    @JmsListener(destination="${spring.activemq.queue-name}", containerFactory="queueListener")
+    public void readActiveQueue(String message) {
+        System.out.println("queue接收到：" + message);
+    }
+}

src/main/java/com/vcarecity/mq/consumer/TopicConsumerListener.java

@@ -0,0 +1,14 @@
+package com.vcarecity.mq.consumer;
+
+import org.springframework.jms.annotation.JmsListener;
+import org.springframework.stereotype.Component;
+
+@Component
+public class TopicConsumerListener
+{
+    //topic模式的消费者
+    @JmsListener(destination="${spring.activemq.topic-name}", containerFactory="topicListener")
+    public void readActiveQueue(String message) {
+        System.out.println("topic接收到：" + message);
+    }
+}

src/main/java/com/vcarecity/mq/rest/ProducerController.java

@@ -0,0 +1,45 @@
+package com.vcarecity.mq.rest;
+
+import io.swagger.annotations.Api;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jms.core.JmsMessagingTemplate;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.jms.Destination;
+import javax.jms.Queue;
+import javax.jms.Topic;
+
+@Api(tags = "消息队列：mq")
+@RestController
+@RequestMapping("/api/mq")
+public class ProducerController
+{
+    @Autowired
+    private JmsMessagingTemplate jmsMessagingTemplate;
+
+    @Autowired
+    private Queue queue;
+
+    @Autowired
+    private Topic topic;
+
+    @PostMapping("/queue/test")
+    public String sendQueue(@RequestBody String str) {
+        this.sendMessage(this.queue, str);
+        return "success";
+    }
+
+    @PostMapping("/topic/test")
+    public String sendTopic(@RequestBody String str) {
+        this.sendMessage(this.topic, str);
+        return "success";
+    }
+
+    // 发送消息，destination是发送到的队列，message是待发送的消息
+    private void sendMessage(Destination destination, final String message){
+        jmsMessagingTemplate.convertAndSend(destination, message);
+    }
+}

src/main/java/com/vcarecity/quartz/task/TelNbTokenCheckTask.java

@@ -0,0 +1,16 @@
+package com.vcarecity.quartz.task;
+
+import com.vcarecity.util.Symbol;
+import com.vcarecity.util.TimeUtil;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+public class TelNbTokenCheckTask {
+    @Scheduled(cron = Symbol.CRON+"10 * * * * ? ")
+    public void checkTelNbToken() {
+        System.out.println("TimeUtil.getLocalTime():"+ TimeUtil.getLocalTime());
+    }
+}
+
+

src/main/java/com/vcarecity/swagger/config/SwaggerConfig.java

@@ -0,0 +1,42 @@
+package com.vcarecity.swagger.config;
+
+import com.github.xiaoymin.knife4j.spring.annotations.EnableKnife4j;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+import springfox.bean.validators.configuration.BeanValidatorPluginsConfiguration;
+import springfox.documentation.builders.ApiInfoBuilder;
+import springfox.documentation.builders.PathSelectors;
+import springfox.documentation.builders.RequestHandlerSelectors;
+import springfox.documentation.service.ApiInfo;
+import springfox.documentation.service.Contact;
+import springfox.documentation.spi.DocumentationType;
+import springfox.documentation.spring.web.plugins.Docket;
+import springfox.documentation.swagger2.annotations.EnableSwagger2;
+
+/**
+ * 配置
+ */
+
+@Configuration
+@EnableSwagger2
+@EnableKnife4j
+@Import(BeanValidatorPluginsConfiguration.class)
+public class SwaggerConfig {
+
+    @Bean(value = "defaultApi2")
+    public Docket defaultApi2() {
+        Docket docket = new Docket(DocumentationType.SWAGGER_2).apiInfo(apiInfo())
+                .select()
+                // 这里指定Controller扫描包路径
+                .apis(RequestHandlerSelectors.basePackage("com.vcarecity"))
+                .paths(PathSelectors.any()).build();
+        return docket;
+    }
+
+    private ApiInfo apiInfo() {
+        Contact contact = new Contact("pengsn", "", "");
+        return new ApiInfoBuilder().title("基本应用接口描述").
+                description("基本应用接口描述").contact(contact).version("1.0").build();
+    }
+}

src/main/java/com/vcarecity/util/Symbol.java

@@ -0,0 +1,63 @@
+package com.vcarecity.util;
+
+/**
+ * 符号.
+ */
+public class Symbol
+{
+    /**
+     * %百分号.
+     */
+    public static final String PERCENT = "%";
+
+    /**
+     * ,逗号.
+     */
+    public static final String COMMA = ",";
+
+    /**
+     * .点逗号.
+     */
+    public static final String DOT = ".";
+
+    /**
+     * /斜杠.
+     */
+    public static final String SLASH = "/";
+
+    /**
+     * -横杠.
+     */
+    public static final String LINE = "-";
+
+    /**
+     * 空字符串.
+     */
+    public static final String EMPTY = "";
+
+    /**
+     * _下划线.
+     */
+    public static final String UNDERLINE = "_";
+
+    /**
+     * !感叹号.
+     */
+    public static final String EXCLAMATORY_MARK = "!";
+
+    /**
+     * [左方括号.
+     */
+    public static final String LEFT_SQUARE_BRACKETS = "[";
+
+    /**
+     * ]右方括号.
+     */
+    public static final String RIGHT_SQUARE_BRACKETS = "]";
+
+    /**
+     *
+     */
+    public static final String CRON = "*/";
+
+}

src/main/resources/application-dev.yml

@@ -0,0 +1,17 @@
+#配置数据源
+spring:
+  activemq:
+    broker-url: tcp://127.0.0.1:61616
+    user: admin
+    password: admin
+    close-timeout: 15s   # 在考虑结束之前等待的时间
+    in-memory: true      # 默认代理URL是否应该在内存中。如果指定了显式代理，则忽略此值。
+    non-blocking-redelivery: false  # 是否在回滚回滚消息之前停止消息传递。这意味着当启用此命令时，消息顺序不会被保留。
+    send-timeout: 0     # 等待消息发送响应的时间。设置为0等待永远。
+    queue-name: active.queue
+    topic-name: active.topic.name.model
+
+  pool:
+    enabled: true
+    max-connections: 10   #连接池最大连接数
+    idle-timeout: 30000   #空闲的连接过期时间，默认为30秒

src/main/resources/application-prod.yml

@@ -0,0 +1,17 @@
+#配置数据源
+spring:
+  activemq:
+    broker-url: tcp://127.0.0.1:61616
+    user: admin
+    password: admin
+    close-timeout: 15s   # 在考虑结束之前等待的时间
+    in-memory: true      # 默认代理URL是否应该在内存中。如果指定了显式代理，则忽略此值。
+    non-blocking-redelivery: false  # 是否在回滚回滚消息之前停止消息传递。这意味着当启用此命令时，消息顺序不会被保留。
+    send-timeout: 0     # 等待消息发送响应的时间。设置为0等待永远。
+    queue-name: active.queue
+    topic-name: active.topic.name.model
+
+  pool:
+    enabled: true
+    max-connections: 10   #连接池最大连接数
+    idle-timeout: 30000   #空闲的连接过期时间，默认为30秒

src/main/resources/application.yml

@@ -0,0 +1,21 @@
+server:
+  port: 9090
+
+spring:
+  freemarker:
+    check-template-location: false
+  profiles:
+    active: dev
+  jackson:
+    time-zone: GMT+8
+
+task:
+  pool:
+    # 核心线程池大小
+    core-pool-size: 10
+    # 最大线程数
+    max-pool-size: 30
+    # 活跃时间
+    keep-alive-seconds: 60
+    # 队列容量
+    queue-capacity: 50

src/main/resources/banner.txt

@@ -0,0 +1,8 @@
+       _                 _           _
+      | |               | |         (_)
+   ___| |______ __ _  __| |_ __ ___  _ _ __
+  / _ | |______/ _` |/ _` | '_ ` _ \| | '_ \
+ |  __| |     | (_| | (_| | | | | | | | | | |
+  \___|_|      \__,_|\__,_|_| |_| |_|_|_| |_|
+
+ :: Spring Boot ::       (v2.1.0.RELEASE)

src/main/resources/logback.xml

@@ -0,0 +1,45 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration scan="true" scanPeriod="30 seconds" debug="false">
+    <contextName>spring-boot-starter-activemq-demo</contextName>
+    <property name="log.charset" value="utf-8" />
+    <property name="log.pattern" value="%black(%contextName-) %red(%d{yyyy-MM-dd HH:mm:ss}) %green([%thread]) %highlight(%-5level) %boldMagenta(%logger{36}) - %gray(%msg%n)" />
+
+    <!--输出到控制台-->
+    <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>${log.pattern}</pattern>
+            <charset>${log.charset}</charset>
+        </encoder>
+    </appender>
+
+    <!--普通日志输出到控制台-->
+    <root level="info">
+        <appender-ref ref="console" />
+    </root>
+
+    <!--监控sql日志输出 -->
+    <logger name="jdbc.sqlonly" level="INFO" additivity="false">
+        <appender-ref ref="console" />
+    </logger>
+
+    <logger name="jdbc.resultset" level="ERROR" additivity="false">
+        <appender-ref ref="console" />
+    </logger>
+
+    <!--  如想看到表格数据，将OFF改为INFO  -->
+    <logger name="jdbc.resultsettable" level="OFF" additivity="false">
+        <appender-ref ref="console" />
+    </logger>
+
+    <logger name="jdbc.connection" level="OFF" additivity="false">
+        <appender-ref ref="console" />
+    </logger>
+
+    <logger name="jdbc.sqltiming" level="OFF" additivity="false">
+        <appender-ref ref="console" />
+    </logger>
+
+    <logger name="jdbc.audit" level="OFF" additivity="false">
+        <appender-ref ref="console" />
+    </logger>
+</configuration>