rocketmq 消息自定义_rocketmq中的自定义消息头

在springboot中使用rocketmq的客户端，有2种方式。

一是使用 org.apache.rocketmq的rocketmq-client

二是，在pom.xml中引用

org.apache.rocketmq

rocketmq-spring-boot-starter

2.0.3

在原文的FAQ的6和7中的描述，即可以添加自定义的头属性。

在实验中发现，与原有定义的属性名称重复的自定义名称将按照描述中的说明添加“USER_”，如果不是冲突的名称，则不会被改变。

public void send() throws InterruptedException {

Message> msg = MessageBuilder.withPayload("Hi rocketmq!")

.setHeader(MessageConst.PROPERTY_KEYS, "20191018")

.setHeader("TAGS", "191018")

.setHeader(MessageConst.PROPERTY_BUYER_ID,"20191018a")

.setHeader("MQ", "user_mq")

.build();

template.convertAndSend(topic + ":1018", "topic with tags");

java.lang.Thread.sleep(2000);

template.send(topic, msg);

log.info("send mq message, ext message" + msg.toString());

}

setHeader("TAGS", "191018")，将被过滤掉，setHeader("USER_TAGS", "191018")，在接收端能收到结果的。

想添加tags属性应该只能放在发送函数中的第一个参数中。如代码中的 ‘(topic + ":1018",’

setHeader(MessageConst.PROPERTY_KEYS, "20191018")，是有效的。

比如 MessageConst.PROPERTY_BUYER_ID 这样的MessageConst下的其他属性(试过几个)似乎都被过滤了。并不像是描述中说的那样添加 “USER_”前缀。

标签：自定义,topic,rocketmq,MessageConst,PROPERTY,setHeader,消息

来源： https://www.cnblogs.com/htsky/p/rocketmq.html

rocketmq 消息自定义_rocketmq中的自定义消息头相关推荐

rocketmq 消息自定义_RocketMQ的消息发送及消费
RocketMQ消息支持的模式: 消息支持的模式分为三种:NormalProducer(普通同步),消息异步发送,OneWay. 消息同步发送: 普通消息的发送和接收在前面已经演示过了,在前面的案例中 ...
rocketmq 消息自定义_RocketMQ消息轨迹-设计篇
RocketMQ 消息轨迹主要包含两篇文章:设计篇与源码分析篇,本节将详细介绍RocketMQ消息轨迹-设计相关. RocketMQ消息轨迹,主要跟踪消息发送.消息消费的轨迹,即详细记录消息各个处理环 ...
rocketmq 消息自定义_跟我学RocketMQ[1-4]之消息消费及支持spring
博客地址:朝·闻·道www.wuwenliang.net 本文我将继续讲解如何使用DefaultMQPushConsumer对RocketMQ中的消息进行消费,同时在文章的第二部分将继续带领读者朋友 ...
rocketmq 消息指定_RocketMq 实际案例–普通消息的发送
RocketMq 实际案例–普通消息的发送 @(消息中间件)[RocketMq 实例] 学习 rocketMq 最根本的是要先学会用嘛,在创建 rocketMq 的第一个案例的时候,碰到很多坑,可以记 ...
rocketmq 消息自定义_rocketMq-Topic创建过程
系列 Topic可以理解为在rocketMq体系当中作为一个逻辑消息组织形式,一般情况下一类业务消息会申请一个topic来实现业务之间隔离. Topic的存储 Topic的实际存储模型说明: Top ...
rocketmq 消息删除_RocketMQ 实现分布式事务，达到数据最终一致性
作者:江之北来源:https://www.jianshu.com/p/296e0de1b52e 前言在分布式环境下,经常会有跨服务的事务需求,典型的例子如: 服务A 为账户服务,服务B为包月服务,在 ...
rocketmq 消息删除_RocketMQ源码分析之文件过期删除机制
1.由于RocketMQ操作CommitLog.ConsumeQueue文件,都是基于内存映射方法并在启动的时候,会加载commitlog.ConsumeQueue目录下的所有文件,为了避免内存与磁盘 ...
使用 rocketmq-spring-boot-starter 来配置、发送和消费 RocketMQ 消息
作者 | 辽天来源 | 阿里巴巴云原生公众号导读:本文将 rocktmq-spring-boot 的设计实现做一个简单的介绍,读者可以通过本文了解将 RocketMQ Client 端集成为 sp ...
rocketmq怎么保证消息一致性_RocketMQ为什么要保证订阅关系的一致性？
微信公众号「后端进阶」,专注后端技术分享:Java.Golang.WEB框架.分布式中间件.服务治理等等. 前段时间有个朋友向我提了一个问题,他说在搭建 RocketMQ 集群过程中遇到了关于消费订阅 ...

rocketmq 消息自定义_rocketmq中的自定义消息头

rocketmq 消息自定义_rocketmq中的自定义消息头相关推荐

最新文章

热门文章

rocketmq 消息 自定义_rocketmq中的自定义消息头

rocketmq 消息 自定义_rocketmq中的自定义消息头相关推荐

最新文章

热门文章

rocketmq 消息自定义_rocketmq中的自定义消息头

rocketmq 消息自定义_rocketmq中的自定义消息头相关推荐