Cuối cùng thì tôi cũng đã hoàn thành và nó hoạt động tốt.
Tôi sẽ để bạn ở đây mã của tôi, tôi hy vọng điều này sẽ giúp ích cho những người khác!
var Redis = require('ioredis');
// preferredSlaves array format
var preferredSlaves = [
{ ip: config.redis_slave_1, port: config.redis_port, prio: 1 },
{ ip: config.redis_slave_2, port: config.redis_port, prio: 2 }
];
var redis = new Redis({
port: config.redis_port,
host: config.redis_host,
sentinels: [{ host: config.redis_sentinel_1, port: config.redis_sentinel }, { host: config.redis_sentinel_2, port: config.redis_sentinel }, { host: config.redis_sentinel_3, port: config.redis_sentinel }],
name: config.redis_master_name,
password: config.redis_password,
preferredSlaves: preferredSlaves
});
redis.on('connect', function(err, res) {
logger.info('Connected to Redis ' + process.pid);
redisIsReady = true;
console.log('Connected to Redis ' + process.pid + " REDIS " + JSON.stringify(redis.options) )
});
redis.on('error', function(err) {
logger.error('Error connecting to Redis ' + process.pid);
redisIsReady = false;
console.log('error to Redis ' + err)
});
Cảm ơn vì tất cả phản hồi của bạn,
Trân trọng !!