• RabbitMQ的广播模式（fanout）在（基于xml配置）项目中使用

    项目结构

     

    添加相关的jar包： pom.xml

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <modelVersion>4.0.0modelVersion>
    6.  
    7.     <groupId>com.zgp.alarmgroupId>
    8.     <artifactId>AlarmStatusManageNewartifactId>
    9.     <version>1.0-SNAPSHOTversion>
    10.     <packaging>warpackaging>
    11.  
    12.     <properties>
    13.         <project.build.sourceEncoding>UTF-8project.build.sourceEncoding>
    14.         <maven.compiler.source>1.7maven.compiler.source>
    15.         <maven.compiler.target>1.7maven.compiler.target>
    16.         <junit.version>4.11junit.version>
    17.         <aspectj.version>1.6.8aspectj.version>
    18.         <spring.version>5.0.7.RELEASEspring.version>
    19.         <servlet.version>3.1.0servlet.version>
    20.         <jsp.version>2.3.1jsp.version>
    21.         <jstl.version>1.2jstl.version>
    22.         <slf4j.version>1.7.12slf4j.version>
    23.         <log4j.version>1.2.17log4j.version>
    24.         <mysql.version>5.1.6mysql.version>
    25.         <mybatis.version>3.4.5mybatis.version>
    26.         <mybatis-spring.version>1.3.1mybatis-spring.version>
    27.         <pagehelper.version>5.0.3pagehelper.version>
    28.         <sqlserver.version>4.0sqlserver.version>
    29.         <druid.version>1.1.9druid.version>
    30.         <jackson.version>2.9.5jackson.version>
    31.         
    32.         <rabbitmq.version>2.1.2.RELEASErabbitmq.version>
    33.         
    34.  
    35.     properties>
    36.  
    37.     <dependencies>
    38.         <dependency>
    39.             <groupId>org.aspectjgroupId>
    40.             <artifactId>aspectjweaverartifactId>
    41.             <version>${aspectj.version}version>
    42.         dependency>
    43.         
    44.         <dependency>
    45.             <groupId>org.springframeworkgroupId>
    46.             <artifactId>spring-coreartifactId>
    47.             <version>${spring.version}version>
    48.         dependency>
    49.         <dependency>
    50.             <groupId>org.springframeworkgroupId>
    51.             <artifactId>spring-beansartifactId>
    52.             <version>${spring.version}version>
    53.         dependency>
    54.         <dependency>
    55.             <groupId>org.springframeworkgroupId>
    56.             <artifactId>spring-txartifactId>
    57.             <version>${spring.version}version>
    58.         dependency>
    59.         <dependency>
    60.             <groupId>org.springframeworkgroupId>
    61.             <artifactId>spring-contextartifactId>
    62.             <version>${spring.version}version>
    63.         dependency>
    64.         <dependency>
    65.             <groupId>org.springframeworkgroupId>
    66.             <artifactId>spring-context-supportartifactId>
    67.             <version>${spring.version}version>
    68.         dependency>
    69.  
    70.         <dependency>
    71.             <groupId>org.springframeworkgroupId>
    72.             <artifactId>spring-webartifactId>
    73.             <version>${spring.version}version>
    74.         dependency>
    75.  
    76.         <dependency>
    77.             <groupId>org.springframeworkgroupId>
    78.             <artifactId>spring-webmvcartifactId>
    79.             <version>${spring.version}version>
    80.         dependency>
    81.  
    82.         <dependency>
    83.             <groupId>org.springframeworkgroupId>
    84.             <artifactId>spring-aopartifactId>
    85.             <version>${spring.version}version>
    86.         dependency>
    87.  
    88.  
    89.         <dependency>
    90.             <groupId>org.springframeworkgroupId>
    91.             <artifactId>spring-aspectsartifactId>
    92.             <version>${spring.version}version>
    93.         dependency>
    94.  
    95.         <dependency>
    96.             <groupId>org.springframeworkgroupId>
    97.             <artifactId>spring-jdbcartifactId>
    98.             <version>${spring.version}version>
    99.         dependency>
    100.  
    101.         <dependency>
    102.             <groupId>org.springframeworkgroupId>
    103.             <artifactId>spring-jmsartifactId>
    104.             <version>${spring.version}version>
    105.         dependency>
    106.  
    107.         
    108.         
    109.         <dependency>
    110.             <groupId>org.springframework.datagroupId>
    111.             <artifactId>spring-data-redisartifactId>
    112.             <version>2.0.0.RELEASEversion>
    113.         dependency>
    114.         <dependency>
    115.             <groupId>redis.clientsgroupId>
    116.             <artifactId>jedisartifactId>
    117.             <version>2.9.0version>
    118.         dependency>
    119.  
    120.         
    121.         <dependency>
    122.             <groupId>javax.servletgroupId>
    123.             <artifactId>javax.servlet-apiartifactId>
    124.             <version>${servlet.version}version>
    125.             <scope>providedscope>
    126.         dependency>
    127.         <dependency>
    128.             <groupId>javax.servlet.jspgroupId>
    129.             <artifactId>javax.servlet.jsp-apiartifactId>
    130.             <version>${jsp.version}version>
    131.             <scope>providedscope>
    132.         dependency>
    133.  
    134.         
    135.         <dependency>
    136.             <groupId>javax.servletgroupId>
    137.             <artifactId>jstlartifactId>
    138.             <version>${jstl.version}version>
    139.         dependency>
    140.  
    141.         
    142.         <dependency>
    143.             <groupId>log4jgroupId>
    144.             <artifactId>log4jartifactId>
    145.             <version>${log4j.version}version>
    146.         dependency>
    147.  
    148.         <dependency>
    149.             <groupId>org.slf4jgroupId>
    150.             <artifactId>slf4j-log4j12artifactId>
    151.             <version>${slf4j.version}version>
    152.         dependency>
    153.  
    154.         
    155.         <dependency>
    156.             <groupId>org.mybatisgroupId>
    157.             <artifactId>mybatisartifactId>
    158.             <version>${mybatis.version}version>
    159.         dependency>
    160.         <dependency>
    161.             <groupId>org.mybatisgroupId>
    162.             <artifactId>mybatis-springartifactId>
    163.             <version>${mybatis-spring.version}version>
    164.         dependency>
    165.  
    166.         
    167.         <dependency>
    168.             <groupId>com.github.pagehelpergroupId>
    169.             <artifactId>pagehelperartifactId>
    170.             <version>${pagehelper.version}version>
    171.         dependency>
    172.  
    173.         
    174.         <dependency>
    175.             <groupId>com.microsoft.sqlservergroupId>
    176.             <artifactId>sqljdbc4artifactId>
    177.             <version>${sqlserver.version}version>
    178.         dependency>
    179.  
    180.         
    181.         <dependency>
    182.             <groupId>com.alibabagroupId>
    183.             <artifactId>druidartifactId>
    184.             <version>${druid.version}version>
    185.         dependency>
    186.  
    187.         
    188.         <dependency>
    189.             <groupId>commons-codecgroupId>
    190.             <artifactId>commons-codecartifactId>
    191.             <version>1.11version>
    192.         dependency>
    193.  
    194.         <dependency>
    195.             <groupId>commons-langgroupId>
    196.             <artifactId>commons-langartifactId>
    197.             <version>2.6version>
    198.         dependency>
    199.  
    200.         <dependency>
    201.             <groupId>commons-beanutilsgroupId>
    202.             <artifactId>commons-beanutilsartifactId>
    203.             <version>1.9.3version>
    204.         dependency>
    205.  
    206.         <dependency>
    207.             <groupId>commons-collectionsgroupId>
    208.             <artifactId>commons-collectionsartifactId>
    209.             <version>3.2.2version>
    210.         dependency>
    211.  
    212.         <dependency>
    213.             <groupId>commons-logginggroupId>
    214.             <artifactId>commons-loggingartifactId>
    215.             <version>1.2version>
    216.         dependency>
    217.  
    218.         
    219.         <dependency>
    220.             <groupId>commons-fileuploadgroupId>
    221.             <artifactId>commons-fileuploadartifactId>
    222.             <version>1.3.3version>
    223.         dependency>
    224.         <dependency>
    225.             <groupId>commons-iogroupId>
    226.             <artifactId>commons-ioartifactId>
    227.             <version>2.6version>
    228.         dependency>
    229.  
    230.  
    231.         
    232.         <dependency>
    233.             <groupId>com.fasterxml.jackson.coregroupId>
    234.             <artifactId>jackson-coreartifactId>
    235.             <version>${jackson.version}version>
    236.         dependency>
    237.         <dependency>
    238.             <groupId>com.fasterxml.jackson.coregroupId>
    239.             <artifactId>jackson-databindartifactId>
    240.             <version>${jackson.version}version>
    241.         dependency>
    242.         <dependency>
    243.             <groupId>com.fasterxml.jackson.coregroupId>
    244.             <artifactId>jackson-annotationsartifactId>
    245.             <version>${jackson.version}version>
    246.         dependency>
    247.  
    248.         
    249.         <dependency>
    250.             <groupId>org.quartz-schedulergroupId>
    251.             <artifactId>quartzartifactId>
    252.             <version>2.3.0version>
    253.         dependency>
    254.  
    255.         
    256.         
    257.         <dependency>
    258.             <groupId>org.apache.httpcomponentsgroupId>
    259.             <artifactId>httpcoreartifactId>
    260.             <version>4.4.10version>
    261.         dependency>
    262.  
    263.         
    264.         <dependency>
    265.             <groupId>org.apache.httpcomponentsgroupId>
    266.             <artifactId>httpclientartifactId>
    267.             <version>4.5.6version>
    268.         dependency>
    269.  
    270.  
    271.         <dependency>
    272.             <groupId>org.apache.poigroupId>
    273.             <artifactId>poiartifactId>
    274.             <version>4.1.0version>
    275.         dependency>
    276.         <dependency>
    277.             <groupId>org.apache.poigroupId>
    278.             <artifactId>poi-ooxmlartifactId>
    279.             <version>4.1.0version>
    280.         dependency>
    281.         <dependency>
    282.             <groupId>org.apache.poigroupId>
    283.             <artifactId>poi-ooxml-schemasartifactId>
    284.             <version>4.1.0version>
    285.         dependency>
    286.         <dependency>
    287.             <groupId>org.apache.poigroupId>
    288.             <artifactId>poi-scratchpadartifactId>
    289.             <version>4.1.0version>
    290.         dependency>
    291.         <dependency>
    292.             <groupId>org.apache.poigroupId>
    293.             <artifactId>ooxml-schemasartifactId>
    294.             <version>1.4version>
    295.         dependency>
    296.  
    297.         
    298.         
    299.         
    300.         
    312.  
    313.         
    314.         <dependency>
    315.             <groupId>org.springframework.amqpgroupId>
    316.             <artifactId>spring-rabbitartifactId>
    317.             <version>${rabbitmq.version}version>
    318.         dependency>
    319.  
    320.  
    321.         
    322.         <dependency>
    323.             <groupId>com.getui.pushgroupId>
    324.             <artifactId>restful-sdkartifactId>
    325.             <version>1.0.0.0version>
    326.         dependency>
    327.  
    328.  
    329.         
    330.  
    331.         
    332.  
    333.         
    334.  
    335.         
    336.         
    337.         
    338.  
    339.         <dependency>
    340.             <groupId>junitgroupId>
    341.             <artifactId>junitartifactId>
    342.             <version>${junit.version}version>
    343.             <scope>testscope>
    344.         dependency>
    345.  
    346.  
    347.     dependencies>
    348.  
    349.     <build>
    350.         <finalName>AlarmStatusManagefinalName>
    351.         <pluginManagement>
    352.             <plugins>
    353.                 <plugin>
    354.                     <groupId>org.apache.maven.pluginsgroupId>
    355.                     <artifactId>maven-compiler-pluginartifactId>
    356.                     <version>2.3.2version>
    357.                     <configuration>
    358.                         <source>1.8source>
    359.                         <target>1.8target>
    360.                         <encoding>UTF-8encoding>
    361.                     configuration>
    362.                 plugin>
    363.                 
    364.                 <plugin>
    365.                     <groupId>org.apache.tomcat.mavengroupId>
    366.                     <artifactId>tomcat7-maven-pluginartifactId>
    367.                     <version>2.2version>
    368.                     <configuration>
    369.                         <port>8080port>
    370.                         <path>/AlarmStatusManagepath>
    371.                         <uriEncoding>UTF-8uriEncoding>
    372.                     configuration>
    373.                 plugin>
    374.             plugins>
    375.         pluginManagement>
    376.     build>
    377.  
    378.  
    379.  
    380.  
    381. project>

    配置文件及java类

    1、config.properties、log4j.properties

    config.properties

    1. #RabbitMQ Settings
    2. # rabbit ip   
    3. rabbit.server=192.168.0.103
    4. # rabbit 端口
    5. rabbit.port=5672
    6. # virtual-host  默认为 /
    7. rabbit.vhost=/
    8. # rabbit 用户名
    9. rabbit.username=admin
    10. # rabbit 密码
    11. rabbit.password=admin
    12. # 队列名称
    13. rabbit.fanoutQueue=fanoutQueue
    14. # Exchange名称 
    15. rabbit.fanoutExchange=fanoutExchange
    16.  
    17. # jdbc connection
    18. jdbc.driver=com.microsoft.sqlserver.jdbc.SQLServerDriver
    19. jdbc.url=jdbc:sqlserver://192.168.0.103:1433;DatabaseName=alarm
    20. jdbc.username=sa
    21. jdbc.password=123456
    22.

    onfig.properties

    1. log4j.rootLogger=INFO,ERROR,Console
    2.  
    3. #Console #输出到控制台
    4. log4j.appender.Console = org.apache.log4j.ConsoleAppender 
    5. log4j.appender.Console.layout = org.apache.log4j.PatternLayout 
    6. log4j.appender.Console.layout.ConversionPattern = [%-5p][%-22d{yyyy/MM/dd HH:mm:ssS}][%l]%n%m%n 
    7. log4j.appender.Console.Threshold = DEBUG 
    8. log4j.appender.Console.ImmediateFlush = TRUE 
    9. log4j.appender.Console.Target = System.out 
    10.  
    11.  
    12. #输出到文件
    13. log4j.appender.logFile = org.apache.log4j.FileAppender 
    14. log4j.appender.logFile.layout = org.apache.log4j.PatternLayout 
    15. log4j.appender.logFile.layout.ConversionPattern = [%-5p][%-22d{yyyy/MM/dd HH:mm:ssS}][%l]%n%m%n 
    16. log4j.appender.logFile.Threshold = DEBUG 
    17. log4j.appender.logFile.ImmediateFlush = TRUE 
    18. log4j.appender.logFile.Append = TRUE 
    19. log4j.appender.logFile.File = ${catalina.base}/logs/AlarmStatus_INFO.log 
    20. log4j.appender.logFile.Encoding= UTF-8 
    21.  
    22. #按DatePattern输出到文件
    23. log4j.appender.ERROR = org.apache.log4j.DailyRollingFileAppender 
    24. log4j.appender.ERROR.layout = org.apache.log4j.PatternLayout 
    25. log4j.appender.ERROR.layout.ConversionPattern = [%-5p][%-22d{yyyy/MM/dd HH:mm:ssS}][%l]%n%m%n 
    26. log4j.appender.ERROR.Threshold = ERROR 
    27. log4j.appender.ERROR.ImmediateFlush = TRUE 
    28. log4j.appender.ERROR.Append = TRUE 
    29. log4j.appender.ERROR.File = ${catalina.base}/logs/AlarmStatus_ERROR.log
    30. log4j.appender.ERROR.DatePattern = '_'yyyy-MM-dd'.log'
    31.  
    32.  
    33. #设定文件大小输出到文件
    34. log4j.appender.INFO = org.apache.log4j.RollingFileAppender 
    35. log4j.appender.INFO.layout = org.apache.log4j.PatternLayout 
    36. log4j.appender.INFO.layout.ConversionPattern = [%-5p][%-22d{yyyy/MM/dd HH:mm:ssS}][%l]%n%m%n 
    37. log4j.appender.INFO.Threshold = INFO 
    38. log4j.appender.INFO.ImmediateFlush = TRUE 
    39. log4j.appender.INFO.Append = TRUE 
    40. log4j.appender.INFO.File = ${catalina.base}/logs/AlarmStatus_INFO.log
    41. log4j.appender.INFO.MaxFileSize = 20MB 
    42. log4j.appender.INFO.MaxBackupIndex = 10 
    43.  
    44.  
    45.  
    46.

    2、RabbitMQ配置文件: spring-rabbitmq-server.xml、spring-rabbitmq-client.xml

    spring-rabbitmq-server.xml  服务端

    1. "1.0" encoding="UTF-8"?>
    2. <beans xmlns="http://www.springframework.org/schema/beans"
    3. 	   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4. 	   xmlns:rabbit="http://www.springframework.org/schema/rabbit"
    5. 	   xmlns:context="http://www.springframework.org/schema/context"
    6. 	   xsi:schemaLocation="http://www.springframework.org/schema/rabbit
    7.  	   http://www.springframework.org/schema/rabbit/spring-rabbit.xsd
    8.        http://www.springframework.org/schema/context
    9.        http://www.springframework.org/schema/context/spring-context-4.0.xsd
    10.  	   http://www.springframework.org/schema/beans
    11.  	   http://www.springframework.org/schema/beans/spring-beans-4.0.xsd">
    12.  
    13.  
    14.  
    15. 	
    16.  
    18. 	
    19. 	<rabbit:connection-factory id="connectionFactory"
    20. 							   host="${rabbit.server}"
    21. 							   port="${rabbit.port}"
    22. 							   username="${rabbit.username}"
    23. 							   password="${rabbit.password}"
    24. 							   virtual-host="${rabbit.vhost}"
    25. 							   publisher-confirms="true"
    26. 							   publisher-returns="true"
    27. 							   channel-cache-size="5" />
    28.  
    29. 	
    30. 	<rabbit:admin connection-factory="connectionFactory" />
    31.  
    32. 	
    34.  
    35. 	<rabbit:queue name="${rabbit.fanoutQueue}" auto-declare="true" durable="true" />
    36.  
    37.  
    38. 	
    39. 	
    40. 	<rabbit:fanout-exchange name="${rabbit.fanoutExchange}" auto-declare="true" durable="true">
    41. 		<rabbit:bindings>
    42. 			<rabbit:binding  queue="${rabbit.fanoutQueue}"/>
    43. 		rabbit:bindings>
    44. 	rabbit:fanout-exchange>
    45.  
    46.  
    47. 	
    48.  
    49. 	
    50.  
    51. 	
    52.  
    53. 	<rabbit:template id="rabbitTemplate"
    54. 					 connection-factory="connectionFactory" exchange="${rabbit.fanoutExchange}"
    55. 					 />
    56.  
    57.  
    58.  
    59. beans>
    60.

    spring-rabbitmq-client.xml  客户端

    1. "1.0" encoding="UTF-8"?>
    2. <beans xmlns="http://www.springframework.org/schema/beans"
    3. 	   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4. 	   xmlns:rabbit="http://www.springframework.org/schema/rabbit"
    5. 	   xmlns:context="http://www.springframework.org/schema/context"
    6. 	   xsi:schemaLocation="http://www.springframework.org/schema/rabbit
    7.  	   http://www.springframework.org/schema/rabbit/spring-rabbit.xsd
    8.        http://www.springframework.org/schema/context
    9.        http://www.springframework.org/schema/context/spring-context-4.0.xsd
    10.  	   http://www.springframework.org/schema/beans
    11.  	   http://www.springframework.org/schema/beans/spring-beans-4.0.xsd">
    12.  
    13.  
    15.  
    16. 	
    17. 	<rabbit:connection-factory id="connectionFactory"
    18. 							   host="${rabbit.server}"
    19. 							   port="${rabbit.port}"
    20. 							   username="${rabbit.username}"
    21. 							   password="${rabbit.password}"
    22. 							   virtual-host="${rabbit.vhost}"
    23. 							   publisher-confirms="true"
    24. 							   publisher-returns="true"
    25. 							   channel-cache-size="5" />
    26.  
    27. 	
    28. 	<rabbit:admin connection-factory="connectionFactory" />
    29.  
    30. 	
    32.  
    33. 	
    34.  
    35.  
    36. 	
    37. 	<bean name="queuehandler" class="com.zgp.alarm.rabbitMq.client.RecvHandler" />
    38.  
    39. 	
    40. 	<rabbit:listener-container
    41. 			connection-factory="connectionFactory">
    42. 		<rabbit:listener ref="queuehandler" queues="${rabbit.fanoutQueue}" />
    43. 	rabbit:listener-container>
    44.  
    45. beans>
    46.  
    47.

     

    3、RabbitMQ消息发送端类(消息发布)：StatusSchedule.java (主要是(使用)注入 rabbitTemplate 类发送消息、当然也可以注入将rabbitTemplate 类到后台控制器类或工具类中或配置类中等)

    1. package com.zgp.alarm.schedule;
    2.  
    3. import com.fasterxml.jackson.databind.ObjectMapper;
    4. import com.zgp.alarm.bean.*;
    5. import com.zgp.alarm.service.IAlarmStatusService;
    6. import com.zgp.alarm.utils.CommonUtils;
    7. import com.zgp.alarm.utils.RandomUtils;
    8. import org.slf4j.Logger;
    9. import org.slf4j.LoggerFactory;
    10. import org.springframework.amqp.rabbit.core.RabbitTemplate;
    11. import org.springframework.beans.factory.annotation.Autowired;
    12.  
    13. import java.util.List;
    14.  
    15. public class StatusSchedule {
    16.  
    17.     private static Logger logger = LoggerFactory.getLogger(StatusSchedule.class);
    18.  
    19.     private ObjectMapper mapper = new ObjectMapper();
    20.  
    21.     private RabbitTemplate rabbitTemplate;
    22.  
    23.     @Autowired
    24.     private IAlarmStatusService alarmStatusService;
    25.  
    26.     //处理警情接收确认状态
    27.     public void processAlarmStauts() {
    28.         try{
    29.             logger.info("【处理警情接收确认状态】：开始处理......");
    30.             List datalist = alarmStatusService.getAlarmStatus(1);
    31.             if (datalist != null && datalist.size() > 0){
    32.                 AlarmStatus updateModel = datalist.get(0);
    33.                 for(int i = 0;i < datalist.size();i++){
    34.                     AlarmStatus currentModel = datalist.get(i);
    35.                     MsgContentStatusResult msgContentResult = new MsgContentStatusResult();
    36.                     msgContentResult.setUnitName(currentModel.getUnitName());
    37.                     msgContentResult.setMessageType("1");//消息类型 0：送达 1：确认
    38.  
    39.                     //消息内容
    40.                     AlarmStatusResult alarmStatusResult = new AlarmStatusResult();
    41.                     alarmStatusResult.setMsgid(RandomUtils.getUUID());//消息ID
    42.                     alarmStatusResult.setMsgsendtime(CommonUtils.getCurrentDateTime());//发送消息时间
    43.                     alarmStatusResult.setMsgreceiver("");
    44.                     alarmStatusResult.setMsgsender("ALARM");//消息发送者（系统）
    45.                     alarmStatusResult.setMsgtype("DPHZ");//调派回执信息
    46.                     alarmStatusResult.setMsgcontent(msgContentResult);//消息体
    47. //                    rabbitTemplate.convertAndSend(alarmStatusResult);
    48.  
    49.                     rabbitTemplate.convertAndSend(mapper.writeValueAsString(alarmStatusResult));
    50.  
    51.                     //保存发送记录。
    52.                     AlarmStatusSend statusSend = new AlarmStatusSend(
    53.                             1, 
    54.                             updateModel.getId(),
    55.                             updateModel.getJjdid(),
    56.                             updateModel.getConfirmTime(),
    57.                             alarmStatusResult.getMsgid(),
    58.                             alarmStatusResult.getMsgsendtime(),
    59.                             alarmStatusResult.getMsgsender(),
    60.                             alarmStatusResult.getMsgreceiver(),
    61.                             alarmStatusResult.getMsgtype(),
    62.                             mapper.writeValueAsString(msgContentResult)
    63.                     );
    64.                     Integer saveFlag = alarmStatusService.saveAlarmStatusSend(statusSend);
    65.                     logger.info("【处理警情接收确认状态】：保存状态发送记录表 saveFlag={} , uploadId={} , msgid={} , msgsendtime = {}"
    66.                             , saveFlag , statusSend.getUploadId() , statusSend.getMsgid() ,statusSend.getMsgsendtime());
    67.                 }
    68.                 //更新记录
    69.                 Integer updateFlag = alarmStatusService.updateAlarmStatus(updateModel);
    70.                 logger.info("【处理警情接收确认状态】：更新警情接收确认表 updateFlag={} , 当前记录={}", updateFlag , mapper.writeValueAsString(updateModel));
    71.             }else{
    72.                 logger.info("【处理警情接收确认状态】：本次没有查询到待发转态记录.....");
    73.             }
    74.  
    75.             logger.info("【处理警情接收确认状态】：结束处理......");
    76.         }catch (Exception e){
    77.             e.printStackTrace();
    78.             logger.error("【处理警情接收确认状态】：出现异常，异常信息为：{}",e.getMessage());
    79.         }
    80.     }
    81.  
    82.    
    83.  
    84.     public RabbitTemplate getRabbitTemplate() {
    85.         return rabbitTemplate;
    86.     }
    87.  
    88.     public void setRabbitTemplate(RabbitTemplate rabbitTemplate) {
    89.         this.rabbitTemplate = rabbitTemplate;
    90.     }
    91. }

    4、ActiveMQ消息接收端（监听）类(订阅)： RecvHandler.java
    1. package com.zgp.alarm.rabbitMq.client;
    2.  
    3. import com.fasterxml.jackson.databind.ObjectMapper;
    4. import com.zgp.alarm.bean.AlarmStatus;
    5. import com.zgp.alarm.bean.AlarmStatusResult;
    6. import com.zgp.alarm.bean.Response;
    7. import org.springframework.amqp.core.Message;
    8. import org.springframework.amqp.core.MessageListener;
    9.  
    10. public class RecvHandler implements MessageListener {
    11.  
    12.     private static final ObjectMapper mapper = new ObjectMapper();
    13.  
    14.     @Override
    15.     public void onMessage(Message message) {
    16.         try {
    17.             // msg就是rabbitmq传来的消息，需要的同学自己打印看一眼
    18.             // 使用jackson解析\
    19.             String text = new String(message.getBody());
    20. //            String text2 = mapper.readValue(message.getBody() , String.class);
    21.             System.out.println("接收服务器消息1：" + text);
    22.  
    23.             AlarmStatusResult response = mapper.readValue(text , AlarmStatusResult.class);
    24.             System.out.println("接收服务器消息2：msgid=" + response.getMsgid() + " , message=");
    25. //            JsonNode jsonData = MAPPER.readTree(message.getBody());
    26. //            System.out.println("我是可爱的小猪,我的id是" + jsonData.get("id").asText() + ",我的名字是" + jsonData.get("name").asText());
    27.  
    28.         } catch (Exception e) {
    29.             e.printStackTrace();
    30.         }
    31.     }
    32.  
    33. }

    5、spring主配置文件 applicationContext.xml

    1. "1.0" encoding="UTF-8"?>
    2. <beans xmlns="http://www.springframework.org/schema/beans"
    3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.     xmlns:p="http://www.springframework.org/schema/p"
    5.     xmlns:aop="http://www.springframework.org/schema/aop"
    6.     xmlns:context="http://www.springframework.org/schema/context"
    7.     xmlns:cache="http://www.springframework.org/schema/cache"
    8.     xmlns:jee="http://www.springframework.org/schema/jee"
    9.     xmlns:tx="http://www.springframework.org/schema/tx"
    10.     xsi:schemaLocation="
    11.         http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
    12.         http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
    13.         http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
    14.         http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-4.0.xsd
    15.         http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-4.0.xsd
    16.         http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd">
    17.  
    18.     
    19.     
    20.     
    21.  
    22.     
    23.     <context:property-placeholder location="classpath*:config.properties">context:property-placeholder>
    24.  
    25.  
    26.     
    27.     <bean id="dataSource"
    28. 		class="com.alibaba.druid.pool.DruidDataSource" init-method="init" destroy-method="close">
    29.         <property name="driverClassName" value="${jdbc.driver}" />
    30. 		<property name="url" value="${jdbc.url}"/>
    31. 		<property name="username" value="${jdbc.username}"/>
    32. 		<property name="password" value="${jdbc.password}"/>
    33.         
    34.         <property name="initialSize" value="1" />
    35.         <property name="minIdle" value="1" />
    36.         <property name="maxActive" value="20" />
    37.         
    38.         <property name="maxWait" value="60000" />
    39.         
    40.         <property name="timeBetweenEvictionRunsMillis" value="60000" />
    41.         
    42.         <property name="minEvictableIdleTimeMillis" value="300000" />
    43.         <property name="validationQuery" value="SELECT 'x'" />
    44.         <property name="testWhileIdle" value="true" />
    45.         <property name="testOnBorrow" value="false" />
    46.         <property name="testOnReturn" value="false" />
    47.         
    48.         <property name="poolPreparedStatements" value="true" />
    49.         <property name="maxPoolPreparedStatementPerConnectionSize" value="20" />
    50.         
    51.         <property name="filters" value="stat" />
    52. 	bean>
    53.     <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    54. 		<property name="dataSource" ref="dataSource" />
    55. 		<property name="mapperLocations" value="classpath:/mapper/*.xml">property>
    56. 		<property name="configLocation" value="classpath:mybatis-config.xml">property>
    57.  
    58.         <property name="plugins">
    59.             <array>
    60.                 <bean class="com.github.pagehelper.PageInterceptor">
    61.                     <property name="properties">
    62.                         <value>
    63.                             helperDialect=sqlserver2012
    64.                             reasonable=true
    65.                         value>
    66.                     property>
    67.                 bean>
    68.             array>
    69.         property>
    70. 	bean>
    71.     
    72. 	<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    73. 		<property name="basePackage" value="com.zgp.alarm.dao">property>
    74. 		<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory">property>
    75. 	bean>
    76.  
    77.  
    78.     
    79.     <context:annotation-config>context:annotation-config>
    80.  
    81.     
    82.     
    83.     
    84.     <context:component-scan base-package="com.zgp.alarm.service">
    85.         <context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
    86.     context:component-scan>
    87.  
    88.  
    89.     
    90.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    91.         <property name="dataSource" ref="dataSource" />
    92.     bean>
    93.  
    94.  
    95.     
    96.     <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>
    97.     
    98.  
    99.    
    100.    <context:component-scan base-package="com.zgp.alarm.service.impl" />
    101.    <context:component-scan base-package="com.zgp.alarm.dao" />
    102.  
    103.  
    104.  
    105.     
    106.     <import resource="classpath:spring-rabbitmq-server.xml" />
    107.     
    108.     <import resource="classpath:spring-rabbitmq-client.xml" />
    109.  
    110.  
    111.     
    112.     
    114.  
    115.  
    116.  
    117. beans>

    6、定时任务配置文件：applicationContext-job-faultInfo.xml

    1. "1.0" encoding="UTF-8"?>
    2. <beans xmlns="http://www.springframework.org/schema/beans"
    3. 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
    4. 	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd">
    5.  
    6.  
    7.     <bean id="statusSchedule" class="com.zgp.alarm.schedule.StatusSchedule">
    8.         <property name="rabbitTemplate" ref="rabbitTemplate" >property>
    9.     bean>
    10.  
    11.     
    12.     <bean id="alarmStautsZzdJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"
    13.         depends-on="rabbitTemplate">
    14.         <property name="targetObject" ref="statusSchedule" />
    15.         <property name="targetMethod" value="processAlarmStautsZzd" />
    16.         <property name="concurrent" value="false" />
    17.     bean>
    18.     <bean id="alarmStautsJobTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    19.         <property name="jobDetail" ref="alarmStautsJobDetail" />
    20.         <property name="cronExpression"  >
    21.             <value>0 */1 * * * ?value>
    22.         property>
    23.     bean>
    24.  
    25.  
    26.     
    27.     <bean autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean" >
    28.         <property name="triggers">
    29.             <list>
    30.                 <ref bean="alarmStautsJobTrigger" />
    31.             list>
    32.         property>
    33.     bean>
    34.  
    35. beans>

    7、mybatis配置文件：mybatis-config.xml

    1. "1.0" encoding="UTF-8" ?>
    2. configuration
    3. PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
    4. "http://mybatis.org/dtd/mybatis-3-config.dtd">
    5. <configuration>
    6.  
    7. 	<settings>
    8. 		
    9. 		<setting name="logImpl" value="SLF4J"/>
    10.  
    11. 		
    12. 		<setting name="logImpl" value="STDOUT_LOGGING" />
    13.  
    14. 	settings>
    15. 	
    16. 	<typeAliases>
    17. 		<typeAlias alias="alarmStatus" type="com.zgp.alarm.bean.AlarmStatus">typeAlias>
    18.  
    19. 		<typeAlias alias="alarmStatusSend" type="com.zgp.alarm.bean.AlarmStatusSend" >typeAlias>
    20.  
    21. 		<typeAlias alias="msgContentUnitsResult" type="com.zgp.alarm.bean.MsgContentUnitsResult">typeAlias>
    22.  
    23. 		<typeAlias alias="msgContentCarsResult" type="com.zgp.alarm.bean.MsgContentCarsResult">typeAlias>
    24.  
    25.  
    26.  
    27. 	typeAliases>
    28.  
    29. configuration>

  • 相关阅读:
    进销存软件哪个好？
    『需求优化』使用 postMessage 解决 localStorage 跨域问题
    Android jetpack room 数据库的升级
    深入学习Linux中的“文件系统与日志分析”
    Games104现代游戏引擎入门-lecture15游戏引擎的Gameplay玩法系统基础
    SpringBoot + Apache tika 轻松实现各种文档内容解析
    智能服装行业ERP软件帮助您提高工作效率和利润
    文本编辑器vi--常用命令查阅版（记得收藏）
    算法金 | 选择最佳机器学习模型的 10 步指南
    TCP如何实现可靠传输、流量控制、拥塞控制
  • 原文地址：https://blog.csdn.net/zgphacker2010/article/details/127973357