发送消息到所有浏览器使用基于Java的套接字io客户端的netty

Question

我目前正试图发送消息到所有浏览器基于java的客户端套接字io socket.io-netty。但目前它只发送消息到一个浏览器一次。 的snippent是以下几点：

public class IOClientListener implements INSIOHandler { 
    private INSIOClient ioClient=null; 
    private final static Logger log=LoggerFactory.getLogger(IOClientListener.class); 

    @Override 
    public void OnConnect(INSIOClient client) { 
     System.out.println("A user connected :: " + client.getSessionID()); 
       client.send("Hey you are connected to myhope.com"); 

    } 

    @Override 
    public void OnDisconnect(INSIOClient client) { 
     System.out.println("A user disconnected :: " + client.getSessionID() + " :: hope it was fun"); 
    } 

    @Override 
    public void OnMessage(INSIOClient client, String message) { 
     System.out.println("A message received:: " + message + " :: hope it was fun"); 
    } 

    @Override 
    public void OnShutdown() { 
    } 

    public INSIOClient getIOClient(){ 
     return this.ioClient; 
    } 
} 

我想知道如何使用此客户端广播消息。由于提前

Answer 1

可以使用的Netty通道组用于此目的

.... 
static ChannelGroup allClientChannels = new DefaultChannelGroup(); 


@Override 
public void OnConnect(INSIOClient client) { 
    System.out.println("A user connected :: " + client.getSessionID()); 
      client.send("Hey you are connected to myhope.com"); 

    allClientChannels.add(client.getCTX().getChannel()); 
} 


@Override 
public void OnDisconnect(INSIOClient client) { 
    System.out.println("A user disconnected :: " + client.getSessionID() + " :: hope it was fun"); 
    allClientChannels.remove(client.getCTX().getChannel()); 

} 

...

//when you want to send a broadcase message 

allClientChannels.write(yourMessage); 

更多详细信息，对ChannelGroup API Doc