消息中间件activeMQ原理和使用

一: 消息中间件的优势
1.使用消息中间件,降低了dubbo服务之间的耦合度,使得两个原本使用远程注入耦合了的模块可以实现松耦合,使用消息中间件进了间接通信.
2.缓冲能力,消息中间件就像一个巨大的蓄水池,将高峰期的大量请求存储起来交给后台慢慢处理,对于秒杀业务尤其重要.

二: 消息中间件的两种消息传递模式
1.点对点消息通信型:也称为队列模式,一条特定的消息只给一个特定的消费者,消费完成之后就从持久化存储中删除该数据,生产者将消息发送到指定的队列(queue)中,此时对于消费者来说,获取消息有两种方式.分别是pull和push,其中push方式是activeMQ接收到消息之后去调用消费者的新消息通知接口,相当于activeMQ去通知消费者,但是这样会浪费activeMQ的宝贵线程资源.而pull方式,是消费者循环调用activeMQ的api去获取消息,这样不会消耗activeMQ的线程资源,并且消费者更加主动.push方式由于过多占用activeMQ的线程资源而难以应对高并发,所以并不适用.
2.发布/订阅模式:也称为主题模式,特定的一条消息可以被多个消费者接收,只要消费者订阅了某个主题.消息的生产者会将消息发布到名称为topic的虚拟通道里面去,topic是可以被多个消费者订阅的.这个模式类似于广播模式,但是要求消费者在线监听,如果消费者离线,再次上线是无法获取该消息的,发布/订阅模式采用的是pull方式把消息发送给消费者.

三:两种消息传递模式的配置和使用
1.点对点消息通信型的举例
需求描述:电商系统的商家后台系统,审核商品之后,需要把经过审核的商品的信息同步到solr索引库中,此时商家后台工程和搜索服务(导入solr索引库)之间是耦合的,因为商家后台工程依赖了搜索服务.当商家后台执行了审核方法之后,向activeMQ发送消息,然后搜索服务activeMQ接收消息并更新索引库,因为导入solr索引库只需要执行一次,然后所有的服务就都可以使用,所以使用一对一的消息队列接口.

生产信息:此时,商家后台系统作为生产者,而搜索服务作为消费者.发送消息的步骤:
    1.在pom文件中,如果商家后台系统依赖了了搜索服务,我们需要把依赖删除.然后引入jms和activeMQ的依赖
    2.编辑配置文件,配置工厂类等信息不再叙述,在web.xml中加载此配置文件,因为都是一样的,而队列消息的目的地配置如下图所示

    3.在商家后台系统里面审核方法里面编程,首先注入队列消息的目的地对象Destination,其名称就是我们在上图中配置的id,通过id找到这个指定的bean
    4.然后使用jms模板jmsTemplate调用send方法,以指定数据格式发送数据到activeMQ.

