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

Question

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

阿神 · Answer

Secara kasar boleh diagak bahawa pelayan tidak mempunyai pengekod, jadi ia tidak boleh dihantar sama sekali
Daripada kod yang dipos, anda dapat melihat bahawa terdapat dua cara untuk menghantar mesej kepada klien:

obj.writeAndFlush("hello, it is Server test header ping");

dan

ctx.writeAndFlush(msg);//Object

Dalam netty, semua entri dan keluar adalah ByteBuf Pengarang harus mengesahkan sama ada pelayan mempunyai pengekod yang sepadan dan menukar rentetan kepada ByteBuf.

巴扎黑 · Answer

GatewayService tidak perlu dipaksa untuk menukar kepada jenis SocketChannel apabila menyimpan saluran
Tiada masalah untuk mendapatkan saluran dan melakukan writeAndFlush.
Untuk menyelesaikan masalah selanjutnya, anda boleh melakukan ini,
1 Pantau hasil Janji ctx.writeAndFlush(msg);, seperti

ctx.writeAndFlush(msg).addListener(new ChannelFutureListener() {

    @Override
    public void operationComplete(ChannelFuture future) throws Exception {
        if (future.isSuccess()) {
            // do sth
        } else {
            // do sth
        }
    }
});

2. Perhatikan sama ada pengekod dan penyahkod pada klien dan pelayan adalah sama

天蓬老师 · Answer

Adalah disyorkan untuk menggunakan ChannelGroup untuk mengurus pelanggan. Sebab mengapa pelayan pemimpin tidak boleh menolak data mungkin kerana tiada pengekod ctx.writeAndFlush tidak boleh menulis jenis rentetan secara langsung.

PHPz · Answer

Helo, kod anda boleh diubah suai seperti ini:
Kod Pengendali diubah suai seperti berikut:
@Override

public void channelActive(ChannelHandlerContext ctx) throws Exception {
    String uuid = ctx.channel().id().asLongText();
    GatewayService.addGatewayChannel(uuid, ctx);
    logger.info("a new connect come in: " + uuid);
    logger.info("a new connect come in remote ip: " + ctx.channel().remoteAddress());
}

Perkhidmatan Gerbang:

Perkhidmatan Gateway kelas awam {

private static Map map = new ConcurrentHashMap();
public static void addGatewayChannel(String id, ChannelHandlerContext gateway_ctx){
    map.put(id, gateway_ctx);
}
public static Map getChannels(){
    return map;
}

public static Object getGatewayChannel(String id){
    return map.get(id);
}

public static void removeGatewayChannel(String id){
    map.remove(id);
}

}

Kod untuk melintasi klien adalah seperti berikut:
kelas awam TimeTask melaksanakan Runnable{

private static final Log logger = LogFactory.getLog(TcpCMDHandler.class);
public static final String CHARSET = "UTF-8";
@Override
public void run() {
    sendTaskLoop:
    for(;;){
        System.out.println("task is beginning...");
        try{
            Map map = GatewayService.getChannels();
            Iterator it = map.keySet().iterator();
            while (it.hasNext()) {
                String key = it.next();
                ChannelHandlerContext ctx = (ChannelHandlerContext)map.get(key);
                logger.info("channel id is: " + key);
                logger.info("channel: " + ctx.channel().isActive());

                String bak = "hello, every one!";
                byte[] responB = bak.getBytes(CHARSET);
    //            ByteBuf response = Unpooled.buffer(responB.length);

                final ByteBuf time = ctx.alloc().buffer(responB.length);
                time.writeBytes(responB);

                ctx.writeAndFlush(time); // (3)

// obj.writeAndFlush("hello, ia adalah ping pengepala ujian Pelayan");

            }
        }catch(Exception e){
            break
            sendTaskLoop;
        }
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

}

Itu sahaja. Saya sendiri telah mengujinya dan ia berfungsi