SpringBoot集成Redis并实现主从架构的实践

redis-server.exe redis.windows.conf

redis-cli.exe -h 127.0.0.1 -p 6379

set key value

set Mykey huixiaoyuan

get Mykey

        <!-- 加入jedis依赖 -->
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>2.9.0</version>
        </dependency>

    /**
     * redis连接测试01
     */
    @Test
    public void redisTest01() {
        //连接本地的 Redis 服务
        Jedis jedis = new Jedis("localhost");
        // 如果 Redis 服务设置了密码，需要用下面这行代码输入密码
        // jedis.auth("123456"); 
        System.out.println("连接成功");
        //查看服务是否运行
        System.out.println("服务正在运行: "+jedis.ping());
    }

//不传值，那么使用默认的127.0.0.1地址，6379端口就访问
public Jedis()

//只传入目的地址，那么使用指定的地址和默认的端口号去访问
public Jedis(String host)

//传入目的地址和端口号，那么使用指定的地址和端口号去访问
public Jedis(String host, int port)

##redis配置信息
spring:
  redis:
    database: 0 #redis数据库索引，默认为0
    host: 127.0.0.1 #redis服务器地址
    port: 6379 #redis服务器连接端口
    password: #redis服务器连接密码，默认为null
    timeout: 5000 #redis连接超时时间

redisTemplate.opsForValue();　　//操作字符串
redisTemplate.opsForHash();　　 //操作hash
redisTemplate.opsForList();　　 //操作list
redisTemplate.opsForSet();　　  //操作set
redisTemplate.opsForZSet();　 　//操作有序set

    /**
     * springboot主从连接测试,
     * 使用springRedisTemplate操作
     */
    @Test
    public void redisTest06() {
//        操作字符型
        stringRedisTemplate.opsForValue().set("test06","Test06");
        System.out.println(stringRedisTemplate.opsForValue().get("test06"));

//        设置key的过期时间，30秒
        stringRedisTemplate.expire("test06", 30 * 1000, TimeUnit.MILLISECONDS);

//        根据key获取过期时间
        Long test06ExpireTime = stringRedisTemplate.getExpire("test06");
        System.out.println("根据key获取过期时间:" + test06ExpireTime);

//        根据key获取过期时间，并且换算成指定单位
        Long test06ExpireTimeToUnit = stringRedisTemplate.getExpire("test06", TimeUnit.SECONDS);
        System.out.println("根据key获取过期时间，并且换算成指定单位:" + test06ExpireTimeToUnit);

//        检查key是否存在，返回布尔类型
        Boolean test06IsExist = stringRedisTemplate.hasKey("test06");
        System.out.println("检查key是否存在，返回布尔类型:" + test06IsExist);

    }

##redis配置信息
spring:
  redis:
    database: 0 #redis数据库索引，默认为0
    host: 127.0.0.1 #redis服务器地址
    port: 6379 #redis服务器连接端口
    password: #redis服务器连接密码，默认为null
    timeout: 5000 #redis连接超时时间
    jedis:
      pool: #连接池配置
        max-active: 8 #连接池最大连接数
        max-wait: -1 #连接池最大阻塞等待时间
        max-idle: 8 #连接池中的最大空闲连接数
        min-idle: 0 #连接池中的最小空闲连接数

    /**
     * redis连接测试01
     * 建立简单主从架构
     */
    @Test
    public void redisTest02() {
//        配置redis连接池
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
//        在指定时刻通过连接池能够获取到的最大的jedis的数量
        jedisPoolConfig.setMaxTotal(20);
//        最大空闲jedis的数量
        jedisPoolConfig.setMaxIdle(10);
//        最小空闲jedis的数量
        jedisPoolConfig.setMinIdle(5);

//        建立redis连接池，设置本地地址，端口号，连接超时时间和读写超时时间，如果没有连接密码，那么久为null
        JedisPool jedisPool = new JedisPool(jedisPoolConfig, "127.0.0.1", 6379, 300, null);

//        新建一个jedis，jedis：redis在Java中的客户端实现
        Jedis jedis = null;
        try {
//            从连接池中获取到一个jedis资源
            jedis = jedisPool.getResource();
//            设置key-value，并获取value
            System.out.println(jedis.set("hxy", "888"));
            System.out.println(jedis.get("hxy"));
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
//            注意！！这里不是关闭连接，只是将jedis归还到连接池
            if (jedis != null) {
                jedis.close();
            }
        }
    }