activemq rabbitmq

一.ActiveMQ

1.什么是消息队列

ActiveMQ是Apache出品，最流行的，能力强劲的开源消息总线。

消息队列是在消息的传输过程中保存消息的容器

2.介绍RabbitMQ与ActiveMQ

ActiveMQ 是 Apache 出品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个完全支持 JMS1.1 和 J2EE 1.4 规范的 JMS Provider 实现。

RabbitMQ RabbitMQ 是一个在 AMQP 基础上完成的，可复用的企业消息系统。他遵循 Mozilla Public License 开源协议。开发语言为 Erlang。

3.消息队列的应用场景

消息队列的主要特点是异步处理，主要目的是减少请求响应时间和解耦。所以主要的使用场景就是将比较耗时而且不需要即时（同步）返回结果的操作作为消息放入消息队列。同时由于使用了消息队列，只要保证消息格式不变，消息的发送方和接收方并不需要彼此联系，也不需要受对方的影响，即解耦和。流量的削峰

4.JMS

ActiveMQ用JMS模型

JMS（Java Messaging Service）是 Java 平台上有关面向消息中间件的技术规范，它便于消息系统中的 Java 应用程序进行消息交换,并且通过提供标准的产生、发送、接收消息的接口，简化企业应用的开发。

JMS模型

点对点模型：生产者发送一条消息到 queue，只有一个消费者能收到。

发布订阅模型：发布者发送到 topic 的消息，只有订阅了 topic 的订阅者才会收到消息

5.spring整合ActiveMQ

5.1 创建 spring-activemq-producer

5.1.1 修改pom文件

<dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-all</artifactId> </dependency>  <dependency> <groupId>org.apache.xbean</groupId> <artifactId>xbean-spring</artifactId> </dependency>  <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> </dependency>

5.1.2整合 ActiveMQ

<amq:connectionFactory brokerURL="tcp://192.168.70.151:61616" username="admin" password="admin" id="amqConnectionFactory"/>   <bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactoryBean"> <property name="connectionFactory" ref="amqConnectionFactory"></property> <property name="maxConnections" value="10"></property> </bean>  <bean id="connectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory"> <property name="targetConnectionFactory" ref="pooledConnectionFactory"></property> <property name="sessionCacheSize" value="3"></property> </bean>  <bean id="template" class="org.springframework.jms.core.JmsTemplate">  <property name="connectionFactory" ref="connectionFactory"></property>  <property name="defaultDestinationName" value="test-spring"></property> </bean>

5.2 创建 spring-activemq-consumer

5.2.1 修改pom文件

同上

5.2.2 整合ActiveMQ

5.3 测试整合

5 .3.1Producer 发送消息

如果使用了连接池需要添加两个坐标

<dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-pool</artifactId> <version>5.9.0</version> </dependency> <dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-jms-pool</artifactId> <version>5.9.0</version> </dependency>

5.3.2 发送消息

@Service public class UserServiceImpl implements UserService { @Autowired private JmsTemplate jmsTemplate; @Override public void addUser(final Users user) { //发送消息 this.jmsTemplate.send(new MessageCreator(){ @Override public Message createMessage(Session session) throws JMSException { Message message =session.createObjectMessage(user); return message; } }); } }

5.3.3 Consumer 接收消息

@Component(value="myListener") public class MyMessageListener implements MessageListener{ @Autowired private UserService userService; @Override public void onMessage(Message message) { //处理消息 ObjectMessage objMessage =(ObjectMessage)message; Users user=null; try { user = (Users)objMessage.getObject(); } catch (JMSException e) { // TODO Auto-generated catch block e.printStackTrace(); } this.userService.showUser(user); } }

二.RabbitMQ 原理图