电脑做微信推送的网站,wordpress国内备份神器,海报设计的基本要素,怎样创作一个网站1、RocketMq基本概念 Topic 消息主题#xff0c;一级消息类型#xff0c;通过Topic对消息进行分类。更多信息#xff0c;请参见Topic与Tag最佳实践。 消息#xff08;Message#xff09; 消息队列中信息传递的载体。 Message ID 消息的全局唯一标识#xff0c;由云消息队…1、RocketMq基本概念 Topic 消息主题一级消息类型通过Topic对消息进行分类。更多信息请参见Topic与Tag最佳实践。 消息Message 消息队列中信息传递的载体。 Message ID 消息的全局唯一标识由云消息队列 RocketMQ 版系统自动生成唯一标识某条消息。 Message Key 消息的业务标识由消息生产者Producer设置唯一标识某个业务逻辑。 Tag 消息标签二级消息类型用来进一步区分某个Topic下的消息分类。更多信息请参见Topic与Tag最佳实践。 Producer 消息生产者也称为消息发布者负责生产并发送消息。 Producer实例 Producer的一个对象实例不同的Producer实例可以运行在不同进程内或者不同机器上。Producer实例线程安全可在同一进程内多线程之间共享。 Consumer实例 Consumer的一个对象实例不同的Consumer实例可以运行在不同进程内或者不同机器上。一个Consumer实例内配置线程池消费消息。 Group 一类Producer或Consumer这类Producer或Consumer通常生产或消费同一类消息且消息发布或订阅的逻辑一致。 Group ID Group的标识。 队列Message Queue 即Topic Partition物理上的概念。每个Topic包含一个或多个队列。创建Topic时队列由系统自动分配不支持自定义修改。 集群消费 一个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 版提供类似XA或Open XA的分布事务功能通过云消息队列 RocketMQ 版的事务消息能达到分布式事务的最终一致。 顺序消息 云消息队列 RocketMQ 版提供的一种按照顺序进行发布和消费的消息类型分为全局顺序消息和分区顺序消息。 全局顺序消息 对于指定的一个Topic所有消息按照严格的先入先出FIFO的顺序进行发布和消费。 分区顺序消息 对于指定的一个Topic所有消息根据Sharding Key进行区块分区。同一个分区内的消息按照严格的FIFO顺序进行发布和消费。Sharding Key是顺序消息中用来区分不同分区的关键字段和普通消息的Message Key是完全不同的概念。 消息堆积 Producer已经将消息发送到云消息队列 RocketMQ 版的服务端但由于Consumer消费能力有限未能在短时间内将所有消息正确消费掉此时在云消息队列 RocketMQ 版的服务端保存着未被消费的消息该状态即消息堆积。 消息过滤 Consumer可以根据消息标签Tag对消息进行过滤确保Consumer最终只接收被过滤后的消息类型。消息过滤在云消息队列 RocketMQ 版的服务端完成。 消息轨迹 在一条消息从Producer发出到Consumer消费处理过程中由各个相关节点的时间、地点等数据汇聚而成的完整链路信息。通过消息轨迹您能清晰定位消息从Producer发出经由云消息队列 RocketMQ 版服务端投递给Consumer的完整链路方便定位排查问题。 死信队列 死信队列用于处理无法被正常消费的消息。当一条消息初次消费失败云消息队列 RocketMQ 版会自动进行消息重试达到最大重试次数后若消费依然失败则表明Consumer在正常情况下无法正确地消费该消息。此时云消息队列 RocketMQ 版不会立刻将消息丢弃而是将这条消息发送到该Consumer对应的特殊队列中。 消息路由 消息路由常用于不同地域之间的消息同步保证地域之间的数据一致性。云消息队列 RocketMQ 版的全球消息路由功能依托阿里云优质基础设施实现的高速通道专线可以高效地实现不同地域之间的消息同步复制。 以上基本概念链接来自 https://help.aliyun.com/zh/apsaramq-for-rocketmq/cloud-message-queue-rocketmq-4-x-series/product-overview/terms?spma2c4g.11186623.0.0.77d8395bADOQft
