src/main/java/org/springblade/modules/webscoket/service/impl/PushMsgServiceImpl.java
@@ -27,8 +27,11 @@ public void pushMsg(String msg) { ChannelGroup group = NettyConfig.getChannelGroup(); String name = group.name(); JSONObject jsonObject = new JSONObject(); jsonObject.put("xqid", msg); jsonObject.put("type", "taks"); System.out.println("空间大小:" + group.size() + ",名字:" + name); group.writeAndFlush(new TextWebSocketFrame(msg)); group.writeAndFlush(new TextWebSocketFrame(String.valueOf(jsonObject))); } @Override