Netty的MQTTDecoder主要接收 MQTT 1.0.1（推送）和 MQTT 1.0.3（发布）的消息。这两个版本都支持最大消息大小为16KB。但是，由于 MQTT 的消息通常会包含很多其他数据，所以即使消息的大小不超过16KB，也可能会导致接收器接收到超过16KB的数据。

为了解决这个问题，你可以使用MQTTDecoder的sendAll方法来一次性发送所有收到的消息，然后再使用sendAll方法来接收和解码这些消息。

例如：

```java MqttDecoder decoder = new MqttDecoder(); MqttMessage message = new MqttMessage();

// 一次发送所有的消息 decoder.sendAll(message);

// 接收并解码消息 List messages = decoder.receiveAll(16 * 1024); for (MqttMessage message : messages) { // 处理消息 } ```

这样，即使消息的大小超过16KB，你也不会收到超过16KB的数据。

另外，你还可以使用MqttDecoder的sendAndReceive方法来一次性发送所有收到的消息，然后在消息被解码之前继续接收其他消息。这样，你就可以在接收消息的同时处理其他消息。