netty websocket学习

【硬核】肝了一月的Netty知识点

超详细Netty入门，看这篇就够了！

vue+websokect实现实时聊天，可单聊、可群聊（一）
vue实现聊天栏定位到最底部（超简单、可直接复制使用）
vue实现指定div右键显示菜单，并实现复制内容到粘贴板

Springboot实现websocket（连接前jwt验证token）

vue中audio标签自定义音频播放栏

netty-websocket 鉴权token及统一请求和响应头（鉴权控制器）

一个优秀活跃的视频转码项目分享

动手打造属于自己的直播间（Vue+SpringBoot+Nginx）

42-Netty基础-Websocket-Netty握手源码分析 - B站视频 - 很详细
43-FrameDecoder源码分析
44-Netty基础-WebSocket08FrameEncoder源码分析
46-Netty基础-WebSocket-HandshakeComplete握手成功事件
47-Netty基础-WebSocket-DefaultChannelGroup消息群发

【netty专栏】 - 待学习

WebSocket协议：5分钟从入门到精通

SpringBoot+Netty+WebSocket实现在线聊天有对应的B站视频和代码-已fork - 代码

SpringBoot 整合 Netty + Websocket

Spring boot 项目（二十三）——用 Netty+Websocket实现聊天室

springBoot + netty搭建高性能 websocket 服务 & 性能测试（包含python 测试脚本）
springBoot使用webSocket的几种方式以及在高并发出现的问题及解决

SpringBoot2+Netty+WebSocket(netty实现websocket，支持URL参数)
SpringBoot整合Netty处理WebSocket（支持url参数）
使用Netty处理WebSocket请求

SpringBoot 集成 Netty 使用WebSocket功能，并实现token校验

微服务springcloud环境下基于Netty搭建websocket集群实现服务器消息推送----netty是yyds

SpringBoot2+Netty+WebSocket(netty实现websocket）

SpringBoot 整合 Netty 实现 WebSocket

Netty实战，Springboot + netty +websocket 实现推送消息

springboot实现webrtc

更新啦，SpringBoot+websocket聊天-增加语音功能

Springboot整合WebSocket实现网页版聊天，快来围观！

Spring WebSocket传递多媒体消息

Springboot+Netty搭建分布式的WebSocket简单集群，后续完善即时通讯聊天系统

EasyMedia项目 — Springboot、netty实现的http-flv、websocket-flv直播点播，支持rtsp、h264、h265、rtmp等多种源，h5纯js播放（不依赖flash），不需要nginx等第三方拉流服务

js Blob、ArrayBuffer(Uint8Array、TypedArray、DataView)、Buffer、DataUrl
【OFD】ArrayBuffer 和 Uint8Array

package com.zzhua.test06;import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.http.*;
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolConfig;
import io.netty.handler.codec.http.websocketx.WebSocketServerProtocolHandler;public class NettyWsServer {public static void main(String[] args) throws InterruptedException {EventLoopGroup bossGroup = new NioEventLoopGroup();EventLoopGroup workerGroup = new NioEventLoopGroup(16);try {ServerBootstrap serverBootstrap = new ServerBootstrap();serverBootstrap.group(bossGroup, workerGroup).channel(NioServerSocketChannel.class).childHandler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ch.pipeline().addLast("http-decoder", new HttpRequestDecoder());ch.pipeline().addLast("http-encoder", new HttpResponseEncoder());ch.pipeline().addLast("aggregator", new HttpObjectAggregator(65536));WebSocketServerProtocolConfig wsServerConfig = WebSocketServerProtocolConfig.newBuilder().websocketPath("/websocket").maxFramePayloadLength(Integer.MAX_VALUE).checkStartsWith(true).build();ch.pipeline().addLast("websocketHandler", new WebSocketServerProtocolHandler(wsServerConfig));ch.pipeline().addLast("wsTextHandler", new WsTextHandler());}});ChannelFuture channelFuture = serverBootstrap.bind(8080).sync();channelFuture.channel().closeFuture().sync();} finally {workerGroup.shutdownGracefully();bossGroup.shutdownGracefully();}}
}

package com.zzhua.test06;import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import io.netty.handler.codec.http.websocketx.PingWebSocketFrame;
import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
import io.netty.handler.codec.http.websocketx.WebSocketFrame;import java.nio.charset.StandardCharsets;public class WsTextHandler extends SimpleChannelInboundHandler<WebSocketFrame> {@Overrideprotected void channelRead0(ChannelHandlerContext ctx, WebSocketFrame msg) throws Exception {System.out.println("收到消息: " + msg.content().toString(StandardCharsets.UTF_8));TextWebSocketFrame textWebSocketFrame = new TextWebSocketFrame();textWebSocketFrame.content().writeBytes("收到了".getBytes());ctx.channel().writeAndFlush(textWebSocketFrame);}
}

<script>var ws = new WebSocket('ws://localhost:8080/websocket')ws.onmessage  = msg => {console.log('收到消息: ' + msg.data);}ws.onclose = () => {console.log('关闭连接');}ws.onerror = () => {console.log('连接错误');}ws.onopen = function (event) {console.log("建立连接成功")ws.send('halo')}</script>