我一直在尝试django-channels，包括阅读文档和使用示例。
我希望能够向单个用户发送一条消息，该消息通过将新实例保存到数据库来触发。
我的用例是创建一个新通知（通过 celery 任务），一旦保存通知，就会将此通知发送给单个用户。
这听起来是可能的（来自django-channels 文档）
...关键部分是您可以运行代码（并在通道上发送）以响应任何事件 - 包括您创建的事件。您可以在模型保存、其他传入消息或视图和表单内的代码路径上触发。
但是，进一步阅读文档并使用django-channels 示例，我不知道该怎么做。数据绑定和 liveblog 示例演示了发送到一个组，但我看不到如何只发送给单个用户。
由于组在通道 2 上的工作方式与在通道 1 上的工作方式不同，因此更新很少。不再有组类，如此处所述。
对我有用的是：
# Required for channel communication
from channels.layers import get_channel_layer
from asgiref.sync import async_to_sync
def send_channel_message(group_name, message):
channel_layer = get_channel_layer()
async_to_sync(channel_layer.group_send)(
'{}'.format(group_name),
{
'type': 'channel_message',
'message': message
}
)
不要忘记在 Consumer 中定义处理消息类型的方法！
# Receive message from the group
def channel_message(self, event):
message = event['message']
# Send message to WebSocket
self.send(text_data=json.dumps({
'message': message
}))
扩展@Flip 为该特定用户创建组的答案。
在 ws_connect 函数的 python 函数中，您可以将该用户添加到一个组中：
消费者.py
from channels.auth import channel_session_user_from_http
from channels import Group
@channel_session_user_from_http
def ws_connect(message):
if user.is_authenticated:
Group("user-{}".format(user.id)).add(message.reply_channel)
要从您的 python 代码向该用户发送消息：
我的观点.py
import json
from channels import Group
def foo(user):
if user.is_authenticated:
Group("user-{}".format(user.id)).send({
"text": json.dumps({
"foo": 'bar'
})
})
如果他们已连接，他们将收到消息。如果用户没有连接到 websocket，它将静默失败。
您还需要确保仅将一个用户连接到每个用户的组，否则多个用户可能会收到您仅针对特定用户的消息。
查看 django 频道示例，特别是multichat，了解如何实现路由、在客户端创建 websocket 连接和设置 django_channels。
确保您还查看了django 频道文档。
在Channels 2中，您可以将self.channel_name连接方法保存在 db 中，该方法是每个用户的特定哈希。此处的文档
from asgiref.sync import async_to_sync
from channels.generic.websocket import AsyncJsonWebsocketConsumer
import json
class Consumer(AsyncJsonWebsocketConsumer):
async def connect(self):
self.room_group_name = 'room'
if self.scope["user"].is_anonymous:
# Reject the connection
await self.close()
else:
# Accept the connection
await self.channel_layer.group_add(
self.room_group_name,
self.channel_name
)
await self.accept()
print( self.channel_name )
最后一行返回类似specific.WxuYsxLK!owndoeYTkLBw
您可以将此特定哈希保存在用户表中。
最好的方法是为该特定用户创建组。当 ws_connect 您可以将该用户添加到Group("%s" % <user>).add(message.reply_channel)
注意：我的 websocket 网址是
ws://127.0.0.1:8000/<user>
只是为了扩展@luke_aus 的答案，如果您正在使用 ResourceBindings，您也可以这样做，只有“拥有”对象的用户才能检索这些更新：
就像@luke_aus 回答一样，我们将用户注册到它自己的组中，我们可以在其中发布仅对该用户可见的操作（ update， ）等：create
from channels.auth import channel_session_user_from_http,
from channels import Group
@channel_session_user_from_http
def ws_connect(message):
Group("user-%s" % message.user).add(message.reply_channel)
现在我们可以更改相应的绑定，使其仅在绑定对象属于该用户时发布更改，假设模型如下：
class SomeUserOwnedObject(models.Model):
owner = models.ForeignKey(User)
现在我们可以将此模型绑定到我们的用户组，所有操作（更新、创建等）将只发布给这个用户：
class SomeUserOwnedObjectBinding(ResourceBinding):
# your binding might look like this:
model = SomeUserOwnedObject
stream = 'someuserownedobject'
serializer_class = SomeUserOwnedObjectSerializer
queryset = SomeUserOwnedObject.objects.all()
# here's the magic to only publish to this user's group
@classmethod
def group_names(cls, instance, action):
# note that this will also override all other model bindings
# like `someuserownedobject-update` `someuserownedobject-create` etc
return ['user-%s' % instance.owner.pk]
虽然已经晚了，但我有一个直接解决渠道 2 的解决方案，即使用send而不是group_send
send(self, channel, message)
| Send a message onto a (general or specific) channel.
将其用作 -
await self.channel_layer.send(
self.channel_name,
{
'type':'bad_request',
'user':user.username,
'message':'Insufficient Amount to Play',
'status':'400'
}
)
处理它-
await self.send(text_data=json.dumps({
'type':event['type'],
'message': event['message'],
'user': event['user'],
'status': event['status']
}))
谢谢