Springboot集成ActiveMQ

ActiveMQ介绍 1. 简介

MQ：即消息队列 Message Queue

Message：是在两台计算机间传送的数据单位。消息可以非常简单，例如只包含文本字符串；也可以更复杂，可能包含嵌入对象。

message queue ： “消息队列”是在消息的传输过程中保存消息的容器。

类比操作系统中两个进程通过消息队列进行通信

业务场景：

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

作用：

ActiveMQ是消息队列技术，为解决高并发问题而生
ActiveMQ生产者消费者模型（生产者和消费者可以跨平台、跨系统）
ActiveMQ支持如下两种消息传输方式

发送消息方式

点对点模式，生产者生产了一个消息，只能由一个消费者进行消费
发布/订阅模式，生产者生产了一个消息，可以由多个消费者进行消费

一种是持久化消息,一种是非持久化消息,如果发送的消息是持久化消息的话,消息是不会丢失的,ActiveMQ默认的是使用kahaDB来做数据的持久化,但是我们也可以用效率更高的levelDB,并且leverDB可以和zookeeper结合,实现ActiveMQ集群,持久化同步的问题

2. Springboot集成ActiveMQ

添加依赖

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

创建消息队列对象

	@Bean
	public ActiveMQQueue queue(){
		return new ActiveMQQueue("active.queue");
	}

创建消息产生者

@RestController
public class QueueController {

    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;
    @Autowired
    private ActiveMQQueue queue;

    @RequestMapping("/send")
    public void send(){
        this.jmsMessagingTemplate.convertAndSend(this.queue
        ,"新发送的消息!");
    }
}

创建消息接收者

@RestController
public class CustomerController {
    @JmsListener(destination = "active.queue")
    public void readActive(String message){
        System.out.println("接收到" + message);
    }

}

启动springboot项目，即可查看到通过消息队列传递了消息

Springboot集成ActiveMQ

大数据系统相关栏目本月热门文章