知识大全 Spring2.5整合ActiveMQ 5.2（P2P文本消息）

Posted 2022-07-18 消息

篇首语：青春须早为，岂能长少年。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 Spring2.5整合ActiveMQ 5.2（P2P文本消息）相关的知识，希望对你有一定的参考价值。

Spring2.5整合ActiveMQ 5.2（P2P文本消息） 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

　　项目环境

　　JDK

　　ActiveMQ

　　所用的包都是ActiveMQ自带的引用的包如下图

　　 package stujms p ptxt; import ntext ApplicationContext; import ntext support ClassPathXmlApplicationContext; import sprre JmsTemplate; import sprre MessageCreator; import javax jms Destination; import javax jms JMSException; import javax jms Message; import javax jms Session; /** * 消息发送者 * * @author leizhimin : : */ public class MySender public static void main(String[] args) ApplicationContext ctx = new ClassPathXmlApplicationContext( /applicationContext xml ); JmsTemplate template = (JmsTemplate) ctx getBean( jmsTemplate ); Destination destination = (Destination) ctx getBean( destination ); template send(destination new MessageCreator() public Message createMessage(Session session) throws JMSException return session createTextMessage( 发送消息 Hello ActiveMQ Text Message！ ); ); System out println( 成功发送了一条JMS消息 );

　　 package stujms p ptxt; import ntext ApplicationContext; import ntext support ClassPathXmlApplicationContext; import sprre JmsTemplate; import javax jms Destination; import javax jms JMSException; import javax jms TextMessage; /** * 消息接收者 * * @author leizhimin : : */ public class MyReceiver public static void main(String[] args) throws JMSException ApplicationContext ctx = new ClassPathXmlApplicationContext( /applicationContext xml ); JmsTemplate template = (JmsTemplate) ctx getBean( jmsTemplate ); Destination destination = (Destination) ctx getBean( destination ); while (true) TextMessage txtmsg = (TextMessage) template receive(destination); if (null != txtmsg) System out println( 收到消息内容为: + txtmsg getText()); else break;

　　 <?xml version= encoding= UTF ?> <beans xmlns= xmlns:xsi= instance xmlns:context= xsi:schemaLocation= beans xsd context xsd > <! 配置JMS连接工厂 > <bean id= connectionFactory class= apache activemq spring ActiveMQConnectionFactory > <property name= brokerURL value= tcp://localhost: /> </bean> <! 配置JMS模版 > <bean id= jmsTemplate class= sprre JmsTemplate > <property name= connectionFactory ref= connectionFactory /> </bean> <! 发送消息的目的地（一个队列） > <bean id= destination class= mand ActiveMQQueue > <! 设置消息队列的名字 > <constructor arg index= value= HelloWorldQueue /> </bean> </beans>

　　运行发送端三次

　　成功发送了一条JMS消息 Process finished with exit code

　　然后再运行接收端一次

　　收到消息内容为: 发送消息 Hello ActiveMQ Text Message！收到消息内容为: 发送消息 Hello ActiveMQ Text Message！收到消息内容为: 发送消息 Hello ActiveMQ Text Message！

　　继续测试发现接收端接收一条消息后不退出程序而是继续等待一旦有消息发送过来就获取到然后输出！

　　发一张图看看

cha138/Article/program/Java/ky/201311/28780