草庐IT

rocketMq

全部标签

ActiveMQ、RocketMQ、RabbitMQ、Kafka区别

一、三大应用场景(优点)解耦、异步、削峰解耦:只需要将消息写入消息队列,需要消息的去消息队列中订阅就好异步:一些非必要的逻辑可以采用异步来完成,从而提升响应速度削峰:某个时间段并发量特别大的时候可以将消息发送到消息队列中,然后从消息队列中慢慢拉取进行消费解耦传统模式:image.png传统模式缺点:系统间耦合性太强,如上图所示,系统A在代码中直接调用系统B和系统C,如果将来系统D要接入,系统A还要修改代码,过于麻烦!image.png中间件模式优点:将消息写入消息队列,要消息的系统自己从消息队列中订阅,从而系统A不再需要做任何修改异步传统模式:image.png一些非必要的业务逻辑以同步的方式

ActiveMQ、RocketMQ、RabbitMQ、Kafka区别

一、三大应用场景(优点)解耦、异步、削峰解耦:只需要将消息写入消息队列,需要消息的去消息队列中订阅就好异步:一些非必要的逻辑可以采用异步来完成,从而提升响应速度削峰:某个时间段并发量特别大的时候可以将消息发送到消息队列中,然后从消息队列中慢慢拉取进行消费解耦传统模式:image.png传统模式缺点:系统间耦合性太强,如上图所示,系统A在代码中直接调用系统B和系统C,如果将来系统D要接入,系统A还要修改代码,过于麻烦!image.png中间件模式优点:将消息写入消息队列,要消息的系统自己从消息队列中订阅,从而系统A不再需要做任何修改异步传统模式:image.png一些非必要的业务逻辑以同步的方式

RocketMQ消息发送流程

大家好,我是Leo。今天聊一下RocketMQ消息发送,重试机制,故障延迟机制,获取路由机制,消息队列的选择消息发送关系图首先放一下BrokerCluster,Broker,Topic,Queue的关系图。因为下文主要会沿着这四块进行梳理发送的三种方式消息发送的三种方式同步:发送者向MQ发送一条消息后,一直等待服务器返回成功才继续下一个。异步:发送者向MQ发送一条消息后,通过回调函数调用消息发布函数继续发送,主线程立即返回。单向:发送者向MQ发送一条消息后,直接返回,不等待消息服务器的结果,也不注册函数,简单来说,就是只管发。其他啥也不管。源码packageorg.apache.rocketm

RocketMQ消息发送流程

大家好,我是Leo。今天聊一下RocketMQ消息发送,重试机制,故障延迟机制,获取路由机制,消息队列的选择消息发送关系图首先放一下BrokerCluster,Broker,Topic,Queue的关系图。因为下文主要会沿着这四块进行梳理发送的三种方式消息发送的三种方式同步:发送者向MQ发送一条消息后,一直等待服务器返回成功才继续下一个。异步:发送者向MQ发送一条消息后,通过回调函数调用消息发布函数继续发送,主线程立即返回。单向:发送者向MQ发送一条消息后,直接返回,不等待消息服务器的结果,也不注册函数,简单来说,就是只管发。其他啥也不管。源码packageorg.apache.rocketm