今天，我遇到了一个广告网络的相对现实的需求，如下所示：是最多的广告服务器，可以接收很多从发布者的应用程序加载广告的请求。 。 。此时，可以将请求的数据发送到某些中间机构（交换），然后它们将返回广告数据。 。 。由于请求量很大并且延迟不能太大，因此仅在与这些中介机构进行通信时才能使用长连接，并且不能为每个发出http请求的请求生成连接。 。 。实际上，过去使用Netty开发作为服务器的一般想法如下：（1）创建一个eventLoopGroup来维护nio的io事件（2）创建一个niosocketchanel，然后将其注册到eventLoopGroup，不带通道设置初始化的处理程序（3）调用通道的connect方法以发起与远端的连接请求（4）建立链接后，将使用刚才提到的初始化处理程序进行响应，并添加http解码和编码通道的处理程序。 。 （5）最后，您可以开始http通信。 。当然，请不要主动断开此处的频道。让对方的服务器断开连接，超时或执行其他操作。 。无论如何，客户端将不会主动断开连接。 。 。实际上，只要弄清楚了上述步骤，编写代码并使用netty来实现基于长连接的http客户端就非常简单。 。直接转到代码：［java］查看普通copypackage fjs；导入java.net.InetSocketAddress;导入java.net.URI;导入java.net.URISyntaxExcepTIon; TI.AtomicInteger; parallel.atomic.AtomicLong;导入io.netty.channel.Channel;导入io.netty.channel.ChannelHandlerContext;导入io.netty.channel.ChannelInboundHandler; import io.netty.channel.nio.NioEventLoop.import io channel .socket.nio.NioSocketChannel;导入io.netty.handler.codec.http.FullHttpRequest;导入io.netty.handler.codec.http.HttpClientCodec;导入io.netty.handler.codec.http.HttpMethod;导入io.netty。 .handler.codec.http.HttpVersion;导入io.netty.handler.codec.http.QueryStringEncoder;导入io.netty.handler.codec.http.DefaultFullHttpRequest;公共类Fjs {public staTIc AtomicIntegerte; number = new AtomicIntegerte（0）公共静态AtomicLong时间= new AtomicLong（0）; public static void doIt（Channel channel）{if（number.get（）＆quot; 50）{number.i ncrementAndGet（）; time.set（System.currentTimeMillis（））; QueryStringEncoder编码器=新的QueryStringEncoder（＆ldquo; http：//www.baidu.com/oapi/reqAd.jsp？pub = 923875870＆amp; amp; adspace = 65826983＆amp; amp; ad = 1 = 1＆amp; amp;响应= HTML＆amp; amp; devip = 22.56.22.66＆amp; amp;用户= 900＆amp; amp;格式= IMG＆amp;位置=顶部＆amp; amp;高度=＆amp;宽度=＆amp;设备= Mozilla％2F5.0％20％28Linux ％3B％20Android％204.2.1％3B％20en-us％3B％20Nexus％204％20Build％2FJOP40D％29％20AppleWebKit％2F535.19％20％28KHTML％2C％20like％20Gecko％29％20Chrome％2F18.0.1025 .166％20Mobile％20Safari％2F535.19＆amp; amp; beacon = TRUE＆amp; amp; phpsnip = 104＆amp; rdquo;）; URI uriGet = null;尝试{uriGet = new URI（encoder.toString（））; e）捕获（URISyntax（））; } catch {System.out.println（＆quot;我擦拭、、＆rdquo;）； } FullHttpRequest请求=新的DefaultFullHttpRequest（HttpVersion.HTTP_1_1，HttpMethod.GET，uriGet.toASCIIString（））; channel.pipeline（）。write（request）; Channel.flush（）; } else {System.out.println（＆amp; ld＆quot; over＆amp; rdquo;）; }} public static void channel main（String args []）newEventLoopGroupChannelException {io oopGroup Nio = newEvent Nio NioSocketChannel（）; //创建一个通道，并在稍后使用它来启动链接channel.pipeline（）。 addFirst（new InitHandler（））; //为此通道添加一个初始化处理程序，以响应稍后通道的成功建立。group.register（channel）; //注册此频道channel.connect（new InetSocketAddress（＆amp; ld.www.baidu.com＆rdquo ;, 80））; //调用连接方法Thread.currentThread（）。sleep（Long.MAX_VALUE）; }公共静态类InitHandler实现ChannelInboundHandler {公共无效handlerAdded（ChannelHandlerContext ctx）引发异常{// TODO自动生成的方法stub}公共无效handlerRemoved（ChannelHandlerContext ctx）引发异常{// TODO自动生成的方法stub}公共无效channelRegistered（ ChannelHandlerContext ctx）引发生成的异常{Channel Handler引发生成的异常{公共通道ctx公共方法x异常{// TODO自动生成的方法stub}