我在我的web应用中使用jdish.publish,在我的桌面应用中使用jedis.subscribe。因此两者都是独立的应用程序。
我有一个pubsub类
public class RedisNewPostListener extends JedisPubSub {
private final Jedis jedis;
private final AppInstances appInstances;
public RedisNewPostListener(AppInstances instances, Jedis jedis) {
this.jed
全
我已经安装了最新的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
EdgeX默认使用Redis PubSub作为其消息传递总线()。
我已经在本地启动了Redis服务器。
我已经运行了Core数据和/或设备服务,我认为默认配置为使用Redis Pub/Sub。
我有一个虚拟设备服务,它将数据发布到edgex/events/#主题()。
最后,我已经将我的应用程序服务配置为订阅主题edgex/events/#,如示例所示。
[Trigger.EdgexMessageBus]
Type = "redis" # message bus type (i.e "redis`, `mqtt` or
以此示例代码为例:
//Redis Variables
var redis = require('socket.io/node_modules/redis');
var RedisStore = require('socket.io/lib/stores/redis');
var pub = redis.createClient();
var sub = redis.createClient();
var client = redis.createClient();
var redis_store = new RedisStore({
我正在学习如何使用。
我是专门的功能。
我将与和结合使用。
我遇到过
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
我用的是redis-py。我订阅了redis数据库,并像这样阅读通知:
>>> p.psubscribe("__keyspace@{}__:*".format(...))
>>> for message in p.listen():
... # do something with the message
我想获取消息的操作,比如删除或添加,我该怎么做呢?
谢谢~