# 利刃出鞘_Tomcat 核心原理解析(十一)-- WebSocket -- 1

2024-09-02 15:52

本文主要是介绍# 利刃出鞘_Tomcat 核心原理解析(十一)-- WebSocket -- 1,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

利刃出鞘_Tomcat 核心原理解析(十一)-- Tomcat 附加功能 WebSocket – 1

一、Tomcat专题 - WebSocket - 介绍

1、Tomcat 附加功能:websocket 介绍

1)websocket :是 HTML5 新增的协议,它的目的是在浏览器和服务器之间建立一个不受限的双向通信的通道,
比如说,服务器可以在任意时刻发送消息给浏览器。

2)为什么传统的 HTTP 协议不能做到 websocket 实现的功能?

  • 这是因为 HTTP 协议是一个请求-响应协议,请求必须先由浏览器发给服务器服务器才能响应这个请求,再把数据发送给浏览器。
    换句话说,浏览器不主动请求,服务器是没法主动发数据给浏览器的,

  • 这样一来,要在浏览器中搞一个实时聊天,或者在线多人游戏的话就没法实现了,只能借助 Elash 这些插件,

3)也有人说,HTTP 协议其实也能实现啊,比如用轮询或者 comet。

  • 轮询:是指浏览器通过 Javascript 启动一个定时器,然后以固定的间隔给服务器发请求,询问服务器有没有新消息。
    这个机制的缺点一是实时性不够,二是频繁的请求会给服务器带来极大的压力。

  • comet 本质上也是轮询,但是在没有消息的情况下,服务器先拖一段时间,等到有消息了再回复,这个机制暂时地解决了实时性问题,

但是它带来了新的问题:

以多线程模式运行的服务器会让大部分线程大部分时间都处于挂起状态,极大地浪费服务器资源。
另外,一个 HTTP 连接在长时间没有数据传输的情况下,链路上的任何一个网关都可能关闭这个连接,
而网关是我们不可控的,这就要求 comet 连接必须定期发一些 ping 数据表示连接“正常工作"。

tomcat-67.png

2、以上两种机制都治标不治本,所以,HTML5 推出了 websocket 标准,让浏览器和服务器之间可以建立无限制的全双工通信,任何一方都可以主动发消息给对方。websocket 并不是全新的协议,而是利用了 HTTP 协议来建立连接。

tomcat-68.png

3、websocket 连接是如何创建的。

1)首先,websocket连接必须由浏览器发起,因为请求协议是一个标准的HTTP请求,格式如下:

tomcat-69.png

2)该请求和普通的HTTP请求有几点不同:

  • 1.GET请求的地址不是类似 http://,而是以 ws:// 开头的地址;
  • 2.请求头 connection:upgrade 和 请求头 upgrade:websocket 表示这个连接将要被转换为 websocket 连接;
  • 3.sec-websocket-Key 是用于标识这个连接, 是一个BASE64编码的密文,要求服务端响应一个对应加密的sec-websocket-Accept头信息作为应答。
  • 4.sec-websocket-version 指定了 websocket 的协议版本;
  • 5.HTTP101 状态码表明服务端已经识别并切换为 Websocket 协议,sec-websocket-Accept 是服务端与客户端一致的秘钥计算出来的信息。

二、Tomcat专题 - WebSocket - Tomcat的支持

1、Tomcat 的 Websocket

Tomcat 的 7.0.5 版本开始支持 websocket,并且实现了 Java websocket 规范(JSR356),而在7.0.5版本之前(7.0.2之后)则采用自定义 API,即 websocketservlet 实现。

2、Java websocket 应用由一系列的 nebsocketEndpoint 组成。Endpoint 是一个 Java 对象,代表 websocket 链接的一端,对于服务端,可以视为处理具体 websocket 消息的接口,就像 servlet 之与 http 请求一样。

3、可以通过两种方式定义 Endpoint:

1)第一种是编程式,即继承类 javax.websocket.Endpoint 并实现其方法。

2)第二种是注解式,即定义一个POJO,并添加 @serverEndpoint 相关注解。

4、Endpoint 实例在 websocket 握手时创建,并在客户端与服务端链接过程中有效,最后在链接关闭时结束,在 Endpoint 接口中明确定义了与其生命周期相关的方法, 规范实现者确保生命周期的各个阶段调用实例的相关方法。生命周期方法如下:

