問題描述當用netty的ChannelGroup分組進行廣播時，如果有多個組的話，在初始化ChannelGroup時參數中的EventExecutor該如何設置？是直接GlobalEventExecutor.INSTANCE讓所有ChannelGroup公用同一個？還是說每個group再new一個，如果要給每個group分配不同的又該用哪個類？問題出現的環境背景及自己嘗試過哪些方法正在寫一個im應用，想用一個ChannelGroup對應一個群組的方式來實現向不同的群組發送不同的消息但是完全搜不到有關創建多個ChannelGroup時該如何做的信息大部分都是下么這樣，只創建一個，然后直接向所有連接廣播 private static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);但是如果有多個組該怎么辦？還是說類似于下面這樣自己去維護一個組和連接之間的關系，然后在廣播時手動的去遍歷一個組向其中的所有channel寫入消息？for(Channel ch:map.get(groupid)){
ch.writeAndFlush(msg)
}
1 回答
白板的微信
TA貢獻1883條經驗 獲得超3個贊
ChannelGroup的EventExecutor主要是用來異步通知使用的。
比如:ch.writeAndFlush(msg)是一個異步調用，調用后立即會返回一個ChannelGroupFuture,當異步操作完成，會使用EventExecutor來執行在ChannelGroupFuture里添加的那些Listener。
所以如果你的程序里沒有大量回調，并且回調中都是很簡單的非阻塞調用，使用GlobalEventExecutor.INSTANCE完全夠用。
不過在Netty源碼中，有大量的Future都是使用的這個Executor，所以我覺得自己new一個或者每次使用的時候從自己的EventGroup中拿一個
添加回答
舉報
0/150
提交
取消