消息队列activemq整合spring发送端和接收端配置
2017-06-23 21:47
621 查看
发送端的配置
目标连接
工厂
模板
队列目的地.....主题目的地
<bean id="targetConnection" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://192.168.25.128:61616"></property>
</bean>
<!-- 通用的connectionfacotry 指定真正使用的连接工厂 -->
<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="targetConnection"></property>
</bean>
<!-- 接收和发送消息时使用的类 模板对象-->
<bean class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"></property>
</bean>
<!-- <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg name="name" value="item-change-queue"></constructor-arg>
</bean> -->
<bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
<constructor-arg name="name" value="item-change-topic"></constructor-arg>
</bean>
接收端的配置,接收端是通过监听器实现功能的.--
目标连接
工厂
接收发送的模板
监听器
监听器容器
监听器容器可以配置两个,相当于两个客户端,每个容器都会收到一条消息
<bean id="targetConnection" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://192.168.25.128:61616"></property>
</bean>
<!-- 通用的connectionfacotry 指定真正使用的连接工厂 -->
<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="targetConnection"></property>
</bean>
<!-- 接收和发送消息时使用的类 模板对象-->
<bean class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"></property>
</bean>
<!-- 监听器 -->
<bean id="myMessageListener" class="com.itheima.activemq.spring.MyMessageListener"></bean>
<!-- 监听容器,作用:启动线程做监听 -->
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"></property>
<property name="destination" ref="topicDestination"></property>
<property name="messageListener" ref="myMessageListener"></property>
</bean>
<bean id="myMessageListener2" class="com.itheima.activemq.spring.MyMessageListener"></bean>
<!-- 监听容器,作用:启动线程做监听 -->
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"></property>
4000
<property name="destination" ref="topicDestination"></property>
<property name="messageListener" ref="myMessageListener2"></property>
</bean>
---------------------------------------------------------------华丽的分割线-------------------------------------------------------------------------
需要写一个类,实现监听器中未实现的方法.在onmessage当中,写接收到消息之后的逻辑代码.
public class MyMessageListener implements MessageListener {
@Override
public void onMessage(Message message) {
//获取消息
if(message instanceof TextMessage){
TextMessage textMessage = (TextMessage)message;
String text;
try {
text = textMessage.getText();
System.out.println(text);
} catch (JMSException e) {
e.printStackTrace();
}
}
}
}
目标连接
工厂
模板
队列目的地.....主题目的地
<bean id="targetConnection" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://192.168.25.128:61616"></property>
</bean>
<!-- 通用的connectionfacotry 指定真正使用的连接工厂 -->
<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="targetConnection"></property>
</bean>
<!-- 接收和发送消息时使用的类 模板对象-->
<bean class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"></property>
</bean>
<!-- <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
<constructor-arg name="name" value="item-change-queue"></constructor-arg>
</bean> -->
<bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
<constructor-arg name="name" value="item-change-topic"></constructor-arg>
</bean>
接收端的配置,接收端是通过监听器实现功能的.--
目标连接
工厂
接收发送的模板
监听器
监听器容器
监听器容器可以配置两个,相当于两个客户端,每个容器都会收到一条消息
<bean id="targetConnection" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://192.168.25.128:61616"></property>
</bean>
<!-- 通用的connectionfacotry 指定真正使用的连接工厂 -->
<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="targetConnection"></property>
</bean>
<!-- 接收和发送消息时使用的类 模板对象-->
<bean class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory"></property>
</bean>
<!-- 监听器 -->
<bean id="myMessageListener" class="com.itheima.activemq.spring.MyMessageListener"></bean>
<!-- 监听容器,作用:启动线程做监听 -->
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"></property>
<property name="destination" ref="topicDestination"></property>
<property name="messageListener" ref="myMessageListener"></property>
</bean>
<bean id="myMessageListener2" class="com.itheima.activemq.spring.MyMessageListener"></bean>
<!-- 监听容器,作用:启动线程做监听 -->
<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="connectionFactory" ref="connectionFactory"></property>
4000
<property name="destination" ref="topicDestination"></property>
<property name="messageListener" ref="myMessageListener2"></property>
</bean>
---------------------------------------------------------------华丽的分割线-------------------------------------------------------------------------
需要写一个类,实现监听器中未实现的方法.在onmessage当中,写接收到消息之后的逻辑代码.
public class MyMessageListener implements MessageListener {
@Override
public void onMessage(Message message) {
//获取消息
if(message instanceof TextMessage){
TextMessage textMessage = (TextMessage)message;
String text;
try {
text = textMessage.getText();
System.out.println(text);
} catch (JMSException e) {
e.printStackTrace();
}
}
}
}
相关文章推荐
- ActiveMQ整合Spring实现消息机制二(消息接收端配置)
- Spring整合ActiveMQ一(消息发送端配置)
- activemq与spring整合,自动消费队列的配置与代码
- ActiveMQ消息队列和spring进行整合实例
- Spring整合ActiveMQ实现简单的消息队列
- Spring整合ActiveMQ实现简单的消息队列
- spring整合apache activemq实现消息发送的三种方式代码配置实例
- Java消息队列-Spring整合ActiveMq
- Java消息队列-Spring整合ActiveMq
- 详解Java消息队列-Spring整合ActiveMq
- Java消息队列-Spring整合ActiveMq
- Java消息队列-Spring整合ActiveMq
- spring整合activemq消息队列之点对点模式
- Spring整合ActiveMQ完成消息队列MQ编程
- Java消息队列-Spring整合ActiveMq
- Java消息队列-Spring整合ActiveMq
- Java消息队列-Spring整合ActiveMq
- ActiveMQ消息中间件整合Java配置实例
- 一、消息队列之ActiveMQ的安装、配置和C#样例代码
- spring整合activemq发送MQ消息[Topic模式]实例,activemqmq