给RABBITMQ发送消息时，设置请求头HEADER

默认如下:

content-type：text/plain

要求如下：

content-type:application/json

解决方法如下（针对消息的生产者）：

在MessagePostProcessor中给message的头做自定义处理（这个功能类似于spring的BeanPostProcessor）对消息的扩展处理，个人认为rabbitMq应该是参考spring的实现方法去实现的。

private final static MessagePostProcessor messagePostProcessor = message -> {
message.getMessageProperties().setContentType("application/json");
message.getMessageProperties().setContentEncoding("UTF-8");
return message;
};

然后在发送消息给消费者时候带上自己的自定义的消息头：

public static void sendMessageByJson(String exchangeName, String routingkey, Object msg){
amqpTemplate.convertAndSend(exchangeName, routingkey, msg, messagePostProcessor);
}

至此完成要求！

给RABBITMQ发送消息时，设置请求头HEADER相关推荐

给RabbitMQ发送消息时，设置请求头Header。
消费者的请求头生产者设置请求头由于消费者那里,@Payload是接受的消息体,使用了@Header注解,需要请求头,生产者这边就要设置请求头,然后rabbitTemplate再调用convertA ...
微信小程序设置请求头header 参数 token 验证
小程序开发中需要在请求头header中用到 token 验证 header:{ 'content-type': 'application/x-www-form-urlencoded', 'access ...
android 使用mediaplayer播放视频的时候设置请求头header
很简单,使用如下代码就行 Uri uri = Uri.parse("http://47.96.22.18:8002/test.pg1");Map<String, String ...
构建header爬虫构建请求头header
今天学写爬虫,刚上来就碰壁了,大多数浏览器都有反爬虫机制,于是要学会设置请求头header,这样就可以伪装成浏览器. Header来源打开任意浏览器某一网页,按F12,点开network,再按提示按 ...
http使用post上传文件时，请求头和主体信息总结
请求头必须配置如下行: Content-Type' : 'multipart/form-data; boundary=---12321 boundary=---12321位文件的分界线 body如下 ...
阿里云OSS上传文件设置请求头
之前写过一篇发送文件消息的,原生input上传文件(聊天发送文件消息),这次的需求就是更改上传地址,使用阿里云OSS上传. 如果想了解阿里云对象存储OSS是如何使用的,请看阿里云存储对象OSS使用讲解 ...
爬虫实战学习笔记_6 网络请求request模块：基本请求方式+设置请求头+获取cookies+模拟登陆+会话请求+验证请求+上传文件+超时异常
1 requests requests是Python中实现HTTP请求的一种方式,requests是第三方模块,该模块在实现HTTP请求时要比urlib.urllib3模块简化很多,操作更加人性化. ...
爬虫实战学习笔记_2 网络请求urllib模块+设置请求头+Cookie+模拟登陆
1 urllib模块 1.1 urllib模块简介 Python3中将urib与urllib2模块的功能组合,并且命名为urllib.Python3中的urllib模块中包含多个功能的子模块,具体内容 ...
ajax中设置请求头和自定义请求头
回到文章总目录 1.创建在testfour文件夹并在这个文件夹里面 2.创建post.html文件 3.创建server.js文件本篇文章使用了鼠标移动至方框则自动发送请求至服务端通常设置请求头 ...

给RABBITMQ发送消息时，设置请求头HEADER

给RABBITMQ发送消息时，设置请求头HEADER相关推荐

最新文章

热门文章