在Kubernetes抛出错误上的Redis主/从设置: BRPOPLPUSH { ReplyError: MOVED 2651
在Kubernetes抛出错误上的Redis主/从设置: BRPOPLPUSH { ReplyError: MOVED 2651
提问于 2019-05-15 02:28:41
我正在使用优秀的基于Redis的Bull.js作为Kubernetes上的作业队列。
它被配置为一个集群：
当Kubernetes在部署时重新启动时，我会遇到以下错误：
BRPOPLPUSH { ReplyError: MOVED 2651 <IP_ADDRESS>:6379
at parseError (/usr/src/app/node_modules/ioredis/node_modules/redis-parser/lib/parser.js:179:12)
at parseType (/usr/src/app/node_modules/ioredis/node_modules/redis-parser/lib/parser.js:302:14)
command:
{ name: 'brpoplpush',
args:
[ '{slack}:slack notifications:wait',
'{slack}:slack notifications:active',
'5' ] } }<IP_ADDRESS>在哪里，我认为集群IP？我没有配置它，但我正在尝试调试它。我想知道我是否需要为Bull.js启用集群模式，或者这是否是Bull.js项目之外的配置问题？
还是K8s的网络问题？
启用：https://github.com/OptimalBits/bull#cluster-support是解决方案吗？这样做对吗？
这是我的代码：
import Queue from 'bull';
import config from 'config';
import { run as slackRun } from './tasks/send-slack-message';
import { run as emailRun } from './tasks/send-email';
const redisConfig = {
redis: {
host: config.redis.host,
port: config.redis.port
}
};
const slackQueue = new Queue('slack notifications', { ...redisConfig, ...{ prefix: '{slack}' } });
const emailQueue = new Queue('email notifications', { ...redisConfig, ...{ prefix: '{email}' } });
slackQueue.process(slackRun);
emailQueue.process(emailRun);
emailQueue.on('completed', (job, result) => {
job.remove();
});
export { emailQueue, slackQueue };import { emailQueue, slackQueue } from 'worker/worker';
const queueOptions = {
attempts: 2,
removeOnComplete: true,
backoff: {
type: 'exponential',
delay: 60 * 1000
}
};
emailQueue.add(
{
params: {
from: email,
fromname: name,
text: body
}
},
queueOptions
);
slackQueue.add(
{
channelId: SLACK_CHANNELS.FEEDBACK,
attachments: [
{
text: req.body.body
}
]
},
queueOptions
);这是configmap：
Name: redis-cluster-config
Namespace: default
Labels: <none>
Annotations: <none>
Data
====
update-node.sh:
----
#!/bin/sh
REDIS_NODES="/data/nodes.conf"
sed -i -e "/myself/ s/[0-9]\{1,3\}\.[0-9]\{1,3\}\.[0-9]\{1,3\}\.[0-9]\{1,3\}/${POD_IP}/" ${REDIS_NODES}
exec "$@"
redis.conf:
----
cluster-enabled yes
cluster-require-full-coverage no
cluster-node-timeout 15000
cluster-config-file nodes.conf
cluster-migration-barrier 1
appendonly yes
# Other cluster members need to be able to connect
protected-mode no
Events: <none>回答 1
Stack Overflow用户
回答已采纳
发布于 2019-05-19 21:39:07
不过，希托巴特是对的。
如果这没有帮助的话：
const Redis = require('ioredis');
...
const ioCluster = new Redis.Cluster([redisConfig.redis]);
const slackQueue = new Queue('slack notifications', {
prefix: '{slack}' ,
createClient: () => ioCluster
});
const emailQueue = new Queue('email notifications', {
prefix: '{email}' ,
createClient: () => ioCluster
});我将不使用ioredis，或者尝试将redis引擎降级到4.x。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/56140999
复制相关文章
相似问题
腾讯云开发者
