python+websocket服务器给客户端发消息_基于python的websockets的推送消息

服务器和客户端建立联系之后，达到要求就给客户端发送消息，不需要客户端每次都请求。

服务器端

import asyncio
import websockets
import random
 
dic_send = 2
 
"""实现一直给客户端发消息，异步等待3秒，达到特定要求给客户端发送"""
async def echo(websocket, path):
    cnt = 0
    while True:
        x = random.randint(1,3)
        if x == dic_send:
            cnt +=1
            await websocket.send(str(cnt)+": "+str(dic_send)) # 第几个2传过来
        print(x)
        await asyncio.sleep(3)
 
 
start_server = websockets.serve(echo,'192.168.4.27',5678) # 地址改为你自己的地址
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

客户端

import asyncio
import websockets
 
 
async def hello(uri):
    async with websockets.connect(uri) as websocket:
        while True:
            recv_text = await websocket.recv()
            print("> {}".format(recv_text))
 
 
asyncio.get_event_loop().run_until_complete(
    hello('ws://192.168.4.27:5678')) # 地址改为你自己的地址

先运行服务器端，再运行客户端，当服务器端的数字为2时发送给客户端，每隔3秒判定一次，不是2就不发。