Websocket详细介绍

news2025/1/9 15:06:40

需求背景

在某个资产平台，在不了解需求的情况下，我突然接到了一个任务，让我做某个页面窗口的即时通讯，想到了用websocket技术，我从来没用过，被迫接受了这个任务，我带着浓烈的兴趣，就去研究了一下，网上资料那么多，我们必须找到适合自己的方案，我们开发的时候一定要基于现有框架的基础上去做扩展，不然会引发很多问题，比如：运行不稳定、项目无法启动等，废话不多说，直接上代码

WebScoekt介绍

WebSocket是一种在单个TCP连接上进行全双工通信的协议。WebSocket通信协议于2011年被IETF定为标准RFC 6455，并由RFC7936补充规范。WebSocket API也被W3C定为标准。
WebSocket使得客户端和服务器之间的数据交换变得更加简单，允许服务端主动向客户端推送数据。在WebSocket API中，浏览器和服务器只需要完成一次握手，两者之间就直接可以创建持久性的连接，并进行双向数据传输。
在这里插入图片描述

特点

  • 较少的控制开销。在连接创建后，服务器和客户端之间交换数据时，用于协议控制的数据包头部相对较小。在不包含扩展的情况下，对于服务器到客户端的内容，此头部大小只有2至10字节（和数据包长度有关）；对于客户端到服务器的内容，此头部还需要加上额外的4字节的掩码。相对于HTTP请求每次都要携带完整的头部，此项开销显著减少了。
  • 更强的实时性。由于协议是全双工的，所以服务器可以随时主动给客户端下发数据。相对于HTTP请求需要等待客户端发起请求服务端才能响应，延迟明显更少；即使是和Comet等类似的长轮询比较，其也能在短时间内更多次地传递数据。
    保持连接状态。与HTTP不同的是，Websocket需要先创建连接，这就使得其成为一种有状态的协议，之后通信时可以省略部分状态信息。而HTTP请求可能需要在每个请求都携带状态信息（如身份认证等）。
  • 更好的二进制支持。Websocket定义了二进制帧，相对HTTP，可以更轻松地处理二进制内容。
    可以支持扩展。Websocket定义了扩展，用户可以扩展协议、实现部分自定义的子协议。如部分浏览器支持压缩等。
  • 更好的压缩效果。相对于HTTP压缩，Websocket在适当的扩展支持下，可以沿用之前内容的上下文，在传递类似的数据时，可以显著地提高压缩率。

解决方案介绍


PS：基于websocket的特点，我们打算放弃Ajax轮询，因为当客户端过多的时候，会导致消息收发有延迟、服务器压力增大。

API介绍


思路解析

首先，我们既然要发送消息，客户端和客户端是无法建立连接的，我们可以这样做，我们搭建服务端，所有的客户端都在服务端注册会话，我们把消息发送给服务端，然后由服务端转发给其他客户端，这样就可以和其他用户通讯了。

示例代码

服务端配置

package unicom.assetMarket.websocket.config;

import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
import unicom.assetMarket.websocket.handler.MyMessageHandler;
import unicom.assetMarket.websocket.interceptor.WebSocketInterceptor;

/**
 * @Author 庞国庆
 * @Date 2023/02/15/15:36
 * @Description
 */
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry webSocketHandlerRegistry) {
        webSocketHandlerRegistry.addHandler(new MyMessageHandler(), "/accept")
            .addInterceptors(new WebSocketInterceptor())
            //允许跨域
            .setAllowedOrigins("*");
        webSocketHandlerRegistry.addHandler(new MyMessageHandler(),"/http/accept")
            .addInterceptors(new WebSocketInterceptor())
            .setAllowedOrigins("*").withSockJS();
    }

}

Interceptor

package unicom.assetMarket.websocket.interceptor;

import lombok.extern.slf4j.Slf4j;
import org.springframework.http.server.ServerHttpRequest;
import org.springframework.http.server.ServerHttpResponse;
import org.springframework.http.server.ServletServerHttpRequest;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.server.support.HttpSessionHandshakeInterceptor;
import java.util.Map;

/**
 * @Author 庞国庆
 * @Date 2023/02/15/15:52
 * @Description
 */
@Slf4j
public class WebSocketInterceptor  extends HttpSessionHandshakeInterceptor {

    @Override
    public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map<String, Object> attributes) throws Exception {
        if (request instanceof ServletServerHttpRequest) {
            ServletServerHttpRequest request1 = (ServletServerHttpRequest) request;
            String userId = request1.getServletRequest().getParameter("userId");
            attributes.put("currentUser", userId);
            log.info("用户{}正在尝试与服务端建立链接········", userId);
        }
        return super.beforeHandshake(request, response, wsHandler, attributes);
    }

    @Override
    public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Exception ex) {
        super.afterHandshake(request, response, wsHandler, ex);
    }
}

