python创建websocket服务器实现循环发送消息过程
WebSocket协议是在2008年由Web应用程序设计师和开发人员创建的，目的是为了在Web浏览器和服务器之间提供更高效、更低延迟的双向通信。
它允许客户端和服务器在任何时候发送消息，无需重新建立TCP连接。
WebSocket可以在Web浏览器和服务器之间传输文本和二进制数据，使得构建实时Web应用程序变得更加简单。
在Python中使用WebSocket
Python中有多个库可以帮助我们使用WebSocket，如：websockets、aiohttp等。
在本文中，我们将使用websockets库来演示WebSocket编程。
要安装websockets库，你可以使用pip：
pip install websockets
创建WebSocket服务器
使用websockets库，我们可以轻松地创建一个WebSocket服务器。
以下是一个简单的示例：
import asyncio
import websockets
async def echo(websocket, path):
async for message in websocket:
print(f"Received message: {message}")
await websocket.send(f"Echo: {message}")
start_server = websockets.serve(echo, "localhost", 8765)
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()在这个示例中，我们定义了一个名为echo的协程函数，它接收两个参数：websocket和path。该函数使用async for循环读取客户端发送的消息，并将消息发送回客户端。
然后，我们使用websockets.serve()函数创建一个WebSocket服务器，监听本地主机的8765端口。最后，我们使用asyncio的事件循环启动服务器。
连接上服务器直接推消息
我这里有一个需求，当一个客户端连接上服务器后，立马向客户端源源不断的发送消息，就可以这样改造：
import asyncio
import time
import websockets
async def echo(websocket, path):
print(f"websocket echo: {path} , {websocket}")
# await websocket.send(f"Echo: 11111")
message = 1
while True:
await websocket.send(f"Echo: {message}")
print(f"Echo: {message}")
message += 1
time.sleep(1)
start_server = websockets.serve(echo, "localhost", 8765)
print(f"websocket listen：ws://localhost:8765")
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()
使用Postman测试
可以先使用postman创建一个websocket连接测试一下：
创建WebSocket客户端
要创建一个WebSocket客户端，我们同样可以使用websockets库。
以下是一个简单的客户端示例：
import asyncio
import websockets
async def main():
async with websockets.connect("ws://localhost:8765") as websocket:
message = "Hello, server!"
await websocket.send(message)
print(f"Sent: {message}")
response = await websocket.recv()
print(f"Received: {response}")
asyncio.run(main())
在这个示例中，我们使用websockets.connect()函数建立与WebSocket服务器的连接。然后，我们使用send()方法向服务器发送消息，并使用recv()方法接收服务器的响应。
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了python并发爬虫实用工具tomorrow实用解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2019-09-09
这篇文章主要为大家详细介绍了python使用adbapi实现MySQL数据库的异步存储，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2019-03-03
为大家分享一下python读取和保存图片5种方法与比较,python中对象之间的赋值是按引用传递的，如果需要拷贝对象，需要用到标准库中的copy模块2018-09-09
permute中参数为张量的维度,将不同维度以不同的维度排列,得到一个新的张量,在深度学习中的主要作用是将特征值聚类,下面这篇文章主要给大家介绍了关于pytorch中permute()函数用法的相关资料,需要的朋友可以参考下2022-04-04
这篇文章主要介绍了python3 MKL库 安装使用教程的相关资料,需要的朋友可以参考下2023-11-11
在python2.7版本中，MySQLdb模块还不是python的内置模块，但是MySQLdb模块又是Python与MySQL连接的桥梁，对于作为MySQL DBA又很喜欢Python语言的我来说，MySQLdb真的是必需品呢。所以就需要自己进行安装了，这篇文章就给大家详细介绍了关于用yum安装MySQLdb模块的步骤。2016-12-12
Python读取xlsx文件报错:xlrd.biffh.XLRDError: Excel xlsx file;no
这篇文章主要给大家介绍了关于Python库xlrd中的xlrd.open_workbook()函数读取xlsx文件报错:xlrd.biffh.XLRDError: Excel xlsx file;not supported问题解决的相关资料,文中通过图文介绍的非常详细,需要的朋友可以参考下2022-08-08
通常使用TOF等3d摄像头采集的格式一般只是深度图,下面这篇文章主要给大家介绍了关于如何基于Python深度图生成3D点云的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考下2022-12-12
requirements.txt文件是项目的依赖包及其对应版本号的信息列表，本文主要介绍了Python requirements.txt的具体使用，具有一定的参考价值，感兴趣的可以了解一下2024-01-01
一直在学习Python爬虫，所以今天就心血来潮来写了个爬虫，抓取该网站上所有美剧链接，并保存在文本文档中，想要哪部剧就直接打开复制链接到迅雷就可以下载啦2016-09-09
最新评论