try { MqttPublishMessage mqttPublishMessage = (MqttPublishMessage) mqttMessage; ByteBuf byteBuf = mqttPublishMessage.payload(); byteBuf.retainedDuplicate(); ctx.writeAndFlush(mqttPublishMessage); } catch (Exception e) { e.printStackTrace(); throw e; }
博客摘录「 springboot+netty+mqtt服务端实现」2024年10月11日
电脑手机
2024-11-26 12:10:01
882
版权声明:如无特殊标注,文章均来自网络,本站编辑整理,转载时请以链接形式注明文章出处,请自行分辨。
本文链接:https://www.shbk5.com/dnsj/75204.html