如何使用一个线程监听所有订阅通道的redis？
在云计算领域中，使用一个线程监听所有订阅通道的Redis可以通过以下步骤实现：
- 首先，确保已经安装并配置好Redis服务器，并且已经创建了需要订阅的通道。
- 在开发中，可以使用各种编程语言来连接Redis服务器，如Python、Java、Node.js等。选择一种你熟悉的编程语言，并安装相应的Redis客户端库。
- 在代码中，使用Redis客户端库连接到Redis服务器，并订阅需要监听的通道。具体的代码实现会因所选的编程语言和Redis客户端库而有所不同。
- 创建一个线程来监听订阅通道。线程可以使用Redis客户端库提供的订阅方法，如
subscribe或psubscribe。这些方法允许你指定要监听的通道或通配符。 - 在监听线程中，可以通过回调函数来处理接收到的订阅消息。根据业务需求，你可以在回调函数中执行相应的逻辑操作，如处理消息、存储数据等。
- 如果需要监听多个订阅通道，可以在订阅方法中指定多个通道或通配符。这样，线程将同时监听这些通道，并在有消息到达时触发相应的回调函数。
- 在监听线程中，可以使用循环来持续监听订阅通道。这样，线程将一直运行，直到手动停止或程序退出。
需要注意的是，使用单个线程监听所有订阅通道可能会导致性能问题，特别是在订阅通道数量较多或消息频繁的情况下。在实际应用中，可以考虑使用多线程或其他异步机制来提高性能和并发处理能力。
对于腾讯云的相关产品和产品介绍链接地址，可以参考以下内容：
- 腾讯云Redis：提供高性能、可扩展的分布式缓存服务，支持主从复制、读写分离、持久化等特性。详情请参考：https://cloud.tencent.com/product/redis
请注意，以上答案仅供参考，具体实现方式和腾讯云产品选择应根据实际需求和情况进行评估和决策。
相关·内容
11回答
我想使用redis的pubsub来传输一些消息，但不希望使用listen被阻塞，就像下面的代码：
import redis
rc = redis.Redis()
ps = rc.pubsub()
ps.subscribe(['foo', 'bar'])
rc.publish('foo', 'hello world')
for item in ps.listen():
if item['type'] == 'message':
print item['channe
浏览 0提问于2011-10-24得票数 32
回答已采纳
我们知道命令会阻塞Redis服务器，所以需要使用*SCAN命令。
据我所知，Redis服务器可以处理很多pubsub连接。那么，如果我在这样的服务器上调用命令，在执行此命令期间，它是否可以处理pubsub连接或其他命令？
浏览 13提问于2016-07-15得票数 0
1回答
我正在学习如何使用。
我是专门的功能。
我将与和结合使用。
我遇到过
var Redis = require("ioredis");
var redis = new Redis();
var pub = new Redis();
redis.subscribe("news", "music", function(err, count) {
// Now we are subscribed to both the 'news' and 'music' channels.
// `count` represen
浏览 3提问于2019-11-13得票数 0
回答已采纳
1回答
我计划重新设计一个现有的系统，使用Akka，Play和Websockets。
我目前的系统是基于Jetty和Websockets的。
我有一个快速的消息流被发布到一个Redis频道。在我的web应用程序层中，我使用Jedis订阅服务器订阅这些消息，然后将这些消息推送到Websocket，然后显示在浏览器上。
我想让这个转变有两个主要原因：( a)由于使用了Actors ( b)能够使用不同的参与者连接到多个流，所以更好和更简单的容错。
在我目前的设计中，我有一个主管，为每一个新频道创建一个新的儿童演员。然后，子演员订阅一个Redis频道。我的问题是，将消息(从Redis频道接收)推送到播放We
浏览 2提问于2014-03-21得票数 0
回答已采纳
1回答
我有一个python程序如下
import json
import threading
import redis
CHANNELS_PREFIX = 'client'
class Listener(threading.Thread):
STOP = 1
CONTINUE = 0
def __init__(self, r):
threading.Thread.__init__(self)
self.redis = r
self.pubsub = self.redis.pubsub()
浏览 0提问于2019-04-23得票数 1
回答已采纳
1回答
我有我的后端副本，以便提供水平扩展。后端有apollo graphql订阅。还存在为特定订阅提供通知的微服务。 因为我没有在后端保持任何状态，所以我尝试用实现Redis PUB/SUB来解决这个问题。微服务收到事件后，会发布到后台。 在后端的订阅解析器中 webhookCalled: {
subscribe: withFilter(
() => pubsubMyEvent.asyncIterator([MY_EVENT]),
(payload, _, context) => {
return
浏览 15提问于2020-07-13得票数 4
回答已采纳
2回答
如果我在Redis上的PUBLISH上有一个订阅者，但该订阅者需要1秒才能接收到消息，那么它将阻塞PUBLISH一秒，还是它们是独立的呢？
如果它们独立工作，那么有多少PUBLISH命令会在糟糕的事情发生之前排队呢？
浏览 3提问于2016-06-01得票数 1
回答已采纳
全
我已经安装了最新的Redis 2.4.16，并试图在java中使用它的Pub/Sub系统。我每秒钟都要给一个频道留言。发布服务器没有问题，但订阅服务器与消息崩溃。
异常：
redis.clients.jedis.exceptions.JedisDataException: ERR only (P)SUBSCRIBE / (P)UNSUBSCRIBE / QUIT allowed in this context
at redis.clients.jedis.Protocol.processError(Protocol.java:59)
at redis.clients.jedis.Proto
浏览 6提问于2012-08-25得票数 4
回答已采纳
我刚刚开始和redis混在一起，下面的场景告诉我：
考虑你有一个提交的表格，你想要保持跟踪的人在其中写(在一个网站)。你也想在某个地方监视它。
我想的是，由于redis是单线程的，所以在redis的内存中写在块上永远不会出现问题。
这里的问题是，显示器是否应该简单地从同一条信息中读取，或者是否应该订阅它并从中获取值？
对于像我这样的初学者来说，这两种方法基本上都是一样的，这两种方法都需要客户端在一个时间间隔内从字段中读取数据。有什么明显的区别吗？
浏览 3提问于2014-02-22得票数 1
回答已采纳
1回答
设置redis背板每篇文章：https://docs.microsoft.com/en-us/aspnet/core/signalr/redis-backplane?view=aspnetcore-3.1，一个人如何查看redis中发布的消息？我想确保redis pub/sub在不部署到2个不同的节点的情况下被实际使用。 配置： public void ConfigureServices(IServiceCollection services)
{
services.AddSignalR().AddStackExchangeRedis("localhost:6379"
浏览 28提问于2020-01-14得票数 0
回答已采纳
这也许是一个更普遍的线程问题，我不确定。
但是我有一个WPF应用程序，它订阅频道并监听来自redis数据库的消息。
App.SubscriptionThread = new Thread(() =>
{
_redisSubscription.SubscribeToChannels("ChannelA", "ChannelB");
});
App.SubscriptionThread.Start();
一旦我开始做这件事，我就不知道该如何阻止它。
我试过的东西。
使用Thread.Abort。这显然没有阻止它，因为线程只是进入一个挂起然
浏览 4提问于2014-01-18得票数 6
回答已采纳
2回答
我在node.js中有这样的服务器
socket.on('connection', function(client) {
const subscribe = redis.createClient(6379, '127.0.0.1')
subscribe.psubscribe('kitchen_*');
subscribe.on("pmessage", function(pattern, channel, message) {
client.emit(cha
浏览 1提问于2014-05-13得票数 1
回答已采纳
我有一个laravel应用程序，在它中，我使用php棘轮库在客户端和用户之间建立持久连接，以实现实时通信(目前这只是一种方式，即只有服务器才能向客户端发送消息)。
有了这个体系结构，我如何才能拥有多个这样的laravel服务器，每个服务器都有自己的一组客户端连接到它们，以便相互通信？
我正在考虑使用REDIS，并拥有一个redis服务器，我所有的节点都会连接到这个服务器(使用pub子)。
我的服务类似于一个组消息应用程序(一个用户有多个组，一个组有多个用户)，到目前为止(我只有一个服务器，没有redis)，我得到所有用户组，并订阅这些主题(主题名类似于GROUP_ 1、GROUP_ 8、GRO
浏览 2提问于2016-06-23得票数 1
如何在redis的pubsub和阻塞操作之间进行选择？
Redis提供了像BLPOP这样的阻塞操作，它会阻塞操作，直到可以从列表中弹出一个元素。为什么我不应该使用它来实现PUBSUB的功能。PUBSUB允许您定义比基本列表更高级别结构的通道。如果我的用例很简单，没有多个通道，我可以使用基本的阻塞操作吗？
浏览 0提问于2014-04-26得票数 6
我试着用redis向频道广播这个消息，但是每个用户都有他们自己的频道和他们的user_id。 我认为可以使用的方法是获取所有活跃的通道，然后逐个发布。因为据我所知redis不能发布不同的频道。 但问题是，在我使用的lib go-redis中，当用户使用PUBSUB CAHNNELS命令检查redis时，没有通道结果。我在文档中读到了subribe函数不会立即激活通道。那么我怎么才能获得subribe频道呢？ 有没有解决这个问题的办法？我正在使用golang-redis https://godoc.org/github.com/go-redis/redis
浏览 16提问于2019-05-11得票数 1
1回答
我使用Redis实现缓存结构，我的域如下所示：
有多个类别(3000+类别)。每个类别包含多个问题(每个类别大约有20-30个问题)。每个问题都有几个属性，比如它是否已经发布，类型是什么，等等
在加载问题时，我需要从几个类别中加载问题，并使用用户指定的与问题属性匹配的一些问题归档器:发布、键入等
我使用string和set：在Redis中实现了这一点。
每个问题都以字符串形式存储在Redis (序列化的JSON)中，其中键为：“QuestionId：”
每个类别都有属于它的问题ids列表(Redis设置)，其中键为：“CategoryId：问句”
对于每个类别，每个用户可过滤的属性都有自己的一
浏览 0提问于2014-11-17得票数 3
回答已采纳
我在使用Microsoft.Extensions.Caching.StackExchangeRedis的.NET 5中有一个Web。我已经使用给定包中的扩展方法添加了Redis cache的IDistributedCache实现。 services.AddStackExchangeRedisCache(options =>
{
options.Configuration = Configuration.GetConnectionString("RedisConnection");
}); 现在，当我从Redis请求一些东西时(因为它是一个单例)，它应该创建一个连
浏览 225提问于2021-10-28得票数 0
回答已采纳
我有几个问题，我在Redis教程中找不到答案 1)如何查看/查看Redis PubSub通道的值? Redis命令是用来调试Redis的，但我想看看之前推到通道的是什么。 2)通道和队列的确切区别是什么？ 3)如何在免费的web应用中监控Redis集群？
浏览 26提问于2019-03-02得票数 0
回答已采纳
我用的是redis-py。我订阅了redis数据库，并像这样阅读通知：
>>> p.psubscribe("__keyspace@{}__:*".format(...))
>>> for message in p.listen():
... # do something with the message
我想获取消息的操作，比如删除或添加，我该怎么做呢？
谢谢~
浏览 3提问于2018-11-13得票数 0
好的，我之前问过一个关于我的选择，我已经看过sockets.io和redis了，我真的很喜欢我看到的。
无论如何，我希望有多个客户端连接到一个node.js服务器。然后，当我的redis数据库发生变化时，例如从0到1的一些布尔值，我希望所有node.js连接将此更新发送给所有客户端。
我不是在寻找一些代码来循环和检查这种变化，我想知道当redis数据库中发生变化时，我如何才能向特定的客户端触发事件。任何psuedo代码都能帮我解决这个问题，那就太棒了。我也非常感谢任何展示如何将事件与redis实例中的更改挂钩的node.js代码。
干杯，乔希
浏览 0提问于2011-11-26得票数 0
回答已采纳
1回答
我正在用java构建一个推送服务器，并计划使用Redis PubSub来排队发送消息给客户端。
现在，我的实现在每个设备上都有一个redis订阅者。因此，当一个设备上线时，它将为它的设备订阅一个redis队列。
这种规模还可以吗?/有没有更好的方法？我会有成千上万的订阅者。
浏览 0提问于2014-01-07得票数 2
当我使用redis-cli时，在进入"pub/sub“模式后，我找不到任何方法订阅其他频道。例如：
$ redis-cli
redis> SUBSCRIBE channel:1
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "channel:1"
3) (integer) 1
当我按Ctrl-C组合键时，redis-cli退出而不是"pub/sub“模式。有人知道如何解决这个问题吗？
浏览 2提问于2012-11-20得票数 4
回答已采纳
谁能告诉我Redis pub-sub可以支持的并发通道的最大数量是多少？订阅者和发布者的数量有上限吗？
浏览 26提问于2020-01-23得票数 9
我正在尝试使用Redis Cookbook示例：
var http = require('http'),
io = require('socket.io')
fs = require('fs'),
redis = require('redis'),
rc = redis.createClient(9189, "pike.redistogo.com");
rc.auth("passwd", function() {
console.log("Connected! to redistog
浏览 0提问于2011-09-19得票数 9
回答已采纳
我正在构建一个部署到Heroku的应用程序，它使用WebSocket和Redis。
当我只使用1dyno时，WebSocket连接工作正常，但是当我缩放到2时，我发送事件给我的应用程序做了两次。
const ws = require('ws')
const jwt = require('jsonwebtoken')
const redis = require('redis')
const User = require('../models/user')
function verifyClient (info, callback
浏览 0提问于2018-11-01得票数 0
这是我的代码，使用socket.io作为WebSocket，并使用发布/订阅redis作为后端。
var io = io.listen(server),
buffer = [];
var redis = require("redis");
var subscribe = redis.createClient(); **<--- open new connection overhead**
io.on('connection', function(client) {
console.log(client.request.header
浏览 0提问于2011-04-21得票数 40
回答已采纳
我正在构建一个实时可视化，使用redis作为python和节点之间的pubsub信使。有一个python脚本总是在运行，它用hmset设置redis散列。如果我输入下面的示例命令："HGETALL‘sellers 80183917’“在redis客户机中，我最终得到了正确的数据。
问题在js方面。我正在使用socketio和redis库来侦听redis实例，并通过d3js在网上发布结果。
我使用节点运行以下代码：
var express = require('express');
var app = express();
var redis = require('
浏览 3提问于2016-09-27得票数 10
我有两个服务器server-a和server-b。
对于通常使用socket.io的服务器，这两个服务器都使用redis适配器。然后客户端可以连接到server-a或server-b。
现在的问题是:如果客户端连接到server-a并发出消息。server-b是否有获得消息的选项？
客户端代码：
io.emit('sendMessage',myMessage)
服务器-代码：
io.on('sendMessage',function(){
console.log('Server A got the message')
}
服务器-代码：
浏览 3提问于2016-08-08得票数 0
回答已采纳
我正在尝试使用nodejs和node_redis构建一个通用的发布/订阅服务器，它从浏览器接收带有通道名称的请求，并用该通道发布的任何数据进行响应。为此，我使用来自浏览器的长轮询请求，并通过在通道上收到消息时发送响应来处理这些请求。
对于每个新请求，都会创建一个用于订阅频道的对象(如果且仅当该对象不存在时)。
clients = {};
//when request comes in,
clients[channel] = redis.createClient();
clients[channel].subscribe(channel);
这是处理订阅渠道的最好方法，还是有其他更直观的方法？
浏览 22提问于2011-02-28得票数 4
回答已采纳
我的芹菜任务是对数据库存储的实体进行耗时的计算。工作流是这样的:从数据库获取信息，将其编译成可序列化的对象，保存对象。其他任务正在对加载的对象执行其他计算(如呈现图像)。
但是序列化很耗时，所以我希望每个实体有一个任务运行一段时间，它在内存中保存序列化的对象，并通过消息传递队列(redis pubsub)处理客户端请求。如果暂时没有请求，则任务将退出。在此之后，如果客户端需要完成一些工作，它将运行另一个任务，该任务加载对象，处理对象，并为其他作业进行一段时间的调整。此任务应在启动时进行检查，如果只有一个工作人员在此特定实体上，以避免冲突。，那么检查这个实体的另一个任务的最佳策略是什么？
( 1
浏览 0提问于2018-07-17得票数 0
1回答
我正在使用websockets、redis和线程进行基本的聊天设置。我在线程启动之前创建一个客户端数组，然后更新客户端数组。但是，线程中的客户端数组从未更新过。因此，当我试图向连接的客户端发布时，什么都不会发布。我正在处理一个，不知道为什么客户端数组没有更新。
这是我的代码：
class ChatBackend
KEEPALIVE_TIME = 15 # in seconds
CHANNEL = "chat-demo"
def initialize(app)
@app = app
@clients = []
uri
浏览 1提问于2015-09-21得票数 0
回答已采纳
我有一台Node.js服务器--我想让进程侦听来自自身的消息--这只是为了测试。我遇到的问题是，当向同一个进程发布消息时，订阅者似乎根本没有接收到它。
我有这样的设置：
var redis = require('redis');
var rcPub = redis.createClient();
var rcSub = redis.createClient();
var message = String('testing123');
rcSub.subscribe('redis_channel@test_overall_health');
浏览 1提问于2015-06-19得票数 3
回答已采纳
堆栈:Ruby2.3.1，Rack，瘦
简单的websocket服务器：
require 'redis'
require 'em-hiredis'
require 'faye/websocket'
require 'json'
ws_channel = {}
App = lambda do |env|
$redis ||= EM::Hiredis.connect('redis://127.0.0.1:6379')
if Faye::WebSocket.websocket?(env)
ws = Faye::We
浏览 3提问于2017-02-27得票数 1
回答已采纳
Redis服务器重启后，如何启动Redis实例运行的所有进程？
在我的应用程序中，我可以看到创建了Redis实例，但是Redis实例正在执行的所有订阅都没有重新启动。因此，应用程序不能从事件总线/ Redis总线接收新消息。
浏览 25提问于2015-09-02得票数 0
我对Pub/Sub范式感兴趣，以便提供通知系统(即:类似于Facebook)，特别是在一个web应用程序中(在同一个web服务器上的多个web应用程序中)和一个或多个订阅者，负责在web上为前端用户显示通知。
我发现Redis似乎是一个很棒的服务器，它提供了一些有趣的特性:缓存(比如Memcached)、Pub/Sub、queue。
不幸的是，我没有在web上下文中找到任何示例(ASP.NET，使用Ajax/jQuery)，除了WebSockets和NodeJS，但我不想(太早)使用这些示例。我想我需要一个进程(订阅者)来接收来自发布者的消息，但是我不知道如何在web应用程序中这样做(pub/
浏览 6提问于2011-06-22得票数 7
在我的项目中，我正在集群模式下使用亚马逊elastiCache。我使用了redis的键空间通知功能来监听特定的过期时间，在没有聚类.But的情况下工作得很好，我无法在订阅块中获取消息。
subscribe(`__keyevent@0__:expired`);
redis keyspace notification aws elastiCache for redis
浏览 1提问于2020-03-03得票数 1
我想知道是否有一种方法可以在指定的终止日期之后清除/刷新我的c#服务中的整个缓存。我如何在c#中实现这一点？
C#
// library
using StackExchange.Redis;
public class RedisCacheService
{
// Fields
ConnectionMultiplexer _Redis = null;
IDatabase _RedisDB = null;
// ctor
public RedisCacheService(String redisConnectionString) // , DateTim
浏览 4提问于2017-04-13得票数 1
回答已采纳
当我的web应用程序订阅一个Redis频道(主要是在Application_Start上)时，它应该自动加载当前频道的内容，而不是等待该频道的下一次发布。
我找不到任何方法来实现这一点--但由于这个“问题”似乎如此普遍和微不足道，我想肯定有一个简单的解决方案？
在web应用中，我使用的是StackExchange.Redis (如果这是相关的话)。谁能帮上忙？提前谢谢你！
浏览 22提问于2018-03-02得票数 0
5回答
我一直在尝试不同的nodeJS发布/订阅实现，想知道哪种实现最适合特定的应用程序。该应用程序的要求涉及多通道、多用户3D环境中的对象的实时同步。
我从使用socket.io开始，创建了一个基本的通道数组，当用户发送消息时，它循环通过该通道中的用户，并向用户的客户端发送消息。这个方法运行得很好，我对它没有任何问题。
为了对象持久化，我使用node_redis添加了Redis支持。然后，我将通道数组上的client.send循环替换为Redis发布/订阅作为抽象层。但是我注意到我需要为每个订阅的用户创建一个新的Redis客户端。而且我仍然需要存储socket.io客户端信息，以便在发布时向其发送消
浏览 0提问于2011-05-06得票数 14
回答已采纳
我希望构建一个像facebook这样的通知系统，其中我的应用程序逻辑(publisher)将所有用户生成的通知推送到redis系统。
User 1 --------------> Redis (Channel : notifications)
User 2 --------------> Redis (Channel : notifications)
User 3 --------------> Redis (Channel : notifications)
正如您在上面看到的，用户生成的所有活动都被发送到相同的通道通知。
我有一个node.js /socket.io服务器作
浏览 4提问于2014-07-03得票数 2
回答已采纳
2回答
我正在使用node js和redis实现一个TCP聊天服务器，但是我似乎不能使用发布和订阅在redis上持久化聊天数据，因此当我离开聊天室并重新进入聊天室时，我将不会更新最新的消息，我应该如何实现这样的东西？
浏览 3提问于2013-02-20得票数 0
回答已采纳
我查看了这些文档：
它指出：
当您订阅一个频道时，您将得到一条消息，该消息表示为包含三个元素的多批量回复。消息的第一个元素是消息的类型(例如订阅或取消订阅)。消息的第二个元素是要订阅或取消订阅的给定通道的名称。消息的第三个元素是当前订阅的通道数：
> SUBSCRIBE first second
*3 #three elements in this message: “subscribe”, “first”, and 1
$9 #number of bytes in the element
subscribe #kind of message
$5
浏览 2提问于2013-07-27得票数 1
回答已采纳
1回答
最近才开始阅读关于Redis和它是一个非常快的键值商店。它在引擎盖下也做了很多工作，因为它为缓存保留了大量内存，但在需要时也会写入磁盘。这是很好的，但它应该在什么时候使用。我觉得到处使用Redis可能有点过分，但它在哪里有意义呢？
上面的链接显示了一个很好的用户模型示例，它使用Redis来促进用户友谊。现在，在我看来，如果我只有10个用户，那么我可以写
class User < ActiveRecord::Base
# follow a user
def follow!(user)
$redis.multi do
$redis.sadd(self.redis
浏览 0提问于2014-05-23得票数 1
如何将发布到Redis通道的消息仅发送到订阅的服务器(连接到订阅者)，而不发送到我的其他服务器(其中所需的订阅者未连接)。
我使用的是Socket.IO和Redis服务器。
浏览 3提问于2017-06-27得票数 0
1回答
我正在使用BROADCAST_DRIVER=redis触发Laravel5.2事件。一旦我在命令提示符上运行了以下服务：
在第一个选项卡中，运行节点socket.js
你应该会看到“监听3000端口”
在第二个选项卡中，运行redis-server --端口3001。
在它打开两个浏览器窗口并排，在第一个点击网址："“
在第二部分："“
继续刷新第一个窗口，您将看到第二个页面的内容更新。
但是我不想刷新页面，我只想在后台触发广播事件，也不想运行服务“节点socket.js和redis服务器-端口3004”。
我已经安装了节点、redis、express iore
浏览 3提问于2016-06-03得票数 0
回答已采纳
1回答
红系酒吧/分限
、、
使用Redis pub/sub，是否有办法限制Redis将发布到的侦听器数量？
例如，使用Node.js术语：
var redis = require('redis');
var rcPub = redis.createClient();
var rcSub = redis.createClient();
rcPub.publish('channel','messageA',{limit:1}); //desired functionality/syntax
基本上，当我向Redis发送messageA时，我想告诉Redis只向一个侦听器/订
浏览 1提问于2015-06-02得票数 2
回答已采纳
我正在尝试创建聊天室应用程序，并使用redis酒吧/订阅广播信息在订户之间。每个会议室都是一个频道。问题是，随着时间的推移，我可以拥有无限多的频道。
是否对我可以在redis中拥有的最大频道数有任何限制？是否有任何方法自动过期/删除尚未收到任何发布消息的通道？
浏览 0提问于2020-09-18得票数 0
回答已采纳
的架构是什么？
客户机/服务器数据库同步在中到底是如何工作的
redis DB的用途是什么，您用它进行数据同步吗？
我想要一个类似于这个架构的图片：
浏览 3提问于2015-10-17得票数 1
回答已采纳
1回答
我需要关于使用网络套接字和redis酒吧/子频道的性能建议。我用龙卷风做网络服务器。
我有大约100个客户，他们在听某一事件的状态。每个客户端都有单独的事件，只需要侦听自己的事件。套接字连接是短命的，大约1-20秒。我认为有两种选择：
为每个套接字事件对在redis中创建单独的发布/子通道。在这种情况下，我将有许多渠道。
创建一个发布/子通道，订阅它的所有客户端，并过滤控制器中的消息，将它们转发给适当的客户端。在这种情况下，我有许多客户听一个频道。
这些选项中哪一个对性能更好？
浏览 1提问于2015-03-04得票数 0
回答已采纳
我有两个角色医生和病人..。
当病人做A动作时，我想要一个广播去看医生的名单，不是所有的医生，而是他们的名单。
在我的测试中，我能够做到这一点:在节点中订阅redis到以医生和连字符为前缀的通道，然后是UserID.
redis.subscribe('Doctor-1', function(err, count) {
});
但是，对于生产，我不能硬编码那个ID，我需要的是以下内容
redis.subscribe('Doctor-*', function(err, count) {
});
但通配符似乎行不通..。
对我如何订阅通配符有什么想法吗？
浏览 2提问于2017-12-27得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
