| | |
|---|
| | | System.out.println("客户端断开连接：" + ctx.channel()); |
|---|
| | | //用户离线状态 |
|---|
| | | String name = ChannelSupervise.findName(ctx.channel().id().asShortText()); |
|---|
| | | if ( name != null &&!name.equals("ping") ){ |
|---|
| | | String num="0"; |
|---|
| | | //工作状态(0闲置，1工作中) |
|---|
| | | String workSt = "0"; |
|---|
| | | webSocketHandler.suserService.updateUser(num,name,workSt); |
|---|
| | | ChannelSupervise.removeChannel(ctx.channel()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | |
|---|
| | | } |
|---|
| | | // 返回应答消息 |
|---|
| | | String request = ((TextWebSocketFrame) frame).text(); |
|---|
| | | |
|---|
| | | if (!request.equals("ping")){ |
|---|
| | | //把用户信息添加到通道里 |
|---|
| | | ChannelSupervise.addChannel(ctx.channel(),request); |
|---|
| | | //用户在线状态 |
|---|
| | |
|---|
| | | String num="1"; |
|---|
| | | //工作状态(0闲置，1工作中) |
|---|
| | | String workSt = "0"; |
|---|
| | | |
|---|
| | | if (!request.equals("ping")){ |
|---|
| | | webSocketHandler.suserService.updateUser(num,request,workSt); |
|---|
| | | } |
|---|
| | | |
|---|
