Netty 常用的场景：
1.充当HTTP 服务器，但Netty 并没有遵循servlet 的标准，反而实现了自己的一套标准进行Http 服务；
2,RPC 远程调用，在分布式系统中常用的框架
3.Socket 长连接
需要了解的名词
1.NioEventLoopGroup: 对线程的控制，线程组,事件循环组,死循环,需要定义两个线程组，一个只用于接收客户端的请求，一个负责具体的处理
2.Bootstrap :对服务启动的封装，可以很轻松的启动服务管道，进行服务的启动
3.Channel:渠道，每一个请求都会形成一个渠道
4.initChannel:连接一旦被创建，就会执行initChannel方法
5.ChannelPipline:连接的管道，里面装有很多的ChannelHandler处理器（第6）
6.ChannelHandler:定义我们自己的处理器，因为流程进行到这里我们的请求已经进来了，需要我们进行自己的逻辑处理与响应，相当于filter 一样； netty也提供了很多的处理器；
7.ByteBuf:很重要，以后详细讲解
8.ChannelGroup :用来存放一个一个的Channel 对象的Channel 组 ,可以通过 new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);进行获取
接下来是示例代码：我们目前刚接触，我们先不用管它里面具体怎么实现的，只要先对netty 有一个全局的认识，知道它的执行流程就可以，知道执行流程后再深入学习每一步的作用，这样我们就不会太迷茫
基本上，所有netty 编程中都会遵循以下三点：
1. 创建线程组,即EventLoopGroup
2.进行服务启动类，即bootstrap
3.针对自己的业务，创建自己的Handler
1.我们的启动类
public class WebSocketService { public static void main(String[] args) throws Exception { //一样，定义线程组 EventLoopGroup boosGroup =new NioEventLoopGroup(); EventLoopGroup workGroup =new NioEventLoopGroup(); //服务启动类 try { ServerBootstrap bootstrap=new ServerBootstrap(); bootstrap.group(boosGroup,workGroup) .channel(NioServerSocketChannel.class) //添加日志 .handler(new LoggingHandler(LogLevel.INFO)) .childHandler(new WebSocketInitializer()); //端口绑定 ChannelFuture channelFuture=bootstrap.bind(9077).sync(); channelFuture.channel().closeFuture().sync(); } finally { boosGroup.shutdownGracefully(); workGroup.shutdownGracefully(); } } }
2.初始化器，用来存放Hander 的
/** * initializer 初始化器 * @author cys * */ public class WebSocketInitializer extends ChannelInitializer<SocketChannel> { @Override protected void initChannel(SocketChannel ch) throws Exception { ChannelPipeline pip =ch.pipeline(); //=====websocket 是基于http协议基础之上的，所以要有http的支持=======// //编解码器 pip.addLast(new HttpServerCodec()); //对大数据的支持 pip.addLast(new ChunkedWriteHandler()); // 对httpMessage进行聚合，聚合成FullHttpRequest或FullHttpResponse // 几乎在netty中的编程，都会使用到此hanler pip.addLast(new HttpObjectAggregator(1024*64)); //This handler does all the heavy lifting for you to run a websocket server. //这个handler 做了所有的繁重的工作，对于你运行的websocket服务器 //处理了frame 的 close ping pang binary text ，运行中并带到下一个关于你的实现的handler pip.addLast(new WebSocketServerProtocolHandler("/ws"));//===>ws://localhost:8066/ws //自定义自己的处理类,WebSocketServerProtocolHandler 会将数据帧带到你的handler中 pip.addLast(new WebSocketMyHandler()); } }
3.定义自己的Handler ，也就是自己的逻辑处理
/** * webSocket 自定义handler * webSocket 对于数据的传输都是基于Frame（帧）的 ，关于frame 一共有五种类型，遵循RFC标准,netty 实现了这五种标准，所有netty 对websocket 有很好的支持 * 1.BinaryWebSocketFrame * 2.TextWebSocketFrame * 3.PongWebSocketFrame * 4.PingWebSocketFrame * 5.CloseWebSocketFrame * ping、pong 的操作，对应的是 WebSocket 的两个控制帧 ==心跳 * * @author cys * */ public class WebSocketMyHandler extends SimpleChannelInboundHandler<TextWebSocketFrame> { //当前的channel 组 private static ChannelGroup channelGroup =new DefaultChannelGroup(GlobalEventExecutor.INSTANCE); @Override protected void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame msg) throws Exception { Channel ch =ctx.channel(); //msg.text()接收客户端的消息 String text=msg.text(); System.out.println("收到消息"+text); for(Channel self :channelGroup) { if(ch ==self) { ch.writeAndFlush(new TextWebSocketFrame("我：===>"+text)); } else { self.writeAndFlush(new TextWebSocketFrame(ch.remoteAddress()+"===>"+text)); } } } /** * 当有新的Channel连接 时候会触发 */ @Override public void handlerAdded(ChannelHandlerContext ctx) throws Exception { Channel ch = ctx.channel(); channelGroup.writeAndFlush(new TextWebSocketFrame(ch.remoteAddress()+"---上线")); System.out.println(ch.remoteAddress()+"已经连接"); channelGroup.add(ctx.channel()); } /** * 连接断开的时候触发 */ @Override public void handlerRemoved(ChannelHandlerContext ctx) throws Exception { Channel ch = ctx.channel(); System.out.println(new TextWebSocketFrame(ch.remoteAddress()+"已经断开")); channelGroup.writeAndFlush(ch.remoteAddress()+"---下线"); } /** * 出现异常时候触发,关闭当前连接 */ @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { ctx.channel().close(); } }
4.因为websocket 是基于HTML5的，所以客户端就是我们支持websocket的浏览器，
<!DOCTYPE html> <html> <head> <meta charset="UTF-8"> <title>web socket连接</title> </head> <body> <div>发送消息</div> <input type="text" id="msgContent"/> <input type="button" value="send" onclick="CHAT.chat()"/> <div>接收消息</div> <div id="reciveMsg" style="background-color:pink"></div> <script type="text/javascript"> window.CHAT ={ socket:null, init: function(){ if(window.WebSocket){ CHAT.socket =new WebSocket("ws://10.9.121.91:9077/ws"); CHAT.socket.onopen = CHAT.onopen, CHAT.socket.onclose =CHAT.onclose, CHAT.socket.onerror =CHAT.onerror, CHAT.socket.onmessage =CHAT.onmessage } else{ alert("不支持socket"); } }, chat: function(){ //消息发送 var content =document.getElementById("msgContent"); if (CHAT.socket != null && CHAT.socket != undefined && CHAT.socket.readyState == WebSocket.OPEN) { CHAT.socket.send(content.value); } else { // 重连websocket CHAT.init(); } } , //客户端与服务器链接触发 onopen :function(){ console.log("链接已经链接"); }, onclose :function(){ console.log("链接已经关闭"); }, onerror:function(){ console.log("出现错误"); }, onmessage:function(e){ console.log("链接消息"); var reciveMsg =document.getElementById("reciveMsg"); var html =reciveMsg.innerHTML; reciveMsg.innerHTML =html+"<br/>"+e.data; } } CHAT.init(); </script> </body> </html>