\u7f51\u7edc\u7f16\u7a0b\u662f\u6307\u901a\u8fc7\u200b\u200b\u7f51\u7edc\u534f\u8bae（\u5982TCP\/IP）\u200b\u200b\u5b9e\u73b0\u4e0d\u540c\u8bbe\u5907\u95f4\u6570\u636e\u901a\u4fe1\u7684\u6280\u672f\u3002\u6838\u5fc3\u76ee\u6807\u662f\u8ba9\u7a0b\u5e8f\u80fd\u591f\u901a\u8fc7\u7f51\u7edc\u4e0e\u5176\u4ed6\u7a0b\u5e8f\u4ea4\u6362\u6570\u636e，\u4f8b\u5982\u7f51\u9875\u6d4f\u89c8\u3001\u5373\u65f6\u901a\u8baf\u3001\u6587\u4ef6\u4f20\u8f93\u7b49\u573a\u666f\u5747\u4f9d\u8d56\u7f51\u7edc\u7f16\u7a0b\u3002<\/p>\n
\u65e9\u671f\u7f51\u7edc\u7f16\u7a0b\u591a\u57fa\u4e8e\u200b\u200bBIO（\u540c\u6b65\u963b\u585eIO）\u200b\u200b，\u5176\u6838\u5fc3\u903b\u8f91\u662f：<\/p>\n
\u200b\u200b\u95ee\u9898\u603b\u7ed3\u200b\u200b：\u7ebf\u7a0b\u8d44\u6e90\u6602\u8d35\u3001\u6269\u5c55\u6027\u5dee\u3001\u8d44\u6e90\u5229\u7528\u7387\u4f4e\u3002<\/p>\n
\u7f51\u7edc\u901a\u4fe1\u9700\u9075\u5faa\u5206\u5c42\u534f\u8bae，\u6700\u5e38\u7528\u7684\u662f\u200b\u200bTCP\/IP\u6a21\u578b\u200b\u200b：<\/p>\n
Netty\u662f\u7531JBOSS\u63d0\u4f9b\u7684\u200b\u200b\u5f02\u6b65\u4e8b\u4ef6\u9a71\u52a8\u7684\u7f51\u7edc\u5e94\u7528\u6846\u67b6\u200b\u200b，\u57fa\u4e8eJava NIO\u5b9e\u73b0，\u4e13\u4e3a\u89e3\u51b3\u9ad8\u5e76\u53d1\u3001\u4f4e\u5ef6\u8fdf\u7f51\u7edc\u901a\u4fe1\u95ee\u9898\u8bbe\u8ba1\u3002\u5b83\u7b80\u5316\u4e86NIO\u7684\u590d\u6742\u64cd\u4f5c（\u5982\u7ebf\u7a0b\u7ba1\u7406\u3001\u7f13\u51b2\u533a\u5904\u7406），\u63d0\u4f9b\u4e86\u9ad8\u6027\u80fd\u3001\u53ef\u6269\u5c55\u7684\u7f51\u7edc\u7f16\u7a0b\u80fd\u529b\u3002<\/p>\n
\u5b9e\u73b0\u4e00\u4e2a\u7b80\u5355\u7684\u200b\u200bEcho\u670d\u52a1\u5668\u200b\u200b：\u5ba2\u6237\u7aef\u53d1\u9001\u4efb\u610f\u6d88\u606f，\u670d\u52a1\u5668\u63a5\u6536\u540e\u539f\u6837\u8fd4\u56de\u3002\u8be5\u6848\u4f8b\u53ef\u6f14\u793aNetty\u7684\u6838\u5fc3\u6d41\u7a0b（\u670d\u52a1\u7aef\u542f\u52a8\u3001\u4e8b\u4ef6\u5904\u7406\u3001\u5ba2\u6237\u7aef\u4ea4\u4e92）\u3002<\/p>\n
\u5728pom.xml\u4e2d\u6dfb\u52a0\u4f9d\u8d56：<\/p>\n
<dependency>
\n <groupId>io.netty<\/groupId>
\n <artifactId>netty-all<\/artifactId>
\n <version>4.1.96.Final<\/version>
\n<\/dependency> <\/p>\n
\u670d\u52a1\u7aef\u6838\u5fc3\u6d41\u7a0b：\u521b\u5efaEventLoopGroup\u2192\u914d\u7f6eServerBootstrap\u2192\u7ed1\u5b9a\u7aef\u53e3\u2192\u542f\u52a8\u670d\u52a1\u3002<\/p>\n
import io.netty.bootstrap.ServerBootstrap;
\nimport io.netty.channel.*;
\nimport io.netty.channel.nio.NioEventLoopGroup;
\nimport io.netty.channel.socket.SocketChannel;
\nimport io.netty.channel.socket.nio.NioServerSocketChannel;
\nimport io.netty.handler.codec.string.StringDecoder;
\nimport io.netty.handler.codec.string.StringEncoder;<\/p>\n
public class EchoServer {
\n private final int port;<\/p>\n
public EchoServer(int port) {
\n this.port = port;
\n }<\/p>\n
public void start() throws Exception {
\n \/\/ 1. \u521b\u5efa\u4e24\u4e2aEventLoopGroup：bossGroup\u5904\u7406\u8fde\u63a5\u8bf7\u6c42，workerGroup\u5904\u7406IO
\n EventLoopGroup bossGroup = new NioEventLoopGroup(1); \/\/ 1\u4e2a\u7ebf\u7a0b\u5904\u7406\u8fde\u63a5
\n EventLoopGroup workerGroup = new NioEventLoopGroup(); \/\/ \u9ed8\u8ba4CPU\u6838\u5fc3\u6570\u7ebf\u7a0b\u5904\u7406IO<\/p>\n
try {
\n \/\/ 2. \u914d\u7f6e\u670d\u52a1\u7aef\u542f\u52a8\u5668
\n ServerBootstrap b = new ServerBootstrap();
\n b.group(bossGroup, workerGroup)
\n .channel(NioServerSocketChannel.class) \/\/ \u4f7f\u7528NIO\u4f20\u8f93
\n .childHandler(new ChannelInitializer<SocketChannel>() { \/\/ \u5b50\u5904\u7406\u5668（\u5ba2\u6237\u7aef\u8fde\u63a5\u540e\u89e6\u53d1）
\n @Override
\n protected void initChannel(SocketChannel ch) {
\n \/\/ 3. \u6784\u5efa\u5904\u7406\u5668\u94fe：\u89e3\u7801\u2192\u4e1a\u52a1\u5904\u7406\u2192\u7f16\u7801
\n ChannelPipeline pipeline = ch.pipeline();
\n pipeline.addLast(new StringDecoder()); \/\/ \u5b57\u7b26\u4e32\u89e3\u7801\u5668（\u5c06ByteBuf\u8f6cString）
\n pipeline.addLast(new StringEncoder()); \/\/ \u5b57\u7b26\u4e32\u7f16\u7801\u5668（\u5c06String\u8f6cByteBuf）
\n pipeline.addLast(new EchoServerHandler()); \/\/ \u81ea\u5b9a\u4e49\u4e1a\u52a1\u5904\u7406\u5668
\n }
\n })
\n .option(ChannelOption.SO_BACKLOG, 128) \/\/ \u8fde\u63a5\u961f\u5217\u5927\u5c0f
\n .childOption(ChannelOption.SO_KEEPALIVE, true); \/\/ \u4fdd\u6301\u957f\u8fde\u63a5<\/p>\n
\/\/ 4. \u7ed1\u5b9a\u7aef\u53e3\u5e76\u542f\u52a8\u670d\u52a1
\n ChannelFuture f = b.bind(port).sync();
\n System.out.println("Echo\u670d\u52a1\u5668\u542f\u52a8，\u7aef\u53e3：" + port);<\/p>\n
\/\/ 5. \u7b49\u5f85\u670d\u52a1\u7aef\u5173\u95ed
\n f.channel().closeFuture().sync();
\n } finally {
\n \/\/ 6. \u4f18\u96c5\u5173\u95ed\u7ebf\u7a0b\u6c60
\n bossGroup.shutdownGracefully();
\n workerGroup.shutdownGracefully();
\n }
\n }<\/p>\n
public static void main(String[] args) throws Exception {
\n new EchoServer(8080).start();
\n }
\n} <\/p>\n
\u5904\u7406\u5ba2\u6237\u7aef\u6d88\u606f\u5e76\u56de\u5199：<\/p>\n
import io.netty.channel.ChannelHandlerContext;
\nimport io.netty.channel.ChannelInboundHandlerAdapter;<\/p>\n
public class EchoServerHandler extends ChannelInboundHandlerAdapter {
\n @Override
\n public void channelRead(ChannelHandlerContext ctx, Object msg) {
\n \/\/ \u76f4\u63a5\u4f7f\u7528ctx.writeAndFlush\u56de\u5199\u6d88\u606f（\u81ea\u52a8\u7f16\u7801）
\n ctx.writeAndFlush(msg);
\n }<\/p>\n
@Override
\n public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
\n \/\/ \u5f02\u5e38\u5904\u7406：\u6253\u5370\u65e5\u5fd7\u5e76\u5173\u95ed\u8fde\u63a5
\n cause.printStackTrace();
\n ctx.close();
\n }
\n} <\/p>\n
\u5ba2\u6237\u7aef\u6838\u5fc3\u6d41\u7a0b：\u8fde\u63a5\u670d\u52a1\u7aef\u2192\u53d1\u9001\u6d88\u606f\u2192\u63a5\u6536\u54cd\u5e94\u3002<\/p>\n
import io.netty.bootstrap.Bootstrap;
\nimport io.netty.channel.*;
\nimport io.netty.channel.nio.NioEventLoopGroup;
\nimport io.netty.channel.socket.SocketChannel;
\nimport io.netty.channel.socket.nio.NioSocketChannel;
\nimport io.netty.handler.codec.string.StringDecoder;
\nimport io.netty.handler.codec.string.StringEncoder;<\/p>\n
public class EchoClient {
\n private final String host;
\n private final int port;<\/p>\n
public EchoClient(String host, int port) {
\n this.host = host;
\n this.port = port;
\n }<\/p>\n
public void start() throws Exception {
\n EventLoopGroup group = new NioEventLoopGroup();<\/p>\n
try {
\n Bootstrap b = new Bootstrap();
\n b.group(group)
\n .channel(NioSocketChannel.class)
\n .handler(new ChannelInitializer<SocketChannel>() {
\n @Override
\n protected void initChannel(SocketChannel ch) {
\n ChannelPipeline pipeline = ch.pipeline();
\n pipeline.addLast(new StringDecoder());
\n pipeline.addLast(new StringEncoder());
\n pipeline.addLast(new EchoClientHandler()); \/\/ \u5ba2\u6237\u7aef\u4e1a\u52a1\u5904\u7406\u5668
\n }
\n });<\/p>\n
\/\/ \u8fde\u63a5\u670d\u52a1\u7aef
\n ChannelFuture f = b.connect(host, port).sync();
\n Channel channel = f.channel();<\/p>\n
\/\/ \u53d1\u9001\u6d4b\u8bd5\u6d88\u606f
\n String message = "Hello, Netty!";
\n channel.writeAndFlush(message);
\n System.out.println("\u5ba2\u6237\u7aef\u53d1\u9001：" + message);<\/p>\n
\/\/ \u7b49\u5f85\u5173\u95ed
\n f.channel().closeFuture().sync();
\n } finally {
\n group.shutdownGracefully();
\n }
\n }<\/p>\n
public static void main(String[] args) throws Exception {
\n new EchoClient("127.0.0.1", 8080).start();
\n }
\n}<\/p>\n
\/\/ \u5ba2\u6237\u7aef\u4e1a\u52a1\u5904\u7406\u5668（\u53ef\u9009，\u6b64\u5904\u53ef\u76f4\u63a5\u5728main\u4e2d\u53d1\u9001）
\nclass EchoClientHandler extends ChannelInboundHandlerAdapter {
\n @Override
\n public void channelRead(ChannelHandlerContext ctx, Object msg) {
\n System.out.println("\u5ba2\u6237\u7aef\u63a5\u6536：" + msg);
\n }
\n} <\/p>\n
RPC\u6846\u67b6\u9700\u8981\u9ad8\u6548\u7684\u8de8\u8fdb\u7a0b\u901a\u4fe1，Netty\u7684\u5f02\u6b65\u975e\u963b\u585e\u6a21\u578b\u80fd\u652f\u6491\u9ad8\u5e76\u53d1\u8fde\u63a5，\u914d\u5408\u81ea\u5b9a\u4e49\u7f16\u89e3\u7801\u5668（\u5982Protobuf）\u5b9e\u73b0\u4f4e\u5ef6\u8fdf\u6570\u636e\u4f20\u8f93\u3002<\/p>\n
IM\u9700\u8981\u957f\u8fde\u63a5\u7ef4\u6301\u548c\u9ad8\u5e76\u53d1\u6d88\u606f\u5904\u7406，Netty\u7684EventLoop\u53ef\u9ad8\u6548\u7ba1\u7406\u6570\u4e07\u957f\u8fde\u63a5，\u652f\u6301\u5fc3\u8df3\u68c0\u6d4b\u3001\u6d88\u606f\u5e7f\u64ad\u7b49\u529f\u80fd\u3002<\/p>\n
\u6e38\u620f\u670d\u52a1\u5668\u9700\u5904\u7406\u5927\u91cf\u73a9\u5bb6\u5b9e\u65f6\u4ea4\u4e92（\u5982\u79fb\u52a8\u3001\u6218\u6597\u6307\u4ee4），Netty\u7684\u4f4e\u5ef6\u8fdfIO\u548c\u7075\u6d3b\u7684\u5904\u7406\u5668\u94fe\u80fd\u6ee1\u8db3\u9ad8\u5e76\u53d1\u3001\u4f4e\u5ef6\u8fdf\u9700\u6c42\u3002<\/p>\n
Spring WebFlux\u5e95\u5c42\u57fa\u4e8eReactor Netty\u5b9e\u73b0，\u5229\u7528Netty\u7684\u5f02\u6b65\u975e\u963b\u585e\u7279\u6027\u652f\u6301\u54cd\u5e94\u5f0f\u7f16\u7a0b，\u5904\u7406\u9ad8\u5e76\u53d1HTTP\u8bf7\u6c42\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u6587\u7ae0\u6d4f\u89c8\u9605\u8bfb848\u6b21\uff0c\u70b9\u8d5e13\u6b21\uff0c\u6536\u85cf8\u6b21\u3002\u7f51\u7edc\u7f16\u7a0b\u662f\u6307\u901a\u8fc7\u200b\u200b\u7f51\u7edc\u534f\u8bae\uff08\u5982TCP\/IP\uff09\u200b\u200b\u5b9e\u73b0\u4e0d\u540c\u8bbe\u5907\u95f4\u6570\u636e\u901a\u4fe1\u7684\u6280\u672f\u3002\u6838\u5fc3\u76ee\u6807\u662f\u8ba9\u7a0b\u5e8f\u80fd\u591f\u901a\u8fc7\u7f51\u7edc\u4e0e\u5176\u4ed6\u7a0b\u5e8f\u4ea4\u6362\u6570\u636e\uff0c\u4f8b\u5982\u7f51\u9875\u6d4f\u89c8\u3001\u5373\u65f6\u901a\u8baf\u3001\u6587\u4ef6\u4f20\u8f93\u7b49\u573a\u666f\u5747\u4f9d\u8d56\u7f51\u7edc\u7f16\u7a0b\u3002<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[43,78,44],"topic":[],"class_list":["post-45221","post","type-post","status-publish","format-standard","hentry","category-server","tag-43","tag-78","tag-44"],"yoast_head":"\n