使用channels.generic.websocket.WebsocketConsumer()在Python中处理Websocket连接

在Python中，可以使用Django Channels库的WebsocketConsumer类来处理WebSocket连接。WebsocketConsumer提供了处理WebSocket请求和处理通信的方法，允许你发送和接收消息。

下面是一个使用WebsocketConsumer的简单示例：

from channels.generic.websocket import WebsocketConsumer
import json

class MyConsumer(WebsocketConsumer):
    def connect(self):
        # 在建立WebSocket连接时调用
        self.accept()

    def disconnect(self, close_code):
        # 在断开WebSocket连接时调用
        pass

    def receive(self, text_data):
        # 在接收到WebSocket消息时调用
        text_data_json = json.loads(text_data)
        message = text_data_json['message']

        # 处理接收到的消息
        response = self.process_message(message)

        # 发送响应消息给客户端
        self.send(text_data=json.dumps({
            'response': response
        }))

    def process_message(self, message):
        # 处理接收到的消息的逻辑
        return f"You sent: {message}"

在上面的示例中，我们创建了一个MyConsumer类，继承自WebsocketConsumer类，然后重写了connect、disconnect和receive方法。connect方法在建立WebSocket连接时调用，而disconnect方法在断开WebSocket连接时调用。receive方法在接收到WebSocket消息时调用。

在connect方法中，我们调用self.accept()来接受WebSocket连接。

在disconnect方法中，我们可以选择在断开连接时执行一些清理操作。

在receive方法中，我们首先通过json模块将接收到的消息（字符串格式）解析为JSON对象，然后提取需要的数据。接下来，我们使用self.process_message方法处理接收到的消息，该方法可以根据业务逻辑进行自定义实现。最后，我们将响应消息作为JSON字符串发送给客户端。

可以将上述代码集成到Django Channels项目中，然后运行websocket服务器以接收连接。例如，可以在routing.py文件中配置路由来将WebSocket请求与MyConsumer类相关联：

from django.urls import re_path

from . import consumers

websocket_urlpatterns = [
    re_path(r'ws/my_consumer/$', consumers.MyConsumer.as_asgi()),
]

这样，当有来自/ws/my_consumer/路径的WebSocket请求时，将使用MyConsumer处理该请求。

需要注意的是，该示例只是一个简单的起点，实际使用中你可以根据需要定制自己的WebsocketConsumer子类，实现更复杂的业务逻辑。