WebSocket是一类在Web插件中同时实现点对点的协定，容许伺服器和插件间展开动态的传输。在Python中，能采用websockets程序库展开WebSocket程式设计。第一集将如是说怎样采用websockets库展开Python中WebSocket的自学讲义。
加装websockets库
在已经开始以后，须要先加装websockets库。能采用pip指示来加装：
pip install websockets
伺服器端WebSocket
上面是两个单纯的伺服器端WebSocket实例，采用websockets程序库窃听插件的相连允诺，并与插件展开传输。
import asyncioimport websocketsasync def echo(websocket, path): async for message in websocket:# 转交插件推送的最新消息 print(fReceived message:{message})# 推送最新消息给插件 response = fResponse:{message} await websocket.send(response)startserver = websockets.serve(echo,localhost,8765)asyncio.geteventloop().rununtilcomplete(startserver)asyncio.geteventloop().runforever()
在以内实例中，采用websockets.serve()表达式建立了两个WebSocket伺服器，并选定了窃听的PS3门牌号和路由器。echo()表达式做为WebSocket处置表达式，当插件相连获得成功后，将处置插件的最新消息，并推送积极响应。
插件WebSocket
上面是两个单纯的插件WebSocket实例，采用websockets程序库相连到伺服器端WebSocket并展开传输。
import asyncioimport websocketsasync def connect(): async with websockets.connect(ws://localhost:8765) as websocket:# 推送最新消息给伺服器端 message =Hello, WebSocket! await websocket.send(message) print(fSent message:{message})# 转交伺服器端的积极响应 response = await websocket.recv() print(fReceived response:{response})asyncio.geteventloop().rununtilcomplete(connect())
在以内实例中，采用websockets.connect()表达式相连到伺服器端WebSocket，并推送最新消息给伺服器端。然后通过websocket.recv()表达式转交伺服器端的积极响应。
WebSocket事件处置
websockets库提供了多种事件处置表达式，能用于处置WebSocket的不同事件，例如相连获得成功、最新消息转交、相连关闭等。上面是两个单纯的实例：
import asyncioimport websocketsasync def handlemessage(websocket, message): print(fReceived message:{message})# 处置最新消息 response = fResponse:{message} await websocket.send(response)async def echo(websocket, path):# 处置相连获得成功事件 print(fClient connected) while True: try:# 转交消息 message = await websocket.recv() await handlemessage(websocket, message) except websockets.ConnectionClosed:# 处置相连关闭事件 print(fClient disconnected) breakstartserver = websockets.serve(echo,localhost,8765)asyncio.geteventloop().rununtilcomplete(startserver)asyncio.geteventloop().runforever()
在以内实例中，handlemessage()表达式用于处置转交到的最新消息，能根据实际需求展开自定义处置逻辑。echo()表达式通过websockets.serve()建立了两个WebSocket伺服器，并在其中采用两个无限循环来处置转交到的最新消息。当插件相连获得成功时，会触发相连获得成功事件，并输出相应的日志。当插件断开相连时，会触发相连关闭事件，并输出相应的日志。
插件WebSocket事件处置
websockets库也提供了插件WebSocket的事件处置表达式，例如相连获得成功、最新消息转交、相连关闭等。上面是两个单纯的实例：
import asyncioimport websocketsasync def handleresponse(response): print(fReceived response:{response})# 处置伺服器端的积极响应async def connect(): async with websockets.connect(ws://localhost:8765) as websocket: print(fConnected to server) while True: try:# 转交服务端的最新消息 response = await websocket.recv() await handleresponse(response) except websockets.ConnectionClosed: print(fConnection closed) breakasyncio.geteventloop().rununtilcomplete(connect())
在以内实例中，handleresponse()表达式用于处置转交到的伺服器端积极响应，能根据实际需求展开自定义处置逻辑。connect()表达式通过websockets.connect()相连到伺服器端WebSocket，并在两个无限循环中处置转交到的最新消息。当相连关闭时，会触发相连关闭事件，并输出相应的日志。
异常处置
在WebSocket程式设计中，可能会出现各种异常情况，例如相连失败、相连关闭、最新消息推送失败等。websockets库提供了相应的异常类，能用于捕获和处置这些异常。上面是两个单纯的异常处置实例：
import asyncioimport websocketsasync def connect(): try: async with websockets.connect(ws://localhost:8765) as websocket:# 推送最新消息给伺服器端 message =Hello, WebSocket! await websocket.send(message) print(fSent message:{message})# 转交伺服器端的积极响应 response = await websocket.recv() print(fReceived response:{response}) except websockets.exceptions.WebSocketException as e: print(fWebSocket exception:{e})asyncio.geteventloop().rununtilcomplete(connect())
在以内实例中，采用try-except语句来捕获websockets.exceptions.WebSocketException异常，用于处置WebSocket相关的异常情况，例如相连失败、相连关闭等。
总结
通过自学websockets库的基本用法，能在Python中展开WebSocket程式设计，同时实现与Web插件的动态传输。第一集讲义如是说了伺服器端WebSocket的建立、插件WebSocket的相连与事件处置，以及异常处置等基本概念。希望这个简单的Python中WebSocket程式设计的自学讲义对您有帮助，让您能够在实际项目中应用WebSocket技术。
