正在显示
1 个修改的文件
包含
1 行增加
和
0 行删除
| @@ -42,6 +42,7 @@ public class CIMServerHandle extends SimpleChannelInboundHandler<CIMRequestProto | @@ -42,6 +42,7 @@ public class CIMServerHandle extends SimpleChannelInboundHandler<CIMRequestProto | ||
| 42 | public void channelInactive(ChannelHandlerContext ctx) throws Exception { | 42 | public void channelInactive(ChannelHandlerContext ctx) throws Exception { |
| 43 | CIMUserInfo userInfo = SessionSocketHolder.getUserId((NioSocketChannel) ctx.channel()); | 43 | CIMUserInfo userInfo = SessionSocketHolder.getUserId((NioSocketChannel) ctx.channel()); |
| 44 | userOffLine(userInfo, (NioSocketChannel) ctx.channel()); | 44 | userOffLine(userInfo, (NioSocketChannel) ctx.channel()); |
| 45 | + ctx.channel().close(); | ||
| 45 | } | 46 | } |
| 46 | 47 | ||
| 47 | @Override | 48 | @Override |
-
请 注册 或 登录 后发表评论