java - netty如何实现向客户端主动发送消息

Question

需求场景：
智能家居网关(以下简称gateway)，需要和netty服务器通讯(以下简称netty)，netty和gateway之间需要保持长连接(换句话说，netty和gateway之间都会主动给对方发送消息)

碰到的问题:
netty作为服务器端如何主动的向gateway发送消息，我尝试当每个gateway连接到netty（TCP/IP）时使用一个map把该channelSocket的id和该channelSocket绑定在一起

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {
        String uuid = ctx.channel().id().asLongText();
        GatewayService.addGatewayChannel(uuid, (SocketChannel)ctx.channel());
        System.out.println("a new connect come in: " + uuid);
    }

GatewayService其实就是一个ConcurrentHashMap

public class GatewayService {
    
    private static Map<String, SocketChannel> map = new ConcurrentHashMap<>();
    
    public static void addGatewayChannel(String id, SocketChannel gateway_channel){
        map.put(id, gateway_channel);
    }
    
    public static Map<String, SocketChannel> getChannels(){
        return map;
    }

    public static SocketChannel getGatewayChannel(String id){
        return map.get(id);
    }
    
    public static void removeGatewayChannel(String id){
        map.remove(id);
    }
}

我在服务器端尝试每间隔一段时间loop这个ConcurrentHashMap如果里面已经有绑定的channelSocket，就使用write方法向客户端发送消息

Runnable sendTask = new Runnable() {
            @Override
            public void run() {
                sendTaskLoop:
                    for(;;){
                        System.out.println("task is beginning...");
                        try{
                            Map<String, SocketChannel> map = GatewayService.getChannels();
                            Iterator<String> it = map.keySet().iterator();
                            while (it.hasNext()) {
                                String key = it.next();
                                SocketChannel obj = map.get(key);
                                System.out.println("channel id is: " + key);
                                System.out.println("channel: " + obj.isActive());
                                obj.writeAndFlush("hello, it is Server test header ping");
                            }
                        }catch(Exception e){break sendTaskLoop;}
                        try {
                            Thread.sleep(5000);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
            }
        };
        new Thread(sendTask).start();

理论上客户端应该是可以接受到我发送的消息，但是我观察了一下源代码，发现writeAndFlush这个方法最终会被handler触发，于是我又在handler中覆写了write方法

    @Override
    public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
        System.out.println("write handler");
        ctx.writeAndFlush(msg);
    }

可是最终结果客户端并没有收到任何消息，请问netty如何主动向客户端发送消息？

Answer 1

サーバーにはエンコーダーがないため、メッセージをまったく送信できないと大まかに推測できます。
投稿されたコードから、クライアントにメッセージを送信するには 2 つの方法があることがわかります。

リーリー

と

リーリー

netty では、すべてのエントリと出口は ByteBuf です。作成者は、サーバーに対応するエンコーダがあるかどうかを確認し、 文字列 を ByteBuf に変換する必要があります。

Answer 2

チャネルを保存するときに GatewayService を強制的に SocketChannel 型に変換する必要はありません。
チャネルの取得と writeAndFlush の実行には問題はありません。
問題をさらにトラブルシューティングするには、
1. ctx.writeAndFlush(msg); の Promise 結果を監視します (

など)。 リーリー

2. クライアントとサーバーのエンコーダーとデコーダーが同じかどうかに注意してください

Answer 3

クライアントの管理には ChannelGroup を使用することをお勧めします。リーダー サーバーがデータをプッシュできない理由は、ctx.writeAndFlush が文字列型を直接書き込むことができないためである可能性があります。

Answer 4

こんにちは。コードは次のように変更できます:
ハンドラーのコードは次のように変更されます:
@Override

リーリー

ゲートウェイサービス:

パブリック クラス GatewayService {

リーリー

}

クライアントを走査するコードは次のとおりです:
public class TimeTaskimplements Runnable{

リーリー

// obj.writeAndFlush("こんにちは、サーバー テスト ヘッダー ping です");

リーリー

}

それだけです。私は個人的にテストしましたが、うまくいきました