博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
四.rocketMQ原理
阅读量:4345 次
发布时间:2019-06-07

本文共 665 字,大约阅读时间需要 2 分钟。

⦁    mqnamesrv服务

    broker启动的时候(单个、多个),都会去查找namesrv注册。

    Producer发生消息的时候会根据topic获取路由到broker的信息。

    Consumer根据topic到namesrv获取topic的路由到broker的信息。

     broker启动的时候会定时任务,每10秒会向namesrv发送心跳请求,并注册topic信息到broker

⦁ 功能:
     接收broker的请求注册broker的路由信息。
     接收client的请求根据某个topic获取所有broker的路由信息。

⦁ 消息订阅

RocketMQ消息订阅有两种模式:一种是Push模式,即MQServer主动向消费端推送

说明:但在具体实现时,Push和Pull模式都是采用消费端主动拉取的方式。

DefaultMQProducer、TransactionMQProducer、DefaultMQPushConsumer、DefaultMQPullConsumer消息订阅ConsumerDefaultMQPushConsumer consumer = new DefaultMQPushConsumer("QuickStartConsumer");消息产生者ProducerDefaultMQProducer producer = new DefaultMQProducer("QuickStartProducer");

转载于:https://www.cnblogs.com/xxt19970908/p/6717113.html

你可能感兴趣的文章
如何使用mysql
查看>>
linux下wc命令详解
查看>>
敏捷开发中软件测试团队的职责和产出是什么?
查看>>
在mvc3中使用ffmpeg对上传视频进行截图和转换格式
查看>>
python的字符串内建函数
查看>>
Spring - DI
查看>>
微软自己的官网介绍 SSL 参数相关
查看>>
Composite UI Application Block (CAB) 概念和术语
查看>>
ajax跨域,携带cookie
查看>>
阶段3 2.Spring_01.Spring框架简介_03.spring概述
查看>>
阶段3 2.Spring_02.程序间耦合_1 编写jdbc的工程代码用于分析程序的耦合
查看>>
阶段3 2.Spring_01.Spring框架简介_04.spring发展历程
查看>>
阶段3 2.Spring_02.程序间耦合_3 程序的耦合和解耦的思路分析1
查看>>
阶段3 2.Spring_02.程序间耦合_5 编写工厂类和配置文件
查看>>
阶段3 2.Spring_01.Spring框架简介_05.spring的优势
查看>>
阶段3 2.Spring_02.程序间耦合_7 分析工厂模式中的问题并改造
查看>>
阶段3 2.Spring_03.Spring的 IOC 和 DI_2 spring中的Ioc前期准备
查看>>
阶段3 2.Spring_03.Spring的 IOC 和 DI_4 ApplicationContext的三个实现类
查看>>
阶段3 2.Spring_02.程序间耦合_8 工厂模式解耦的升级版
查看>>
阶段3 2.Spring_03.Spring的 IOC 和 DI_6 spring中bean的细节之三种创建Bean对象的方式
查看>>