您现在的位置是：首页 > 其他

当前栏目

python websocket 聊天服务器

服务器消息

2023-03-02 11:00:24 时间

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

前提：

安装

pip install -U channels
    
    add channels to your INSTALLED_APPS setting

服务端：consumers.py

# -*- coding: utf-8 -*-
    from __future__ import unicode_literals
    
    import datetime
    import json
    
    from channels import Group
    from channels.auth import channel_session_user_from_http, channel_session_user
    
    
    @channel_session_user_from_http
    def ws_connect(message, game, room_id):
        # Add to the chat group
        Group(game).add(message.reply_channel)
        # Accept the connection
        message.reply_channel.send({"accept": True})
    
    
    @channel_session_user
    def ws_message(message, game, room_id):
        user = message.user
        if not user.id:
            data = {'stream': 'unauthorized', 'payload': {}}
            Group(game).send({"text": json.dumps(data)}, immediately=True)
            return
    
        data = {
            'stream': 'test',
            'payload': {
                'id': user.id,
                'username': user.username,
            }
        }
        Group(game).send({"text": json.dumps(data)}, immediately=True)
    
    
    @channel_session_user
    def ws_disconnect(message, game, room_id):
        Group(game).discard(message.reply_channel)

路由文件：routing.py

fromchannels.routing import route
    from myapp.consumers import ws_add, ws_message, ws_disconnect
    channel_routing= [
        route("websocket.connect",ws_add,path=r"^/(?P<game>[a-zA-Z]+)/(?P<room_id>[0-9]+)/$"),
        route("websocket.receive",ws_message,path=r"^/(?P<game>[a-zA-Z]+)/(?P<room_id>[0-9]+)/$"),
       route("websocket.disconnect", ws_disconnect,path=r"^/(?P<game>[a-zA-Z]+)/(?P<room_id>[0-9]+)/$"),
    ]

配置文件：setting.py

CHANNEL_LAYERS = {
        "default": {
            "BACKEND": "asgiref.inmemory.ChannelLayer",
            "ROUTING": "common.routing.channel_routing",
        },
    }

它将channel数据存储在内存中的一个字典里，所以不能跨进程。当部署时还是要换成Redis后端asgi\_redis等。

CHANNEL_LAYERS = {
        "default": {
            "BACKEND": "asgi_redis.RedisChannelLayer",
            "CONFIG": {
                "hosts": [("localhost", 6379)],
            },
            "ROUTING": "myproject.routing.channel_routing",
        },
    }

因为Channles是分布式系统，默认它按workers从队列中获得的顺序处理消息。很可能interface server发出非常近的connect和receive消息，connect还未被处理完，receive就被另一个worker处理。

Channels的解决方法是enforce\_ordering装饰器。所有websocket消息都包含一个order键，这个装饰器用这个键确保message按顺序处理。有两个模式：

Slightordering：connect先处理，其他无序。

Strictordering：所有都按序。

参考：http://blog.csdn.net/linshiyx/article/details/51680418

http://blog.csdn.net/zhu\_free/article/details/48137375

http://www.toutiao.com/i6396086415800664577/

https://github.com/jacobian/channels-example

转载于:https://my.oschina.net/jamescasta/blog/876273

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20210726/bbb945125a6f47d6b4703235aac4dc89.png

猜你喜欢

七个我最常用的 JavaScript 实用程序函数
在 Vue 中，使用 $attrs 构建高级组件
你可能不知道的 Npm 实用技巧
一个快速的Vue3无限滚动组件
我找到了一个快速定位SpringBoot接口超时问题的神器！
使用 Lambda 实现超强的排序功能
Python使用Dash开发网页应用
非常简洁地重试Retry组件，使用起来杠杠的
用 Classmethod 自定义创建对象的方式
如何理解 Python 装饰器
宾大机器学习PhD：我是如何从头开始写一篇顶级论文的？
世界上最好的编程语言PHP和Facebook的感情经历
「稀疏编码」从理论走向实用！马毅教授NeurIPS 2022新作：稀疏卷积性能和稳健性超越ResNet
推特裁员大反转！马斯克哭求被裁员工回来
从UseEffect看React、Vue设计理念的不同
小扎动刀！Meta启动史上最大规模裁员，数千人将失业
借助 :has 实现3D轮播图
终于彻底搞懂 Watch、WatchEffect 了，原来功能如此强大！
小冰公司完成10亿元融资！全面升级「数字员工」产品线
仅需10%参数量即超越SOTA！浙大、字节、港中文联合提出「类别级位姿估计」任务新框架｜CoRL2022

zl程序教程

当前栏目

python websocket 聊天服务器

相关文章