使用netty的简单demo

/** * Created on 2018年5月17日 by caiming */ package com.demo; import java.net.InetSocketAddress; import io.netty.bootstrap.Bootstrap; import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelInitializer; import io.netty.channel.EventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup; import io.netty.channel.socket.SocketChannel; import io.netty.channel.socket.nio.NioSocketChannel; /** * * @Title Echo客户端 * @Description 1、初始化客户端，创建一个BootStrap实例 * 2、为进行事件处理分配一个NioEventLoopGroup实例，其中事件处理包括创建新的连接以及处理入站和出站数据 * 3、为服务器连接建立一个InetSocketAddress实例 * 4、当连接被建立时，一个EchoClientHandler实例会被安装到ChannelPipeline中 * 5、在一切都设置完成后，调用Bootstrap.conncet()方法连接到远程节点 * @author caiming * @version 1.0 * @修改记录 * @修改序号，修改日期，修改人，修改内容 */ public class EchoClient { private final String host; private final int port; public EchoClient(String host, int port) { this.host = host; this.port = port; } public void start() throws Exception { EventLoopGroup group = new NioEventLoopGroup(); try { // 创建Bootstrap Bootstrap b = new Bootstrap(); b.group(group) //指定EventLoopGroup以处理客户端事件；需要适用于NIO的实现 .channel(NioSocketChannel.class) //适用于NIO传输的Channel类型 .remoteAddress(new InetSocketAddress(host, port)) //設置服務端InetSocketAddress .handler(new ChannelInitializer<SocketChannel>() { //创建Channel时向ChannelPipeline添加一个EchoClientHandler实例 @Override protected void initChannel(SocketChannel ch) throws Exception { ch.pipeline().addLast(new EchoClientHandler()); } }); ChannelFuture f = b.connect().sync();//连接到远程节点，阻塞等待直到连接完成 f.channel().closeFuture().sync();//阻塞，直到channel关闭 } finally { group.shutdownGracefully().sync();//关闭线程池并释放所有资源 } } public static void main(String[] args) throws Exception { new EchoClient("localhost", 8888).start(); } }