方法含义描述注解
onOpen当开启一个新的会话时调用,该方法是客户端与服务端握手成功后调用的方法。@onopen
onClose当会话关闭时调用。@onClose
onError当连接过程中异常时调用。@onError

5、编程式 和 注解式 接收和发送消息。

  • 编程式通过为 session 添加 Messagexandler 消息处理器来接收消息。
  • 采用注解方式定义 Endpoint 时,可以通过 @onMessage 注解指定接收消息的方法。发送消息则由 RemoteEndpoint 完成,其实例由 session 维护。
  • 根据使用情况, 可以通过 session.getBasicRemote 获取同步消息发送的实例,然后调用其 sendxxx() 方法就可以发送消息,可以通过 session.getAsyncRemote 获取异步消息发送实例。

6、…\apache-tomcat-8.5.42-src\java\javax\websocket\Endpoint.java 类,源码:


package javax.websocket;public abstract class Endpoint {public abstract void onOpen(Session session, EndpointConfig config);public void onClose(Session session, CloseReason closeReason) {// NO-OP by default}public void onError(Session session, Throwable throwable) {// NO-OP by default}
}

三、 Tomcat专题 - WebSocket - 案例 - 需求及流程分析

1、WebSocket DEMO 案例需求:通过 websocket 实现一个简易的聊天室功能。

tomcat-70.png

2、WebSocket DEMO 案例流程

1)登录聊天室

2)登录后,进入聊天界面,进行聊天。

3)用户1 聊天界面,用户2 聊天界面。

4)好友列表、单独聊天模式与广播模式。

   tomcat-71.png

3、WebSocket DEMO 案例 实现流程

tomcat-72.png

4、消息格式

客户端 --> 服务端: {“fromName”:“Deng”,“toName”:“HEIMA”,“content”:“约会呀”}

服务端 --> 客户端:

1)如果 type 为 user,则说明返回的是用户列表

{“data” : “HEIMA, Deng, ITCAST” ,“toName” :“” ,“fromName” :“”,“type” :“user” }

2)如果 type 为 message,则说明返回的是消息内容

{“data” : “你好” ,“toName” : “HE IMA” , " fromName" : “Deng” ,“type” : “message” }

四、Tomcat专题 - WebSocket - 案例 - 准备工作

1、打开 idea 创建 名为 dzs168_chat_room 的 Web Application 项目

