netty Force-closing a channel whose registration task was not accepted by an event loop问题

我这边第一次连接netty可以，但是关闭netty连接以后，再次使用连接就会报这个错，其实很简单的问题，但是一下子蒙住了，搞了半天，后来发现是全局变量的问题，

我把下面这两行代码放入了全局变量里，重启系统第一次连接没问题，关闭连接第二次开启连接就出现报错 Force-closing a channel whose registration task was not accepted by an event loop 连接不上。

 EventLoopGroup parentGroup = new NioEventLoopGroup();//负责网络的读写EventLoopGroup childGroup = new NioEventLoopGroup();

因为我还得需要通过接口关闭连接，针对上面问题我是这样改的

定义一个安全线程的hashmap用来存储EventLoopGroup 对象，在关闭资源方法里通过map取出来进行关闭，就不会出现这个问题了

@Component
public class NettyServer {private static Logger logger = LoggerFactory.getLogger(NettyServer.class);private ConcurrentHashMap mapEventLoopGroup = new ConcurrentHashMap();private Channel channel;// 开启连接public ChannelFuture bing(InetSocketAddress address) {// 配置服务端NIO线程组-负责接收客户端的连接EventLoopGroup parentGroup = new NioEventLoopGroup();//负责网络的读写EventLoopGroup childGroup = new NioEventLoopGroup();ServerBootstrap b = new ServerBootstrap();ChannelFuture channelFuture = null;System.out.println("进入bind方法");try {// 添加boss和worker组b.group(parentGroup, childGroup)// 非阻塞模式.channel(NioServerSocketChannel.class)// 设置TCP的缓冲区.option(ChannelOption.SO_BACKLOG, 128)// 增加接收缓冲区.option(ChannelOption.RCVBUF_ALLOCATOR, new FixedRecvByteBufAllocator(4096))// childHandler 去绑定具体的事件处理器.childHandler(new ChannelInit());// 绑定端口channelFuture = b.bind(address).syncUninterruptibly();System.out.println("绑定端口");System.out.println(channelFuture);channel = channelFuture.channel();System.out.println(channel);mapEventLoopGroup.put("parent", parentGroup);mapEventLoopGroup.put("child", childGroup);} catch (Exception e) {// 优雅退出，释放线程池资源System.out.println("进入catch方法");e.printStackTrace();parentGroup.shutdownGracefully();childGroup.shutdownGracefully();} finally {if (null != channelFuture && channelFuture.isSuccess()) {logger.info("netty服务启动完成！");} else {logger.error("netty服务启动失败！");}}return channelFuture;}// 关闭连接public boolean destroy() {try {if (null == channel) {return false;} else {channel.close();channel = null;System.out.println("关闭channel");}if (mapEventLoopGroup.containsKey("parent")) {EventLoopGroup parentGroup = (EventLoopGroup) mapEventLoopGroup.get("parent");parentGroup.shutdownGracefully();System.out.println("关闭parent");mapEventLoopGroup.remove("parent");}if (mapEventLoopGroup.containsKey("child")) {EventLoopGroup child = (EventLoopGroup) mapEventLoopGroup.get("child");child.shutdownGracefully();System.out.println("关闭child");mapEventLoopGroup.remove("child");}return true;} catch (Exception e) {e.printStackTrace();return false;}}public Channel getChannel() {return channel;}/** @Author df* @Description 发送消息* @Date 15:28 2021/1/14**/public AjaxResult sendMessage(byte[] byteData, String orderNo) {System.out.println("进入发送message方法(),命令号是:" + orderNo);System.out.println(ServerHandler.ctxMaps.size());try {// 指定不同的连接请求发送命令for (Map<String, ChannelHandlerContext> ctxMap : ServerHandler.ctxMaps) {if (ctxMap.containsKey(orderNo)) {ChannelHandlerContext ctx = ctxMap.get(orderNo);if (ctx == null) {return AjaxResult.error("请确保打开TCP连接操作！");}// netty需要转换ByteBuf才可使用ByteBuf bytebuf = Unpooled.buffer();bytebuf.writeBytes(byteData);ServerHandler.isAccess = true;ctx.writeAndFlush(bytebuf);String ip = IpCabinetBind.findOrderNoByIp(orderNo);String msg = "给Ip为：" + ip + "发送了命令号是" + orderNo + "指令";System.out.println(msg);Session session = WebSocketServer.sessionPools.get("android");if (session != null) {boolean isSucc = WebSocketServer.sendMessage(session, msg);}}}} catch (Exception e) {e.printStackTrace();ServerHandler.isAccess = false;return AjaxResult.error("服务器报错！发送指令失败！");}return null;}
}

netty Force-closing a channel whose registration task was not accepted by an event loop问题相关推荐

Netty是如何把Channel 从Boss线程传到Work线程的？
在 ServerBootstrapAcceptor#channelRead 方法中调用childGroup 将Channel 注册到work 线程中的. 一. 处理流程 io.netty.channe ...
python3 异步错误 asyncio.Semaphore RuntimeError: Task got Future attached to a different loop
错误现象 asyncio.Semaphore RuntimeError: Task got Future attached to a different loop asyncio.Semaphore ...
Netty入门——组件（Channel）一
目录一.channel的主要作用二.EventLoop处理io任务代码示例 2.1.服务端代码示例 2.2.客户端代码示例 2.3.服务端和客户端查看控制台输出结果三.ChannelFuture ...
【Netty】NIO 通道 ( Channel ) 组件
文章目录 I . 通道 ( Channel ) 概念简介 II . 通道 ( Channel ) 常用类 III . 常用的通道 ( Channel ) 之套接字通道 ( SocketChanne ...
Netty学习总结（4）——图解Netty之Pipeline、channel、Context之间的数据流向
以下所绘制图形均基于Netty4.0.28版本. 一.connect(outbound类型事件) 当用户调用channel的connect时,会发起一个outbound类型的事件,该事件将在pipel ...
深入理解netty（二）Channel
上一篇文章介绍过channel,channel里面主要是封装了对于客户端连接的建立等的一些api,以及socket等,对于封装的api可以进行一些读写先留两个问题: 1.服务端的socket在哪里初 ...
netty源码分析系列——Channel
2019独角兽企业重金招聘Python工程师标准>>> 前言 Channel是netty中作为核心的一个概念,我们从启动器(Bootstrap)中了解到最终启动器的两个关键操作con ...
Netty Channel源码分析
原文:https://wangwei.one/posts/netty-channel-source-analyse.html 前面,我们大致了解了Netty中的几个核心组件.今天我们就来先来介绍Net ...
netty源码解解析(4.0)-3 Channel的抽象实现
AbstractChannel和AbstractUnsafe抽象类 io.netty.channel.AbstractChannel 从本章开始,会有大量的篇幅涉及到代码分析.为了能够清晰简洁的地说明 ...
netty 5 alph1源码分析(服务端创建过程）
研究了netty的服务端创建过程.至于netty的优势,可以参照网络其他文章.<Netty系列之Netty 服务端创建>是李林锋撰写的netty源码分析的一篇好文,绝对是技术干货.但抛开 ...

netty Force-closing a channel whose registration task was not accepted by an event loop问题

netty Force-closing a channel whose registration task was not accepted by an event loop问题相关推荐

最新文章

热门文章