DjangoChannels实现点对点实时聊天和消息推送功能_django实时聊天 - CSDN文库

773 浏览量更新于2023-05-26 评论收藏 81KB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

资源详情

资源评论

资源推荐

Django Channels 实现点对点实时聊天和消息推送功能实现点对点实时聊天和消息推送功能

主要介绍了Django Channels 实现点对点实时聊天和消息推送功能，本文分步骤给大家介绍的非常详细，具有

一定的参考借鉴价值,需要的朋友可以参考下

简介在很多实际的项目开发中，我们需要实现很多实时功能；而在这篇文章中，我们就利用django channels简单地实现了点

对点聊天和消息推送功能。

手边有一个项目需要用到后台消息推送和用户之间一对一在线聊天的功能。例如用户A评论了用户B的帖子，这时候用户B就

应该收到一条通知，显示自己的帖子被评论了。这个功能可以由最基本的刷新页面后访问数据库来完成，但是这样会增加对后

台服务器的压力，同时如果是手机客户端的话，也会造成流量的损失。于是，我们考虑使用websocket建立一个连接来完成这

个功能。

但是django并不支持websocket，因此在一番寻找之后发现了django-channels这个项目，它允许Django项目不仅可以处理

HTTP，还可以处理需要长时间连接的协议 - WebSockets，MQTT，chatbots，业余无线电等等。

作者本人也接触channels没多久，为了搞这两个功能看channels文档看到自闭，最终简单实现了这两个功能，特地记录一下

一：安装一：安装channels

如果使用的是django 1.9 及以上，在pip安装channels时可以不加-U参数

pip install channels

安装结束后，我们把channels作为一个app添加进入我们的django项目，在settings.py中添加

INSTALLED_APPS = [

'django.contrib.admin',

'django.contrib.auth',

'django.contrib.contenttypes',

'django.contrib.sessions',

'django.contrib.messages',

'django.contrib.staticfiles',

'Your-app',

'channels',

]

在这里，我们使用redis做为channels的通道后端，以便支持更多的功能，具体涉及到的一些功能在后文中会提及。于是我们

还需要安装一些依赖包以支持其正常工作

pip install channels_redis

然后在settings.py文件中添加

CHANNEL_LAYERS = {

"default": {

"BACKEND": "channels_redis.core.RedisChannelLayer",

"CONFIG": {

"hosts": [('127.0.0.1', 6379)],

},

# 配置路由的路径

# "ROUTING": "exmchannels.routing.channel_routing",

},

}

ASGI_APPLICATION = 'exmchannels.routing.application'

二：点对点聊天二：点对点聊天

在项目目录下新建一个文件，用来存放我们的channels代码，为channel。在channel中新建一个comsumers.py文件，在其中

新建一个ChatComsumer类用来处理我们聊天时的websocket请求。相对于建立一个聊天室，在这里不同的是我们在

ChatComsumer中添加了一个chats来记录每一个group中的连接数。以此根据这个连接数来判断，聊天双方是否都已连接进入

该个聊天group。

同时，我们设定聊天组的命名形式为user_a的id加上下划线_加上user_b的id，其中id值从小到大放置，例如：

195752_748418

class ChatConsumer(AsyncJsonWebsocketConsumer):

chats = dict()

async def connect(self):

self.group_name = self.scope['url_route']['kwargs']['group_name']

await self.channel_layer.group_add(self.group_name, self.channel_name)

# 将用户添加至聊天组信息chats中

try:

ChatConsumer.chats[self.group_name].add(self)

except:

本内容试读结束，登录后可阅读更多

下载后可阅读完整内容，剩余2页未读，立即下载

评论0

weixin_38518518

粉丝: 6
资源: 959

会员权益专享

图片转文字

全年可省5，000元立即开通

最新资源

资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！点击此处反馈