python用Websocket实现长连接
时间: 2023-12-14 20:04:08 浏览: 135
python实现websocket
5星 · 资源好评率100%
要在Python中使用Websocket实现长连接,你可以使用第三方库`websocket`或者`websockets`。这两个库都提供了简单易用的接口来创建Websocket服务器和客户端。
首先,你需要安装相应的库。可以使用pip命令来安装它们:
```bash
pip install websocket
```
或者
```bash
pip install websockets
```
接下来,你可以使用下面的示例代码来创建一个简单的Websocket服务器:
```python
import websocket
def on_message(ws, message):
print(f"Received message: {message}")
def on_error(ws, error):
print(f"Error: {error}")
def on_close(ws):
print("Connection closed")
def on_open(ws):
ws.send("Hello, server!")
if __name__ == "__main__":
websocket.enableTrace(True)
ws = websocket.WebSocketApp("ws://your-websocket-server-url",
on_message=on_message,
on_error=on_error,
on_close=on_close)
ws.on_open = on_open
ws.run_forever()
```
在上面的代码中,你需要替换`ws://your-websocket-server-url`为你实际的Websocket服务器地址。然后,定义了几个回调函数:`on_message`用于处理接收到的消息,`on_error`用于处理错误,`on_close`用于处理连接关闭,`on_open`用于在连接建立后发送一条初始消息。
运行上述代码后,它将与Websocket服务器建立连接,并在收到消息时打印出来。你可以根据实际需求,修改回调函数的实现来处理接收到的消息。
如果你想要创建一个Websocket客户端,可以使用`websockets`库,示例代码如下:
```python
import asyncio
import websockets
async def hello():
async with websockets.connect("ws://your-websocket-server-url") as websocket:
await websocket.send("Hello, server!")
response = await websocket.recv()
print(f"Received message: {response}")
if __name__ == "__main__":
asyncio.get_event_loop().run_until_complete(hello())
```
在上面的代码中,你同样需要替换`ws://your-websocket-server-url`为实际的Websocket服务器地址。然后,使用`websockets.connect`函数来连接服务器,并使用`websocket.send`发送消息,使用`websocket.recv`接收服务器返回的消息。
运行上述代码后,它将连接到Websocket服务器,发送一条消息并等待接收服务器的响应。
这些示例代码只是简单的演示,你可以根据自己的需求进行修改和扩展。
阅读全文