websocket测试

zengh

2021-04-25 6972afbf3b2cab802671a80aa2e858a329b5f55f

websocket测试

 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/nettyServer/ServerHandler.java

@@ -1802,7 +1802,7 @@
                        serverHandler.operationService.save(operation);

                        //通过websocket给前端接警员发送信息
                        //serverHandler.pushMsgService.pushMsg(alarm.getAlarmId(), alarm.getId().toString());
                        serverHandler.pushMsgService.pushMsg(alarm.getAlarmId(), alarm.getId().toString());
                    }

                    outData.add("LEOK#@");

 blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/webscoket/WebSocketHandler.java

@@ -123,11 +123,11 @@
            webSocketHandler.suserService.updateUser(num,request,workSt);
        }

        TextWebSocketFrame tws = new TextWebSocketFrame(new Date().toString()
            + ctx.channel().id() + "：" + ctx.channel());
        // 返回【谁发的发给谁】

        ctx.channel().writeAndFlush(tws);
//        TextWebSocketFrame tws = new TextWebSocketFrame(new Date().toString()
//            + ctx.channel().id() + "：" + ctx.channel());
//        // 返回【谁发的发给谁】
//
//        ctx.channel().writeAndFlush(tws);
        // 群发
        //  ChannelSupervise.send2All(tws);
    }