Joseph Wyatt

好的，加一下技术交流群，我来解决下！ ---原始邮件--- 发件人: ***@***.***> 发送时间: 2022年6月18日(周六) 中午11:04 收件人: ***@***.***>; 抄送: ***@***.***>; 主题: [quickmsg/smqtt] Qos为2，连接数为10，每个链接发送3000条消息就会收不到消息 (Issue #18) 生产环境下，发现运行一段时间后，就有消息无法收到的现象，经排查和脚本测试，在Qos=2的情况下，broker收到3w条消息后，就没办法将PUBREC消息发送出去，从日志上看，应该是没有收到PUBREC消息，其他的MQTT-Broker 正常。 — Reply to this email directly, view it on GitHub, or unsubscribe....

VertxHandler ： protected void reportBytesRead(Object msg) { if (msg instanceof ByteBuf) { this.reportBytesRead((long)((ByteBuf)msg).readableBytes()); } } MqttEncoder && MqttDecoder is before VertxHandler ，so msg is Mqtt object

2.0最近发布，修复内存泄露问题！ ---Original--- From: ***@***.***> Date: Mon, Aug 22, 2022 19:24 PM To: ***@***.***>; Cc: ***@***.***>; Subject: [quickmsg/smqtt] OutOfDirectMemoryError: failed to allocate 16777216byte(s) of direct memory (used: 3724541959, max: 3739746304) (Issue...

这种是，没有发送connect报文，导致， ---原始邮件--- 发件人: ***@***.***> 发送时间: 2022年8月19日(周五) 下午3:16 收件人: ***@***.***>; 抄送: ***@***.***>; 主题: Re: [quickmsg/smqtt] 遇到空指针异常 (Issue #19) — Reply to this email directly, view it on GitHub, or unsubscribe. You...

能提供更详细得日志吗？可以试用我们商业版 ---原始邮件--- 发件人: ***@***.***> 发送时间: 2022年8月19日(周五) 下午5:32 收件人: ***@***.***>; 抄送: ***@***.******@***.***>; 主题: Re: [quickmsg/smqtt] 遇到空指针异常 (Issue #19) 这种是，没有发送connect报文，导致， … ---原始邮件--- 发件人: @.> 发送时间: 2022年8月19日(周五) 下午3:16 收件人: @.>; 抄送: @.>; 主题:...

加微信17512575402 ---原始邮件--- 发件人: ***@***.***> 发送时间: 2022年8月19日(周五) 中午12:19 收件人: ***@***.***>; 抄送: ***@***.***>; 主题: [quickmsg/smqtt] 遇到空指针异常 (Issue #19) 12:13:48.153 [business-io-1262] ERROR i.g.q.core.protocol.PublishProtocol - error java.lang.NullPointerException: null at java.base/java.util.concurrent.ConcurrentHashMap.computeIfAbsent(ConcurrentHashMap.java:1693) at io.github.quickmsg.core.spi.DefaultMessageRegistry.saveSessionMessage(DefaultMessageRegistry.java:32) at io.github.quickmsg.core.protocol.PublishProtocol.filterOfflineSession(PublishProtocol.java:128)...

When I operate the cache, I throw the following exception: Target of invocation cannot be found! Partition owner is null but partitions can't be assigned since all nodes in the...

We use version 4.2.5

> ```java > } > castOptions.setTrafficShapingOptions(new io.vertx.core.net.TrafficShapingOptions() > .setOutboundGlobalBandwidth(rootConfig.getTraffic().getGlobalWriteSize()) > .setInboundGlobalBandwidth(rootConfig.getTraffic().getGlobalReadSize())); > ``` Through stress testing, we found that the actual read and write traffic will be much larger than...

> ```java > Verticle > ``` The above is the traffic code I set, is there a problem with Verticle?