netty客户端和服务端通讯

package my.test.netty_test.client; import java.net.InetSocketAddress; import io.netty.bootstrap.Bootstrap; import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelInitializer; import io.netty.channel.ChannelOption; import io.netty.channel.EventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.SocketChannel; import io.netty.channel.socket.nio.NioSocketChannel; /** * netty通讯客户端 * @ClassName: NettyClient * @Description: TODO * @author: autor * @date: 2018年10月26日 下午4:46:19 */ public class NettyClient { //监听服务的ip private static final String HOST = "127.0.0.1"; //监听服务的端口号 private static final int PORT = 8001; public static void main(String[] args) { // TODO Auto-generated method stub NettyClient client = new NettyClient(); client.connect(); } public void connect(){ //初始化用于连接及I/O工作的"线程池" EventLoopGroup group = new NioEventLoopGroup(); //初始化Bootstrap实例， 此实例是netty客户端应用开发的入口 Bootstrap boot = new Bootstrap(); try{ //设置线程池 boot.group(group); //指定通道channel的类型，由于是客户端，故而是NioSocketChannel boot.channel(NioSocketChannel.class); /*1:ChannelOption.SO_BACKLOG, 1024 * BACKLOG用于构造服务端套接字ServerSocket对象，标识当服务器请求处理线程全满时， * 用于临时存放已完成三次握手的请求的队列的最大长度。如果未设置或所设置的值小于1，Java将使用默认值50 * * 2:ChannelOption.SO_KEEPALIVE, true * 是否启用心跳保活机制。在双方TCP套接字建立连接后（即都进入ESTABLISHED状态） * 并且在两个小时左右上层没有任何数据传输的情况下，这套机制才会被激活。 * * 3:ChannelOption.TCP_NODELAY, true * 用于启用或关于Nagle算法。如果要求高实时性，有数据发送时就马上发送，就将该选项设置为true关闭Nagle算法； * 如果要减少发送次数减少网络交互，就设置为false等累积一定大小后再发送。默认为false */ boot.option(ChannelOption.SO_KEEPALIVE, true); //绑定端口号和ip boot.remoteAddress(new InetSocketAddress(HOST, PORT)); //业务处理 boot.handler(new ChannelInitializer<SocketChannel> (){ @Override protected void initChannel(SocketChannel ch) throws Exception { // TODO Auto-generated method stub System.out.println("客户端处理业务逻辑"); //ch.pipeline().addLast(new ObjectEncoder()); //ch.pipeline().addLast(new ObjectDecoder(Integer.MAX_VALUE, ClassResolvers.weakCachingConcurrentResolver(null))); ch.pipeline().addLast(new ClientHandler()); } }); //异步连接服务器 ChannelFuture future = boot.connect().sync(); System.out.println("完成连接"); future.channel().closeFuture().sync(); System.out.println("完成通讯。。。。。。"); }catch(Exception e){ e.printStackTrace(); }finally{ try { group.shutdownGracefully().sync(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }