From e0c9e1abf2776ef07e35cdbe9dfb3c686ad2c897 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=89=91=E5=99=A8=E8=BF=91?= <zhihao.ye@qq.com>
Date: Tue, 25 May 2021 14:13:43 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=8F=82=E6=95=B0=E4=B8=BABy?=
=?UTF-8?q?teBuf=E9=80=A0=E6=88=90=E7=9A=84ClassCastException?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../github/yezhihao/netmc/codec/MessageEncoderWrapper.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/src/main/java/io/github/yezhihao/netmc/codec/MessageEncoderWrapper.java b/src/main/java/io/github/yezhihao/netmc/codec/MessageEncoderWrapper.java
index d1bebab..38c133b 100644
--- a/src/main/java/io/github/yezhihao/netmc/codec/MessageEncoderWrapper.java
+++ b/src/main/java/io/github/yezhihao/netmc/codec/MessageEncoderWrapper.java
@@ -31,7 +31,10 @@ public class MessageEncoderWrapper extends ChannelOutboundHandlerAdapter {
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) {
ByteBuf buf = null;
try {
- buf = encoder.encode(msg);
+ if (msg instanceof ByteBuf)
+ buf = (ByteBuf) msg;
+ else
+ buf = encoder.encode(msg);
if (log.isInfoEnabled())
log.info("<<<<<原始报文[ip={}],hex={}", ctx.channel().remoteAddress(), ByteBufUtil.hexDump(buf));