栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

利用netty-mqtt-client发布和订阅消息的格式转换

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

利用netty-mqtt-client发布和订阅消息的格式转换

在利用netty-mqtt-client实现Mqtt消息的发布和订阅中描述了如何实现消息的发布和订阅
但是消息有不同的格式,例如字符串和16进制hex,对于不同的格式,在发布和订阅式需要转换格式,然后进行处理,否则会出现乱码。

1.发布16进制消息
String msg = "5A00F201";  //16进制字符串
mqttClient.publish(topic,Unpooled.copiedBuffer(CronUtil.hexToByteArray(msg)), MqttQoS.AT_MOST_ONCE,false);
2.订阅16进制消息
@Override
public void onMessage(String topic, ByteBuf payload) {
	String message = ByteBufUtil.hexDump(payload).toUpperCase();
	log.info("消息主题:" + topic);
	log.info("消息内容:" + message);
}
3.发布字符串消息
String msg = "hello";
mqttClient.publish(topic, Unpooled.copiedBuffer(msg.getBytes()), MqttQoS.AT_MOST_ONCE,false);
4.订阅字符串消息
@Override
public void onMessage(String topic, ByteBuf payload) {
	String message = payload.toString(CharsetUtil.UTF_8);
	log.info("消息主题:" + topic);
	log.info("消息内容:" + message);
}
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/759562.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号