BizSpring

Appearance

大纲

Redisson Redis ​

概述 ​

Redis Cluster 是官方提供的一种用数据分片来实现横向扩容的解决方案，由一个或多个 Redis 服务组成一个无主集群。
对 Key 使用哈希算法将数据分散倒 16384 个哈希槽，让集群中的节点一起来分摊这些槽位；每个节点都可以进行哈希运算，并且保存了所有节点与槽位的映射关系。
客户端通过直连集群任一节点发送操作指令，当操作经过节点哈希计算得出指令不应由本节点处理时，会向客户端返回 MOVED 错误，并附带正确的节点地址，客户端再访问正确的节点来完成操作。

部署 Redis Cluster ​

编辑脚本
可以先看下目录下的 README 文档了解如何使用脚本。

shell
echo "进入集群脚本目录" > /dev/null
cd ~/soft/redis/redis-6.2.5/utils/create-cluster/

echo "编辑脚本" > /dev/null
vim create-cluster

脚本开始部分：PORT=30000 代表创建的集群节点端口号从 30000 开始；NODES=6 代表集群节点总数为 6；REPLICAS=1 代表每个节点包含一个副本/从节点，那就意味着集群由 3 个主节点分摊槽位并提供服务，每个主节点分配一个从节点实现高可用。
image.png

创建节点 ​

节点产生的文件都会放在当前所在目录下。

shell
./create-cluster start

image.png

自动分配集群 ​

shell
./create-cluster create

从控制台可以看到将 16384 个槽位分成了 3 份，并分配给了 30001~30003 主节点，30004~30005 分别追随了三个主节点，最后输入 yes 同意这个配置。
黄颜色警告是指从节点和主节点在一台服务器，实际使用肯定需要分开实现高可用。
image.png
image.png

停止、清除集群 ​

shell
# 停止集群
./create-cluster stop

# 清除日志、数据等相关文件
./create-cluster clean

手动分配集群 ​

其实这种方式跟自动分配最终实现是一样的，只不过自动分配的脚本帮我们拼接了指令然后执行了而已。

shell
# 用脚本创建 6 个节点
./create-cluster start

# 分配，指明节点地址和副本数量
redis-cli --cluster create 127.0.0.1:30001 127.0.0.1:30002 127.0.0.1:30003 127.0.0.1:30004 127.0.0.1:30005 127.0.0.1:30006 --cluster-replicas 1

测试 ​

连接节点设置数据，加上 -c 表示操作 Cluster 节点，好处是如果节点经过哈希计算告诉客户端正确的节点地址时，客户端会自动帮你重定向到正确的节点完成操作。
你也可以不加 -c 来连接节点执行操作，只不过客户端工具不会帮你重定向来完成，而是打印 MOVE 错误。

shell
redis-cli -c -p 30001

image.png
你可以执行 KEYS * 操作，只不过返回的只有当前节点的所有 key；
你可以使用 WATCH、MULTI 尝试以事务的方式来设置多个数据，不过最后 EXEC 提交会报错事务超时，因为你多个操作在不同节点之间跳转，提交事务和开启事务不是同一节点，整个混乱了。
image.png
正确实现事务的方式是在多个操作的 key 前加相同的 {tag}，哈希算法只会对这个 tag 进行计算，最后落到同一个节点上。
image.png

其他问题 ​

多服务器如何配置？
创建节点这一步在每个服务器创建好节点，同样按手动分配集群的方试填写多个服务器对应的 IP 和 端口号就行了。

如何重新分片？
我们可以通过重新分片来解决数据倾斜的问题。
执行下面命令表明连接这个节点进行重新分片操作，同时打印出所有节点信息，然后会询问你要转移走多少个槽位（这里输入了 2000）。

shell
redis-cli --cluster reshard 127.0.0.1:30001

image.png
问你接收这些槽位的节点 ID 是多少（这里输入了主节点 30002 的 ID）。
然后要你依次输入多个源节点，就是从哪些节点移走共 2000 个槽位。你可以依次填节点 ID 回车，最后输入 done 完成；也可以直接输入 all 从其他所有节点转移（这里输入了主节点 30001 的 ID）。
image.png
最终结果就是从 30001 转移了 2000 个槽位到 30002。经过计算还会询问你是否同意这个分片计划，输入 yes 完成。

如果想再细粒度的控制这个分片过程是做不到的。

其他集群操作指令 ​

shell
# 查看集群指令帮助信息
redis-cli --cluster help

# 这两个指令都可以看到集群相关信息，连任一节点都可以
redis-cli --cluster info 127.0.0.1:30001
redis-cli --cluster check 127.0.0.1:30001

Redis集群+Redisson配置 ​

Redis Cluster Template配置类

配置文件

集群Template 配置文件在BizSpring\bizspring-base\bizspring-base-data\src\main\java\cn\bizspring\cloud\common\data\cache\目录下，文件名称RedisClusterTemplateConfig.java

java
package cn.bizspring.cloud.common.data.cache;

// ...

@EnableCaching
@Configuration
@AllArgsConstructor
@AutoConfigureBefore(RedisAutoConfiguration.class)
public class RedisClusterTemplateConfig {

