python websocket服务器端定时主动发送消息__websocket服务端如何主动发消息

相关文章推荐

酷酷的煎鸡蛋 · Golang WebSocket Ping ...· 1 月前 ·

飘逸的荔枝 · WebSockets support in ...· 3 周前 ·

安静的电影票 · pycharm绘制图横纵坐标不显示中文 - ...· 2 月前 ·

独立的熊猫 · 修改数组的一些字段，组中某属性取出拼接成一个 ...· 10 月前 ·

高大的日光灯 · Vue如何循环提取对象数组中的值_51CTO ...· 1 年前 ·

寂寞的手术刀 · sql 该列值为空时，则显示另一列 ...· 1 年前 ·

长情的斑马 · css --- > ...· 1 年前 ·

服务器端

import asyncio
import websockets
import asyncio
import websockets
from websockets.legacy.server import WebSocketServerProtocol
import json
import time
import threading
clients={}

async def ws_handle(websocket: WebSocketServerProtocol, path: str):
# if(websocket in clients):

async for message in websocket:
print(message)
jsonmsg = json.loads(message)

        if("deviceMac" in jsonmsg):
mac = jsonmsg["deviceMac"]
if(mac not in clients):
clients[mac] = websocket


        await websocket.send(message)



async def sendmsg(mac,mssage):
# if(websocket in clients):
websocket = clients[mac] 
await websocket.send(mssage)



async def main():
async with websockets.serve(ws_handle, "127.0.0.1", 8080):
await asyncio.Future()              # run forever


def WebSocketServer():
asyncio.run(main())

thread = threading.Thread(target=WebSocketServer)
thread.start()

async def test():
flag=0
while(True):
flag = flag + 1
for client in clients: 
await sendmsg(client, str(flag)+"haha") #依次给每个客户端都发一条信息 
time.sleep(1)

def asyntest():
asyncio.run(test())

thread2 = threading.Thread(target=asyntest)
thread2.start()

客户端

<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Title</title>
<script src="https://cdn.bootcss.com/jquery/3.2.0/jquery.js"></script>
</head>
<body>
<div id="time" style="width: 300px;height: 50px;  text-align: center;line-height: 50px;margin-left: 40%;font-size: 20px"></div>
<input type="button" onclick="sayhello()"  value="测试websocket"/>

<script>
window.ws = new WebSocket("ws://127.0.0.1:8080/");  //连接server

window.ws.onmessage = function (event) {
content = document.createTextNode(event.data); // 接收数据
$("#time").html(content);

            };

function  sayhello(params) { 
console.log('{"deviceMac":"testdev"}');
window.ws.send('{"deviceMac":"testdev"}');
            }

</script>
</body>
</html>

推荐文章

酷酷的煎鸡蛋 · Golang WebSocket Ping Pong

1 月前

飘逸的荔枝 · WebSockets support in ASP.NET Core | Microsoft Learn

3 周前

安静的电影票 · pycharm绘制图横纵坐标不显示中文 - CSDN文库

2 月前

独立的熊猫 · 修改数组的一些字段，组中某属性取出拼接成一个值并用逗号分隔_数组循环取出某个属性用逗号隔开-CSDN博客

10 月前

高大的日光灯 · Vue如何循环提取对象数组中的值_51CTO博客_vue v-for循环数组

1 年前

寂寞的手术刀 · sql 该列值为空时，则显示另一列怎么写？_百度知道

1 年前

长情的斑马 · css --- > 使用scss生成常用的基本css样式_栗子好好吃的博客-CSDN博客

1 年前