Apache RocketMQ 从入门到实战
定延迟时间后才能被消费端消费。 本文来自『中间件兴趣圈』公众号,仅作技术交流,未授权任何商业行为。 17 > 1.1 RocketMQ 核心概念扫盲篇 RocketMQ 目前支持指定级别的延迟,其延迟级别如下: 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h 五、消息过滤 消息过滤是指消费端可以根据某些条件对一个 topic rms 子元素。 accessKey 登录用户名,长度必须大于 6 个字符。 secretKey 登录密码。长度必须大于 6 个字符。 whiteRemoteAddress 用户级别的 IP 地址白名单。其类型为一个字符串,其配置规则与 globalWhiteRemot eAddresses,但只能配置一条规则。 admin boolean 类型,设置是否是 admin。如下权限只有 本文来自『中间件兴趣圈』公众号,仅作技术交流,未授权任何商业行为。 145 > 1.15 RocketMQ ACL 使用指南 SUB 拥有订阅权限。 3. 权限验证流程 上面定义了全局白名单、用户级别的白名单,用户级别的权限,为了更好的配置 ACL 权限规则,下面给出权限匹配逻辑。 本文来自『中间件兴趣圈』公众号,仅作技术交流,未授权任何商业行为。 1.15 RocketMQ ACL 使用指南 < 1460 码力 | 165 页 | 12.53 MB | 1 年前3Apache RocketMQ 介绍
不会因为操作系 的崩溃而导致数据丢失。 ● RocketMQ经过一系列的实践和优化,处理速度从最初的10,000TPS到目前已经超过50,000TPS。 纯比较TPS的话虽然还不如Kafka的百万级别,但在支持事务的消息中间件来说已经是非常优秀了。 ● RocketMQ采用长轮询,消息投递延迟通常在几个毫秒左右。 ● RocketMQ单机最高支持5万个队列,且负载不会发生明显递增。 ● R Iaas平台首选的消息服务,其背后的支持力度不言而喻。 ActiveMQ最初主要的开发者在LogicBlaze,现在主要开发红帽,是JMS规范的参考实现,也是Apach 旗下的老牌消息服务引擎。JMS虽说是一个API级别的协议,但其内部还是定义了一些实现约束,不 缺少多语言支撑。ActiveMQ的生态堪称丰富多彩,在该Apache顶级项目下,拥有不少子项目,包括 HornetMQ演变而来的Artemis,基于Scala号称下一代AMQ的Apollo等。0 码力 | 5 页 | 375.48 KB | 1 年前3RocketMQ v3.2.4 开发指南
来查询消息,由于是哈希索引,请尽可能 保证 key 唯一,例如订单号,商品 Id 等。 Flag 0 选填,完全由应用来设置,RocketMQ 不做干预 DelayTimeLevel 0 选填,消息延时级别,0 表示不延时,大于 0 会延时特定的时间才会被消费 WaitStoreMsgOK TRUE 选填,表示消息是否在服务器落盘后才返回应答。 Message 数据结构各个字段都可以通过 get、set0 码力 | 52 页 | 1.61 MB | 1 年前3
共 3 条
- 1