Handler

package unicom.assetMarket.websocket.handler;

import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.*;
import org.springframework.web.socket.handler.TextWebSocketHandler;
import unicom.assetMarket.assetChat.service.CamsMarketChatMessageService;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * @Author 庞国庆
 * @Date 2023/02/15/15:52
 * @Description
 */
@Slf4j
@Component
public class MyMessageHandler extends TextWebSocketHandler {

	//存储所有客户端的会话信息（线程安全）
    private final static Map<String, WebSocketSession> sessions = new ConcurrentHashMap<>();

    @Autowired(required = false)
    private CamsMarketChatMessageService service;

    @Override
    public void afterConnectionEstablished(WebSocketSession webSocketSession) throws Exception {
        String userId = this.getUserId(webSocketSession);
        if (StringUtils.isNotBlank(userId)) {
            sessions.put(userId, webSocketSession);
            log.info("用户{}已经建立链接", userId);
        }
    }

    @Override
    public void handleMessage(WebSocketSession webSocketSession, WebSocketMessage<?> webSocketMessage) throws Exception {
        String message = webSocketMessage.toString();
        String userId = this.getUserId(webSocketSession);
        log.info("服务器收到用户{}发送的消息:{}", userId, message);
        //webSocketSession.sendMessage(webSocketMessage);
        if (StringUtils.isNotBlank(message)) {
            //保存用户发送的消息数据
            service.saveData(message);
            //发送消息给指定用户
            doMessage(message);
        }
    }

    @Override
    public void handleTransportError(WebSocketSession webSocketSession, Throwable throwable) throws Exception {
        WebSocketMessage message = new TextMessage("发送异常：" + throwable.getMessage());
        //webSocketSession.sendMessage(message);
    }

    @Override
    public void afterConnectionClosed(WebSocketSession webSocketSession, CloseStatus closeStatus) throws Exception {
        String userId = this.getUserId(webSocketSession);
        if (StringUtils.isNotBlank(userId)) {
            sessions.remove(userId);
            log.info("用户{}已经关闭会话", userId);
        } else {
            log.error("没有找到用户{}的会话", userId);
        }
    }

    @Override
    public boolean supportsPartialMessages() {
        return false;
    }

    /**
     * 根据会话查找已经注册的用户id
     *
     * @param session
     * @return
     */
    private String getUserId(WebSocketSession session) {
        String userId = (String) session.getAttributes().get("currentUser");
        return userId;
    }

    /**
     * 发送消息给指定用户
     *
     * @param userId
     * @param contents
     */
    public void sendMessageUser(String userId, String contents) throws Exception {
        WebSocketSession session = sessions.get(userId);
        if (session != null && session.isOpen()) {
            WebSocketMessage message = new TextMessage(contents);
            session.sendMessage(message);
        }
    }

    /**
     * 接收用户消息，转发给指定用户
     * @param msg
     * @throws Exception
     */
    public void doMessage(String msg) throws Exception {
        JSONObject jsonObject = JSONObject.parseObject(msg);
        String sendStaffId = jsonObject.getString("sendStaffId");
        String reciveStaffId = jsonObject.getString("reciveStaffId");
        String message = jsonObject.getString("message");
        //替换敏感字
        message = service.replaceSomething(message);
        this.sendMessageUser(reciveStaffId,message);
    }

}

JS代码

$(function() {
    connectWebSocket();
});

/**
 * 和服务器建立链接
 */
function connectWebSocket() {
    var userId = $("#sendStaffId").val();
    var host = window.location.host;
    if ('WebSocket' in window) {
        if (userId) {
            client = new WebSocket( "ws://"+ host + "/frm/accept?userId=" + userId,null);
            client.onopen = function (event) {
                console.log("连接成功");
            }
            client.onmessage = function (event) {
                console.log("接收到服务端的内容为：" + event.data);
            }
            client.onerror = function (event) {
                console.log("连接失败");
            }
            client.onclose = function (event) {
                console.log("与服务器断开连接");
            }
        }
    }
}

PS：这里我遇到了1个坑，就是在连接服务端的时候老是连接不上，我们在配置的代码中指定的匹配URL为 /accept，但是我发现就是连不上，后来找了很多资料，原来是忘了加个url，这个url就是我们在web.xml中配置的DispatcherServlet的拦截url，如下：
在这里插入图片描述
运行效果如下：
在这里插入图片描述
PS：页面还没写完，暂时先写到这里～

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/352436.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

