!1 修正一处粘包时可能产生的错误

Merge pull request !1 from talent-tan/master

mica-mqtt-codec/src/main/java/net/dreamlu/iot/mqtt/codec/MqttDecoder.java

@@ -46,9 +46,9 @@ public final class MqttDecoder {
 		this.maxBytesInMessage = maxBytesInMessage;
 	}
 
-	public MqttMessage decode(ChannelContext ctx, ByteBuffer buffer) {
+	public MqttMessage decode(ChannelContext ctx, ByteBuffer buffer, int limit, int position, int readableLength) {
 		// 1. 首先判断缓存中协议头是否读完（MQTT协议头为2字节）
-		if (buffer.limit() < MQTT_PROTOCOL_LENGTH) {
+		if (readableLength < MQTT_PROTOCOL_LENGTH) {
 			return null;
 		}
 		// 2. 解析 FixedHeader

mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/client/MqttClientAioHandler.java

@@ -52,7 +52,7 @@ public class MqttClientAioHandler implements ClientAioHandler {
 
 	@Override
 	public Packet decode(ByteBuffer buffer, int limit, int position, int readableLength, ChannelContext channelContext) throws AioDecodeException {
-		return mqttDecoder.decode(channelContext, buffer);
+		return mqttDecoder.decode(channelContext, buffer, limit, position, readableLength);
 	}
 
 	@Override

mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/MqttServerAioHandler.java

@@ -59,7 +59,7 @@ public class MqttServerAioHandler implements ServerAioHandler {
 	 */
 	@Override
 	public Packet decode(ByteBuffer buffer, int limit, int position, int readableLength, ChannelContext context) throws AioDecodeException {
-		return mqttDecoder.decode(context, buffer);
+		return mqttDecoder.decode(context, buffer, limit, position, readableLength);
 	}
 
 	/**