New file |
| | |
| | | package com.example.erp.tools.netty; |
| | | |
| | | import io.netty.channel.group.ChannelGroup; |
| | | import io.netty.channel.group.DefaultChannelGroup; |
| | | import io.netty.handler.codec.http.websocketx.TextWebSocketFrame; |
| | | import io.netty.util.concurrent.GlobalEventExecutor; |
| | | import org.springframework.context.annotation.Bean; |
| | | |
| | | /** |
| | | * MyChannelHandlerPool |
| | | * 通道组池,管理所有websocket连接 |
| | | */ |
| | | |
| | | |
| | | public class MyChannelHandlerPool { |
| | | |
| | | public MyChannelHandlerPool(){} |
| | | |
| | | public static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE); |
| | | |
| | | public void sendMsg(String message){ |
| | | channelGroup.writeAndFlush(new TextWebSocketFrame(message)); |
| | | } |
| | | } |
| | | |
| | | |