整合redis可查看博文
springboot 整合redis_springboot整合redis csdn-CSDN博客
集群中操作注意事项
1 多键操作失败:
当使用multiGet等需要同时访问多个键的方法时,如果没有使用Hash Tags,这些键可能会被分配到不同的槽中。如果这些槽位于不同的Redis节点上,那么multiGet将无法正确返回所有键的值。
2 Pipeline操作受限:
在Redis集群中,pipeline操作不能跨越多个槽进行。如果通过pipeline发送的命令涉及多个不同的槽(即键被分配到了不同的节点),则可能会导致部分命令失败或者整个pipeline操作效率降低。
3 事务支持有限:
Redis集群不支持原生的MULTI/EXEC事务模型,特别是当事务涉及多个不同的槽时。因此,尝试在集群模式下使用事务来管理多个键的操作可能会失败。
代码示例
1 application.yml
spring:application:name: zha7zha8data:redis:cluster:nodes:- 192.168.1.100:6381- 192.168.1.100:6382- 192.168.1.100:6383- 192.168.1.100:6384- 192.168.1.100:6385- 192.168.1.100:6386
2 测试类,注意:{user}: 这样的标识,名称无所谓,只要都加了相同的标识,写了些反例和正例
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.StringRedisTemplate;
import java.util.Arrays;
import java.util.List;@SpringBootTest(classes = Zha7zha8Application.class)
public class RedisClusterTest {@Autowiredprivate StringRedisTemplate redisTemplate;/*** 反例:未使用 Hash Tags,可能导致 Key 分配到不同的 Slot* 注意:由于 'user:dfss' 和 'user:00' 没有共同的 Hash Tag,* 这些键可能会被分配到不同的槽中,这在某些情况下(如 multiGet)可能会导致问题。* 例如,在Redis集群环境中,如果这些键位于不同的节点上,那么 multiGet 可能无法正确返回所有键的值。*/@Testvoid testWithoutHashTags() {// 定义两个没有使用 Hash Tags 的键String key1 = "user:dfss";String key2 = "user:11";// 设置键值对redisTemplate.opsForValue().set(key1, "Alice");redisTemplate.opsForValue().set(key2, "Bob");// 尝试从 Redis 中获取这两个值List<String> values = redisTemplate.opsForValue().multiGet(Arrays.asList(key1, key2));System.out.println("从 Redis 中获取的值 (无 Hash Tags): " + values);}/*** 正例:使用 Hash Tags 确保 'user:1' 和 'user:2' 在同一个 Slot* 使用相同的 Hash Tag '{user}' 确保了 'user:1' 和 'user:2' 被分配到同一个槽中,* 这样可以保证 multiGet 操作能够成功返回所有相关的键值。*/@Testvoid testWithHashTags() {// 定义两个使用相同 Hash Tags 的键String key1 = "{user}:1";String key2 = "{user}:2";// 设置键值对redisTemplate.opsForValue().set(key1, "Alice");redisTemplate.opsForValue().set(key2, "Bob");// 从 Redis 中获取这两个值List<String> values = redisTemplate.opsForValue().multiGet(Arrays.asList(key1, key2));System.out.println("从 Redis 中获取的值 (有 Hash Tags): " + values);}/*** Pipeline 操作反例* 注意:由于 'user:1' 和 'user:2' 没有共同的 Hash Tag,* 这些键可能会被分配到不同的槽中。虽然 pipeline 操作会尝试执行所有的命令,* 但如果涉及到跨多个节点的操作,可能会导致部分命令失败或效率降低。*/@Testvoid pipelineOperationWithoutHashTags() {// 定义两个没有使用 Hash Tags 的键String key1 = "user:1";String key2 = "user:2";// Pipeline 操作List<Object> results = redisTemplate.executePipelined((RedisCallback<String>) connection -> {connection.set(key1.getBytes(), "Alice".getBytes());connection.set(key2.getBytes(), "Bob".getBytes());return null;});System.out.println("Pipeline 操作的结果 (无 Hash Tags): " + results);}/*** Pipeline 操作正例* 使用相同的 Hash Tag '{user}' 确保了 'user:1' 和 'user:2' 被分配到同一个槽中,* 这使得 pipeline 操作能够在同一节点上顺利执行,提高了操作的一致性和效率。*/@Testvoid pipelineOperationWithHashTags() {// 定义两个使用相同 Hash Tags 的键String key1 = "{user}:1";String key2 = "{user}:2";// Pipeline 操作List<Object> results = redisTemplate.executePipelined((RedisCallback<String>) connection -> {connection.set(key1.getBytes(), "Alice".getBytes());connection.set(key2.getBytes(), "Bob".getBytes());return null;});System.out.println("Pipeline 操作的结果 (有 Hash Tags): " + results);}
}