网站首页
编程语言
数据库
系统相关
其他分享
编程问答
itlaoqi
2022-09-30
(转载)【RocketMQ 课程笔记】18.消费者基于自定义属性实现SQL过滤
消费者基于自定义属性实现SQL过滤在发送消息时,发送方可以自定义消息的用户属性,消费者可以利用SQL92的WHERE子句语法实现消息过滤。相比Tag过滤,消息过滤使用更加灵活,也更
2022-09-28
(转载)【RocketMQ 课程笔记】17.消费者基于Tag实现消息过滤
消费者基于Tag实现消息过滤在发送消息时,需要设置消息的“标记Tag”,Tag用于说明消息的某项特征,消费者可以根据这个特征决定是否接收这些消息。消息发送者com.itlaoqi.roc
2022-09-28
(转载)【RocketMQ 课程笔记】16.实现集群消费模式与广播消费模式
集群消费模式与广播消费模式环境准备生产者CmProducer生产者是一致的,循环生成10条普通消息投给给Broker,主题为:cm-sample-data,Tag:test,Key:n@Slf4jpublicclassCmPro