阿里rocketmq与自建rocketmq
一、搭环境
阿里rocketmq不用搭建, https://help.aliyun.com/document_detail/34411.html?spm=a2c4g.11186623.6.546.1787650eShM7ho
开源rocketmq(window+rocketmq) https://www.cnblogs.com/amuge/articles/10275292.html
二、发送消息类型:
三、名词解释 https://help.aliyun.com/document_detail/29533.html?spm=a2c4g.11186623.6.542.1cfa77d7wLCfvb
消息相关名词:
Topic:消息主题 , 一级消息类型
Tag:消息标签,二级消息类型,用来进一步区分某个Topic下的消息分类
Message:消息体
MessageID:消息的全局唯一标识;
Producer:消息生产者(消息发布者)
Producer实例:Producer 的一个对象实例,不同的 Producer 实例可以运行在不同进程内或者不同机器上。Producer 实例线程安全,可在同一进程内多线程之间共享。
consumer:消息消费者(消息订阅者),负责接收消费消息
Consumer 的一个对象实例,不同的 Consumer 实例可以运行在不同进程内或者不同机器上。一个 Consumer 实例内配置线程池消费消息。
Group 一类 Producer 或 Consumer,这类 Producer 或 Consumer 通常生产或消费同一类消息,且消息发布或订阅的逻辑一致。
Group ID Group 的标识。
消费相关名词:
集群消费 一个 Group ID 所标识的所有 Consumer 平均分摊消费消息。例如某个 Topic 有 9 条消息,一个 Group ID 有 3 个 Consumer 实例,那么在集群消费模式下每个实例平均分摊,只消费其中的 3 条消息
广播消费 一个 Group ID 所标识的所有 Consumer 都会各自消费某条消息一次。例如某个 Topic 有 9 条消息,一个 Group ID 有 3 个 Consumer 实例,那么在广播消费模式下每个实例都会各自消费 9 条消息。
消息类型名词:
定时消息 Producer 将消息发送到消息队列 RocketMQ 服务端,但并不期望这条消息立马投递,而是推迟到在当前时间点之后的某一个时间投递到 Consumer 进行消费,该消息即定时消息。
延时消息 Producer 将消息发送到消息队列 RocketMQ 服务端,但并不期望这条消息立马投递,而是延迟一定时间后才投递到 Consumer 进行消费,该消息即延时消息。
事务消息 消息队列 RocketMQ 提供类似 X/Open XA 的分布事务功能,通过消息队列 RocketMQ 的事务消息能达到分布式事务的最终一致。
顺序消息 消息队列 RocketMQ 提供的一种按照顺序进行发布和消费的消息类型, 分为全局顺序消息和分区顺序消息。
全局顺序消息 对于指定的一个 Topic,所有消息按照严格的先入先出(FIFO)的顺序进行发布和消费。
分区顺序消息 对于指定的一个 Topic,所有消息根据 sharding key 进行区块分区。同一个分区内的消息按照严格的 FIFO 顺序进行发布和消费。Sharding key 是顺序消息中用来区分不同分区的关键字段,和普通消息的 key 是完全不同的概念。
四、apache rocketmq名词解释
Producer Group(生产组):相同角色组成的组
Name Server:为producer和consumer提供路由(用户broker发现)
Broker:提供轻量级的topic和queue机制处理消息存储,同时支持推push和拉pull模式和主从结构的容错机制
五、发送消息
http://rocketmq.apache.org/docs/simple-example/
http://rocketmq.apache.org/docs/order-example/
http://rocketmq.apache.org/docs/schedule-example/
http://rocketmq.apache.org/docs/transaction-example/
转载于:https://www.cnblogs.com/amuge/p/10284514.html
阿里rocketmq与自建rocketmq相关推荐
- 从阿里云到自建:RocketMQ迁移的注意事项
这里是weihubeats,觉得文章不错可以关注公众号小奏技术,文章首发.拒绝营销号,拒绝标题党 背景 因为某些原因,我们需要将阿里云的云RocketMQ迁移到自建RocketMQ 开源版本Rocke ...
- rocketmq存储结构_阿里专家分享内部绝密RocketMQ核心原理与最佳实践笔记
本文源码以RocketMQ 4.2.0 和 RocketMQ 4.3.0 为 基 础 , 从RocketMQ的实际使用到RocketMQ的源码分析,再到RocketMQ企业落地实践方案,逐步讲解.使读 ...
- clickhouse原理解析与应用实践 pdf_阿里专家分享内部绝密RocketMQ核心原理与最佳实践PDF...
前言 本文源码以RocketMQ 4.2.0 和 RocketMQ 4.3.0 为 基 础 , 从RocketMQ的实际使用到RocketMQ的源码分析,再到RocketMQ企业落地实践方案,逐步讲解 ...
- 《RocketMQ技术内幕:RocketMQ架构设计与实现原理》一导读...
内容介绍 本书由RocketMQ社区早期的布道者和技术专家撰写,Apache RocketMQ创始人/Linux OpenMessaging创始人兼主席/Alibaba Messaging开源技术负责 ...
- 阿里高级技术专家张建飞:深度剖析领域模型vs数据模型的用法
张建飞 frank 读完需要 21 分钟 速读仅需 7 分钟 阿里巴巴高级技术专家,著有图书<代码精进之路 从码农到工匠>,维护公众号<从码农到工匠> ID:craftsman ...
- RocketMQ 实战-SpringBoot整合RocketMQ同步消息、异步消息、单向消息
官方样例:https://gitee.com/apache/rocketmq/blob/master/docs/cn/RocketMQ_Example.md 1. 同步消息 producer向 bro ...
- RocketMQ 实战-SpringBoot整合RocketMQ
1. 消息生产者 1.1 maven 依赖 <?xml version="1.0" encoding="UTF-8"?> <project x ...
- 你瞧不起的低代码开发,阿里云总裁张建锋,他看上了
"未来不会用低代码,正如10年前不懂Excel,它将是一项基本能力." 对低代码评价之高,正是2022云栖大会,来自阿里云总裁张建锋发表的内容. 普通人说出这番内容,难免被吐槽,然 ...
- [施工中]Java阿里云服务器ECS建站操作不完全指北
[施工中]Java阿里云服务器ECS建站操作不完全指北 ECS建站操作记录 前言 一 .Xshell6与Xftp6 1.1Xshell与Xftp的作用 1.2如何从官网下载xshell与xftp 1. ...
最新文章
- PHP:第四章——PHP数组array_diff计算数组差集
- DEDE无简略标题时显示完整标题
- rsync 一条命令实现远程文件传输
- photoshop 工具栏中英文对照
- 理解Vue的计算属性
- jquery load 和 iframe 比较
- Android 打造编译时注解解析框架
- Linux find xargs rm .orig
- codewars python Regex validate PIN code
- js正则表达式把数字格式化成XXXX-XXX-XXX
- 2021最新的NVIDIA显卡排行榜前十
- 【OI备忘录】dalao博文收藏夹
- 东野圭吾《解忧杂货店》读后感
- 数据库架构(一) 插入数据库
- 正则表达式:回车和换行的区别
- 华为android9王者荣耀卡,华为mate9玩王者荣耀怎么样 mate9玩王者荣耀卡吗
- 我总结了五种常用聚类分析算法,推荐收藏
- 【亿可控】第一天系统分析与设计
- 手机python软件怎么下载词云_从零开始教你用 Python 做词云
- 【第三章】 C语言之牛客网刷题笔记 【点进来保证让知识充实你一整天】
热门文章
- 如果是自学WEB前端的话,该如何才能找到一份7K实习生工作呢?
- C语言头文件一般以什么名称结尾,c语言书写规范.doc
- java 全局返回码设计_服务返回码的设计
- system verilog编程题_拼多多2020校招部分算法编程题合集
- eureka动态扩容_SpringCloud- 第二篇 Eureka快速上手
- cut out数据增强_ChIP-Seq数据分析(PE型)
- mysql错误码 1045_MySql错误代码1045的解决方法
- labview与单片机正弦信号_LabVIEW小白入门——低通滤波器
- scipy.ndimage.filters.gaussian_filter()
- too many connections的一个实践