栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

阿里云服务器,docker组建redis集群,及遇到的问题

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

阿里云服务器,docker组建redis集群,及遇到的问题

安装docker

yum install docker

centos7 启动docker、配置开机启动
systemctl start docker.service
systemctl enable docker.service
docker拉取redis镜像
docker pull redis
docker pull redis:5.0.2       指定版本 
创建redis容器

在这里有一个注意点,有的参数位置不要搞乱,我之前redis镜像放在了v参数前面,导致创建成功,启动容器就退出 exited(1)。网上各种文章都没说到这个

docker create --name redis-node01 --net host -v /data/redis-data/node01:/data -v /myredis/conf:/usr/local/etc/redis redis --cluster-enabled yes --cluster-config-file nodes-node-01.conf --port 6379
docker create --name redis-node02 --net host -v /data/redis-data/node02:/data -v /myredis/conf:/usr/local/etc/redis redis --cluster-enabled yes --cluster-config-file nodes-node-02.conf --port 6380
docker create --name redis-node03 --net host -v /data/redis-data/node03:/data -v /myredis/conf:/usr/local/etc/redis redis --cluster-enabled yes --cluster-config-file nodes-node-03.conf --port 6381
--name 指定容器名称,启动停止的时候用
--net host 指定docker网络类型,与主机共享Network Namespace
--v 主机与容器目录挂载,/data/redis-data/node1的内容会映射到/data
redis 使用的镜像
--cluster-enabled 开启集群
--cluster-config-file 集群配置文件,会自己生成,在这个 /data/redis-data/node1目录中
--port 主机与容器同一个端口
启动容器

docker start redis-node01 redis-node02 redis-node03

其它命令
docker stop redis-node01 redis-node02 redis-node03
docker rm redis-node01 redis-node02 redis-node03
rm -rf /data/redis-data
进入redis容器

docker exec -it redis-node01 /bin/bash

组建redis集群

redis-cli --cluster create xx.96.57.37:6379 xx.96.57.37:6380 xx.96.57.37:6381 --cluster-replicas 0

这里我遇到过问题,阿里云服务器要开发端口(6379-6381和16389-16381),还有Linux防火墙的端口,我嫌麻烦直接关闭了
之前redismanage可以连接,服务器内部可以连接。Java spring连不上。
按别人的方式没用,可能不是一样原因,但是一样的报错 too many cluster redirections 啥啥啥的

可能遇到这种错误用下面的方法,可以解决

检测
redis-cli --cluster check xx.96.57.37:6379
检测结果
[ERR] Not all 16384 slots are covered by nodes
进行修复
redis-cli --cluster fix xx.96.57.37:6379

查看组建成功

java连接集群,这里也可参考其他人的文章,别人的也许更详细

导入maven依赖


     org.springframework.boot
     spring-boot-starter-data-redis
 
 
     redis.clients
     jedis
     2.9.3
 
 
     org.apache.commons
     commons-pool2
     2.9.0
 

properties配置

spring.redis.jedis.pool.max-wait = 5000
spring.redis.jedis.pool.max-Idle = 100
spring.redis.jedis.pool.min-Idle = 10
spring.redis.timeout = 100
spring.redis.cluster.nodes = 39.96.57.37:6379,39.96.57.37:6380,39.96.57.37:6381
spring.redis.cluster.max-redirects=5

读取配置

@Component
@ConfigurationProperties(prefix = "spring.redis.cluster")
@Data
public class ClusterConfigurationProperties {

    private List nodes;

    private Integer maxRedirects;

}

配置redis连接工厂

@Configuration
public class RedisClusterConfig {

    @Autowired
    private ClusterConfigurationProperties clusterProperties;

    @Bean
    public RedisConnectionFactory connectionFactory() {
        RedisClusterConfiguration configuration = new
                RedisClusterConfiguration(clusterProperties.getNodes());
        configuration.setMaxRedirects(clusterProperties.getMaxRedirects());
        return new JedisConnectionFactory(configuration);
    }

    @Bean
    public RedisTemplate redisTemplate(RedisConnectionFactory  redisConnectionfactory) {
        RedisTemplate redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionfactory);
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(new StringRedisSerializer());
        redisTemplate.afterPropertiesSet();

        return redisTemplate;
    }
}
测试
@RunWith(SpringRunner.class)
@SpringBootTest
public class TestRedis {
    @Autowired
    RedisTemplate redisTemplate;

    @Test
    public void testSave(){
        redisTemplate.opsForValue().set("a","123");
        String value = redisTemplate.opsForValue().get("a");
        System.out.println(value);
    }
}

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/272440.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号