activeMQ小知识:基本使用阐述

简介:ActiveMQ是Apache下的使用Java语言开发的开源项目,是基于JMS(Java Message Servie)规范的一种消息中间件的实现,支持事务 和负载,而且可以很方便的跟spring整合。之所以使用ActiveMQ,是为了实现系统业务的解耦,异步消息的推送,增加系统并发量,提高用户体验。例如以我在工作中的使用,在比较耗时且异步的远程开锁操作时使用。

两种消息方式:

点对点方式(PTP):一个消费者对应一个生产者,生产者生产消息只能被指定的消费者消费。

发布/订阅模式(Publish/Sub):一个生产者产生消息发送后,可以被多个消费者进行接收。生产者生产的消息在没有被消费者消费之前,并不会将消息持久化到activemq的服务端,发送的消息会自动消失。所以 测试的时候需要先创建消费者对象,然后在发送消息,防止消息丢失。

不同点:两种方式大同小异,只是PTP传递消息的方法:消息的生产者发送以后,消息会持久化在activemq的服务端,如果该消息给消费者消费,在服务端持久化的消息也就同时被删除。
发布订阅传递消息的方法:消息的生产者发送消息以后,如果没有消费者消费,消息不会持久化在activemq的客户端,会立即消失。如果创建的消息被消费,会的activemq的服务端显示消息相关内容。

设置消息延时发送

根据项目需要可以设置消息的延时发送
(1)首先在进入activemq的安装目录下的conf目录下

(2)编辑activemq.xml,设置为延时发送机制
在这里插入图片描述spring集成activeMQ:https://blog.csdn.net/weixin_43945983/article/details/85097365

猜你喜欢

转载自blog.csdn.net/weixin_43945983/article/details/108128920