if(status.equals("1")) {
//调用方法获取集合
List<TbItem> list = goodsService.findItemListByGoodsIdandStatus(ids, status);
//判断,如果获取的集合的长度大于0
if(list.size()>0) {//将list集合转换成json字符串发送final String jsonString = JSON.toJSONString(list);//调用send方法发送jmsTemplate.send(queueSolrDestination, new MessageCreator() {@Overridepublic Message createMessage(Session session) throws JMSException {return session.createTextMessage(jsonString);}});
}

消费信息:此时,搜索服务作为消费者来获取activeMQ里面的数据,然后做存入索引库的操作,步骤如下:
    1.在搜索服务中然后引入jms和activeMQ的依赖
    2.编辑配置文件,在web.xml中加载此配置文件,下图是消费者配置文件的需要修改的地方,如果还有其他操作把这两份配置复制一下即可

    3.在搜索服务下定义一个监听器类,名称和上述配置文件中的name=messageListener的属性的引用itemSearchListener相同,首字母改大写,实现MessageListener接口,加上@Component注解.
    4.在重写的onMessage方法里面,获取activeMQ里面传递的数据,然后注入搜索服务,此时就是在同一个工程之类注入,可以做到高内聚,调用搜索服务的方法导入到solr索引库.

@Component
public class ItemSearchListener implements MessageListener {@Autowiredprivate ItemSearchService itemSearchService;@Overridepublic void onMessage(Message messgae) {TextMessage textMessage=(TextMessage)messgae;String text;try {//获取内容text = textMessage.getText();//将text转换成集合List<TbItem> list=JSON.parseArray(text,TbItem.class);//调用importList方法,导入到solr索引库itemSearchService.importList(list);} catch (JMSException e) {e.printStackTrace();}}
}

2.发布/订阅模式的举例
    需求描述:电商系统的商家后台系统,审核商品之后,需要把审核的商品的id传递给页面服务,由页面服务使用freemarker生成一个个的商品静态页面,消息中间件activeMQ实现运营商后台和页面生成服务之间的松耦合,商家后台审核之后,向activeMQ发送消息(审核通过的商品的id数组),然后页面生成服务接收activeMQ的消息,执行商品详情页的生成操作.我们搭建的多台服务器上,每一台服务器上都有相同的页面,也就是说这里的消息生产者(运营商服务)和消息消费者(页面服务)之间是发布订阅的关系,运营商服务发布消息,多个服务器(页面服务)订阅该消息,然后执行生成静态页面的操作.
    生产信息:商家后台系统作为消息的生产者,需要把审核的商品的id的数组发送到activeMQ里面去.步骤如下:
    1.在pom文件中,如果商家后台系统依赖了了页面服务,我们需要把依赖删除.然后引入jms和activeMQ的依赖
    2.编辑配置文件,配置工厂类等信息不再叙述,在web.xml中加载此配置文件,因为都是一样的,而发布/订阅消息的目的地配置如下图所示

    3.在商家后台系统里面审核方法里面编程,首先注入队列消息的目的地对象,Destination,其名称就是我们在上图中配置的id,通过id找到这个指定的bean.
    4.然后使用jms模板jmsTemplate调用send方法,已指定数据格式发送数据到activeMQ

for(final Long id:ids) {//itemPageService.genItemHtml(id);jmsTemplate.send(topicPageDestination, new MessageCreator() {@Overridepublic Message createMessage(Session session) throws JMSException {//将id以文本形式传递到activeMQreturn session.createTextMessage(id+"");}});
}

消费消息:页面服务作为消息的消费者,从activeMQ里面获取数据,根据数据调用服务层方法完成页面生成的操作.
    1.在页面服务中然后引入jms和activeMQ的依赖
    2.编辑配置文件,在web.xml中加载此配置文件,下图是消费者配置文件的需要修改的地方,如果还有其他操作把这两份配置复制一下即可

    3.在搜索服务下定义一个监听器类,名称和上述配置文件中的name=messageListener的属性的引用pageDeleteListener相同,首字母改大写,实现MessageListener接口.
    4.在重写的onMessage方法里面,获取activeMQ里面传递的数据,然后注入页面服务,此时就是在同一个工程之类注入,可以做到高内聚,调用页面服务的方法创建静态页面.

@Component
public class PageListener implements MessageListener {@Autowiredprivate ItemPageService itemPageService;@Overridepublic void onMessage(Message message) {//强制转换TextMessage textMessage= (TextMessage)message;try {//获取内容String text = textMessage.getText();//调用服务层方法,创建商品页面itemPageService.genItemHtml(Long.parseLong(text));} catch (JMSException e) {e.printStackTrace();}}
}

四 :配置的时候,配置队列模式还是发布/订阅模式,他的区别在于:

消息中间件activeMQ原理和使用相关推荐

消息中间件-Activemq之Broker-Cluster
2019独角兽企业重金招聘Python工程师标准>>> 接着上一篇消息中间件-Activemq之Master-Slaver,下面看看Broker-Cluster实现负载均衡 Brok ...
消息中间件ActiveMQ、RabbitMQ、RocketMQ、ZeroMQ、Kafka如何选型
转载自消息中间件ActiveMQ.RabbitMQ.RocketMQ.ZeroMQ.Kafka如何选型? 最近要为公司的消息队列中间件进行选型,市面上相关的开源技术又非常多,如ActiveMQ.Ra ...
消息中间件之ActiveMQ原理及使用教程(持久化、JMS可靠消息、重试机制与幂等性问题)
消息中间件产生的背景 1.在客户端与服务器进行通讯时,客户端调用后,必须等待服务对象完成处理返回结果才能继续执行,这个过程是基于请求与响应的同步过程. 2.客户与服务器对象的生命周期紧密耦合,客户进程 ...
Java消息中间件(activeMQ)
文章目录 **第一章消息中间件概述** 1. 消息中间件的好处 2. 什么是消息中间件 3. 什么是JMS(规范) 4. 什么是AMQP(协议) 5. 几个常用消息中间对比 **第二章初始JMS* ...
消息中间件ActiveMQ 5：可持久化方式AMQ和KahaDB
文章目录 ActiveMQ 的持久化方式一.需要进行消息持久化的原因二.持久化方式 1.AMQ message Store(了解) 2.KahaDB消息存储(默认) ActiveMQ 的持久化方式 ...
ActiveMQ原理分析
持久化消息和非持久化消息的发送策略消息同步发送和异步发送 ActiveMQ支持同步.异步两种发送模式将消息发送到broker上.同步发送过程中,发送者发送一条消息会阻塞直到broker反馈一个确认消 ...
ActiveMQ 原理与应用
在介绍activemq之前,先简单介绍JMS,它是J2EE的13个规范之一,提供的是消息中间件的规范. JMS包括以下基本构件: 连接工厂,是客户用来创建连接的对象,ActiveMQ提供的是Activ ...
从ActiveMQ原理到实例
在介绍activemq之前,先简单介绍JMS,它是J2EE的13个规范之一,提供的是消息中间件的规范. JMS包括以下基本构件: 连接工厂,是客户用来创建连接的对象,ActiveMQ提供的是Activ ...
分布式消息通信ActiveMQ原理分析一
本章知识点: 1. 持久化消息和非持久化消息的发送策略2. 消息的持久化方案及实践3. 消费端消费消息的原理持久化消息与非持久化消息的发送策略消息同步发送和异步发送同步发送过程中,发送者发送一条 ...

消息中间件activeMQ原理和使用

消息中间件activeMQ原理和使用相关推荐

最新文章

热门文章