On peut à peu près deviner que le serveur n'a pas d'encodeur, il ne peut donc pas être envoyé du tout
D'après le code publié, vous pouvez voir qu'il existe deux façons d'envoyer des messages au client :

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

et

ctx.writeAndFlush(msg);//Object

Dans netty, toutes les entrées et sorties sont ByteBuf L'auteur doit confirmer si le serveur dispose d'un encodeur correspondant et convertir la chaîne en ByteBuf.

GatewayService n'a pas besoin d'être forcé à se convertir en type SocketChannel lors de l'enregistrement du canal
Il n'y a aucun problème pour obtenir le canal et exécuter writeAndFlush.
Afin de résoudre davantage le problème, vous pouvez procéder comme suit :
1. Surveiller le résultat de la promesse de ctx.writeAndFlush(msg);, par exemple

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

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

2. Faites attention à ce que l'encodeur et le décodeur des deux côtés du client et du serveur soient identiques

Il est recommandé d'utiliser ChannelGroup pour gérer les clients. La raison pour laquelle le serveur leader ne peut pas transmettre de données peut être due au fait qu'il n'y a pas d'encodeur. ctx.writeAndFlush ne peut pas écrire directement les types de chaîne.

Bonjour, votre code peut être modifié comme ceci :
Le code du handler est modifié comme suit :
@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());
}

GatewayService :

classe publique GatewayService {

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

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

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

}

Le code pour parcourir le client est le suivant :
la classe publique TimeTask implémente 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<String, Object> map = GatewayService.getChannels();
            Iterator<String> 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("bonjour, c'est le ping de l'en-tête de test du serveur");

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

}

C'est tout. Je l'ai personnellement testé et ça marche