SpringBoot +docker 集成 ActiveMQ

SpringBoot +docker 集成 ActiveMQ

ActiveMQ 介绍

MQ （MessageQueue）中文称消息队列，用于消息接收和转发的容器，可用于消息推送。Active MQ 是一个Java的开源消息系统。很好的支持了 JMS 规范。

ActiveMQ 安装

这里使用的Docker安装 地址：​​docker安装activemq​​

ActiveMQ 集成

在pom.xml中引入依赖

org.springframework.boot spring-boot-starter-activemq

在application.properties配置

###ActiveMQ 配置spring.activemq.broker-url = tcp://localhost:61616spring.activemq.in-memory = truespring.activemq.pool.enable = falsespring.activemq.package.trust-all = true

ActiveMQ 使用

我们都知道QQ空间有一个发说说的功能，这里有很多的用户同一时刻会发送大量的说说，这样我们如果采用同步的方式，每一个用户都占用一条线程，那么会导致系统性能大幅度降低。这样就需要我们的ActiveMQ来进行异步消费抵抗高使用量的冲击。

设计一个可以实现异步消费的生产者和消费者模型消费者

import org.springframework.jms.annotation.JmsListener;import org.springframework.stereotype.Component;/** * 描述：消费者 * @author wangyu * @date 2019/5/16 */@Componentpublic class Consumer { @JmsListener(destination = "activemq.queue") public void receiveQueue(String text) { System.out.println("信息接受*** "+text+" ***成功"); }}

@JmsListener(destination = “activemq.queue”) 监听队列信息 destination = “activemq.queue” ：监听的队列名

生产者

import javax.jms.Destination;import org.springframework.jms.core.JmsTemplate;import org.springframework.stereotype.Service;import javax.annotation.Resource;/** * 描述：生产者 * @author wangyu * @date 2019/5/15 */@Servicepublic class Producer { @Resource private JmsTemplate jmsTemplate ; public void sendMessage(Destination destination, final String message) { jmsTemplate.convertAndSend(destination,message); }}

生产者消费者模型测试

/** * 描述：ActiveMQ 测试*/@Testpublic void testActiveMQ() { Destination destination = new ActiveMQQueue("activemq.queue") ; producer.sendMessage(destination,"ActiveMQ测试消息");}

打印出如下结果：

信息接受*** ActiveMQ测试消息 ***成功 以QQ空间的数据库简单的操作测试ActiveMQ的使用

根据我们对插入数据的操作和生产者消费者的模型结合，就是将我们的设置说说内容的操作放到生产者中，而将保存的插入数据库的操作放到消费者中。就可以达到异步插入的目的。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。