13-高并发-netty原理和基础-详解Channel通道

野性酷女 2023-05-29 09:24 9阅读 0赞

protected AbstractChannel(Channel parent) {
                this.parent = parent; //父通道//对于连接监听通道来说，其父通道为null
                id = newId();
                unsafe = newUnsafe(); //底层的NIO通道，完成实际的IO操作
                pipeline = newChannelPipeline(); //一条通道，拥有一条流水线
            }

**方法1. ChannelFuture connect(SocketAddress address)**  
此方法的作用为：连接远程服务器。方法的参数为远程服务器的地址，调用后会立即返回，返回值为负责连接操作的异步任务ChannelFuture。此方法在客户端的传输通道使用。  
**方法2. ChannelFuture bind（SocketAddress address）**  
此方法的作用为：绑定监听地址，开始监听新的客户端连接。此方法在服务器的新连接监听和接收通道使用。  
**方法3. ChannelFuture close()**  
此方法的作用为：关闭通道连接，返回连接关闭的ChannelFuture异步任务。如果需要在连接正式关闭后执行其他操作，则需要为异步任务设置回调方法；或者调用ChannelFuture异步任务的sync( ) 方法来阻塞当前线程，一直等到通道关闭的异步任务执行完毕。  
**方法4. Channel read()**  
此方法的作用为：读取通道数据，并且启动入站处理。具体来说，从内部的Java NIO Channel通道读取数据，然后启动内部的Pipeline流水线，开启数据读取的入站处理。此方法的返回通道自身用于链式调用。  
**方法5. ChannelFuture write（Object o）**  
此方法的作用为：启程出站流水处理，把处理后的最终数据写到底层Java NIO通道。此方法的返回值为出站处理的异步处理任务。  
**方法6. Channel flush()**  
此方法的作用为：将缓冲区中的数据立即写出到对端。并不是每一次write操作都是将数据直接写出到对端，write操作的作用在大部分情况下仅仅是写入到操作系统的缓冲区，操作系统会将根据缓冲区的情况，决定什么时候把数据写到对端。而执行flush()方法立即将缓冲区的数据写到对端。