修改bug

Pu Zhibing

5 天以前 9641d9ebc7b32b7e2cee898c8e9250e798c97e1b

 MessagePushTravel/src/main/java/com/sinata/push/util/echo/DiscardServerHandler.java

@@ -1,6 +1,5 @@
package com.sinata.push.util.echo;

import com.sinata.push.util.SpringUtil;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelPromise;
@@ -8,14 +7,13 @@
import io.netty.handler.timeout.IdleState;
import io.netty.handler.timeout.IdleStateEvent;
import io.netty.util.ReferenceCountUtil;
import org.springframework.data.redis.core.RedisTemplate;

import java.net.InetSocketAddress;
import java.util.HashMap;

public class DiscardServerHandler extends SimpleChannelInboundHandler<String>  {

   private NettyServerController nettyServerController = SpringUtil.getObject(NettyServerController.class);
   private NettyServerController nettyServerController = new NettyServerController();
   
   public static boolean isdebug = true;

@@ -92,7 +90,7 @@
            String msg = NettyMsg.setMsg(Method.ok, new HashMap<String, Object>());
            if(ctx != null && ctx.channel().isActive()) {
               ctx.writeAndFlush(Unpooled.copiedBuffer((msg).getBytes()));
//               System.err.println(msg);
               System.err.println(msg);
            }
         }
      }
@@ -103,11 +101,11 @@
   public void channelInactive(ChannelHandlerContext ctx) throws Exception {
      if(isdebug) {
         InetSocketAddress insocket = (InetSocketAddress) ctx.channel().remoteAddress();
//         System.err.println(insocket.getAddress() + ": Disconnect connection......");
         System.err.println(insocket.getAddress() + ": Disconnect connection......");
      }
      NettyChannelMap.remove(ctx);
      System.err.println("清除通道" + ctx);
//      super.channelInactive(ctx);
      super.channelInactive(ctx);
   }

   public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {