java activeMQ消息的发送与接收

刺骨的言语ヽ痛彻心扉 2022-06-08 23:51 488阅读 0赞

java activeMQ消息的发送与接收

  1.        activemq是我们经常用到的消息队列之一，比如说速度快，对spring的很好的支持，支持多种协议等等，今天我们就来看一下activeMQ消息的发送与接收的源代码。
  3.   我这里使用了两个配置文件，其实在一个配置文件里面就可以完成发送与接收功能，但是为了方便观察日志，我就使用了两个配置文件。在使用代码之前需要搭建好activeMQ消息队列环境。
  5.    一、代码目录结构
  7.    所建立的工程是maven工程，代码结构如图所示：

20170822163146931

  1.        一、maven配置pom.xml
  3. <project xmlns="http://maven.apache.org/POM/4.0.0" 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.0</modelVersion>
  6.     <groupId>Test</groupId>
  7.     <artifactId>Test</artifactId>
  8.     <version>0.0.1-SNAPSHOT</version>
  11.     <dependencies>
  12.         <dependency>
  13.             <groupId>com.alibaba</groupId>
  14.             <artifactId>fastjson</artifactId>
  15.             <version>1.2.16</version>
  16.         </dependency>
  17.         <dependency>
  18.         <groupId>org.json</groupId>
  19.         <artifactId>org.json</artifactId>
  20.         <version>chargebee-1.0</version>
  21.     </dependency>
  22.         <dependency>
  23.             <groupId>junit</groupId>
  24.             <artifactId>junit</artifactId>
  25.             <version>4.12</version>
  26.             <scope>test</scope>
  27.         </dependency>
  28.         <dependency>
  29.             <groupId>com.cloudhopper.proxool</groupId>
  30.             <artifactId>proxool</artifactId>
  31.             <version>0.9.1</version>
  32.             <exclusions>
  33.                 <exclusion>
  34.                     <artifactId>log4j</artifactId>
  35.                     <groupId>log4j</groupId>
  36.                 </exclusion>
  37.             </exclusions>
  38.         </dependency>
  39.         <dependency>
  40.             <groupId>org.apache.activemq</groupId>
  41.             <artifactId>activemq-all</artifactId>
  42.             <version>5.11.0</version>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>org.springframework</groupId>
  46.             <artifactId>spring-jms</artifactId>
  47.             <version>4.1.4.RELEASE</version>
  49.         </dependency>
  50.         <dependency>
  51.             <groupId>org.springframework</groupId>
  52.             <artifactId>spring-jdbc</artifactId>
  53.             <version>4.1.4.RELEASE</version>
  54.         </dependency>
  55.         <dependency>
  56.             <groupId>org.springframework</groupId>
  57.             <artifactId>spring-core</artifactId>
  58.             <version>4.1.4.RELEASE</version>
  59.         </dependency>
  60.         <dependency>
  61.             <groupId>org.springframework</groupId>
  62.             <artifactId>spring-beans</artifactId>
  63.             <version>4.1.4.RELEASE</version>
  64.         </dependency>
  65.         <dependency>
  66.             <groupId>org.springframework</groupId>
  67.             <artifactId>spring-context</artifactId>
  68.             <version>4.1.4.RELEASE</version>
  69.         </dependency>
  70.         <dependency>
  71.             <groupId>org.springframework</groupId>
  72.             <artifactId>spring-context-support</artifactId>
  73.             <version>4.1.4.RELEASE</version>
  74.         </dependency>
  75.         <dependency>
  76.             <groupId>org.apache.cxf</groupId>
  77.             <artifactId>cxf-rt-frontend-jaxws</artifactId>
  78.             <version>2.7.3</version>
  79.         </dependency>
  80.         <dependency>
  81.             <groupId>org.apache.cxf</groupId>
  82.             <artifactId>cxf-rt-transports-http</artifactId>
  83.             <version>2.7.3</version>
  84.         </dependency>
  85.         <dependency>
  86.             <groupId>org.apache.cxf</groupId>
  87.             <artifactId>cxf-rt-transports-http-jetty</artifactId>
  88.             <version>2.4.5</version>
  89.         </dependency>
  90.         <dependency>
  91.             <groupId>org.slf4j</groupId>
  92.             <artifactId>slf4j-api</artifactId>
  93.             <version>1.7.5</version>
  94.         </dependency>
  97.         <dependency>
  98.             <groupId>com.h2database</groupId>
  99.             <artifactId>h2</artifactId>
  100.             <version>1.3.152</version>
  101.         </dependency>
  102.         <dependency>
  103.             <groupId>org.apache.httpcomponents</groupId>
  104.             <artifactId>httpclient</artifactId>
  105.             <version>4.1.1</version>
  106.         </dependency>
  107.         <dependency>
  108.             <groupId>dom4j</groupId>
  109.             <artifactId>dom4j</artifactId>
  110.             <version>1.6.1</version>
  111.         </dependency>
  112.         <dependency>
  113.             <groupId>commons-dbutils</groupId>
  114.             <artifactId>commons-dbutils</artifactId>
  115.             <version>1.3</version>
  116.         </dependency>
  117.         <dependency>
  118.             <groupId>org.freemarker</groupId>
  119.             <artifactId>freemarker</artifactId>
  120.             <version>2.3.16</version>
  121.         </dependency>
  122.         <dependency>
  123.             <groupId>jaxen</groupId>
  124.             <artifactId>jaxen</artifactId>
  125.             <version>1.1.1</version>
  126.         </dependency>
  127.         <dependency>
  128.             <groupId>net.sourceforge.saxon</groupId>
  129.             <artifactId>saxon</artifactId>
  130.             <version>9.1.0.8</version>
  131.         </dependency>
  132.         <dependency>
  133.             <groupId>net.sourceforge.saxon</groupId>
  134.             <artifactId>saxon</artifactId>
  135.             <version>9.1.0.8</version>
  136.             <classifier>xqj</classifier>
  137.         </dependency>
  138.         <dependency>
  139.             <groupId>net.sourceforge.saxon</groupId>
  140.             <artifactId>saxon</artifactId>
  141.             <version>9.1.0.8</version>
  142.             <classifier>xpath</classifier>
  143.         </dependency>
  144.         <dependency>
  145.             <groupId>net.sourceforge.saxon</groupId>
  146.             <artifactId>saxon</artifactId>
  147.             <version>9.1.0.8</version>
  148.             <classifier>xom</classifier>
  149.         </dependency>
  150.         <dependency>
  151.             <groupId>net.sourceforge.saxon</groupId>
  152.             <artifactId>saxon</artifactId>
  153.             <version>9.1.0.8</version>
  154.             <classifier>sql</classifier>
  155.         </dependency>
  156.         <dependency>
  157.             <groupId>net.sourceforge.saxon</groupId>
  158.             <artifactId>saxon</artifactId>
  159.             <version>9.1.0.8</version>
  160.             <classifier>s9api</classifier>
  161.         </dependency>
  162.         <dependency>
  163.             <groupId>net.sourceforge.saxon</groupId>
  164.             <artifactId>saxon</artifactId>
  165.             <version>9.1.0.8</version>
  166.             <classifier>jdom</classifier>
  167.         </dependency>
  168.         <dependency>
  169.             <groupId>net.sourceforge.saxon</groupId>
  170.             <artifactId>saxon</artifactId>
  171.             <version>9.1.0.8</version>
  172.             <classifier>dom4j</classifier>
  173.         </dependency>
  174.         <dependency>
  175.             <groupId>net.sourceforge.saxon</groupId>
  176.             <artifactId>saxon</artifactId>
  177.             <version>9.1.0.8</version>
  178.             <classifier>dom</classifier>
  179.         </dependency>
  180.         <dependency>
  181.             <groupId>xom</groupId>
  182.             <artifactId>xom</artifactId>
  183.             <version>1.1</version>
  184.         </dependency>
  185.         <dependency>
  186.             <groupId>stax</groupId>
  187.             <artifactId>stax</artifactId>
  188.             <version>1.2.0</version>
  189.         </dependency>
  190.         <dependency>
  191.             <groupId>org.drools</groupId>
  192.             <artifactId>drools-core</artifactId>
  193.             <version>5.3.0.Final</version>
  194.         </dependency>
  195.         <dependency>
  196.             <groupId>org.drools</groupId>
  197.             <artifactId>drools-compiler</artifactId>
  198.             <version>5.3.0.Final</version>
  199.         </dependency>
  200.         <dependency>
  201.             <groupId>commons-io</groupId>
  202.             <artifactId>commons-io</artifactId>
  203.             <version>2.2</version>
  204.         </dependency>
  205.         <dependency>
  206.             <groupId>javax.xml.bind</groupId>
  207.             <artifactId>jsr173_api</artifactId>
  208.             <version>1.0</version>
  209.         </dependency>
  210.         <dependency>
  211.             <groupId>org.springframework</groupId>
  212.             <artifactId>spring-test</artifactId>
  213.             <version>4.1.4.RELEASE</version>
  214.         </dependency>
  216.         <dependency>
  217.             <groupId>corba</groupId>
  218.             <artifactId>corba-connect</artifactId>
  219.             <version>0.0.2</version>
  220.         </dependency>
  222.         <dependency>
  223.             <groupId>com.ustcinfo.inm.data</groupId>
  224.             <artifactId>inm-data-spi</artifactId>
  225.             <version>0.0.1-SNAPSHOT</version>
  226.         </dependency>
  227.         <dependency>
  228.             <groupId>com.taobao.metamorphosis</groupId>
  229.             <artifactId>metamorphosis-client</artifactId>
  230.             <version>1.4.4</version>
  231.         </dependency>
  232.         <dependency>
  233.             <groupId>com.googlecode.aviator</groupId>
  234.             <artifactId>aviator</artifactId>
  235.             <version>2.2.1</version>
  236.         </dependency>
  237.         <dependency>
  238.             <groupId>com.jcraft</groupId>
  239.             <artifactId>jsch</artifactId>
  240.             <version>0.1.50</version>
  241.         </dependency>
  242.     </dependencies>
  243.     <build>
  244.         <sourceDirectory>src</sourceDirectory>
  245.         <plugins>
  246.             <plugin>
  247.                 <artifactId>maven-compiler-plugin</artifactId>
  248.                 <version>3.3</version>
  249.                 <configuration>
  250.                     <source>1.8</source>
  251.                     <target>1.8</target>
  252.                 </configuration>
  253.             </plugin>
  254.         </plugins>
  255.     </build>
  256. </project>
  258.      二、LoadUtil.java加载类
  260. package www.activemq.load; import javax.jms.Destination; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import org.springframework.jms.core.JmsTemplate; /** * 加载配置文件工具类 * @author Administrator * */ public class LoadUtil { ApplicationContext applicationContext; JmsTemplate template;//jsm对象，可以发送和消费消息 Destination destination;//队列名称 /** * 加载方法 * @param path 文件路径名称 */ public void load(String path){ applicationContext = new ClassPathXmlApplicationContext(path); template = (JmsTemplate) applicationContext.getBean("jmsTemplate"); destination = (Destination) applicationContext.getBean("queueDestination"); this.setApplicationContext(applicationContext); this.setDestination(destination); this.setDestination(destination); } public ApplicationContext getApplicationContext() { return applicationContext; } public void setApplicationContext(ApplicationContext applicationContext) { this.applicationContext = applicationContext; } public JmsTemplate getTemplate() { return template; } public void setTemplate(JmsTemplate template) { this.template = template; } public Destination getDestination() { return destination; } public void setDestination(Destination destination) { this.destination = destination; } }
  265.      三、QueueProducer.java发送消息到activeMQ类
  267. package www.avtivemq.sendmessage; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.Session; import org.springframework.jms.core.JmsTemplate; import org.springframework.jms.core.MessageCreator; import www.activemq.load.LoadUtil; public class QueueProducer{ /** * 发送消息到activemq的实现方法 * @param msg //发送消息的内容，为字符串类型 */ public void sendMessage(String msg) { LoadUtil lu = new LoadUtil(); lu.load("activemq-config.xml"); JmsTemplate template = lu.getTemplate(); String destination = template.getDefaultDestination().toString(); System.out.println("向队列" + destination + "发送了消息:" + msg); template.send(new MessageCreator() { public Message createMessage(Session session) throws JMSException { return session.createTextMessage(msg); } }); } /** * 主方法 * @param args */ public static void main(String[] args) { QueueProducer producer = new QueueProducer(); producer.sendMessage("zcinfo_test"); } }
  269.    四、activemq-config.xml配置文件
  271. <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jms="http://www.springframework.org/schema/jms" xsi:schemaLocation="http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-4.1.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> <!--配置连接工厂地址--> <bean id="activeMQConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="tcp://192.0.81.80:8765"></property> <!-- <property name="brokerURL" value="failover:(tcp://tcp://192.0.81.83:8765,tcp://tcp://192.0.81.84:8765,tcp://tcp://192.0.81.85:8765)"></property> --> </bean> <!--配置队列名称 --> <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg> <value>UEAP_TO_GZZC_QUEUE_TEST</value> </constructor-arg> </bean> <!-- 配置JMS模版，这是spring提供的 --> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <property name="connectionFactory" ref="activeMQConnectionFactory"></property> <property name="defaultDestination" ref="queueDestination"></property> <property name="receiveTimeout" value="10000"></property> </bean> </beans>
  273.      五、ActivemqConsumer.java消费类
  275. package www.activemq.receivemessage;
  277. import javax.jms.Message;
  278. import javax.jms.MessageListener;
  279. import javax.jms.TextMessage;
  281. import www.activemq.load.LoadUtil;
  283. public class ActivemqConsumer implements MessageListener{
  285.     @Override
  286.     public void onMessage(Message message) {
  287.         TextMessage tm = (TextMessage)message;
  288.         System.out.println("监听到MQ中有数据......");
  289.         try {
  290.             System.out.println("获取MQ中数据信息>>>>>>>>>>" +  tm.getText());
  291.         }catch (Exception e) {
  292.             e.printStackTrace();
  293.         }
  294.     }
  296.     /**
  297.      * 加载配置文件之后监听器会自动调用onMessage方法，并且保持服务一直开启很实用
  298.      * @param args
  299.      */
  300.     public static void main(String[] args) {
  301.         new LoadUtil().load("activemq-context.xml");
  302.     }
  303. }
  305.       六、activemq-context.xml配置文件
  307. <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:jms="http://www.springframework.org/schema/jms" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms-3.0.xsd"> <context:component-scan base-package="com.starit.analyse" /> <!-- Spring提供的JMS工具类，它可以进行消息发送、接收等 --> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 --> <property name="connectionFactory" ref="connectionFactory"/> </bean> <!-- 真正可以产生Connection的ConnectionFactory，由对应的 JMS服务厂商提供--> <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <!-- <property name="brokerURL" value="failover:(tcp://192.0.81.83:8765:8400,tcp://192.0.81.84:8765,tcp://192.0.81.85:8765)"/> --> <property name="brokerURL" value="failover:(tcp://192.0.81.80:8765)?jms.prefetchPolicy.all=1"/> </bean> <!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory --> <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"> <!-- 目标ConnectionFactory对应真实的可以产生JMS Connection的ConnectionFactory --> <property name="targetConnectionFactory" ref="targetConnectionFactory"/> </bean> <!--这个是队列目的地--> <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg> <value>UEAP_TO_GZZC_QUEUE_TEST</value> </constructor-arg> </bean> <!-- 消息监听器 加载此处会自动调用监听方法并且一直保持服务开启，很实用 --> <bean id="consumerMessageListener" class="www.activemq.receivemessage.ActivemqConsumer"/> <!-- 消息监听容器 --> <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="connectionFactory" ref="connectionFactory" /> <property name="destination" ref="queueDestination" /> <property name="messageListener" ref="consumerMessageListener" /> <property name="concurrentConsumers" value="1"/> </bean> </beans>
  309.      七、测试结果
  311.     （1）发送消息

20170822171033778 

  1.          （2）activemq显示收到消息

20170822171041983 

  1.     （3）接收消息，服务一直开启接收发送者消息

20170822171048584

发表评论

表情：
评论列表 （有 0 条评论，488人围观）

还没有评论，来说两句吧...

相关阅读