發送消息到所有瀏覽器使用基於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