返回顶部
首页 > 资讯 > 服务器 >Netty 教程 – 实现WebSocket通讯
  • 544
分享到

Netty 教程 – 实现WebSocket通讯

websocket网络服务器 2023-09-05 21:09:34 544人浏览 泡泡鱼
摘要

websocket WEBSocket协议是基于tcp的一种新的网络协议,它实现了浏览器与服务器全双工(full-duplex)通信,允许服务器主动发送信息给客户端 优点及作用 Http协议的弊端: Http协议为半双工协议。(半双工:同一

websocket

WEBSocket协议是基于tcp的一种新的网络协议,它实现了浏览器与服务器全双工(full-duplex)通信,允许服务器主动发送信息给客户端

优点及作用

Http协议的弊端:

  • Http协议为半双工协议。(半双工:同一时刻,数据只能在客户端和服务端一个方向上传输)
  • Http协议冗长且繁琐
  • 易收到攻击,如长轮询
  • 非持久化协议

WebSocket的特性:

  • 单一的 TCP 连接,采用全双工模式通信
  • 对代理、防火墙和路由器透明
  • 无头部信息和身份验证
  • 安全开销
  • 通过 ping/pong 帧保持链路激活
  • 持久化协议,连接建立后,服务器可以主动传递消息给客户端,不再需要客户端轮询

实现原理

在实现Websocket连线过程中,需要通过浏览器发出Websocket连线请求,然后服务器发出回应,这个过程通常称为握手 。在 WebSocket api,浏览器和服务器只需要做一个握手的动作,然后,浏览器和服务器之间就形成了一条快速通道。两者之间就直接可以数据互相传送。在此WebSocket 协议中,为我们实现即时服务带来了两大好处:

Header 互相沟通的Header是很小的-大概只有 2 Bytes

GET ws://localhost:5050/websocket HTTP/1.1Host: localhost:5050Connection: UpgradePragma: no-cacheCache-Control: no-cacheUpgrade: websocketOrigin: http://localhost:63342Sec-WebSocket-Version: 13User-Agent: Mozilla/5.0 (windows NT 10.0; WOW64) AppleWebKit/537.36 (Khtml, like Gecko) Chrome/61.0.3163.79 Safari/537.36Accept-Encoding: gzip, deflate, brAccept-Language: zh-CN,zh;q=0.8Cookie: idea-d796403=9d25c0a7-d062-4c0f-a2ff-e4da09ea564eSec-WebSocket-Key: IzEaiuZLxeIhjjYDdTp+1g==Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits

Sec-WebSocket-Key 是随机生成的,服务端会使用它加密后作为 Sec-WebSocket-Accept 的值返回;
Sec-WebSocket-Protocol 是一个用户定义的字符串,用来区分同URL下,不同的服务所需要的协议;
Sec-WebSocket-Version 是告诉服务器所使用的Websocket Draft(协议版本)

Server Push 服务器的推送,服务器不再被动的接收到浏览器的请求之后才返回数据,而是在有新数据时就主动推送给浏览器。

HTTP/1.1 101 Switching Protocolsupgrade: websocketconnection: Upgradesec-websocket-accept: nO+qX20rjrTLHaG6iQyllO8KEmA=

经过服务器的返回处理后连接握手成功,后面就可以进行TCP通讯,WebSocket在握手后发送数据并象下层TCP协议那样由用户自定义,还是需要遵循对应的应用协议规范…

WebSocket服务

定义初始化参数

public interface Init {    int PORT = 5050;    String HOST = "localhost";    String WEB_SOCKET_URL = String.fORMat("ws://%s:%d/websocket", HOST, PORT);}

创建一个WebSocketServer类,然后重写初始化事件(基本上与上一章编写的文件下载类似,都需要依赖HTTP的解码器与通信支持的模块…)

public class WebSocketServer {    private static final Logger LOG = Logger.getLogger(WebSocketServer.class.getName());    public static void run(int port) throws Exception {        EventLoopGroup bossGroup = new NIOEventLoopGroup();        EventLoopGroup workerGroup = new NioEventLoopGroup();        try {            ServerBootstrap bootstrap = new ServerBootstrap();            bootstrap.group(bossGroup, workerGroup)                    .channel(NiOServerSocketChannel.class)                    .childHandler(new ChannelInitializer() {                        @Override                        protected void initChannel(Channel channel) throws Exception {ChannelPipeline pipeline = channel.pipeline();pipeline.addLast("http-codec", new httpserverCodec()); // Http消息编码解码pipeline.addLast("aggregator", new HttpObjectAggregator(65536)); // Http消息组装pipeline.addLast("http-chunked", new ChunkedWriteHandler()); // WebSocket通信支持pipeline.addLast("handler", new WebSocketServerHandler()); // WebSocket服务端Handler                        }                    });            Channel channel = bootstrap.bind(port).sync().channel();            LOG.info("WebSocket 已经启动,端口:" + port + ".");            channel.closeFuture().sync();        } finally {            bossGroup.shutdownGracefully();            workerGroup.shutdownGracefully();        }    }    public static void main(String[] args) throws Exception {        WebSocketServer.run(Init.PORT);    }}

创建WebSocketServerHandler,重写以下三个方法

  • messageReceived:消息接收,判断请求消息来源,从而做不同处理
  • channelReadComplete:Channel读取完毕后执行的回调操作
  • exceptionCaught:异常后回调操作
public class WebSocketServerHandler extends SimpleChannelInboundHandler {    private static final Logger LOG = Logger.getLogger(WebSocketServerHandler.class.getName());    private WebSocketServerHandshaker handshaker;    @Override    public void messageReceived(ChannelHandlerContext ctx, Object msg)            throws Exception {        // 传统的HTTP接入        if (msg instanceof FullHttpRequest) {            handleHttpRequest(ctx, (FullHttpRequest) msg);        }        // WebSocket接入        else if (msg instanceof WebSocketFrame) {            handleWebSocketFrame(ctx, (WebSocketFrame) msg);        }    }    @Override    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {        ctx.flush();    }    @Override    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)            throws Exception {        cause.printStackTrace();        ctx.close();    }} 

第一次握手请求是由HTTP协议承载来完成握手请求操作

定义handleHttpRequestsendHttpResponse方法,处理HTTP的请求,首先判断是否为WebSocket握手请求,如果不是则抛出错误消息

private void handleHttpRequest(ChannelHandlerContext ctx, FullHttpRequest req) throws Exception {    // 如果HTTP解码失败,返回HHTP异常    if (!req.decoderResult().isSuccess() || (!"websocket".equals(req.headers().get("Upgrade")))) {        sendHttpResponse(ctx, req, new DefaultFullHttpResponse(HTTP_1_1,                BAD_REQUEST));        return;    }    // 构造握手响应返回,本机测试    WebSocketServerHandshakerFactory wsFactory = new WebSocketServerHandshakerFactory(Init.WEB_SOCKET_URL, null, false);    handshaker = wsFactory.newHandshaker(req);    if (handshaker == null) {        WebSocketServerHandshakerFactory.sendUnsupportedVersionResponse(ctx.channel());    } else {        handshaker.handshake(ctx.channel(), req);    }}private static void sendHttpResponse(ChannelHandlerContext ctx, FullHttpRequest req, FullHttpResponse res) {    // 返回应答给客户端    if (res.status().code() != 200) {        ByteBuf buf = Unpooled.copiedBuffer(res.status().toString(), CharsetUtil.UTF_8);        res.content().writeBytes(buf);        buf.release();        setContentLength(res, res.content().readableBytes());    }    // 如果是非Keep-Alive,关闭连接    ChannelFuture f = ctx.channel().writeAndFlush(res);    if (!isKeepAlive(req) || res.status().code() != 200) {        f.addListener(ChannelFutureListener.CLOSE);    }}

来源地址:https://blog.csdn.net/weixin_37948564/article/details/129502514

--结束END--

本文标题: Netty 教程 – 实现WebSocket通讯

本文链接: https://www.lsjlt.com/news/396194.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
  • Netty 教程 – 实现WebSocket通讯
    WebSocket WebSocket协议是基于TCP的一种新的网络协议,它实现了浏览器与服务器全双工(full-duplex)通信,允许服务器主动发送信息给客户端 优点及作用 Http协议的弊端: Http协议为半双工协议。(半双工:同一...
    99+
    2023-09-05
    websocket 网络 服务器
  • golang WebSocket教程:如何实现实时通信
    Golang WebSocket教程:如何实现实时通信首先,让我们来介绍一下什么是WebSocket。WebSocket是一种在Web浏览器和服务器之间进行全双工通信的协议。与HTTP协议不同,WebSocket允许服务器向客户端推送数据,...
    99+
    2023-12-17
    golang WebSocket教程:实时通信
  • Uniapp使用GoEasy实现websocket实时通讯
    Uniapp作为近来最火的移动端开发技术,一套代码,可以打包成Android/iOS app和各种平台的小程序,可谓是没有最方便只有更方便。GoEasy上架DCloud Uniapp插件市场已经有一段时间了,收到很多Uniapp开发人员的赞...
    99+
    2023-06-03
  • SpringBoot怎么实现WebSocket即时通讯
    这篇“SpringBoot怎么实现WebSocket即时通讯”文章的知识点大部分人都不太理解,所以小编给大家总结了以下内容,内容详细,步骤清晰,具有一定的借鉴价值,希望大家阅读完这篇文章能有所收获,下面我们一起来看看这篇“SpringBoo...
    99+
    2023-06-30
  • nodejs结合Socket.IO实现websocket即时通讯
    目录为什么要用 websocketSocket.io开源项目效果预览app.jsindex.html为什么要用 websocket websocket 是一种网络通信协议,一般用来进...
    99+
    2024-04-02
  • AndroidFlutter基于WebSocket实现即时通讯功能
    目录前言联系人界面构建聊天界面的实现消息界面的 MultiProvider运行效果前言 我们在前面花了很大篇幅介绍 Provider 状态管理,这是因为在 Flu...
    99+
    2024-04-02
  • 微信小程序如何使用WebSocket实现即时通讯
    使用WebSocket实现即时通讯功能,可以让用户实时收发消息,并保持连接状态。在微信小程序中,可以通过wx.connectSock...
    99+
    2024-04-03
    微信小程序 WebSocket
  • SpringBoot整合Netty实现WebSocket的示例代码
    目录一、pom.xml依赖配置二、代码2.1、NettyServer 类2.2、SocketHandler 类2.3、ChannelHandlerPool 类2.4、Applicat...
    99+
    2024-04-02
  • Python实现命令行通讯录实例教程
    1、实现目标 编写一个命令行通讯录程序,可以添加、查询、删除通讯录好友及电话 2、实现方法 创建一个类来表示一个人的信息。使用字典存储每个人的对象,名字作为键。 使用pickle模块永久地把这些对象存储...
    99+
    2022-06-04
    命令行 实例教程 通讯录
  • Netty实战入门教程之 什么是Netty
    目录一、BIO、NIO、AIO二、什么是Netty?三、为什么学习Netty?四、原生NIO存在的问题五、Netty有什么好处六、那些领域用到了Netty七、Netty模型♨️简单版...
    99+
    2024-04-02
  • SpringBoot实现WebSocket即时通讯的示例代码
    目录1、引入依赖2、WebSocketConfig 开启WebSocket3、WebSocketServer4、测试连接发送和接收消息5、在线测试地址6、测试截图1、引入依赖 <...
    99+
    2024-04-02
  • SpringBoot+WebSocket实现即时通讯的方法详解
    目录环境信息服务端实现导入依赖创建配置类创建一个注解式的端点并在其中通过配套注解声明回调方法服务端主动发送消息给客户端客户端实现Java客户端实现在前端环境(vue)中使用webso...
    99+
    2024-04-02
  • nodejs如何结合Socket.IO实现websocket即时通讯
    这篇文章给大家分享的是有关nodejs如何结合Socket.IO实现websocket即时通讯的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。为什么要用 websocketwebsocket 是一种网络通信协议,一...
    99+
    2023-06-25
  • Springboot+Netty+Websocket实现消息推送实例是怎样的
    Springboot+Netty+Websocket实现消息推送实例是怎样的,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。 前言We...
    99+
    2024-04-02
  • 基于html5和nodejs相结合实现websocket即使通讯
    最近都在学习HTML5,做canvas游戏之类的,发现HTML5中除了canvas这个强大的工具外,还有WebSocket也很值得注意。可以用来做双屏互动游戏,何为双屏互动游戏?就是通过移动端设备来控制PC...
    99+
    2022-06-04
    通讯 nodejs websocket
  • Android Flutter基于WebSocket怎么实现即时通讯功能
    这篇文章主要介绍“Android Flutter基于WebSocket怎么实现即时通讯功能”,在日常操作中,相信很多人在Android Flutter基于WebSocket怎么实现即时通讯功能问题上存在疑惑,小编查阅了各...
    99+
    2023-06-29
  • 在Asp.netcore中实现websocket通信
    今天小试了一下在Asp.net core中使用websocket,这里记录一下: 在 Startup 类的 Configure 方法中添加 WebSocket 中间件。 app.Us...
    99+
    2024-04-02
  • Node.js怎么实现WebSocket通信
    这篇文章主要讲解了“Node.js怎么实现WebSocket通信”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“Node.js怎么实现WebSocket通信”吧!node的依赖包node中实现...
    99+
    2023-07-04
  • Netty框架实现TCP/IP通信的完美过程
          项目中需要使用到TCP/IP协议完成数据的发送与接收。如果只是用以前写的简单的socket套接字方法,每次接收...
    99+
    2024-04-02
  • Netty框架实现TCP/IP通信的详细过程
    这篇文章主要介绍“Netty框架实现TCP/IP通信的详细过程”,在日常操作中,相信很多人在Netty框架实现TCP/IP通信的详细过程问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”Netty框架实现TCP/...
    99+
    2023-06-20
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作