赞
踩
WebSocket是一种在单个TCP连接上进行全双工通信的协议。
WebSocket使得客户端和服务器之间的数据交换变得更加简单,允许服务端主动向客户端推送数据。在WebSocket API中,浏览器和服务器只需要完成一次握手,两者之间就直接可以创建持久性的连接,并进行双向数据传输。
为什么需要websocket协议?
传统的模式的缺点:浏览器需要不断的向服务器发出请求,然而HTTP请求可能包含较长的头部,其中真正有效的数据可能只是很小的一部分,显然这样会浪费很多的带宽等资源。
HTML5定义了WebSocket协议,能更好的节省服务器资源和带宽,并且能够更实时地进行通讯。
1.单工: 数据传输只允许在一个方向上的传输,只能一方来发送数据,另一方来接收数据并发送。例如:对讲机
2.半双工:数据传输允许两个方向上的传输,但是同一时间内,只可以有一方发送或接受消息。例如:打电话
3.全双工:同时可进行双向传输。例如:websocket
请求的地址: 一般是:ws://***,或者是使用了SSL/TLS加密的安全协议wss:,用来标识是WebSocket请求。
server.py
import asyncio import websockets import websockets_routes import json # 初始化一个router对象 router = websockets_routes.Router() @router.route("/{id}") #添加router的route装饰器,它会路由uri。 async def light_status(websocket, path): async for message in websocket: print("got a message:{}".format(message)) print(path.params['id']) #message = json.loads(message) #print(message) await asyncio.sleep(2) await websocket.send(message) async def main(): # rooter是一个装饰器,它的__call__函数有三个参数,第一个参数是self。 # 所以这里我们需要使用lambda进行一个转换操作,因为serv的wshander函数只能接收2个参数 async with websockets.serve(lambda x, y: router(x, y), "127.0.0.1", 8765): print("======") await asyncio.Future() # run forever if __name__ == "__main__": asyncio.run(main())
client.py
import asyncio import websockets import json async def hello(): try: async with websockets.connect('ws://127.0.0.1:8765/123') as websocket: light_addr = {"name":"lilei","id":"123-345"} light_addr = json.dumps(light_addr) await websocket.send(light_addr) recv_msg = await websocket.recv() print(recv_msg) except websockets.exceptions.ConnectionClosedError as e: print("connection closed error") except Exception as e: print("e:",e) asyncio.run(hello())
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。