java使用netty

╰+攻爆jí腚メ 2023-10-18 15:28 99阅读 0赞

> Netty为什么会高效？回答就是良好的线程模型，和内存管理。在Java的NIO例子中就我将客户端的操作单独放在一个线程中处理了，这么做的原因在于如果将客户端连接串起来，后来的连接就要等前一个处理完，当然这并不意味着多线程比单线程有优势，而是在于每个客户端都需要进行读取准备好的缓存数据，再执行一些业务逻辑。如果业务逻辑耗时很久，那么顺序执行的方式没有多线程优势大。另一个方面目前多核CPU很常见了，多线程是个不错的选择。这些在第一节就说明过，也提到过NIO并不是提升了IO操作的速度，而是减少了CPU的浪费时间，这些概念不能搞混。

netty作为一款服务端框架，其优势在于自身良好的线程模型架构，关于netty的基本架构，我用几张图进行说明，netty主要处理方式有三种线程模型，1、 单线程 2、主从线程 3、主从多线程

1、事件分离器把接收到的客户事件分发到不同的事件处理器中，在netty中，处理器定义为channelHandler:如下图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70]  
2、netty处理请求结构，理解起来就是，客户端发起请求，服务端开辟一个两个线程组，一个线程组负责接收请求，由于是线程组，可理解为线程池，能够处理的并发请求量就提升了，然后是工作线程，主线程组把请求转发给从线程组，也叫工作线程池，这个线程组负责执行具体的业务，  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70 1]

3、那么最终的处理结构就是，  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70 2]

下面用具体的代码来模拟一下上述过程的实现，这里为了演示，做一个客户端访问具体的端口号，由服务端返回一条信息，

4、pom文件：

<dependency>
    			<groupId>io.netty</groupId>
    			<artifactId>netty-all</artifactId>
    			<version>5.0.0.Alpha2</version>
    			
    		</dependency>
    
    5、测试主类，

package com.congge.sort.netty.day1;

import io.netty.bootstrap.ServerBootstrap;  
import io.netty.channel.ChannelFuture;  
import io.netty.channel.EventLoopGroup;  
import io.netty.channel.nio.NioEventLoopGroup;  
import io.netty.channel.socket.nio.NioServerSocketChannel;

/\*\*

*  netty测试
 *  @author asus
 *

\*/  
public class HelloServer \{

public static void main(String[] args) {
    	
    	//定义主线程组，用于接收客户端请求，但是并不做任何逻辑处理
    	EventLoopGroup bossGroup = new NioEventLoopGroup();
    	//从线程组，主线程组会把相应的请求转交给该线程组，由从线程组去做任务
    	EventLoopGroup workerGroup = new NioEventLoopGroup();
    	//创建netty服务器
    	ServerBootstrap serverBootstrap = new ServerBootstrap();
    	try {
    		//服务器设置绑定两个线程组，并设置相应的助手类【handler】
    		serverBootstrap.group(bossGroup, workerGroup)
    						.channel(NioServerSocketChannel.class)				//设置nio双向通道
    						.childHandler(new HelloServerInitializer());		//子处理器
    		
    		//启动server并绑定端口号
    		ChannelFuture channelFuture = serverBootstrap.bind(8088).sync();
    		//关闭监听的channel
    		channelFuture.channel().closeFuture().sync();
    	} catch (Exception e) {
    		e.printStackTrace();
    	}finally {
    		bossGroup.shutdownGracefully();
    		workerGroup.shutdownGracefully();
    	}
    	
    }

上述方法体中有一个很重要的组件叫做channelHandler，客户端连接服务端后的初始化业务逻辑操作均在这个hander里面进行编写，可以自定义，非常灵活，这里我用一个自定义的，

package com.congge.sort.netty.day1;
    
    
    import io.netty.channel.ChannelInitializer;
    import io.netty.channel.ChannelPipeline;
    import io.netty.channel.socket.SocketChannel;
    import io.netty.handler.codec.http.HttpServerCodec;
    
    /**
     * 初始化配置器，channel注册成功后，会执行里面相应的初始化方法
     * @author asus
     *
     */
    public class HelloServerInitializer extends ChannelInitializer<SocketChannel>{
    
    	@Override
    	protected void initChannel(SocketChannel channel) throws Exception {
    		
    		//channel获取相应的管道
    		ChannelPipeline pipeline = channel.pipeline();
    		
    		//为管道增加相应的handler，可理解为是拦截器，或者监听器，监听客户端建立连接后的信息
    		//当请求到服务端，我们需要对写出到客户端的数据做编码处理
    		pipeline.addLast("httpCode",new HttpServerCodec());
    		
    		//添加自定义助手类，可添加多个
    		pipeline.addLast("myHandler",new MyHandler());
    		
    	}
    
    }

MyHandler为具体的执行业务逻辑，这里只是简单的写了一句字符串发送给客户端，

package com.congge.sort.netty.day1;
    
    import io.netty.buffer.ByteBuf;
    import io.netty.buffer.Unpooled;
    import io.netty.channel.Channel;
    import io.netty.channel.ChannelHandlerContext;
    import io.netty.channel.SimpleChannelInboundHandler;
    import io.netty.handler.codec.http.DefaultFullHttpResponse;
    import io.netty.handler.codec.http.FullHttpResponse;
    import io.netty.handler.codec.http.HttpHeaderNames;
    import io.netty.handler.codec.http.HttpObject;
    import io.netty.handler.codec.http.HttpRequest;
    import io.netty.handler.codec.http.HttpResponseStatus;
    import io.netty.handler.codec.http.HttpVersion;
    import io.netty.util.CharsetUtil;
    
    /**
     * 自定义助手类
     * @author asus
     *
     */
    public class MyHandler extends SimpleChannelInboundHandler<HttpObject>{
    
    	@Override
    	protected void messageReceived(ChannelHandlerContext context, HttpObject msg) 
    			throws Exception {
    		
    		//通过context的上下文获取channel
    		Channel channel = context.channel();
    		
    		if(msg instanceof HttpRequest){
    			//获取请求地址
    			System.out.println(channel.remoteAddress());
    		}
    		
    		//自定义相应客户端信息
    		ByteBuf content = Unpooled.copiedBuffer("hello neyy <<<>>>",CharsetUtil.UTF_8);
    		
    		//侯建httpResponse对象
    		FullHttpResponse response = new DefaultFullHttpResponse(
    				HttpVersion.HTTP_1_1, 
    				HttpResponseStatus.OK,
    				content);
    		
    		//设置response对象的头信息
    		response.headers().set(HttpHeaderNames.CONTENT_TYPE,"text/plain");
    		response.headers().setInt(HttpHeaderNames.CONTENT_LENGTH,content.readableBytes());
    		
    		//将数据刷到客户端
    		context.writeAndFlush(response);
    		
    	}
    
    }

然后我们启动一下服务端，直接运行main函数即可，然后浏览器输入，[http://localhost:8088/，][http_localhost_8088]  
可以看到收到了服务端推送过来的内容，  
![在这里插入图片描述][20190313223634797.png]  
到这里基本上就实现了服务端定向推送内容到客户端的实现

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20190313222021843.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20190313222411975.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20190313222744721.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW5nY29uZ3lpNDIw,size_16,color_FFFFFF,t_70
[http_localhost_8088]: http://localhost:8088/%EF%BC%8C
[20190313223634797.png]: https://img-blog.csdnimg.cn/20190313223634797.png