node.js - 如何为发布订阅实例化多个Redis连接(node.js + node_redis)

Question

场景

使用 node_redis 构建一个简单的 Redis 发布订阅(聊天)示例:https://github.com/nelsonic/hapi-socketio-redis-chat-example (使用 Hapi.js 和 Socket.io)

我们在项目中创建了一个 Node 模块 redis_connection.js(参见:http://git.io/vqaos)来实例化 Redis 连接，因为我们不想重复多次连接(到 RedisCloud)的代码:

var redis = require('redis');
var url   = require('url');
var redisURL    = url.parse(process.env.REDISCLOUD_URL);
var redisClient = redis.createClient(redisURL.port, redisURL.hostname,
                  {no_ready_check: true});
redisClient.auth(redisURL.auth.split(":")[1]);

module.exports = redisClient;

然后我们像这样使用:

var redisClient = require('./redis_connection.js');

// Confirm we are able to connect to  RedisCloud:
redisClient.set('redis', 'working', redisClient.print);
redisClient.get('redis', function (err, reply) {
  console.log('RedisCLOUD is ' +reply.toString());
});

这适用于 Redis 的正常 GET/SET 操作，但是当我们尝试实例化到 Redis 的多个连接时(例如:一个用于发布，另一个用于订阅，第三个仅用于 GET/SET 键/值)，我们得到一个错误:

问题

我们看到以下错误:

错误:订阅者模式下的连接，只能使用订阅者命令

我们做错了什么？

我们看到此问题时的完整代码:http://git.io/vqa6y

注意事项

我们尝试挖掘关于此的现有 SO Q/A，例如:

• Publish subscribe with nodejs and redis(node_redis)
• Redis publish/subscribe: see what channels are currently subscribed to
• how to use the redis publish/subscribe

但没有找到完全符合我们情况的解决方案...

(非常感谢任何建议/帮助!)

Answer 1

未经测试，但评论时间太长。

尝试定义另一个 redis 连接模块，一个用于您的常规使用，另一个仅用于您的 pubsub 订阅使用。

将 redis_pubsub_connection.js 添加到您的项目中:

var redis = require('redis');
var url   = require('url');
var redisURL    = url.parse(process.env.REDISCLOUD_URL);
var redisPubSubClient = redis.createClient(redisURL.port, redisURL.hostname,
                  {no_ready_check: true});
redisPubSubClient.auth(redisURL.auth.split(":")[1]);

module.exports = redisPubSubClient;

并将您的 publish.js require 语句更改为:

var redis = require('./redis_pubsub_connection'); // RedisCloud