如何解决mqtt 通过 django-channels 中的套接字
我正在尝试通过 django-channels 中的 websocket 启动一个 mqtt 代理,以将特定主题的数据发布给授权用户。 我已经定义了一个 url 来过滤特定消费者中的 mqtt 请求,我正在接受套接字请求。 这一切都很好,但是当我建立 mqtt 连接时,套接字一次又一次地重新启动,我不知道为什么会这样!? 而且我将如何从我的观点发送消息也有点令人困惑。
代码片段:
路由.py
from django.urls import re_path
from . import consumer
websocket_urlpatterns = [
re_path(r'ws/data/(?P<room_name>\w+)/(?P<auth_data>\S+)/$',consumer.ChatConsumer.as_asgi()),re_path(r'mqtt',consumer.ChatTwoConsumer.as_asgi())
]
consumer.py
class ChatTwoConsumer(WebsocketConsumer):
def connect(self):
print('here')
self.accept()
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。