webcosket调整

zengh

2021-04-30 25403780e34eca3299ef48bc92ca9488abeb8e98

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

@@ -16,9 +16,12 @@
    @Override
    public void pushMsg(String userId, String msg) {
        Channel channel = NettyConfig.getUserChannelMap().get(userId);
      if (channel != null){
        channel.writeAndFlush(new TextWebSocketFrame(msg));
    }

    }

    @Override
    public void pushMsg(String msg) {
        ChannelGroup group = NettyConfig.getChannelGroup();