ActiveMQ整合Spring入门用法解析
爱编程DE文兄 人气:0一.ActiveMQ整合Spring基础
ActiveMQ和Spring的整合,其实是把activemq的一些对象交给spring来管理,比如连接工厂,queue,top等等
二.依赖
除了activemq本身提供的jar包外,还需要两个spring整合activemq的jar:
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context-support</artifactId> </dependency> <!-- activemq --> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> </dependency>
三.在spring配置文件中,配置activemq相关的对象
》生产者需要配置的对象:activemq原生连接工厂,spring包装过的工厂,JmsTemplate(生产者),queue,topic
<!-- 配置activemq的连接工厂 --> <bean name="activemqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <constructor-arg index="0" value="tcp://192.168.xx.xxx:61616"></constructor-arg> </bean> <!-- 配置spring包装的连接工厂 --> <bean name="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"> <!-- 设置activemq的连接工厂 --> <property name="targetConnectionFactory" ref="activemqConnectionFactory"></property> </bean> <!-- 配置生产者对象:jmstemplate --> <bean name="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <!-- 设置工厂 --> <!-- <constructor-arg name="connectionFactory" ref="connectionFactory"></constructor-arg> --> <property name="connectionFactory" ref="connectionFactory"></property> </bean> <!-- 配置queue对象 --> <bean name="queueDestination" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg name="name" value="spring-active-queue"></constructor-arg> </bean> <!-- 配置topic对象 --> <bean name="topicDestination" class="org.apache.activemq.command.ActiveMQTopic"> <constructor-arg name="name" value="spring-active-topic"></constructor-arg> </bean>
测试代码:
//测试生产者发生queue @Test public void testJMSTemplateByQueue() throws Exception { //创建spring容器 ApplicationContext ioc = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-activemq.xml"); //获取jmstemplate JmsTemplate jmsTemplate = ioc.getBean(JmsTemplate.class); //获取目的对象 Destination queue = (Destination) ioc.getBean("queueDestination"); //发送消息,并设置目的对象和消息 jmsTemplate.send(queue,new MessageCreator() { public Message createMessage(Session session) throws JMSException { TextMessage message = session.createTextMessage(); message.setText("hello spring activemq"); return message; } });
小结:生产者是需要在特定的时间发送指定的消息内容,因此是需要书写代码的
》消费者需要配置的对象:activemq原生连接工厂,spring包装过的工厂,监听容器(消费者),监听器,queue,topic
》之前监听器我们是直接实现匿名内部类的方式,但是在spring这就不能了,还是书写一个实现类并继承messageListener接口
<!-- 配置activemq的连接工厂 --> <bean name="activemqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <constructor-arg index="0" value="tcp://192.168.xx.xxx:61616"></constructor-arg> </bean> <!-- 配置spring包装的连接工厂 --> <bean name="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"> <!-- 设置activemq的连接工厂 --> <property name="targetConnectionFactory" ref="activemqConnectionFactory"></property> </bean> <!-- 配置监听器 --> <bean name="myMessageListener" class="cn.e3mall.search.listener.MyMessageListener"></bean> <!-- 配置监听容器:消费者 --> <bean name="messageListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <!-- 设置连接工厂 --> <property name="connectionFactory" ref="connectionFactory"></property> <!-- 设置目的对象 --> <property name="destination" ref="queueDestination"></property> <!-- 设置监听器 --> <property name="messageListener" ref="myMessageListener"></property> </bean> <!-- 配置queue对象 --> <bean name="queueDestination" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg name="name" value="spring-active-queue"></constructor-arg> </bean> <!-- 配置topic对象 --> <bean name="topicDestination" class="org.apache.activemq.command.ActiveMQTopic"> <constructor-arg name="name" value="spring-active-topic"></constructor-arg> </bean>
测试代码:
@Test public void testListener() throws IOException { ApplicationContext ioc = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-activemq.xml"); System.in.read(); }
小结:我们的测试代码很简单,只要把容器启动了,监听器就会一致监听着。不需要写任何代码,监听器只要一直关注目的对象Destination是否有消息发送过来
加载全部内容