MinIO

MinIO

概述MinIO 是一个基于Apache License v2.0开源协议的对象存储服务。它兼容亚马逊S3云存储服务接口&#xff0c;非常适合于存储大容量非结构化的数据&#xff0c;例如图片、视频、日志文件、备份数据和容器/虚拟机镜像等&#xff0c;而一个对象文件可以是任意大小&#xff0c;从…
阅读更多...
Redis学习【7】之发布_订阅命令和事务

Redis学习【7】之发布_订阅命令和事务

文章目录一 发布/订阅命令1.1 消息系统1.2 subscribe1.3 psubscribe1.4 publish1.5 unsubscribe1.6 punsubscribe1.7 pubsub1.7.1 pubsub channels1.7.2 pubsub numsub1.7.3 pubsub numpat二 Redis 事务2.1 Redis 事务特性Redis 事务实现2.1.1 三个命令2.1.2 基本使用2.2. Redi…
阅读更多...
家用洗地机哪款质量好?洗地机排行榜

家用洗地机哪款质量好?洗地机排行榜

伴随着人们消费水平和生活品质的提升&#xff0c;人们对家庭中的需求也随之提高&#xff0c;洗地机凭借着吸拖洗为一体的功能深受大众喜爱&#xff0c;但是市面上洗地机产品越来越多&#xff0c;清洁效果也参差不齐&#xff0c;到底哪款洗地机质量好呢&#xff0c;跟随笔者脚步…
阅读更多...
FILE文件操作

FILE文件操作

文件指针 每个被使用的文件都在内存中开辟了一个相应的文件信息区&#xff0c;用来存放文件的相关信息&#xff08;如文件的名 字&#xff0c;文件状态及文件当前的位置等&#xff09;。这些信息是保存在一个结构体变量中的。该结构体类型是有系统 声明的&#xff0c;取名FILE…
阅读更多...
ecaozzz

ecaozzz

2. 图形报表ECharts 2.1 ECharts简介 ECharts缩写来自Enterprise Charts&#xff0c;商业级数据图表&#xff0c;是百度的一个开源的使用JavaScript实现的数据可视化工具&#xff0c;可以流畅的运行在 PC 和移动设备上&#xff0c;兼容当前绝大部分浏览器&#xff08;IE8/9/10/…
阅读更多...
面试完阿里，字节，腾讯的测试岗，复盘以及面试总结

面试完阿里，字节，腾讯的测试岗，复盘以及面试总结

前段时间由于某些原因辞职了&#xff0c;最近一直在面试。面试这段时间&#xff0c;经历过不同业务类型的公司&#xff08;电商、酒店出行、金融、新能源、银行&#xff09;&#xff0c;也遇到了很多不同类型的面试官。 参加完三家大厂的面试聊聊我对面试的一些看法&#xff0…
阅读更多...
AWS攻略——子网

AWS攻略——子网

文章目录分配子网给Public子网分配互联网网关创建互联网网关附加到VPC给Public子网创建路由表关联子网打通Public子网和互联网网关创建Public子网下的EC2进行测试配置Private子网路由给Private子网创建路由表附加在Private子网创建Private子网下的EC2进行测试创建实例在跳板机上…
阅读更多...
Mybatis 之useGeneratedKeys注意点

Mybatis 之useGeneratedKeys注意点

一.例子 Order.javapublic class Order {private Long id;private String serial; }orderMapper.xml<?xml version"1.0" encoding"UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org/DTD Mapper 3.0" "http://mybatis.org/dtd…
阅读更多...
java学习--多线程

java学习--多线程

多线程 了解多线程 ​ 多线程是指从软件或者硬件上实现多个线程并发执行的技术。 ​ 具有多线程能力的计算机因有硬件支持而能够在同一时间执行多个线程&#xff0c;提升性能。 并发和并行 并行&#xff1a;在同一时刻&#xff0c;有多个指令在CPU上同时执行并发&#xff1…
阅读更多...
20230217使AIO-3399J开发板上跑通Android11系统

20230217使AIO-3399J开发板上跑通Android11系统

20230217使AIO-3399J开发板上跑通Android11系统 2023/2/17 15:45 1、解压缩SDK&#xff1a;rk3399-android-11-r20211216.tar.xzrootrootrootroot-X99-Turbo:~$ tar xvf rk3399-android-11-r20211216.tar.xz 2、编译U-boot&#xff1a; rootrootrootroot-X99-Turbo:~/rk3399-a…
阅读更多...
没有接口文档的怎样进行接口测试

