websocket介绍并模拟股票数据推流
Websockt概念
Websockt是一种网络通信协议，允许客户端和服务器双向通信。最大的特点就是允许服务器主动推送数据给客户端，比如股票数据在客户端实时更新，就能利用websocket。
Websockt和http协议一样，并不是设置在linux内核中，而是通过用户空间的应用程序来实现和处理。
http网址的格式：协议://域名/路径。如：Example Domain。
websocket网址的格式：ws://域名/路径 或 wss://域名/路径。如：ws://www.example.com/chat。
Websocket与http的关联
1、基于HTTP协议的握手：WebSocket协议的握手过程是基于HTTP协议的。在建立WebSocket连接之前，客户端和服务器之间会进行一次HTTP握手，这是为了协商和确认使用WebSocket协议进行通信。
2、共享同一端口：WebSocket协议使用HTTP协议的80端口（或443端口，用于加密连接），这意味着WebSocket连接可以通过与HTTP服务器共享同一端口来进行通信。这样可以避免在网络上开启新的端口，降低了网络配置的复杂性。
Websocket与http对比
优点
实时性：WebSocket支持双向通信，服务器可以主动推送数据给客户端，实现实时更新和推送功能。
较低的延迟：WebSocket建立一次连接后，可以保持长时间的连接状态，避免了每次请求都要建立新的连接的开销，从而减少了延迟。
较小的数据开销：WebSocket使用二进制消息传输，相对于HTTP的文本数据传输，可以减少数据包的大小，降低网络传输开销。
更少的网络流量：由于WebSocket采用长连接，不需要频繁的请求和响应，可以减少网络流量和负载。
缺点
兼容性问题：WebSocket是HTML5的一部分，相对于HTTP，对于一些低版本的浏览器和服务器来说，支持程度可能较低。
需要服务器端支持：WebSocket需要服务器端支持实现双向通信，而有些服务器可能没有提供WebSocket的支持。
协议复杂性：相对于HTTP来说，WebSocket的协议相对复杂一些，实现和维护的成本可能较高。
Websocket的握手
与http握手的区别
下图是websocket的握手报文案例。与http握手报文的核心区别是两处红框部分是否是Upgrade和websocket。
Websocket的握手流程
1.浏览器发送握手报文。
2.服务器解析出sec-websocket-key
3.sec-websocket-key与GUID字符串联合成新字符串。
GUID是一组固定的字符串，在websocket的官方文档里有规定。
4.用哈希算法对新字符串进行哈希
5.对哈希值转为base64格式，生成value
6.把value配握手返回报文中进行返回
仿股票数据推流
股票数据的推流的特点：客户端连接上服务器之后，服务器就会定时往客户端发送更新过的股票数据。
下图实现了一个简易版的服务器，能定时给连接上的客户端推送数据，当客户端尝试发送数据的时候会断开连接。
import asyncio
import websockets
async def push_price(websocket, path):
while True:
price = "price = 299.9"
await websocket.send(price)
try:
# 接收消息
message = await asyncio.wait_for(websocket.recv(), timeout=1)
# 如果接收到消息，立即断开连接
if message:
await websocket.close()
break
except:
pass
start_server = websockets.serve(push_price, None, 8765) //返回一个协程对象
//该对象的任务函数是push_price
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()客户端
<html>
<head>
<script>
let ws;
function doConnect(addr) {
ws = new WebSocket("ws://" + addr);
ws.onopen = () => {
document.getElementById("log").value += (" Connection opened\n");
};
ws.onmessage = (event) => {
document.getElementById("log").value += (" Receive: " + event.data + "\n\n"); // JSON.stringify()
};
ws.onclose = () => {
document.getElementById("log").value += (" Connection closed\n");
};
}
document.addEventListener("DOMContentLoaded", (event) => {
document.getElementById("btn_connect").onclick = () => {
let server_addr = document.getElementById("server_addr").value;
doConnect(server_addr);
};
document.getElementById("btn_send").onclick = () => {
let msg = document.getElementById("message").value;
ws.send(msg);
document.getElementById("log").value += (" Send: " + msg + "\n");
};
});
</script>
</head>
<body>
<div id="header">
<h1 align="left">WebSocket Client</h1>
Server: <input id="server_addr" type="text" value="192.168.232.132:8888">
<input id="btn_connect" type="button" value="Connect!"><br/><br/>
Message: <input id="message" type="text" value="">
<input id="btn_send" type="button" value="Send"><br/><br/>
<textarea cols="250" id="log" rows="50"></textarea>
</div>
</body>
</html>
~
~
~ 运行结果
相关文章：
Rust XTask 模式介绍与应用
XTask（扩展任务）是一种在Rust项目中定义和执行自定义构建任务的方式。它通过创建一个独立的Rust库或二进制项目来封装这些任务，利用Rust语言的强类型、安全性和跨平台能力，使得构建流程更加健壮、可读和可维护。
ModuleNotFoundError: No module named ‘qcloud_cos‘
是腾讯云提供的一个Python SDK，用于与腾讯云对象存储（COS）服务进行交互。使用pip安装qcloud_cos报以下错误。这个错误表示Python无法找到名为。
SpringBoot系列教程之Bean之指定初始化顺序的若干姿势
之前介绍了@Order注解的常见错误理解，它并不能指定 bean 的加载顺序，那么问题来了，如果我需要指定 bean 的加载顺序，那应该怎么办呢？本文将介绍几种可行的方式来控制 bean 之间的加载顺序。
在Java中使用WebSocket
WebSocket是一种协议，用于在Web应用程序和服务器之间建立实时、双向的通信连接。它通过一个单一的TCP连接提供了持久化连接，这使得Web应用程序可以更加实时地传递数据。WebSocket协议最初由W3C开发，并于2011年成为标准。
SpringBoot接口防抖(防重复提交)的一些实现方案
作为一名老码农，在开发后端Java业务系统，包括各种管理后台和小程序等。在这些项目中，我设计过单/多租户体系系统，对接过许多开放平台，也搞过消息中心这类较为复杂的应用，但幸运的是，我至今还没有遇到过线上系统由于代码崩溃导致资损的情况。这其中的原因有三点：一是业务系统本身并不复杂；二是我一直遵循某大厂代码规约，在开发过程中尽可能按规约编写代码；三是经过多年的开发经验积累，我成为了一名熟练工，掌握了一些实用的技巧。啥是防抖所谓防抖，一是防用户手抖，二是防网络抖动。
SpringBoot请求转发与重定向
但是可能由于B网址相对于A网址过于复杂，这样搜索引擎就会觉得网址A对用户更加友好，因而在重定向之后任然显示旧的网址A，但是显示网址B的内容。在平常使用手机的过程当中，有时候会发现网页上会有浮动的窗口，或者访问的页面不是正常的页面，这就可能是运营商通过某种方式篡改了用户正常访问的页面。重定向，是指在Nginx中，重定向是指通过修改URL地址，将客户端的请求重定向到另一个URL地址的过程，Nginx中实现重定向的方式有多种，比如使用rewrite模块、return指令等。使用场景：在返回视图的前面加上。
TCP协议-TCP连接管理
TCP协议是 TCP/IP 协议族中一个非常重要的协议。它是一种面向连接、提供可靠服务、面向字节流的传输层通信协议。TCP（Transmission Control Protocol，传输控制协议）。
SpringBoot 中实现订单30分钟自动取消的策略
在电商和其他涉及到在线支付的应用中，通常需要实现一个功能：如果用户在生成订单后的一定时间内未完成支付，系统将自动取消该订单。本文将详细介绍基于Spring Boot框架实现订单30分钟内未支付自动取消的几种方案，并提供实例代码。
计算机网络TCP/IP协议-从双绞线到TCP
消息响应也是同理，这种带端口的消息发送方式，其实就是UDP协议，UDP简单粗暴，但是UDP存在很多问题，所以我们需要设计一个稳定可靠的协议，TCP协议，首先，网络是不稳定的，我们发送的消息很有可能会在中途丢失，所以需要设置重试机制，当消息发送失败时重新发送，为了判断是否成功，还需要要求接收方收到消息后，必须发送确认消息，这样就可以保证消息必达，另外大段的内容发送，很容易造成部分丢失，导致全部内容都要重新发送，于是我们可以将数据分包，分成多个包发送。到这，也行你会发现了，演示中的IP地址是怎么设置的呢？
SpringCloud远程调用为啥要采用HTTP，而不是RPC？
通俗的说法就是：比如说现在有两台服务器A和B，一个应用部署在A服务器上，另一个应用部署在B服务器上，如果A应用想要调用B应用提供的方法，由于他们不在一台机器下，也就是说它们不在一个JVM内存空间中，是无法直接调用的，需要通过网络进行调用，那这个调用过程就叫做RPC。建立Socket连接至少需要一对套接字，其中一个运行于客户端，称为ClientSocket ，另一个运行于服务器端，称为ServerSocket ，套接字之间的连接过程分为三个步骤：服务器监听，客户端请求，连接确认。
SpringBoot 优雅实现超大文件上传，通用方案
通俗的说，你把要上传的东西上传，服务器会先做MD5校验，如果服务器上有一样的东西，它就直接给你个新地址，其实你下载的都是服务器上的同一个文件，想要不秒传，其实只要让MD5改变，就是对文件本身做一下修改（改名字不行），例如一个文本文件，你多加几个字，MD5就变了，就不会秒传了。分片上传，就是将所要上传的文件，按照一定的大小，将整个文件分隔成多个数据块（我们称之为Part）来进行分别上传，上传完之后再由服务端对所有上传的文件进行汇总整合成原始的文件。
Springboot + oauth2 单点登录 - 原理篇
OAuth 协议为用户资源的授权提供了一个安全的、开放而又简易的标准，允许用户授权第三方移动应用访问他们存储在另外的服务提供者上的信息，而不需要将用户名和密码提供给第三方移动应用或分享他们数据的所有内容，OAuth2.0是OAuth协议的延续版本，但不向后兼容OAuth 1.0即完全废止了OAuth1.0。授权码模式（authorization code）密码模式（resource owner password credentials）客户端模式（client credentials） 不常用。
Java之网络通信框架mina
mina是一个基于java nio的网络通信框架。主要屏蔽了网络通信的一些细节，对Socket进行封装，并且是NIO的一个实现架构，可以帮助我们快速的开发网络通信，常用于游戏的开发、中间件服务端的程序中。Apache的Mina（Multipurpose Infrastructure Networked Applications）是一个网络应用框架，可以帮助用户开发高性能和高扩展性的网络应用程序；它提供了一个抽象的、事件驱动的异步API，使。
python安装成功的图标_ubuntu下：安装anaconda、环境配置、软件图标的创建、成功启动anaconda图形界面...
Ubuntu安装anaconda常见的四大问题：目录1、介绍2、安装anaconda3、环境配置4、软件图标的创建5、成功启动anaconda图形界面1、介绍先介绍一下anaconda和python的关系：初学者所安装的python2/3只是python的环境，没有python的工具包&a…
CSS局限属性contain：优化渲染性能的利器
在网页开发中，优化渲染性能是一个重要的目标。CSS局限属性contain是一个强大的工具，可以帮助我们提高网页的渲染性能。本文将介绍contain属性的基本概念、用法和优势，以及如何使用它来优化网页的渲染过程。
Docker网络详解
如何自定义一个网络？查看新创键的mynet详细信息：# 创建两个使用相同自定义网络的容器# 测试容器互连^C^C。
DNS轮询解析是什么？
在其最简单的实现中，轮回DNS的工作方式是，不仅用一个潜在的IP地址来响应DNS请求，而且用一个潜在的IP地址列表来响应承载相同服务的几个服务器。传统的负载均衡技术通常需要专门的硬件或软件，但DNS轮询解析是一种负载分配、负载平衡或容错技术，通过管理域名系统（DNS）对来自客户计算机的地址请求的响应，按照适当的统计模型，提供多个冗余的互联网协议服务主机，将流量分散到多个服务器上。因此，虽然轮询DNS是一种简单有效的负载平衡方法，但它也存在一些限制和潜在的问题，需要根据实际情况进行选择和使用。
一文搞懂网络OSI网络模型
在互联网技术里，有两件事最为重要，一个是TCP/IP协议，它是万物互联的事实标准；另一个是Linux操作系统，它是推动互联网技术走向繁荣的基石。在网络编程中最重要的模型便是OSI七层网络模型和TCP/IP四层网络模型七层模型，也称为OSI(Open System Interconnection)参考模型，是国际标准化(ISO)指定的一个用于计算机或通信系统间互联的标准体系。建立七层模型的主要目的是为解决各种网络互联时遇到的兼容性问题。
常见的几种网络抓包及协议分析工具
网络工程师必备技能-抓取网络数据。在本篇博客中，我们将集中记下几个问题进行探讨：Wireshark 是免费的抓取数据包、分析数据包的工具，兼容 Windows、Linux、Mac等主流平台。使用 wireshark 抓包需要的工具是：安装了 wireshark 的 PC。wireshark 抓包的范围是：抓取安装了 wireshark 的 PC 本机的网卡上流经的数据包。其中，网卡指的是 PC 上网使用的模块，常见的包括：以太网网卡、wifi 无线网卡，PC 分别使用它们用于连接以太网、wifi 无线网络。
为什么网线接法要分交叉连接和直连连接两种方式
水晶头有两种连接方式T568A和T568B。网线的两头都使用同一标准连接就是直连线，两头使用不同的标准就是交叉线。
TCP服务器最多支持多少客户端连接
本文从理论和实际两个方面介绍了一个 TCP 服务器支持的最大连接数
websocket服务端本地部署
即登录cpolar官网后，点击预留，保留一个固定tcp端口地址，然后将其配置到相应的隧道中即可。这里我们用cpolar内网穿透来映射内网端口，它支持http/https/tcp协议，不限制流量，无需公网ip，也不用设置路由器，操作简单。注意:该隧道选择的是临时tcp地址和端口,24小时内会变化,如需固定tcp地址,可升级为专业套餐做tcp地址固定!cpolar安装成功后，默认会配置两个默认隧道：一个ssh隧道和一个website隧道，可自行删减或者修改。，可以查看到token码，复制并执行命令进行认证。
微信小程序之WXSS模板样式、页面配置（.json）和网络数据请求
一、WXSS 模板样式1、什么是 WXSS2、WXSS 和 CSS 的关系二、WXSS 模板样式 - rpx1、什么是 rpx 尺寸单位2、rpx 的实现原理3、rpx 与 px 之间的单位换算*三 、WXSS 模板样式 - 样式导入1、什么是样式导入2、@import 的语法格式四、WXSS 模板样式 - 全局样式和局部样式1、全局样式2、局部样式五、页面配置1、页面配置文件的作用2、页面配置和全局配置的关系3、页面配置中常用的配置项。
Java中的方法重载和方法重写有什么区别？
Java中的方法重载（Overloading）和方法重写（Overriding）都是面向对象编程中的重要概念，但它们之间有一些区别。方法重载是指在同一个类中，可以定义多个具有相同名称但参数列表不同的方法。这些方法具有不同的参数类型、参数个数或参数顺序。在调用重载方法时，Java编译器会根据传递给方法的参数类型和数量来选择要调用的正确方法。方法重载主要用于解决方法的命名冲突和提高代码的可读性和可维护性。
python基础使用之变量，表达式，语句
PYTHON基础知识系列之变量、表达式、语句
python基础小知识：引用和赋值的区别
通过引用，就可以在程序范围内任何地方传递大型对象而不必在途中进行开销巨大的赋值操作。不过需要注意的是，这种赋值仅能做到顶层赋值，如果出现嵌套的情况下仍不能进行深层赋值。赋值与引用不同，复制后会产生一个新的对象，原对象修改后不会影响到新的对象。如果在原位置修改这个可变对象时，可能会影响程序其他位置对这个对象的引用
Spring AOP 技术实现原理
Spring AOP的实现基于代理模式，通过代理对象来包装目标对象，实现切面逻辑的注入。通过本文，我们深入了解了Spring AOP是如何基于JDK动态代理和CGLIB代理技术实现的。通过详细的示例演示，希望读者能更清晰地理解Spring AOP的底层原理，并在实际项目中灵活应用这一强大的技术。
基于深度学习的细胞感染性识别与判定
通过引入深度学习技术，我们能够更精准地识别细胞是否受到感染，为医生提供更及时的信息，有助于制定更有效的治疗方案。基于深度学习的方法通过学习大量样本，能够自动提取特征并进行准确的感染性判定，为医学研究提供了更高效和可靠的手段。通过引入先进的深度学习技术，我们能够实现更快速、准确的感染性判定，为医学研究和临床实践提供更为可靠的工具。其准确性和效率将为医学研究带来新的突破，为疾病的早期诊断和治疗提供更可靠的支持。通过大规模的训练，模型能够学到细胞感染的特征，并在未知数据上做出准确的预测。
Golang 搭建 WebSocket 应用（八） - 完整代码
本文应该是本系列文章最后一篇了，前面留下的一些坑可能后面会再补充一下，但不在本系列文章中了。
Python自动化实战之接口请求的实现
作为一位过来人也是希望大家少走一些弯路，如果你不想再体验一次学习时找不到资料，没人解答问题，坚持几天便放弃的感受的话，在这里我给大家分享一些自动化测试的学习资源，希望能给你前进的路上带来帮助。