一、搭环境

阿里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相关推荐

  1. 从阿里云到自建:RocketMQ迁移的注意事项

    这里是weihubeats,觉得文章不错可以关注公众号小奏技术,文章首发.拒绝营销号,拒绝标题党 背景 因为某些原因,我们需要将阿里云的云RocketMQ迁移到自建RocketMQ 开源版本Rocke ...

  2. rocketmq存储结构_阿里专家分享内部绝密RocketMQ核心原理与最佳实践笔记

    本文源码以RocketMQ 4.2.0 和 RocketMQ 4.3.0 为 基 础 , 从RocketMQ的实际使用到RocketMQ的源码分析,再到RocketMQ企业落地实践方案,逐步讲解.使读 ...

  3. clickhouse原理解析与应用实践 pdf_阿里专家分享内部绝密RocketMQ核心原理与最佳实践PDF...

    前言 本文源码以RocketMQ 4.2.0 和 RocketMQ 4.3.0 为 基 础 , 从RocketMQ的实际使用到RocketMQ的源码分析,再到RocketMQ企业落地实践方案,逐步讲解 ...

  4. 《RocketMQ技术内幕:RocketMQ架构设计与实现原理》一导读...

    内容介绍 本书由RocketMQ社区早期的布道者和技术专家撰写,Apache RocketMQ创始人/Linux OpenMessaging创始人兼主席/Alibaba Messaging开源技术负责 ...

  5. 阿里高级技术专家张建飞:深度剖析领域模型vs数据模型的用法

    张建飞 frank 读完需要 21 分钟 速读仅需 7 分钟 阿里巴巴高级技术专家,著有图书<代码精进之路 从码农到工匠>,维护公众号<从码农到工匠> ID:craftsman ...

  6. RocketMQ 实战-SpringBoot整合RocketMQ同步消息、异步消息、单向消息

    官方样例:https://gitee.com/apache/rocketmq/blob/master/docs/cn/RocketMQ_Example.md 1. 同步消息 producer向 bro ...

  7. RocketMQ 实战-SpringBoot整合RocketMQ

    1. 消息生产者 1.1 maven 依赖 <?xml version="1.0" encoding="UTF-8"?> <project x ...

  8. 你瞧不起的低代码开发,阿里云总裁张建锋,他看上了

    "未来不会用低代码,正如10年前不懂Excel,它将是一项基本能力." 对低代码评价之高,正是2022云栖大会,来自阿里云总裁张建锋发表的内容. 普通人说出这番内容,难免被吐槽,然 ...

  9. [施工中]Java阿里云服务器ECS建站操作不完全指北

    [施工中]Java阿里云服务器ECS建站操作不完全指北 ECS建站操作记录 前言 一 .Xshell6与Xftp6 1.1Xshell与Xftp的作用 1.2如何从官网下载xshell与xftp 1. ...

最新文章

  1. PHP:第四章——PHP数组array_diff计算数组差集
  2. DEDE无简略标题时显示完整标题
  3. rsync 一条命令实现远程文件传输
  4. photoshop 工具栏中英文对照
  5. 理解Vue的计算属性
  6. jquery load 和 iframe 比较
  7. Android 打造编译时注解解析框架
  8. Linux find xargs rm .orig
  9. codewars python Regex validate PIN code
  10. js正则表达式把数字格式化成XXXX-XXX-XXX
  11. 2021最新的NVIDIA显卡排行榜前十
  12. 【OI备忘录】dalao博文收藏夹
  13. 东野圭吾《解忧杂货店》读后感
  14. 数据库架构(一) 插入数据库
  15. 正则表达式:回车和换行的区别
  16. 华为android9王者荣耀卡,华为mate9玩王者荣耀怎么样 mate9玩王者荣耀卡吗
  17. 我总结了五种常用聚类分析算法,推荐收藏
  18. 【亿可控】第一天系统分析与设计
  19. 手机python软件怎么下载词云_从零开始教你用 Python 做词云
  20. 【第三章】 C语言之牛客网刷题笔记 【点进来保证让知识充实你一整天】

热门文章

  1. 如果是自学WEB前端的话,该如何才能找到一份7K实习生工作呢?
  2. C语言头文件一般以什么名称结尾,c语言书写规范.doc
  3. java 全局返回码设计_服务返回码的设计
  4. system verilog编程题_拼多多2020校招部分算法编程题合集
  5. eureka动态扩容_SpringCloud- 第二篇 Eureka快速上手
  6. cut out数据增强_ChIP-Seq数据分析(PE型)
  7. mysql错误码 1045_MySql错误代码1045的解决方法
  8. labview与单片机正弦信号_LabVIEW小白入门——低通滤波器
  9. scipy.ndimage.filters.gaussian_filter()
  10. too many connections的一个实践