没有接口文档的怎样进行接口测试

前言&#xff1a; 在进行接口测试之前&#xff0c;一般开发会提供接口文档&#xff0c;给出一些接口参数和必要熟悉&#xff0c;便于我们编写接口脚本。但如果没有提供接口开发文档的请求下&#xff0c;我们该如何编写接口测试脚本呢&#xff1f;在编写测试脚本前要做哪些必要…
阅读更多...
一台电脑安装26个操作系统（windows,macos，linux）

一台电脑安装26个操作系统（windows,macos，linux）

首先看看安装了哪些操作系统1-4: windows系统 四个5.Ubuntu6.deepin7.UOS家庭版8.fydeOS9.macOS10.银河麒麟11.红旗OS12.openSUSE Leap13.openAnolis14.openEuler(未安装桌面UI)15.中标麒麟&#xff08;NeoKylin&#xff09;16.centos17.debian Edu18.fedora19.oraclelinux20.R…
阅读更多...
CCNP350-401学习笔记（1-50题）

CCNP350-401学习笔记（1-50题）

1、Which function does a fabric edge node perform in an SD-Access deployment?A. Connects endpoints to the fabric and forwards their traffic. B. Encapsulates end-user data traffic into LISP. C. Connects the SD-Access fabric to another fabric or external La…
阅读更多...
YOLOv5：GitHub两万八Star项目

YOLOv5：GitHub两万八Star项目

来源&#xff1a;投稿 作者&#xff1a;王同学 编辑&#xff1a;学姐 Yolov5详解 官方源码仓库&#xff1a;https://github.com/ultralytics/yolov5 相关论文&#xff1a;未发表&#xff08;改进点都被你们抢先发了&#xff09; 0 前言 截止到2022年7月&#xff0c;Yolov5项…
阅读更多...
docker目录迁移流程

docker目录迁移流程

概述 在安装测试最新版本的HOMER7的过程中&#xff0c;docker作为基础工具碰到一些问题&#xff0c;针对问题进行总结。 docker的默认工作目录在/var目录&#xff0c;而在我们的环境中&#xff0c;/var目录空间预留不足&#xff0c;随着docker的运行&#xff0c;/var目录空间…
阅读更多...
WiFi网络带宽、流量监控管理

WiFi网络带宽、流量监控管理

当您的组织拥有越来越多的有线和无线设备时&#xff0c;有必要在预算、性能和安全性之间取得准确的平衡。尽管无线设备可以为用户提供灵活性&#xff0c;但鉴于其动态性质&#xff0c;发现和管理这些设备可能极具挑战性。 为用户提供功能性无线网络性能&#xff0c;同时确保没…
阅读更多...
Spire.Office 8.2.2 for NET 开年之喜

Spire.Office 8.2.2 for NET 开年之喜

Spire.Office for .NET对文档的操作包括打开&#xff0c;创建&#xff0c;修改&#xff0c;转换&#xff0c;打印&#xff0c;浏览 Word、Excel、PowerPoint 和 PDF 文档&#xff0c;以及将数据从数据源导出为常用的文档格式&#xff0c;如&#xff1a;Word&#xff0c;Excel&a…
阅读更多...
每天10个前端小知识 【Day 16】

每天10个前端小知识 【Day 16】

&#x1f469; 个人主页&#xff1a;不爱吃糖的程序媛 &#x1f64b;‍♂️ 作者简介&#xff1a;前端领域新星创作者、CSDN内容合伙人&#xff0c;专注于前端各领域技术&#xff0c;成长的路上共同学习共同进步&#xff0c;一起加油呀&#xff01; ✨系列专栏&#xff1a;前端…
阅读更多...
【老王读Spring Transaction-6】spring-tx与DataSource连接池整合的原理

【老王读Spring Transaction-6】spring-tx与DataSource连接池整合的原理

06spring-tx与DataSource连接池的原理前言Spring 版本正文事物连接: Spring-managed transactional Connectionsspring-tx 与 DataSource 的整合SpringBoot 默认使用的 DataSource 连接池是 Hikari事物连接的关闭/释放: 并不是真正的关闭小结前言 javax.sql.DataSource 是 jav…
阅读更多...
2月，还是不要跳槽

2月，还是不要跳槽

新年已经过去&#xff0c;马上就到金三银四跳槽季了&#xff0c;一些不满现状&#xff0c;被外界的“高薪”“好福利”吸引的人&#xff0c;一般就在这时候毅然决然地跳槽了。 在此展示一套学习笔记 / 面试手册&#xff0c;年后跳槽的朋友可以好好刷一刷&#xff0c;还是挺有必…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023