Java客户端无法连接到运行在本地主机上的Redis Sentinel。

4

我在本地主机上设置了3个Redis服务器和3个Redis Sentinel实例。这些服务器正在运行:

127.0.0.1:6379 // Master
127.0.0.1:6380 // Slave
127.0.0.1:6381 // Slave

并且哨兵正在以以下方式运行:

127.0.0.1:5000
127.0.0.1:5001
127.0.0.1:5002

我有一个(Java)客户端,试图连接到其中一个sentinel,并在redis服务器上设置密钥:

// import statements

public class RedisPush {

    private static final String MASTER_NAME = "mymaster";
    private static final String PASSWORD = "foobared";
    private static final Set sentinels;
    static {
        sentinels = new HashSet();
        sentinels.add("127.0.0.1:5000");
        sentinels.add("127.0.0.1:5001");
        sentinels.add("127.0.0.1:5002");
    }

    public static void pushToRedis() {

        Jedis jedis = null;

        try {
            JedisSentinelPool pool = new JedisSentinelPool(MASTER_NAME, sentinels);
            System.out.println("Fetching connection from pool.");
            jedis = pool.getResource();
            jedis.auth(PASSWORD);
            Socket socket = jedis.getClient().getSocket();

            System.out.println("Connected to " + socket.getRemoteSocketAddress());
            int i = 0;
            while (true) {
                jedis.set("sentinel_key" + i, "value" + i);
                System.out.println(i);
                i++;
                Thread.sleep(1000);
            }

        } catch (Exception e) {
            e.printStackTrace();
        }
        finally {
            if(jedis != null)
                jedis.close();
        }

    }

    public static void main(String[] args) throws Exception {

        while(true) {

            pushToRedis();
            Thread.sleep(1000);
        }
    }
}

起初,我的哨兵配置如下(例如,第一个运行在端口5000上的哨兵):

bind 127.0.0.1
port 5000
sentinel monitor mymaster 127.0.0.1 6379 2
sentinel down-after-milliseconds mymaster 5000
sentinel failover-timeout mymaster 60000
sentinel auth-pass mymaster foobared

如果我尝试运行我的 Java 客户端,会出现以下错误:

Nov 23, 2018 1:52:57 AM redis.clients.jedis.JedisSentinelPool initSentinels
INFO: Trying to find master from available Sentinels...
Nov 23, 2018 1:52:57 AM redis.clients.jedis.JedisSentinelPool initSentinels
WARNING: Cannot get master address from sentinel running @ 192.168.0.102:5001. Reason: redis.clients.jedis.exceptions.JedisConnectionException: java.net.ConnectException: Connection refused (Connection refused). Trying next one.
Nov 23, 2018 1:52:57 AM redis.clients.jedis.JedisSentinelPool initSentinels
WARNING: Cannot get master address from sentinel running @ 192.168.0.102:5000. Reason: redis.clients.jedis.exceptions.JedisConnectionException: java.net.ConnectException: Connection refused (Connection refused). Trying next one.
Nov 23, 2018 1:52:57 AM redis.clients.jedis.JedisSentinelPool initSentinels
WARNING: Cannot get master address from sentinel running @ 192.168.0.102:5002. Reason: redis.clients.jedis.exceptions.JedisConnectionException: java.net.ConnectException: Connection refused (Connection refused). Trying next one.
redis.clients.jedis.exceptions.JedisConnectionException: All sentinels down, cannot determine where is mymaster master is running...
    at redis.clients.jedis.JedisSentinelPool.initSentinels(JedisSentinelPool.java:180)
    at redis.clients.jedis.JedisSentinelPool.<init>(JedisSentinelPool.java:95)
    at redis.clients.jedis.JedisSentinelPool.<init>(JedisSentinelPool.java:82)
    at redis.clients.jedis.JedisSentinelPool.<init>(JedisSentinelPool.java:70)
    at redis.clients.jedis.JedisSentinelPool.<init>(JedisSentinelPool.java:44)
    at RedisPush.pushToRedis(RedisPush.java:29)
    at RedisPush.main(RedisPush.java:61)

然而,如果我将哨兵配置脚本更改为以下内容:
# bind 127.0.0.1
port 5000
protected-mode no
sentinel monitor mymaster 127.0.0.1 6379 2
sentinel down-after-milliseconds mymaster 5000
sentinel failover-timeout mymaster 60000
sentinel auth-pass mymaster foobared

客户端完美地工作,我不明白原因。
据我所知,如果在sentinel.conf文件中未设置requirepass,并且在sentinel.conf文件中注释了bind,则只有在保护模式为yes时,才会避免任何客户端连接到除localhost之外的sentinel。在我的第一个sentinel配置中,我使用了bind命令,但它仍然没有起作用。
为什么注释掉bind并将protected-mode显式设置为no会起作用?
附言:我还尝试同时使用bind 127.0.0.1和protected-mode no,但那也没有起作用。
2个回答

3

我曾经遇到过类似的问题,Jedis抛出了相同的错误,与https://github.com/xetorthio/jedis/issues/1367有关。

在我的Mac上解决这个问题,我执行了sudo ifconfig lo0 alias 127.0.1.1,然后将我的sentinel.conf更改为bind 127.0.1.1,然后更新了我的spring data的yaml文件以连接该IP。

sentinel.nodes: 127.0.1.1:5000, 127.0.1.1:5002, 127.0.1.1:5003

1
sudo ifconfig lo0 alias 127.0.1.1 - 解决了我的问题。 - Kevin Batongbakal
1
HostAndPort.setLocalhost("127.0.0.1"); 在添加了这行代码后,它对我来说运行正常。 - user3198259

-1
Jedis 对 Redis Sentinel 的支持不佳。建议使用Lettuce,它具有更好的连接池管理,并且在 Springboot 上得到了很好的支持。

我给你点赞是因为这是真的。生菜比Redis/Sentinel更好。 - undefined

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接