gpt4 book ai didi

java - Redisson + redis 哨兵。如何处理故障转移并写入redis?

转载 作者:可可西里 更新时间:2023-11-01 10:53:24 40 4
gpt4 key购买 nike

我刚刚编辑了我之前的问题,并提供了更多详细信息(希望有人能够提供帮助)。

我有一个包含 1 个主服务器和 2 个从服务器的 Redis 集群。所有 3 个节点都由 Sentinel 管理。故障转移工作正常,当新的主控被选出时,我可以在新的主控上写(从命令行)。现在,我正在尝试使用 Redisson 编写一个小的 Java 程序,理想情况下应该将记录写入 redis,并能够处理故障转移(据我所知它应该这样做)。到目前为止,这是我的代码。

import org.redisson.Redisson;
import org.redisson.RedissonNode;
import org.redisson.api.*;
import org.redisson.api.annotation.RInject;
import org.redisson.config.Config;
import org.redisson.config.RedissonNodeConfig;
import org.redisson.config.SubscriptionMode;
import java.util.Collections;
import java.util.UUID;


public class RedissonTest {

public static class RunnableTask implements Runnable {
@RInject
RedissonClient client;

@Override
public void run(){
System.out.println("I am in ..");
RMap<String, String> map = client.getMap("completeNewMap");
System.out.println("is thread interrupted?? " + Thread.currentThread().isInterrupted());

NodesGroup ngroup = client.getNodesGroup();
Collection<Node> nodes = ngroup.getNodes();
for(Node node : nodes){
System.out.println("Node ip "+ node.getAddr().toString()+" type: "+node.getType().toString());
}

for(int i=0; i < 10000; i++) {
String key = "bg_key_"+String.valueOf(i);
String value = String.valueOf(UUID.randomUUID());
String oldVal = map.get(key);
map.put(key, value);

RBucket<String> bck = client.getBucket(key);

bck.set(value);

System.out.println("I am going to replace the old value " + oldVal + " with new value " + value + " at key "+key);

}
System.out.println("I am outta here!!");
}
}

public static void main(String[] args) {
Config config = new Config();
config.useSentinelServers()
.setMasterName("redis-cluster")
.addSentinelAddress("192.168.56.101:26379")
.addSentinelAddress("192.168.56.102:26379")
.addSentinelAddress("192.168.56.103:26379")
.setPingTimeout(100)
.setTimeout(60000)
.setRetryAttempts(25)
.setReconnectionTimeout(45000)
.setRetryInterval(1500)
.setReadMode(ReadMode.SLAVE)
.setConnectTimeout(20000)
.setSubscriptionMode(SubscriptionMode.MASTER);

RedissonClient client = Redisson.create(config);

RedissonNodeConfig nodeConfig = new RedissonNodeConfig(config);
nodeConfig.setExecutorServiceWorkers(Collections.singletonMap("myExecutor6", 1));
RedissonNode node = RedissonNode.create(nodeConfig);
node.start();

System.out.println("Node address "+node.getRemoteAddress().toString());
RExecutorService e = client.getExecutorService("myExecutor6");
e.execute(new RunnableTask());
e.shutdown();
if(e.isShutdown()) {
e.delete();
}
client.shutdown();
node.shutdown();
System.out.println("Hello World!" );
}

}

运行代码,发生了一些我不明白的事情。第一个是:

  • 为什么 redisson 将我的 3 台主机识别为 redis 从服务器??
  • 为什么我创建的键值对没有存储到redis中??

我的想法是,在我能够写入 redis 之后,我将开始测试故障转移杀死 master 并期望程序将管理它并继续写入新的 master,而不会丢失消息(它能够在发生故障转移时缓存消息会很好。

这个简单的程序发生的事情是我可以写入 redis,但是当我杀死 master 时,执行只是挂起一个似乎接近 setTimeout 的时间并且没有完成就退出了任务。

有什么建议吗?

最佳答案

您应该将 retryAttempts 参数设置得足够大,以使 Redisson 在故障转移期间幸存下来。

关于java - Redisson + redis 哨兵。如何处理故障转移并写入redis?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50381055/

40 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com