windows下如何把搭建redis cluster集群及配置springboot2.3.x

本篇文章为大家展示了windows下如何把搭建redis cluster集群及配置springboot2.3.x，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。

1.软件环境

Redis-x64-3.2.100.zip

Redis-trib.rb

rubyinstaller-2.3.3-x64.exe

2.解压redis

把下载的redis解压到D盘redis-cluster目录，然后在复制出来五份,端口分别是

6379，6380，6381，6382，6383，6384

3.修改每个redis文件夹下的redis.windows.conf配置文件

进入到每个文件夹下，找到redis.windows.conf,然后改动这些参数

port 6379cluster-enabled yescluster-config-file nodes-6379.confcluster-node-timeout 15000appendonly yes

在每个文件夹下新建start.bat文件

title redis-6379redis-server.exe redis.windows.conf

4.安装 Ruby

redis的集群使用 ruby脚本编写，所以系统需要有 Ruby 环境

5.打开cmd窗口执行

gem install redis

6.启动每个redis,安装集群脚本

把 redis-trib.rb拷贝到redis-cluster文件夹

redis-trib.rb create --replicas 1 127.0.0.1:6379 127.0.0.1:6380 127.0.0.1:6381 127.0.0.1:6382 127.0.0.1:6383 127.0.0.1:6384

--replicas 1 表示每个主数据库拥有从数据库个数为1。master节点不能少于3个，所以我们用了6个redis

集群启动脚本.bat中的命令如下

start /d "D:\redis-cluster\Redis-6379" start.batstart /d "D:\redis-cluster\Redis-6380" start.batstart /d "D:\redis-cluster\Redis-6381" start.batstart /d "D:\redis-cluster\Redis-6382" start.batstart /d "D:\redis-cluster\Redis-6383" start.batstart /d "D:\redis-cluster\Redis-6384" start.batping /n 3 127.1>nulruby redis-trib.rb create --replicas 1 127.0.0.1:6379 127.0.0.1:6380 127.0.0.1:6381 127.0.0.1:6382 127.0.0.1:6383 127.0.0.1:6384

此操作要在第6步执行完毕，集群创建好之后执行，不然集群创建失败，给集群设置密码，密码需要一致不然会失败

masterauth redispasswordrequirepass redispassword

7.和springboot2.3.x集成 POM.XML

            org.springframework.boot        spring-boot-starter-parent        2.3.3.RELEASE                                 org.springframework.boot        spring-boot-starter-data-redis    

application.yml配置

spring:  redis:    cluster:      nodes: 127.0.0.1:6379,127.0.0.1:6380,127.0.0.1:6381,127.0.0.1:6382,127.0.0.1:6383,127.0.0.1:6384

8.RedisUtil.java

package com.example.elasticsearchdemo.util;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.data.redis.core.*;import org.springframework.stereotype.Component;import java.io.Serializable;import java.util.List;import java.util.Set;import java.util.concurrent.TimeUnit;@Componentpublic class RedisUtils {    @Autowired    private RedisTemplate redisTemplate;    /**     * 写入缓存     *     * @param key     * @param value     * @return     */    public boolean set(final String key, Object value) {        boolean result = false;        try {            ValueOperations operations = redisTemplate.opsForValue();            operations.set(key, value);            result = true;        } catch (Exception e) {            e.printStackTrace();        }        return result;    }    /**     * 写入缓存设置时效时间     *     * @param key     * @param value     * @return     */    public boolean set(final String key, Object value, Long expireTime) {        boolean result = false;        try {            ValueOperations operations = redisTemplate.opsForValue();            operations.set(key, value);            redisTemplate.expire(key, expireTime, TimeUnit.SECONDS);            result = true;        } catch (Exception e) {            e.printStackTrace();        }        return result;    }    /**     * 批量删除对应的value     *     * @param keys     */    public void remove(final String... keys) {        for (String key : keys) {            remove(key);        }    }    /**     * 批量删除对应的value (带事务,业务代码中用到事务，则需用此方法)     *     * @param keys     */    public void removeTransactional(final String... keys) {        for (String key : keys) {            removeTransactional(key);        }    }    /**     * 批量删除key     *     * @param pattern     */    public void removePattern(final String pattern) {        Set keys = redisTemplate.keys(pattern);        if (keys.size() > 0)            redisTemplate.delete(keys);    }    /**     * 删除对应的value     *     * @param key     */    public void remove(final String key) {        if (exists(key)) {            redisTemplate.delete(key);        }    }    /**     * 判断缓存中是否有对应的value     *     * @param key     * @return     */    public boolean exists(final String key) {        return redisTemplate.hasKey(key);    }    /**     * 读取缓存     *     * @param key     * @return     */    public Object get(final String key) {        ValueOperations operations = redisTemplate.opsForValue();        return operations.get(key);    }    /**     * 哈希 添加     *     * @param key     * @param hashKey     * @param value     */    public void hmSet(String key, Object hashKey, Object value) {        HashOperations hash = redisTemplate.opsForHash();        hash.put(key, hashKey, value);    }    /**     * 哈希获取数据     *     * @param key     * @param hashKey     * @return     */    public Object hmGet(String key, Object hashKey) {        HashOperations hash = redisTemplate.opsForHash();        return hash.get(key, hashKey);    }    /**     * 列表添加     *     * @param k     * @param v     */    public void lPush(String k, Object v) {        ListOperations list = redisTemplate.opsForList();        list.rightPush(k, v);    }    /**     * 列表获取     *     * @param k     * @param l     * @param l1     * @return     */    public List