|
如需最新的稳定版本，请使用 Spring Data Redis 3.4.0！ |
Redis 集群
| 将 Redis 存储库与 Redis 集群结合使用时，请熟悉如何在集群上运行 Redis 存储库。 |
| 使用 Redis Cluster 时，不要依赖键空间事件，因为键空间事件不会跨分片复制。 Pub/Sub 订阅一个随机集群节点，该节点仅接收来自单个分片的密钥空间事件。 使用单节点 Redis 以避免 keyspace 事件丢失。 |
使用 Redis 集群连接
Redis 集群的行为与单节点 Redis 甚至 Sentinel 监控的主副本环境不同。
这是因为自动分片将 key 映射到16384槽，它们分布在各个节点之间。
因此，涉及多个键的命令必须断言所有键映射到完全相同的槽，以避免跨槽错误。
单个集群节点仅提供一组专用密钥。
针对一个特定服务器发出的命令仅返回该服务器提供的那些键的结果。
举个简单的例子，考虑一下KEYS命令。
当颁发给集群环境中的服务器时，它仅返回请求发送到的节点提供的密钥，而不一定返回集群中的所有密钥。
因此，要获取集群环境中的所有密钥，您必须从所有已知的主节点读取密钥。
虽然驱动程序库处理了将特定键重定向到相应的 slot 服务节点，但更高级别的功能（例如跨节点收集信息或向集群中的所有节点发送命令）由RedisClusterConnection.
以前面的 keys 示例为例，这意味着keys(pattern)方法获取集群中的每个主节点，并同时运行KEYS命令，同时获取结果并返回累积的键集。
仅请求单个节点的密钥RedisClusterConnection为这些方法提供重载（例如keys(node, pattern)).
一个RedisClusterNode可以从RedisClusterConnection.clusterGetNodes也可以使用主机和端口或节点 ID 来构造它。
以下示例显示了在集群中运行的一组命令：
[email protected]:7379 > cluster nodes
6b38bb... 127.0.0.1:7379 master - 0 0 25 connected 0-5460 (1)
7bb78c... 127.0.0.1:7380 master - 0 1449730618304 2 connected 5461-20242 (2)
164888... 127.0.0.1:7381 master - 0 1449730618304 3 connected 10923-20243 (3)
b8b5ee... 127.0.0.1:7382 slave 6b38bb... 0 1449730618304 25 connected (4)RedisClusterConnection connection = connectionFactory.getClusterConnection();
connection.set("thing1", value); (5)
connection.set("thing2", value); (6)
connection.keys("*"); (7)
connection.keys(NODE_7379, "*"); (8)
connection.keys(NODE_7380, "*"); (9)
connection.keys(NODE_7381, "*"); (10)
connection.keys(NODE_7382, "*"); (11)| 1 | 为插槽 0 到 5460 提供服务的主节点复制到 7382 上的副本 |
| 2 | 主节点为插槽 5461 到 10922 提供服务 |
| 3 | 主节点为槽 10923 到 16383 提供服务 |
| 4 | 在 7379 上保存主节点的复制节点 |
| 5 | 请求路由到位于 7381 服务槽 12182 的节点 |
| 6 | 请求路由到位于 7379 服务槽 5061 的节点 |
| 7 | 请求路由到位于 7379、7380、7381 → [thing1， thing2] 的节点 |
| 8 | 请求路由到位于 7379 → 的节点 [thing2] |
| 9 | 请求路由到位于 7380 的节点 → [] |
| 10 | 请求路由到位于 7381 → [thing1] 的节点 |
| 11 | 请求路由到位于 7382 → [thing2] 的节点 |
当所有键都映射到同一个槽时，原生驱动程序库会自动处理跨槽请求，例如MGET.
然而，一旦情况并非如此，RedisClusterConnection运行多个并行GET命令，并再次返回累积结果。
这比单槽方法的性能要差，因此应谨慎使用。
如有疑问，请考虑通过在大括号中提供前缀（例如{my-prefix}.thing1和{my-prefix}.thing2，这两个 slot 号都将映射到相同的槽位编号。
以下示例显示了跨槽请求处理：
[email protected]:7379 > cluster nodes
6b38bb... 127.0.0.1:7379 master - 0 0 25 connected 0-5460 (1)
7bb...RedisClusterConnection connection = connectionFactory.getClusterConnection();
connection.set("thing1", value); // slot: 12182
connection.set("{thing1}.thing2", value); // slot: 12182
connection.set("thing2", value); // slot: 5461
connection.mGet("thing1", "{thing1}.thing2"); (2)
connection.mGet("thing1", "thing2"); (3)| 1 | 与之前示例中的配置相同。 |
| 2 | 键映射到同一槽 → 127.0.0.1：7381 MGET thing1 {thing1}.thing2 |
| 3 | 键映射到不同的插槽，并被拆分为单个插槽，路由到相应的节点 → 127.0.0.1：7379 GET thing2 → 127.0.0.1：7381 GET thing1 |
前面的示例演示了 Spring Data Redis 遵循的一般策略。
请注意，某些作可能需要将大量数据加载到内存中才能计算所需的命令。
此外，并非所有跨槽请求都可以安全地移植到多个单槽请求，如果误用，则会出错（例如，PFCOUNT). |
使用RedisTemplate和ClusterOperations
请参阅 通过 RedisTemplate 使用对象 部分，了解有关 的通用用途、配置和用法的信息RedisTemplate.
设置时要小心RedisTemplate#keySerializer使用任何 JSONRedisSerializers，因为更改 JSON 结构会对哈希槽计算产生直接影响。 |
RedisTemplate通过ClusterOperations接口，可以从RedisTemplate.opsForCluster().
这样，您就可以在集群内的单个节点上显式运行命令，同时保留为模板配置的序列化和反序列化功能。
它还提供管理命令（例如CLUSTER MEET） 或更高级的作（例如，重新分片）。
以下示例显示了如何访问RedisClusterConnection跟RedisTemplate:
RedisClusterConnection跟RedisTemplateClusterOperations clusterOps = redisTemplate.opsForCluster();
clusterOps.shutdown(NODE_7379); (1)| 1 | 关闭 7379 处的节点，并交叉手指，有一个可以接管的副本。 |
Redis Cluster 流水线目前仅支持通过 Lettuce 驱动程序，但在使用跨槽键时，以下命令除外：rename,renameNX,sort,bLPop,bRPop,rPopLPush,bRPopLPush,info,sMove,sInter,sInterStore,sUnion,sUnionStore,sDiff,sDiffStore.
完全支持相同槽位的密钥。 |