ActiveMQ+spring的简单整合

我会带着你远行 2022-02-18 16:11 245阅读 0赞

[浅谈ActiveMQ][ActiveMQ]

## 什么是ActiveMQ: ##

Apache ActiveMQ是最流行、功能最强大的开源消息传递和**集成服务器**。（**消息队列服务**）  
Apache ActiveMQ速度快、支持多语言客户端和协议。

## MQ特点： ##

MQ的消费-生产者模型的一个典型的代表，一端往消息队列中不断的写入消息，而另一端则可以读取或者订阅队列中的消息。MQ和JMS类似，但不同的是JMS是SUN JAVA消息中间件服务的一个标准和API定义，而MQ则是遵循了AMQP协议的具体实现和产品。  
使用场景：  
在项目中，将一些无需即时返回且耗时的操作提取出来，进行了异步处理，而这种异步处理的方式大大的节省了服务器的请求响应时间，从而提高了系统的吞吐量。

## JMS ##

JMS是JAVA EE的标准；  
这种规范（标准）指出：  
消息的发送应该是异步的、非阻塞的。  
这种规范能够使系统实现松耦合，提高系统的扩展性和灵活性。

## JMS API ##

1.ConnectionFactory  
创建ConnectionFactory工厂  
ConnectionFactory factory =new ActiveMQConnectionFactory(user,password,“tcp://localhost:61616”);  
2.Connection  
创建Connection  
Connection connection =factory.createConnection();  
connection.start();  
3.Session  
Session session=connection.createSession(false,Session.acknowledge);  
4.Desination  
两种：主要有topic 消息(1 对多), queue 消息(1对1).  
Queue queue=session.createQueue(“队列名”);  
Topic topic=session.createTopic(“主题名”);  
5.生产者和消费者  
MessageProducer producer=session.createProducer(queue/topic);  
MessageConsumer consumer=session.createConsumer(queue/topic);  
6.创建Message  
TextMessage、MapMessage、ObjectMessage、BytesMessage、StreamMessage  
7.创建监听器  
MessageListener

## 整合Spring ##

**1.配置ActiveMQConnectionFactory**

<bean id="mqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="userName" value="" />
       <property name="password" value="" />
       <property name="brokerURL" value="tcp://localhost:61616" />
       <property name="useAsyncSend" value="true" />//使用异步发送
    </bean>

**2.池化ActiveMQConnectionFactory**

**3.缓冲CachingConnectionFactory**

**4.JmsTemplete**

## Spring消费者 ##

**1.配置ActiveMQConnectionFactory**

1.  池化ActiveMQConnectionFactory

1.  CachingConnectionFactory

4.配置监听器  
监听器要实现MessageListener

public class EmailListener implements MessageListener {
        
        @Autowired
        EmailService emailService;
        
        @Override
        public void onMessage(Message message) {
            if (message != null && message instanceof TextMessage) {
                TextMessage msg = (TextMessage)message;
                String emailMsg;
                try {
                    emailMsg = msg.getText().toString();
                    System.out.println("接收到消息队列的消息:" + emailMsg);
                    
                    // 将json转换为email对象
                    Email email = JSONObject.parseObject(emailMsg, Email.class);
                    
                    System.out.println("开始发送邮件");
                    emailService.sendEmail(email);
                    System.out.println("结束发送邮件");
                    
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        }
        
    }

5.消息的目的地

6.监听器的容器

[ActiveMQ]: https://blog.csdn.net/smile_miracle/article/details/72529165#commentBox