	private ClusterConfigurationProperties clusterConfigurationProperties;

	@Bean
	public LettuceConnectionFactory redisConnectionFactory() {
		RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration(clusterConfigurationProperties.getNodes());
		//支持自适应集群拓扑刷新和静态刷新源
		ClusterTopologyRefreshOptions clusterTopologyRefreshOptions =  ClusterTopologyRefreshOptions.builder()
				.enablePeriodicRefresh()
				.enableAllAdaptiveRefreshTriggers()
				.build();
		ClusterClientOptions clusterClientOptions = ClusterClientOptions.builder()
				.topologyRefreshOptions(clusterTopologyRefreshOptions).build();
		//从优先，读写分离，读从可能存在不一致，最终一致性CP
		LettuceClientConfiguration lettuceClientConfiguration = LettuceClientConfiguration.builder()
				.readFrom(ReadFrom.SLAVE_PREFERRED)
				.clientOptions(clusterClientOptions).build();
		return new LettuceConnectionFactory(redisClusterConfiguration, lettuceClientConfiguration);
	}

	@Bean
	public RedisTemplate<Object, Object> redisTemplate(LettuceConnectionFactory redisConnectionFactory) {
		RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
		redisTemplate.setConnectionFactory(redisConnectionFactory);
		redisTemplate.setKeySerializer(new StringRedisSerializer());
		redisTemplate.setHashKeySerializer(new StringRedisSerializer());
		redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());
		redisTemplate.setHashValueSerializer(new JdkSerializationRedisSerializer());
		redisTemplate.afterPropertiesSet();
		return redisTemplate;
	}

}

application.yaml 配置
Redisson 是 redis 官方发布的分布式锁工具。

配置文件

配置Redisson和集群信息，位置nacos中 application-dev.yml

yaml
# redis 集群修改
  # 集群
    cluster:
      # 各 Redis 节点信息
      nodes: 127.0.0.1:30001,127.0.0.1:30002,127.0.0.1:30003,127.0.0.1:30004,127.0.0.1:30005,127.0.0.1:30006
      maxRedirects: 3

    database: 0
    lettuce:
      pool:
        # 连接池最大连接数 默认8 ，负数表示没有限制
        max-active: 8
        # 连接池最大阻塞等待时间（使用负值表示没有限制） 默认-1
        max-wait: -1
        # 连接池中的最大空闲连接 默认8
        max-idle: 8
        # 连接池中的最小空闲连接 默认0
        min-idle: 0
        
    redisson:
      pool:
        # 连接池最大连接数 默认8 ，负数表示没有限制
        max-active: 8
        # 连接池最大阻塞等待时间（使用负值表示没有限制） 默认-1
        max-wait: -1
        # 连接池中的最大空闲连接 默认8
        max-idle: 8
        # 连接池中的最小空闲连接 默认0
        min-idle: 0
        connTimeout: 10000
        timeout: 3000
        soTimeout: 3000
        size: 32
      config: | 
        clusterServersConfig:
          idleConnectionTimeout: 10000
          connectTimeout: 10000
          timeout: 3000
          retryAttempts: 3
          retryInterval: 1500
          failedSlaveReconnectionInterval: 3000
          failedSlaveCheckInterval: 60000
          # redis 集群密码不设置
          password: null
          subscriptionsPerConnection: 5
          clientName: null
          loadBalancer: !<org.redisson.connection.balancer.RoundRobinLoadBalancer> {}
          subscriptionConnectionMinimumIdleSize: 1
          subscriptionConnectionPoolSize: 50
          slaveConnectionMinimumIdleSize: 24
          slaveConnectionPoolSize: 64
          masterConnectionMinimumIdleSize: 24
          masterConnectionPoolSize: 64
          readMode: "SLAVE"
          subscriptionMode: "SLAVE"
          nodeAddresses:
          - "redis://127.0.0.1:30001"
          - "redis://127.0.0.1:30002"
          - "redis://127.0.0.1:30003"
          - "redis://127.0.0.1:30004"
          - "redis://127.0.0.1:30005"
          - "redis://127.0.0.1:30006"
          scanInterval: 1000
          pingConnectionInterval: 0
          keepAlive: false
          tcpNoDelay: false
        threads: 16
        nettyThreads: 32
        codec: !<org.redisson.codec.MarshallingCodec> {}
        transportMode: "NIO"

使用分布式锁

java
public boolean acquireLock(Order order, User user) {
    String orderId = order.getId();
    RLock lock = redissonClient.getLock(orderId);
    try {
        lock.lock();
        Object userId = redisTemplate.opsForValue().get(Order.CACHE_CLASS_NAME + Order.ORDER_LOCK_CACHE_NAME + orderId);
        if (userId != null && !user.getId().equals(String.valueOf(userId))) {
            return false;
        }
        redisTemplate.opsForValue().set(Order.CACHE_CLASS_NAME + Order.ORDER_LOCK_CACHE_NAME + orderId, user.getId(), 10000, TimeUnit.MILLISECONDS);
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        lock.unlock();
    }

版权许可

Copyright © 2021-2024 bizspring.cn All Rights Reserved BizSpring