netty教程2-用 channelFuture等待处理结果

在发起连接后，可以返回一个channelFuture用来查看链接的处理结果，
1 使用sync方法同步处理结果
2 使用addListener方法异步处理结果
连接成功后向服务端写个消息。
' }3 `1 H6 ]: a4 M+ ^! s代码如下：
; s( d) |* H* Y" V* x% Npackage com.study.nio.ph2;import io.netty.bootstrap.Bootstrap;import io.netty.channel.Channel;import io.netty.channel.ChannelFuture;import io.netty.channel.ChannelFutureListener;import io.netty.channel.ChannelInitializer;import io.netty.channel.nio.NioEventLoopGroup;import io.netty.channel.socket.nio.NioSocketChannel;import io.netty.handler.codec.string.StringEncoder;import lombok.extern.slf4j.Slf4j;import java.net.InetSocketAddress;/** * @program: isc-study * @description: channelFuture等待处理结果 * @author: wangjinwei * @create: 2021-10-26 10:23 **/@Slf4jpublic class EventLoopClient1 {    public static void main(String[] args) throws InterruptedException {        ChannelFuture channelFuture = new Bootstrap().group(new NioEventLoopGroup())                .channel(NioSocketChannel.class)                .handler(new ChannelInitializer<NioSocketChannel>() {                    @Override                    protected void initChannel(NioSocketChannel ch) throws Exception {                        ch.pipeline().addLast(new StringEncoder());                    }                })                .connect(new InetSocketAddress("localhost", 8080));        //1 使用sync方法同步处理结果/*        channelFuture.sync();        Channel channel = channelFuture.channel();        log.debug("{}",channel);        channel.writeAndFlush("hi 老弟");*/        log.info("channelFuture={}", channelFuture);        // 2使用addListener方法异步处理结果        channelFuture.addListener(new ChannelFutureListener() {            @Override            //在连接建立完成后会调用 operationComplete            public void operationComplete(ChannelFuture future) throws Exception {                log.info("channelFuture={}", future);                Channel channel = future.channel();                log.info("{}", channel);                channel.writeAndFlush("hi 老弟");            }        });    }}服务端代码 用 https://www.toutiao.com/i7021040158623613476/?group_id=7021040158623613476服务端代码用 netty教程1-EventLoop分工 里的代码
' t# x- {. p2 u% Z: a( p& j

9 B& K3 B8 O9 F# `

服务端运行结果

客户端运行结果

从客户端的运行结果看39行的channelFuture和45行的future为同一个对象
) c5 ]( Q0 C. z% I( U8 G# v+ `0 ]从客户端的运行结果来看，这个operationComplete方法里是nioEventLoopGroup里的线程运行的