本文共 1489 字,大约阅读时间需要 4 分钟。
添加Maven依赖:
<dependency> <groupId>io.netty</groupId> <artifactId>netty-all</artifactId> <version>4.1.36.Final</version> </dependency>
示例代码:
import io.netty.bootstrap.Bootstrap;import io.netty.channel.*;import io.netty.channel.nio.NioEventLoopGroup;import io.netty.channel.socket.nio.NioSocketChannel;public class NettyClient{ public static void main(String[] args)throws Exception { Bootstrap bootStrap = new Bootstrap(); NioEventLoopGroup workerGroup = new NioEventLoopGroup(); bootStrap.group(workerGroup) .channel(NioSocketChannel.class) .remoteAddress("127.0.0.1",8080) .handler(new ChannelInitializer<Channel>() { @Override protected void initChannel(Channel channel) throws Exception { channel.pipeline().addLast(new ClientHandler()); } }); ChannelFuture future = bootStrap.connect(); if (future.channel().isActive()){ future.channel().writeAndFlush("hello world"); } } static class ClientHandler extends ChannelInboundHandlerAdapter{ @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { System.out.println("read msg : "+msg); ctx.writeAndFlush("Hello World"); super.channelRead(ctx, msg); } }}
转载地址:http://hume.baihongyu.com/