python redis和命令PUBSUB通道
Python Redis是一个Python语言的Redis客户端库，它提供了与Redis数据库进行交互的功能。Redis是一个开源的内存数据结构存储系统，它可以用作数据库、缓存和消息中间件。
PUBSUB是Redis中的一种发布-订阅模式，它允许客户端订阅一个或多个频道，并接收发布到这些频道的消息。通过PUBSUB通道，可以实现实时消息传递和事件驱动的架构。
Python Redis的优势包括：
- 简单易用：Python Redis提供了简洁的API，使得与Redis数据库的交互变得简单和直观。
- 高性能：Redis以内存为存储介质，具有快速的读写速度和低延迟，适用于高并发场景。
- 多种数据结构支持：Redis支持多种数据结构，如字符串、哈希表、列表、集合和有序集合，Python Redis提供了对这些数据结构的操作方法。
- 持久化支持：Redis支持数据持久化，可以将数据保存到磁盘上，以防止数据丢失。Python Redis提供了对Redis的持久化功能的支持。
- 发布-订阅模式：通过PUBSUB通道，Python Redis可以实现实时消息传递和事件驱动的架构，方便实现分布式系统和实时通信。
Python Redis的应用场景包括：
- 缓存：由于Redis的高性能和丰富的数据结构支持，它常被用作缓存层，加速访问数据库或其他计算密集型操作。
- 分布式锁：Redis的原子操作和发布-订阅模式可以用于实现分布式锁，保证多个进程或线程之间的互斥访问。
- 实时消息传递：通过PUBSUB通道，Redis可以实现实时消息传递，适用于聊天应用、实时推送等场景。
- 计数器和排行榜：Redis的原子操作和有序集合可以用于实现计数器和排行榜功能。
- 会话管理：Redis可以用于存储和管理用户会话信息，实现跨请求的状态共享。
腾讯云提供了云数据库Redis版（https://cloud.tencent.com/product/redis）和云消息队列CMQ（https://cloud.tencent.com/product/cmq）等产品，可以与Python Redis结合使用，实现高可用、可扩展的Redis数据库和消息队列服务。
相关·内容
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
回答已采纳
我们知道命令会阻塞Redis服务器，所以需要使用*SCAN命令。
据我所知，Redis服务器可以处理很多pubsub连接。那么，如果我在这样的服务器上调用命令，在执行此命令期间，它是否可以处理pubsub连接或其他命令？
浏览 13提问于2016-07-15得票数 0
堆栈: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教程中找不到答案 1)如何查看/查看Redis PubSub通道的值? Redis命令是用来调试Redis的，但我想看看之前推到通道的是什么。 2)通道和队列的确切区别是什么？ 3)如何在免费的web应用中监控Redis集群？
浏览 26提问于2019-03-02得票数 0
回答已采纳
要订阅哨兵故障转移，通道的名称是什么，以及如何检测到需要刷新订阅函数中的主程序？
我有一个使用Redis实现高可用性和故障转移的多节点Redis设置。
我需要设置一个Pub/Sub到Redis，以检测Redis何时失败并且系统已经选择了一个新的Master。
_sentinel = redis.sentinel.Sentinel([(app.config["REDIS_HOSTNAME"],app.config["REDIS_SENTINEL_PORT"])])
_master = _sentinel.master_for(app.config["RED
浏览 1提问于2016-12-02得票数 1
如何在redis的pubsub和阻塞操作之间进行选择？
Redis提供了像BLPOP这样的阻塞操作，它会阻塞操作，直到可以从列表中弹出一个元素。为什么我不应该使用它来实现PUBSUB的功能。PUBSUB允许您定义比基本列表更高级别结构的通道。如果我的用例很简单，没有多个通道，我可以使用基本的阻塞操作吗？
浏览 0提问于2014-04-26得票数 6
1回答
我使用Redis PubSub消息传递系统用Python语言编写了以下代码。
发布方：
import redis
def func1(m):
queue = redis.StrictRedis(host='localhost', port=6379, db=0)
channel = queue.pubsub()
queue.publish("message", m)
if __name__=='__main__':
while True:
m = raw_input('Enter message: &
浏览 2提问于2017-04-28得票数 4
我正在构建一个实时可视化，使用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
2回答
假设有一个redis客户机订阅通道c1，另一个redis客户端将“数据”发布到通道c1。
此时，当订阅"c1“的客户端获得数据(通过调用pubsub.listen()或pubsub.get_message())或通过redis服务器直接订阅通道c1时，发布的数据是否在redis服务器中挂起？
换句话说，当redis客户端调用pubsub.getMessage()或pubsub.listen()时，redis客户端是向redis服务器发送请求以获取数据，还是只从本地套接字缓冲区获取数据？
当我阅读一些文档时，它是说pubsub.get_message()在内部使用select模块作为套接
浏览 6提问于2015-12-29得票数 0
回答已采纳
import redis
import threading
class Listener(threading.Thread):
def __init__(self, r, channel):
threading.Thread.__init__(self)
self.redis = r
self.pubsub = self.redis.pubsub()
self.pubsub.subscribe(channel)
def run(self):
for item in self.pubsub.listen():
浏览 3提问于2013-11-24得票数 2
2回答
我正在使用gin框架构建一个API服务器。一般来说，我要建两个项目。项目'API'和项目'SOCKET'。项目'API'是主要的REST，它将在安卓系统中使用，使用gin框架(golang)开发。项目'SOCKET'是客户端的套接字服务器，它将使用套接字连接，使用node.js (Socket.IO)
这个过程是这样开始的：
用户A:作为请求者；连接到"API"
用户B:作为响应者；B连接到"SOCKET"
User A调用API requestData，该请求将由"API"的项目处
浏览 4提问于2016-12-17得票数 3
回答已采纳
我试着用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
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中接收密钥更改发布子通知，方法是启动服务器如下：
./redis-server --notify-keyspace-events KEA
然后简单地运行以下脚本：
import redis
connection = redis.StrictRedis()
pubsub = connection.pubsub()
pubsub.subscribe("__keyspace@0__:my_key")
在单独的侦听器线程中。收到的消息如下所示：
{'pattern': None, 'type': 'message',
浏览 3提问于2017-03-02得票数 12
我开始使用aioredis，但我无法使用aioredis创建一个Redis pubsub对象，尽管遵循文档中的方法。 下面是我的代码： redis = await aioredis.create_redis(url, encoding="utf-8")
sub = redis.pubsub()
await sub.subscribe(channel) 我得到了错误：AttributeError: 'Redis' object has no attribute 'pubsub' python3 -m pip show aioredis的输出 Na
浏览 174提问于2021-06-29得票数 0
回答已采纳
我有一个小项目与1个测试，需要很长时间来收集。我已经在收藏品和收藏品报告上盖了图章。在22:51:59和22:52:04之间，我不确定发生了什么，但这就是(空闲？)正在发生暂停。
[pytest]
testpaths = myproject/tests
python_files = *.py
addopts = -s
norecursedirs = docs *.egg-info .git appdir .tox __pycache__ .cache
root@0d696173168f:/var/www/myproject# pytest myproject/tests/redis/
===
浏览 3提问于2016-10-08得票数 0
var redis = require('redis');
var redisClient = redis.createClient({host : 'localhost', port : 6379});
var x = redisClient.pubsub.channels //Cuz this is similar to PUBSUB CHANNELS
console.log(x);
即使在我的redis服务器上有通道时，上面的代码也会返回“未定义”。我.我用得对吗？如果是的话，是否有其他方法可以访问redis服务器上可用的信道。
我正在使用'red
浏览 1提问于2017-06-28得票数 0
回答已采纳
1回答
我正在尝试开发一个基于Python和Redis的通知系统。我一直在检查python redis ，并看到了一个小的模式订阅示例：
p.psubscribe('my-*', ...)
理论上，这就是我的方法，所以我尝试了类似的方法
import redis
import time
r =redis.StrictRedis(host = 'localhost', port=6379, db=0)
p = r.pubsub()
p.psubscribe('*')
for msg in p.listen():
print time.time(
浏览 6提问于2016-11-18得票数 0
回答已采纳
我在pubsub模式下使用Redis作为消息代理。只有1个发布者和N个订阅者在侦听同一通道。对于原始的pubsub模式，这N个订阅者每次都会收到“相同”的消息。我的问题是，Redis内部是否有任何机制或任何其他方式让这些订阅者获得不同的消息？
浏览 4提问于2020-10-24得票数 0
1回答
我正在用java构建一个推送服务器，并计划使用Redis PubSub来排队发送消息给客户端。
现在，我的实现在每个设备上都有一个redis订阅者。因此，当一个设备上线时，它将为它的设备订阅一个redis队列。
这种规模还可以吗?/有没有更好的方法？我会有成千上万的订阅者。
浏览 0提问于2014-01-07得票数 2
1回答
我目前正在开发一个围绕Redis Pubsub的包装器，以获取一个Subscriber实例。我正在尝试使其对连接中断具有健壮性。根据文档，“在网络错误或超时等断开连接的情况下，PubSub对象将在重新连接时重新订阅所有以前的通道和模式”。但它似乎对我不起作用。 下面是一个PubSub流程的工作示例： >>> import redis
>>> r = redis.Redis(host="172.17.0.2", port=6379)
>>> r.ping()
True
>>> sub = r.pubsub(
浏览 59提问于2021-03-31得票数 1
回答已采纳
我有一个通过redis pubsub实时发送财务节拍数据的过程。现在，我希望我的Python应用程序处理输入数据(json)，例如移动平均等计算。我希望通过redis将结果发送回其他任务(根据第一个任务的结果做进一步的计算)。此外，我想要有规律地触发一些任务，每天一次或每秒一次。对于这个复杂和未知的结构问题，我偶然发现了一些解决方案，比如gevent、Celery或just Threads。
但我想知道的是，我有什么选择来正确地做这件事？如何通过以最有效的方式处理Worker/Task内容来构建我的redis pubsub？因此，欢迎您在库(如果您使用过上述内容，请分享您的经验)、技术(Pyt
浏览 0提问于2011-10-13得票数 2
我正在尝试使用python订阅redis中的keyspace事件。我希望在调用.psubscribe()之后不要使用.listen()的for循环。这个是可能的吗？ 我已经用KEA启用了所有的键空间事件。 def subscribe(self, key, handler):
# this function never gets called, if I don't add the for-loop with listen() below
def event_handler(msg):
print('Handler
浏览 72提问于2019-03-12得票数 9
1回答
我有一个节点进程，它当前在上接收POST请求。每当有任务进入时，我都想通知python进程。我使用的是node_redis和redis-py，其实现如下所示。
当节点进程在本地运行时，下面的代码在本地工作得很好，当我将节点端点推送到服务器时，我似乎没有得到事件？
如何从python客户端订阅服务器上的端点？遗漏了什么？我确实在服务器上部署了redis服务器。
javascript
var redis = require("redis"),
//redisClient = redis.createClient();
redisClient = redis.
浏览 9提问于2019-10-26得票数 3
在我现有的djangorest api中，我想从python代码的一侧在Redis通道中发布一条消息。我想异步地这样做，也就是说，想要调用一个异步函数，它将向通道发送消息，同时我的api应该响应用户，而不是阻塞该redis通信。
让我们看看例子。
代码下面的运行良好，
#Python function (api function)
def create(self, request, *args, **kwargs):
queryset = Order.objects.all()
serializer_class = OrderSerializer
#some busin
浏览 2提问于2020-08-25得票数 0
我有一个用Node.js编写的基本Web，它将一个对象作为一个HSET写入一个Redis缓存。两人都在码头集装箱里运行。
我有一个Python脚本运行在同一个VM上，它需要查看Redis缓存，然后在出现新的HSET或对HSET中的字段进行更改时运行一些代码。
我遇到了Redis /Sub，但我不确定这是否真的是正确的使用方式。
为了进行测试，我创建了两个Python脚本。第一个订阅消息传递系统：
import redis
import json
print ("Redis Subscriber")
redis_conn = redis.Redis(
host=
浏览 15提问于2022-11-15得票数 0
回答已采纳
我正在尝试构建的python应用程序遇到了一个问题:基本上，我有一个从Redis PUBSUB连接接收简单json数据的脚本，我想将这些数据作为websocket服务器提供给客户端。因此，基本上，每次我从redis连接收到一条消息时，都必须使用websockets将该消息发送到客户端。 下面是我的基本代码： 从redis pubsub连接接收数据的部分： import json
import redis
redis_url = 'MY-URL'
channel = 'test'
connection = redis.StrictRedis.from_url
浏览 140提问于2021-02-25得票数 0
回答已采纳
1回答
我一直有问题，配置卡夫卡和Redis一起在拉拉维尔。
我能够运行Redis来使用内存数据库.所以Redis工作得很好。
$redis = app()->make('redis');
return $redis->get('name1'); // it runs fine returning value of "name1"
我能够在我的windows系统中配置Kafka，在这里我可以在终端中生成和消费消息。
成功地将Rdkafka配置为php客户端库和扩展。
我在Laravel为卡夫卡使用的软件包是"superbalist/l
浏览 0提问于2018-12-17得票数 0
4回答
我想知道如何异步使用Redis和Tornado。我找到了，但我需要的不仅仅是在代码中添加一个yield。
我有以下代码：
import redis
import tornado.web
class WaiterHandler(tornado.web.RequestHandler):
@tornado.web.asynchronous
def get(self):
client = redis.StrictRedis(port=6279)
pubsub = client.pubsub()
pubsub.subscribe(
浏览 2提问于2013-03-01得票数 14
我正在尝试创建一个系统，通过这个系统，我的应用程序可以接收来自Redis PubSub通道的流数据并对其进行处理。我使用的以及我看到的用于Rust的所有其他Redis驱动程序，都使用阻塞操作从通道获取数据，该通道只在接收数据时返回值：
let msg = match pubsub.get_message() {
Ok(m) => m,
Err(_) => panic!("Could not get message from pubsub!")
};
let payload: String = match msg.get_payload
浏览 1提问于2016-08-11得票数 7
1回答
到目前为止，我一直在这样做：
import (
_redis "gopkg.in/redis.v3"
"strconv"
"time"
)
type Redis struct {
Connector *_redis.Client
PubSub *_redis.PubSub
}
var redis *Redis = nil
func NewRedis() bool {
if redis == nil {
redis = new(Redis)
redi
浏览 2提问于2015-08-31得票数 1
回答已采纳
我想从nodeJs服务器获取redis服务器中的哈希数据
我把这个剧本放在红宝石里
$redis.hset("token:test", 'user_id', 12)
如何在我尝试过的NodeJs服务器中获取“token:test”值
var pubsub = redis.createClient();
pubsub.hget("token:test",'user_id');
但它说未定义的:(
有谁可以帮我？?
浏览 1提问于2011-07-20得票数 1
回答已采纳
我有一个包含2个复制节点的AWS ElastiCache实例(集群模式禁用)。我能够使用redisson (在同一集群中运行的服务)通过我的java客户端进行连接。但是，当我使用python redis客户端时，它似乎无法连接。或者它似乎连接了，但没有订阅。我没有看到任何关于连接的错误，但是当我订阅一个发布/订阅主题时，我也没有得到任何确认。即使是返回成功订阅的1的第一条消息也没有。不知道我做错了什么。同样，如果我连接到本地的redis实例，它也会起作用。代码如下： self.redis_conn = redis.Redis(host=os.environ.get(host), port=6
浏览 25提问于2021-08-16得票数 0
回答已采纳
是否有办法通过StackExchange.Redis库获取特定Redis频道的频道订阅数？当直接与Redis交互时，它将使用PUBSUB命令()，但我在C#客户端库中没有看到类似的调用。
浏览 5提问于2014-10-14得票数 4
回答已采纳
2回答
我使用的是redis-py 2.10.6和redis 4.0.11。
我的应用程序对db和pubsub都使用redis。当我关机时，我经常会被绞死或撞车。后者通常抱怨一个糟糕的文件描述符或文件上的I/O错误(我不使用任何)，而这个错误是在处理pubsub回调时发生的，因此我猜底层问题是一样的:不知怎么的，我没有正确地断开连接，而且我的redis.Redis对象使用的池是活动的和正在运行的。
前一类错误的输出示例(在_read_from_socket期间)：
redis.exceptions.ConnectionError:读取套接字时出错：(9，“坏文件描述符”)
其他时候，堆栈跟踪清楚地显示
浏览 3提问于2019-10-22得票数 5
我所做的：
我正在使用来自github.com/go-redis/redis的golang Redis库。我的客户在一个名为“控制”的PubSub频道上收听。每当消息到达时，我都会处理它并继续接收下一条消息。我没完没了地听着，信息可能会经常传来，有时几天也不会。
我所期望的：
我希望redis频道能够无休止地开放，并在发送消息时接收它们。
我的经历是：
通常情况下，它会运行几天，但是client.Receive()每隔一段时间会返回EOF错误。发生此错误后，客户端将不再在该通道上接收消息。在内部，redis客户端打印以输出以下消息：
redis: 2019/08/29 14:18:57 pu
浏览 0提问于2019-09-03得票数 3
回答已采纳
1回答
我创建了一个简单的Django通道使用者，它连接到Redis通道并从这个通道接收一些数据，我想将这些数据发送到前端。
使用者能够连接到使用者并接收数据；问题是，如果我试图在使用者运行时加载页面，页面将在加载时被卡住。我确信这是因为与Redis通道的连接是一个阻塞操作，或者可能是线程的问题。我对这个概念很陌生，所以我决定提出一个问题。
这是我的消费者：
class EchoConsumer(AsyncConsumer):
async def websocket_connect(self, event):
self.send({
'
浏览 3提问于2020-04-09得票数 1
回答已采纳
3回答
Redis支持PUBSUB。订阅很容易：
redis 127.0.0.1:6379> subscribe foo
Reading messages... (press Ctrl-C to quit)
1) "subscribe"
2) "foo"
3) (integer) 1
但是，取消订阅似乎是不可能的，因为在订阅时，服务器不接受命令。例如，在随redis附带的redis-cli客户机中，控件不会返回给客户机，所以如果我键入unsubscribe，它就不会去任何地方。
这似乎是文档、函数或PEBKAC问题中的一个明显错误。怎么回事？
版本：
$./re
浏览 7提问于2013-07-12得票数 5
1回答
我使用Redis触发子进程并保存对它的引用。当下一条消息传入时，我想终止前面的进程。不幸的是，虽然我可以在调试器中看到子进程，并且它有一个终止()函数，但它似乎不像是main可以看到它--我收到一个错误消息，它说'NoneType‘对象没有属性’终止‘。是否有一种直接的方式来终止这个过程？
我的代码(在“main”中)：
conn = redis.Redis(host="localhost", port="6379")
if not conn.ping():
raise Exception('Redis unavailable&#
浏览 3提问于2021-05-10得票数 0
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
回答已采纳
1回答
我有两个NoSQL DBMS：MongoDB和Redis
Redis有著名的PubSub，MongoDB的逻辑最接近RDBMS，最适合从SQL过渡到NOSQL，而且由于MongoDB用于python Dictionaries和< code >D12</code>，例如，如果用户添加或删除一个产品，则会改变list的长度，因此，可以在此处将代码编写为notificator，
那么在这里使用Redis的好处在哪里呢？
浏览 0提问于2012-09-18得票数 1
回答已采纳
EdgeX默认使用Redis PubSub作为其消息传递总线()。
我已经在本地启动了Redis服务器。
我已经运行了Core数据和/或设备服务，我认为默认配置为使用Redis Pub/Sub。
我有一个虚拟设备服务，它将数据发布到edgex/events/#主题()。
最后，我已经将我的应用程序服务配置为订阅主题edgex/events/#，如示例所示。
[Trigger.EdgexMessageBus]
Type = "redis" # message bus type (i.e "redis`, `mqtt` or
浏览 6提问于2022-08-22得票数 0
回答已采纳
1回答
我正在构建一个以Redis为数据库的通知模型。每次添加到数据库中的特定键时，我都会使用Redis的pubsub特性和基于HTTP的通知通知远程客户机(用Redis-py编写)。
运行性能测试和比较Redis PUBSUB通知和HTTP响应之间的时间相当接近( redis仍然比HTTP快几毫秒。举例说明。Redis通知耗时47ms，HTTP通知耗时56ms)。
我以为Redis PUBSUB会比HTTP快得多。这是通过HTTP发送redis通知的预期性能吗？有没有更快的方式从Redis数据库推送通知(比HTTP更快)？
浏览 12提问于2018-05-16得票数 0
在我的应用程序中，我动态地创建了新的pubsub频道，每天可能有太多的5k。根据我的应用程序的要求，任何频道最多只能使用5分钟。
考虑到这种情况，一周内将有数千个未使用的频道出现在app中。那么，我如何删除不使用的频道，或者我是否应该删除它们。它们是否存储在内存中？通过它们发布的消息会发生什么，它们会留在redis的内存中吗？
谢谢
浏览 8提问于2013-05-16得票数 12
回答已采纳
1回答
我使用python发布和订阅消息队列。
publisher
rc = redis.Redis(host='127.0.0.1', port=6379)
rc.ping()
ps = rc.pubsub()
ps.subscribe('bdwaf')
r_str = "--8198b507-A--"
for i in range(0, 20000):
rc.publish('bdwaf', r_str)
用户
rc = redis.Redis(host='localhost', port=6379)
rc.p
浏览 3提问于2017-06-28得票数 1
从redis获取消息时，onDone:(){print('done')}从不工作。 import 'package:dartis/dartis.dart' as redis show PubSub;
void main() async {
final pubsub = await redis.PubSub.connect<String,
String>('redis://localhost:6379');
// Subscribe to some channels and patterns
pubsub
..s
浏览 16提问于2019-01-06得票数 3
回答已采纳
1回答
我正在使用python从redis获取数据，然后将其解析为kafka。它在大多数情况下都工作得很好。
但是当我使用python模拟构建数据到redis，或者在队列中有一个快速的输入数据时，我不能获得所有的数据。
这是我的代码，关于redis producer来模拟构建20000数据到redis：
rc = redis.Redis(host='127.0.0.1', port=6379)
rc.ping()
ps = rc.pubsub()
ps.subscribe('bdwaf')
r_str = "--8198b507-A--\n[22/Jun/201
浏览 16提问于2017-06-27得票数 0
1回答
我正在编写一个应用程序，其中一个进程应该将数据发送到多个订阅通道。这个过程事先不知道频道(因为客户端订阅了不同的主题)，所以我需要查询所有活动的订阅，以了解要获取和发送哪些数据。我找到了Redis命令：
127.0.0.1:6379> pubsub channels
但是: 1.它总是返回一个空的list。2.我在Jedis或Spring实现中找不到Java的等价物。
浏览 3提问于2015-11-18得票数 1
1回答
我有四个不同的Redis订阅设置在Azure。我还有四个App，每个服务都使用一个Redis订阅。四个App /Redis订阅用于相同的代码库，但环境不同。我用的是测试、分期、东海岸和西海岸的生活环境。
在每个应用程序服务中运行的代码完全相同。
我有一个使用ASP.NET的StackExchange.Redis核心Web项目。在我的Web项目中，我连接到Azure中设置的Redis订阅，它对应于App的环境。作为Web项目启动过程的一部分，我打开了四个PubSub通道。
对于测试、分阶段和西海岸活动环境，创建了四个PubSub通道并正常工作。我可以通过Azure连接到Redis控制台，并运行P
浏览 1提问于2018-04-26得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
