|
@@ -121,7 +121,13 @@ public class GroupNettyClientHandler extends ChannelInboundHandlerAdapter {
|
|
|
*/
|
|
|
@Override
|
|
|
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
|
|
|
- log.info("Client received: {}",msg);
|
|
|
+ if (StringUtil.isJSONObject((String) msg)) {
|
|
|
+ NettyMessage message = StringUtil.tranferItemToDTO((String) msg, NettyMessage.class);
|
|
|
+ if (message.getOpCode() != 9) {
|
|
|
+ log.info("Client received: {}",msg);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
try {
|
|
|
TimeInterval timer = DateUtil.timer();
|
|
|
handlerMsg(ctx, msg);
|