当前位置:   article > 正文

【协议】WebSocket协议总结_socket通信是全双工还是半双工

socket通信是全双工还是半双工

一、简介

WebSocket是一种在单个TCP连接上进行全双工通信的协议。

WebSocket使得客户端服务器之间的数据交换变得更加简单,允许服务端主动向客户端推送数据。在WebSocket API中,浏览器和服务器只需要完成一次握手,两者之间就直接可以创建持久性的连接,并进行双向数据传输。

在这里插入图片描述

为什么需要websocket协议?

传统的模式的缺点:浏览器需要不断的向服务器发出请求,然而HTTP请求可能包含较长的头部,其中真正有效的数据可能只是很小的一部分,显然这样会浪费很多的带宽等资源。
HTML5定义了WebSocket协议,能更好的节省服务器资源和带宽,并且能够更实时地进行通讯。

二、单工、半双工、全双工的区别

1.单工: 数据传输只允许在一个方向上的传输,只能一方来发送数据,另一方来接收数据并发送。例如:对讲机

2.半双工:数据传输允许两个方向上的传输,但是同一时间内,只可以有一方发送或接受消息。例如:打电话

3.全双工:同时可进行双向传输。例如:websocket

三、请求格式

请求的地址: 一般是:ws://***,或者是使用了SSL/TLS加密的安全协议wss:,用来标识是WebSocket请求。

四、使用python实现简单的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())
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30

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())
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17

在这里插入图片描述

在这里插入图片描述

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/人工智能uu/article/detail/898621
推荐阅读
相关标签
  

闽ICP备14008679号