Redis 集群
将 Redis 存储库与 Redis 集群结合使用时,请熟悉如何在集群上运行 Redis 存储库。 |
使用 Redis Cluster 时,不要依赖键空间事件,因为键空间事件不会跨分片复制。 Pub/Sub 订阅一个随机集群节点,该节点仅接收来自单个分片的密钥空间事件。 使用单节点 Redis 以避免 keyspace 事件丢失。 |
使用 Redis 集群连接
Redis 集群的行为与单节点 Redis 甚至 Sentinel 监控的主副本环境不同。
这是因为自动分片将键映射到分布在各个节点的槽之一。
因此,涉及多个键的命令必须断言所有键映射到完全相同的槽,以避免跨槽错误。
单个集群节点仅提供一组专用密钥。
针对一个特定服务器发出的命令仅返回该服务器提供的那些键的结果。
举个简单的例子,考虑一下这个命令。
当颁发给集群环境中的服务器时,它仅返回请求发送到的节点提供的密钥,而不一定返回集群中的所有密钥。
因此,要获取集群环境中的所有密钥,您必须从所有已知的主节点读取密钥。16384
KEYS
虽然驱动程序库处理将特定键重定向到相应的槽服务节点,但更高级别的功能(例如跨节点收集信息或向群集中的所有节点发送命令)由 .
以前面的 keys 示例为例,这意味着该方法会选取集群中的每个 master 节点,并同时在每个 master 节点上运行命令,同时获取结果并返回累积的 key 集。
仅请求单个节点的键会为这些方法提供重载(例如,)。RedisClusterConnection
keys(pattern)
KEYS
RedisClusterConnection
keys(node, pattern)
A 可以从主机和端口或节点 ID 获取,也可以构造。RedisClusterNode
RedisClusterConnection.clusterGetNodes
以下示例显示了在集群中运行的一组命令:
[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] 的节点 |
当所有 key 都映射到同一个 slot 时,原生驱动库会自动提供跨 slot 请求,例如 .
但是,一旦不是这种情况,就会对 slot 服务节点运行多个并行命令,并再次返回累积结果。
这比单槽方法的性能要差,因此应谨慎使用。
如有疑问,请考虑通过在大括号中提供前缀(如 和 )将键固定到同一插槽,这两者都将映射到相同的插槽编号。
以下示例显示了跨槽请求处理:MGET
RedisClusterConnection
GET
{my-prefix}.thing1
{my-prefix}.thing2
[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
使用任何 JSON 进行设置时要小心,因为更改 JSON 结构会立即影响哈希槽计算。RedisTemplate#keySerializer RedisSerializers |
RedisTemplate
通过接口提供对特定于集群的操作的访问,该接口可从 获取。
这样,您就可以在集群内的单个节点上显式运行命令,同时保留为模板配置的序列化和反序列化功能。
它还提供管理命令(例如 )或更多高级操作(例如,重新分片)。ClusterOperations
RedisTemplate.opsForCluster()
CLUSTER MEET
以下示例显示如何使用 进行访问 :RedisClusterConnection
RedisTemplate
RedisClusterConnection
RedisTemplate
ClusterOperations 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 |