WebSocket的简单实现

WebSocket协议是基于TCP的一种新的网络协议。浏览器通信通常是基于HTTP 协议，为什么还需要另一个协议？因为http只能由客户端发起，不能由服务端发起。

而WebSocket 浏览器和服务器只需要完成一次握手，两者之间就直接可以创建持久性的连接，并进行双向数据传输。

▲图源网上

WebSocket规范

WebSocket 协议本质上是一个基于 TCP 的协议。为了建立一个 WebSocket 连接，客户端浏览器首先要向服务器发起一个 HTTP 请求，这个请求和通常的 HTTP 请求不同，包含了一些附加头信息，附加信息如图所示

▲图源网上

连接过程（以js（客户端）和java（服务器端）为例）

1. WebSocket 首先会发出Handshake（握手请求），对应js代码和Java代码里的onopen方法。

2. 客户端发送至服务端

js：ws.send（ String msg） ps：入参可以是字符串或者json字符串java：onMessage(String message）message为客户端传来的信息

3. 服务端发送到客户端

java：sendUser（ String msg） js：ws.onmessage

4.断开连接onclose（ CloseReason reason）

CloseReason.CloseCode ( WebSocket关闭连接的状态码，类似http的404)

js部分：

var ws = new WebSocket("ws://server_ip//websocket")ws.onopen = function(evt){    console.log("Connection open ...");    ws.send("Hello WebSockets!");};    ws.onmessage = function(evt){    console.log("Received Message:" + evt.data);ws.close();};ws.onclose = function(evt){    console.log("Connection closed.");}

java部分（javax实现）：

ps： session 用来唯一标识连接对象

使用注解@ServerEndpoint

@ServerEndpoint(value = "/websocket", configurator = GetHttpSessionConfigurator.class)public class WebSocketEndpoint { private     static Logger logger =LoggerFactory.getLogger(WebSocketEndpoint.class);    // 保存所有的用户session    private static Map<String, Session> SESSION_MAP = new Hashtable<String, Session>();    @OnOpen    public void onOpen(Session session, EndpointConfig config) throws IOException {        logger.info("【WebSocket原生】用户{}连接", session.getId());    HttpSession httpSession = (HttpSession) config.getUserProperties().get(HttpSession.class.getName());    httpSession.setAttribute("scoketSessionId", session.getId()); logger.info("【WebSocket原生】httpSessionId:{},sessionId:{}",    httpSession.getId(),    httpSession.getAttribute("scoketSessionId")); SESSION_MAP.put(session.getId(), session);    // 发送sessionId给前端    Msg4Ws<String> msg4Ws = new Msg4Ws<String>(10000, "ws的sessionId", session.getId());    String message = new ObjectMapper().writeValueAsString(msg4Ws); // 转为json    send2User(session, message);    }@OnMessagepublic void onMessage(Session session, String message) { logger.info("【WebSocket原生】收到消息：" + message); String resultMsg = message + " received at server"; logger.info("【WebSocket原生】返回信息：" + resultMsg); try {    send2User(session, resultMsg);    } catch (IOException e) {    @OnError    public void onError(Throwable t){System.err.println("【WebSockt原生】出错了");t.printStackTrace();    }    @OnClose    public void onClose(Session session,CloseReason reason){logger.info("用户{}"        【WebSockt原生】退出链接："+session.getId());        SESSION_MAP.remove(session.getId());    }/** * 向指定用户发送信息 *  * @param session  *  * @param msg  * @throws IOException  **/     {        SESSION_MAP.get(sessionId).getBasicRemote().sendText(msg);    } }

参考文献

javax websocket：（服务端实现api文档）https://tomcat.apache.org/tomcat-8.0-doc/websocketapi /javax/websocket/package-summary.html

js websocket：（客户端api文档）

https://developer.mozilla.org/zh-CN/docs/Web/API/WebSocket

rfc6455 （websocket协议规范）：https://datatracker.ietf.org/doc/rfc6455/ 产品介绍

WebSocket的简单实现相关推荐

websocket 学习--简单使用，nodejs搭建websocket服务器，到模拟股票，到实现聊天室
websocket简介: WebSocket协议是 HTML5 开始提供的一种基于TCP的一种新的全双工通讯的网络通讯协议.它允许服务器主动发送信息给客户端. 和http协议的不同?? HTTP 协议 ...
SpringBoot +WebSocket实现简单聊天室功能实例
SpringBoot +WebSocket实现简单聊天室功能实例) 一.代码来源二.依赖下载三.数据库准备(sql) 数据库建表并插入sql 四.resources文件配置 application ...
SpringBoot入门建站全系列（二十七）WebSocket做简单的聊天室
SpringBoot入门建站全系列(二十七)WebSocket做简单的聊天室一.概述 WebSocket 是一种网络通信协议.RFC6455 定义了它的通信标准. WebSocket 是 HTML5 ...
基于vert.x与webSocket的简单聊天系统
基于vert.x与webSocket的简单聊天系统使用vert.x和webSocket的简单聊天实现主要的verticle package com.zhku.analysis.service; / ...
WebSocket实现简单的web聊天室
WebSocket实现简单的web聊天室 1.需要Tomcat7.0所以服务器 2.需要JDK7.0 3.手工加入Tomcat7.0中lib目录下的一下三个包catalina.jar.tomcat-c ...
websocket 本地可以服务器断开 springboot linux_SpringBoot+WebSocket实现简单的数据推送...
问题背景为什么要要用websocket呢?websocket相对于传统http协议有什么优势呢? http协议有一个缺陷,就是通信只能由客户端发起,服务器返回数据,不能做到服务器主动向客户端推送.这 ...
基于websocket的简单通信
首次接触websocket通信协议,不足之处希望指出一起进步. 简述 websocket是基于tcp协议的一种网络通信协议,分为客户端和服务端,可以实现客户端与服务端的双向通信. 与tcp的不同之处是 ...
websocket(二)--简单实现网页版群聊
websocket可以实现服务端的消息推送,而不必在客户端轮询,大大的节省的资源,对于实时通讯来说简直是个大喜讯. 在上一篇文章中介绍了协议握手,这篇文章将通过实现简单的群聊来帮助进一步了解webso ...
websocket python unity_Unity中Websocket的简单使用
首先我们需要一个websocket服务器,之前的博文中有做 Tomcat架设简单Websocket服务器用的时候打开就行了,先不管它 Unity中新建场景建UI(UGUI) 有一个连接按钮Butt ...
js 链接websocket马上断开_SpringBoot+WebSocket实现简单的数据推送
问题背景为什么要要用websocket呢?websocket相对于传统http协议有什么优势呢? http协议有一个缺陷,就是通信只能由客户端发起,服务器返回数据,不能做到服务器主动向客户端推送.这 ...

WebSocket的简单实现

WebSocket的简单实现相关推荐

最新文章

热门文章