提交 207fb86b 编写于 作者: 浅梦2013's avatar 浅梦2013

MqttServerTest 关闭 websocket

上级 7a4f0f11
......@@ -43,6 +43,8 @@ public class MqttServerTest {
.port(3883)
// 默认为: 8092(mqtt 默认最大消息大小),为了降低内存可以减小小此参数,如果消息过大 t-io 会尝试解析多次(建议根据实际业务情况而定)
.readBufferSize(512)
// 关闭 websocket,避免和 spring boot 启动的冲突
.websocketEnable(false)
.messageListener((clientId, topic, mqttQoS, payload) -> {
logger.info("clientId:{} topic:{} mqttQoS:{} message:{}", clientId, topic, mqttQoS, ByteBufferUtil.toString(payload));
})
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册