springboot整合redis单机及集群

一、单机配置

properties配置

#单机redis

spring.redis.host=127.0.0.1

spring.redis.port=6379

spring.redis.password=redis

启动类加

@EnableCaching

具体的方法上加

@Cacheable(value="userList")

这样的话，redis 中key值即为userList,value 为方法的返回值。pojo可能会需要序列化。

二、集群配置

properties配置

#集群redis节点以及端口

#spring.redis.cluster.nodes=192.168.1.127:7550,192.168.1.127:7551,192.168.1.127:7552,192.168.1.127:7553

RedisClusterConfig

package com.dc.sb.web.redis;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import redis.clients.jedis.HostAndPort;

import redis.clients.jedis.JedisCluster;

import java.util.HashSet;

import java.util.Set;

/**

 * redis 集群配置类

 * 需要时直接   @Autowired JedisCluster

 * @author DUCHONG

 * @since 2018-12-17 17:28

 **/

@Configuration

public class RedisClusterConfig {

    @Value("spring.redis.cluster.nodes")

    private String redisNodes;

    @Bean

    public JedisCluster getJedisCluster(){

        Set<HostAndPort> nodes=new HashSet<HostAndPort>() ;

        String [] redisnodes=redisNodes.split(",");

        for (String redisnode : redisnodes) {

            String [] arr=redisnode.split(":");

            HostAndPort hostAndPort=new HostAndPort(arr[0],Integer.parseInt(arr[1]));

            nodes.add(hostAndPort);

        }

        return new JedisCluster(nodes);

    }

}

使用时直接

@Autowired

private JedisCluster jedisCluster