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));
|
}
|
}
|
