我正在研究 Lettuce 集群 Java 客戶端。它在拓撲結構 (Apache Strom) 中設置bolt。spout正在從 讀取數據kafka并將其傳遞給bolt。但是，當我開始我的拓撲時，我收到以下錯誤消息并且程序終止。我錯過了什么嗎？是什么原因造成的？堆棧跟蹤29502 [Thread-17-RecommendationLettuceBolt-executor[2 2]] 錯誤 oasutil - 異步循環已死！io.lettuce.core.RedisException：無法從 io.lettuce.core.cluster.RedisClusterClient.loadPartitions（RedisClusterClient.java:865）的初始 URI [RedisURI [host='127.0.0.1', port=7001]] 檢索初始集群分區) ~[lettuce-core-5.1.7.RELEASE.jar:?] 在 io.lettuce.core.cluster.RedisClusterClient.initializePartitions(RedisClusterClient.java:819) ~[lettuce-core-5.1.7.RELEASE.jar: ？] 在 io.lettuce.core.cluster.RedisClusterClient.connect(RedisClusterClient.java:345) ~[lettuce-core-5.1.7.RELEASE.jar:?] 在 com.projectName.indexer.lettuce.LettuceClusterClientProvider.getConnection( LettuceClusterClientProvider.java:72) ~[classes/:?] 在 com.projectName.indexer.lettuce.LettuceCacheRepopulationHandler。輸入代碼private void init() { redisUri = RedisURI.Builder .redis(lettuceConfig.getLettuceClusterHost()) .withPort(lettuceConfig.getLettuceClusterPort()) .withTimeout(Duration.ofMillis(lettuceConfig.getLettuceClusterTimeout())) .build();}public StatefulRedisClusterConnection getConnection() { if (connection == null || !connection.isOpen()) { redisClusterClient = RedisClusterClient.create(redisUri); final ClusterTopologyRefreshOptions topologyRefreshOptions = ClusterTopologyRefreshOptions.builder() .enablePeriodicRefresh(Duration.ofMinutes(BoltConstants.Lettuce.PERIODIC_REFRESH_TIME_IN_MIN)) .enableAdaptiveRefreshTrigger() .build(); final ClusterClientOptions clusterClientOptions = ClusterClientOptions.builder() .autoReconnect(true) .topologyRefreshOptions(topologyRefreshOptions) .build(); } return connection; }環境compile 'io.lettuce:lettuce-core:5.1.7.RELEASE'
1 回答
郎朗坤
TA貢獻1921條經驗 獲得超9個贊
錯誤來了，因為我沒有在我的機器上本地安裝redis 集群。
我使用這些步驟解決了
https://redis.io/ 下載并運行以下命令安裝
$ wget http://download.redis.io/releases/redis-5.0.5.tar.gz
$ tar xzf redis-5.0.5.tar.gz
$ cd redis-5.0.5
$ make //The binaries that are now compiled are available in the src directory
$ src/redis-server
使用 create-cluster 腳本創建 Redis 集群
現在檢查redis-5.0.5/utils/create-clusterRedis 發行版中的目錄。里面有一個腳本create-cluster，它是一個簡單的 bash 腳本。為了啟動一個具有 3 個主節點和 3 個從節點的 6 節點集群，只需鍵入以下命令：
$ create-cluster start? // start?
$ create-cluster create // create cluster
$ create-cluster stop // for stoping?
$ create-cluster clean // clean all the cluster
您將在終端中看到以下輸出
$ ps aux |grep redis
300067846? ? ? ? 28222? ?0.6? 0.0? 4379932? ?2612? ???? Ss? ? 7:41PM? ?0:00.73 ../../src/redis-server *:30004 [cluster]? ? ? ? ? ? ? ? ??
300067846? ? ? ? 28227? ?0.5? 0.0? 4380956? ?2604? ???? Ss? ? 7:41PM? ?0:00.71 ../../src/redis-server *:30006 [cluster]? ? ? ? ? ? ? ? ??
300067846? ? ? ? 28218? ?0.4? 0.0? 4381980? ?2676? ???? Ss? ? 7:41PM? ?0:00.73 ../../src/redis-server *:30002 [cluster]? ? ? ? ? ? ? ? ??
300067846? ? ? ? 28216? ?0.4? 0.0? 4374812? ?2576? ???? Ss? ? 7:41PM? ?0:00.50 ../../src/redis-server *:30001 [cluster]? ? ? ? ? ? ? ? ??
300067846? ? ? ? 28225? ?0.4? 0.0? 4380956? ?2632? ???? Ss? ? 7:41PM? ?0:00.68 ../../src/redis-server *:30005 [cluster]? ? ? ? ? ? ? ? ??
300067846? ? ? ? 28220? ?0.3? 0.0? 4379932? ?2596? ???? Ss? ? 7:41PM? ?0:00.52 ../../src/redis-server *:30003 [cluster]? ? ? ? ? ? ? ? ??
300067846? ? ? ? 85550? ?0.0? 0.0? 4309420? ?1128? ???? S? ? ?3:08PM? ?0:07.76 redis-server *:6379
查看所有主從節點
../redis-5.0.5/utils/create-cluster$ cat nodes-3000*.conf
您可以更新 Redis 集群配置。vi create-cluster根據需要打開并更新以下配置。
// default config are these?
CLUSTER_HOST=127.0.0.1
PORT=30000
TIMEOUT=2000
NODES=6
REPLICAS=1
添加回答
舉報
0/150
提交
取消