| | |
| | | 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; |
| | |
| | | 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 = new NettyServerController(); |
| | | private NettyServerController nettyServerController = SpringUtil.getObject(NettyServerController.class); |
| | | |
| | | public static boolean isdebug = true; |
| | | |