使用python websocket-client主动发送给服务端

要使用Python的websocket-client库向服务端发送消息，您可以使用以下代码：

import websocket

# 创建websocket连接
ws = websocket.WebSocket()
ws.connect("ws://example.com/ws")

# 发送消息
ws.send("Hello, server!")

# 关闭连接
ws.close()

这将创建一个WebSocket连接到服务端，并使用`send()`方法发送一条消息。在发送消息之后，您可以使用`close()`方法关闭连接。

请注意，这只是一个简单的示例，您需要根据您的实际情况修改代码以使用适当的地址和消息。

相关问题

python websocket 服务端如何主动断开连接

在 Python 中可以使用 `websockets` 库来创建 WebSocket 服务端。要主动断开连接，可以使用 `WebSocketServerProtocol.close()` 方法。以下是一个示例代码：

import asyncio
import websockets

async def handle_client(websocket, path):
    try:
        while True:
            # 处理客户端发送的消息
            message = await websocket.recv()
            print(f"Received message: {message}")

            # 根据消息内容判断是否要断开连接
            if message == "close":
                await websocket.close()
                break

            # 回复客户端消息
            await websocket.send(f"Received message: {message}")
    except websockets.exceptions.ConnectionClosedOK:
        print("Connection closed")

start_server = websockets.serve(handle_client, "localhost", 8000)

asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

在上面的代码中，当客户端发送 `"close"` 消息时，服务端会主动断开连接。注意，`WebSocketServerProtocol.close()` 方法是一个异步方法，需要使用 `await` 关键字来等待其执行完成。

用python的websocket库封装一个websocket服务端的class

以下是一个简单的websocket服务端的class，使用Python的websocket库实现：

import asyncio
import websockets

class WebSocketServer:
    def __init__(self, host='localhost', port=8888):
        self.host = host
        self.port = port

    async def handle_client(self, websocket, path):
        async for message in websocket:
            # 处理客户端发送的消息
            await websocket.send('You sent: {}'.format(message))

    async def run(self):
        async with websockets.serve(self.handle_client, self.host, self.port):
            print('WebSocket server running on {}:{}'.format(self.host, self.port))
            await asyncio.Future()  # 保持websocket服务器一直运行

if __name__ == '__main__':
    server = WebSocketServer()
    asyncio.run(server.run())

在这个WebSocketServer类中，我们定义了一个handle_client方法来处理客户端与服务器之间的通信。在这个方法中，我们使用async for循环来接收来自客户端的消息，并使用websocket.send方法将消息发送回客户端。

在run方法中，我们使用websockets.serve方法来创建一个websocket服务器，并将handle_client方法作为回调函数传递给它。最后，我们使用asyncio.Future方法来保持websocket服务器一直运行。

我们可以使用以下代码来启动WebSocket服务器：

if __name__ == '__main__':
    server = WebSocketServer()
    asyncio.run(server.run())

这将创建一个WebSocketServer对象并运行它的run方法，从而启动WebSocket服务器。默认情况下，服务器将在本地主机的8888端口上运行。你可以通过传递host和port参数来更改它们。