Spring Boot 整合ActiveMQ 浅谈Spring Boot 整合ActiveMQ的过程
虾游于海 人气:0想了解浅谈Spring Boot 整合ActiveMQ的过程的相关内容吗,虾游于海在本文为您仔细讲解Spring Boot 整合ActiveMQ的相关知识和一些Code实例,欢迎阅读和指正,我们先划重点:Spring,Boot,整合ActiveMQ,下面大家一起来学习吧。
RabbitMQ是比较常用的AMQP实现,这篇文章是一个简单的Spring boot整合RabbitMQ的教程。
安装ActiveMQ服务器,(也可以不安装,如果不安装,会使用内存mq)
构建Spring boot项目,增加依赖项,只需要添加这一项即可
<!-- 添加acitivemq依赖 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency>
增加Application类
@SpringBootApplication @EnableScheduling //使用定时任务发送消息 public class MqTestApplication { public static void main(String[] args) { SpringApplication.run(MqTestApplication.class, args); } }
配置application.yml
spring: activemq: broker-url: tcp://127.0.01:61616 packages: trust-all: true
构建一个数据Model,可以发送和消费的数据类型有: String, byte array, Map<String,?>, Serializable object.
// 如果发送的消息是一个对象,必须implements Serializable接口 public class TModel implements Serializable { private static final long serialVersionUID = -921008687184331557L; private int count; public TModel(int count) { this.count = count; } @Override public String toString() { return "TModel [count=" + count + "]"; } }
构建Producer
@Component public class Producer { // 在Producer中注入JmsTemplate,我们可以通过这个template发送消息 private final JmsTemplate jmsTemplate; private int count = 0; @Autowired public Producer(JmsTemplate jmsTemplate) { this.jmsTemplate = jmsTemplate; } // 这里使用Spring Boot的定时任务发送消息 @Scheduled(fixedRate = 1000) public void create() { // 使用convertAndSend发送消息 jmsTemplate.convertAndSend("queue1", new TModel(count++)); } }
构建Consumer
@Component public class Consumer { @JmsListener(destination = "queue1") public void comsume(TModel content) { System.out.println("recive message from queue1 [" + content + "]"); } }
特别备注:如果我们的生产者和消费者在不同的Module中时,最好将要消费的数据抽象成公共Module.程序是通过Serializable来序列化和反序列化对象的。必须保证生产者和消费者的对象模型的serialVersionUID是一致的。
项目地址: https://github.com/ldwqh0/active-mq-spring.git
示例:配置rabbitmq ,增加一个队列
@Configuration public class Aqueue { @Bean public Queue queue() { return new Queue("good"); } }
定义一个生产者.
当启用activemq之后,会自动创建一个AmqpTemplate ,可以被注入到任何需要的地方,我们可以通过这个AmqpTemplate发送消息到MQ中
/** * 定义一个生产者 * @author LiDong */ @RestController @RequestMapping("/test") public class SendController { @Autowired private AmqpTemplate template; @GetMapping public String testSend() { // 使用AmqpTemplate发送消息 template.convertAndSend("good", "good"); return "success"; } }
定义消费者,通过指定RabbitListener(queues='good')指定消费的队列
@Component public class Consumer { /** * 定义一个消费者 * @param message */ @RabbitListener(queues = "good") public void handler(String message) { System.out.println("recive message from " + message); } }
启动测试,在浏览器中输入 http://localhost:8080/test 即可发送一条消息到队列中。 该对列可以被消费者处理
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
加载全部内容