--> idea --> File --> New --> Project --> Java Project SDK: ( 1.8(java version "1.8.0_131" ) --> Java EE : 勾选 ( Web Application )--> Next --> Project Name: ( dzs168_chat_room )Project Location: ( ...\dzs168_chat_room\ )	--> Finish	

2、在项目 dzs168_chat_room 中,导入项目依赖( dzs168_chat_room/web/lib/ ),Add as Library…

fastjson-1.2.5.jar
tomcat-websocket.jar
websocket-api.jar

3、在项目 dzs168_chat_room 中,导入静态资源文件。

dzs168_chat_room/web/css/
dzs168_chat_room/web/img/
dzs168_chat_room/web/js/
dzs168_chat_room/web/chat.jsp
dzs168_chat_room/web/login.jsp

4、在项目 dzs168_chat_room 中, Web 应用配置欢迎页面为 login.jsp

(project_tomcat\dzs168_chat_room\web\WEB-INF\web.xml)


<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd"version="3.1"><welcome-file-list><welcome-file>login.jsp</welcome-file></welcome-file-list></web-app>
<!-- project_tomcat\dzs168_chat_room\web\WEB-INF\web.xml -->

5、配置 dzs168_chat_room 应用,进行测试。


idea ---> Run/Debug Configurations 
---> 点击 应用 Tomcat 8.5.47
---> Deployment 删除已经存在的应用。---> 点击 + 添加新应用 Artifact... ,选择我们的项目 dzs168_chat_room.war exploded---> Application context: ( / )---> Apply ---> Server---> On'Update'action:  ( Update classes and resources )---> On frame deactivation: ( Update classes and resources )---> Apply 
---> OK

6、运行 tomcat 服务器,自动打开欢迎页面,localhost:8080

在这里插入图片描述

上一节关联链接请点击
利刃出鞘_Tomcat 核心原理解析(十)-- Tomcat 性能调优–2

这篇关于# 利刃出鞘_Tomcat 核心原理解析(十一)-- WebSocket -- 1的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1130401

相关文章

Java中流式并行操作parallelStream的原理和使用方法

《Java中流式并行操作parallelStream的原理和使用方法》本文详细介绍了Java中的并行流(parallelStream)的原理、正确使用方法以及在实际业务中的应用案例,并指出在使用并行流... 目录Java中流式并行操作parallelStream0. 问题的产生1. 什么是parallelS

Java中Redisson 的原理深度解析

《Java中Redisson的原理深度解析》Redisson是一个高性能的Redis客户端,它通过将Redis数据结构映射为Java对象和分布式对象,实现了在Java应用中方便地使用Redis,本文... 目录前言一、核心设计理念二、核心架构与通信层1. 基于 Netty 的异步非阻塞通信2. 编解码器三、

Java HashMap的底层实现原理深度解析

《JavaHashMap的底层实现原理深度解析》HashMap基于数组+链表+红黑树结构,通过哈希算法和扩容机制优化性能,负载因子与树化阈值平衡效率,是Java开发必备的高效数据结构,本文给大家介绍... 目录一、概述:HashMap的宏观结构二、核心数据结构解析1. 数组(桶数组)2. 链表节点(Node

Java 虚拟线程的创建与使用深度解析

《Java虚拟线程的创建与使用深度解析》虚拟线程是Java19中以预览特性形式引入,Java21起正式发布的轻量级线程,本文给大家介绍Java虚拟线程的创建与使用,感兴趣的朋友一起看看吧... 目录一、虚拟线程简介1.1 什么是虚拟线程?1.2 为什么需要虚拟线程?二、虚拟线程与平台线程对比代码对比示例:三

一文解析C#中的StringSplitOptions枚举

《一文解析C#中的StringSplitOptions枚举》StringSplitOptions是C#中的一个枚举类型,用于控制string.Split()方法分割字符串时的行为,核心作用是处理分割后... 目录C#的StringSplitOptions枚举1.StringSplitOptions枚举的常用

Python函数作用域与闭包举例深度解析

《Python函数作用域与闭包举例深度解析》Python函数的作用域规则和闭包是编程中的关键概念,它们决定了变量的访问和生命周期,:本文主要介绍Python函数作用域与闭包的相关资料,文中通过代码... 目录1. 基础作用域访问示例1:访问全局变量示例2:访问外层函数变量2. 闭包基础示例3:简单闭包示例4

MyBatis延迟加载与多级缓存全解析

《MyBatis延迟加载与多级缓存全解析》文章介绍MyBatis的延迟加载与多级缓存机制,延迟加载按需加载关联数据提升性能,一级缓存会话级默认开启,二级缓存工厂级支持跨会话共享,增删改操作会清空对应缓... 目录MyBATis延迟加载策略一对多示例一对多示例MyBatis框架的缓存一级缓存二级缓存MyBat

Redis中Hash从使用过程到原理说明

《Redis中Hash从使用过程到原理说明》RedisHash结构用于存储字段-值对,适合对象数据,支持HSET、HGET等命令,采用ziplist或hashtable编码,通过渐进式rehash优化... 目录一、开篇:Hash就像超市的货架二、Hash的基本使用1. 常用命令示例2. Java操作示例三

Redis中Set结构使用过程与原理说明

《Redis中Set结构使用过程与原理说明》本文解析了RedisSet数据结构,涵盖其基本操作(如添加、查找)、集合运算(交并差)、底层实现(intset与hashtable自动切换机制)、典型应用场... 目录开篇:从购物车到Redis Set一、Redis Set的基本操作1.1 编程常用命令1.2 集

Redis中的有序集合zset从使用到原理分析

《Redis中的有序集合zset从使用到原理分析》Redis有序集合(zset)是字符串与分值的有序映射,通过跳跃表和哈希表结合实现高效有序性管理,适用于排行榜、延迟队列等场景,其时间复杂度低,内存占... 目录开篇:排行榜背后的秘密一、zset的基本使用1.1 常用命令1.2 Java客户端示例二、zse