redis-cluster通用java接口

Dear 丶 2022-06-16 05:56 124阅读 0赞

## 1.redis-cluster ##

通过结合jedis和spring-data-redis包开发的一个简易方便的redis 集群访问接口。对于redis-cluster方式集群安装参照：[http://blog.csdn.net/cweeyii/article/details/71298905][http_blog.csdn.net_cweeyii_article_details_71298905]

## 2 redis-cluster接口 ##

整个工程代码：[https://github.com/cweeyii/redis-parent][https_github.com_cweeyii_redis-parent]  
接口类：

public interface IRedis<K,HK,HV> {
        void setHashObject(K key, Map<HK, HV> fieldValues, int expireSecond);
    
        void setHashObject(K key, Map<HK, HV> fieldValues);
    
        Map<HK, HV> getHashObject(K key, List<HK> fields);
    
        boolean expire(K key, int expireSeconds);
    
        void setObject(K key, HV value, int expireSecond);
    
        void setObject(K key, HV value);
    
        HV getObject(K key);
    }

实现类：

@Component
    public class RedisImpl<K, HK, HV> implements IRedis<K, HK, HV> {
        private static final int DEFAULT_EXPIRED_TIME=7*24*3600;
        @Resource
        private RedisTemplate<K, HV> redisTemplate;
    
        public void setHashObject(K key, Map<HK, HV> fieldValues, int expireSecond) {
            HashOperations<K, HK, HV> valueOperate = redisTemplate.opsForHash();
            if (!CollectionUtils.isEmpty(fieldValues)) {
                valueOperate.putAll(key, fieldValues);
            }
            expire(key, expireSecond);
        }
    
        @Override
        public void setHashObject(K key, Map<HK, HV> fieldValues) {
            setHashObject(key,fieldValues, DEFAULT_EXPIRED_TIME);
        }
    
        public Map<HK, HV> getHashObject(K key, List<HK> fields) {
            HashOperations<K, HK, HV> valueOperate = redisTemplate.opsForHash();
    
            Map<HK, HV> map = new HashMap<>();
            if (!CollectionUtils.isEmpty(fields)) {
                for (HK field : fields) {
                    HV obj = valueOperate.get(key, field);
                    map.put(field, obj);
                }
            }
            return map;
        }
    
        public boolean expire(K key, int expireSeconds) {
            return redisTemplate.expire(key, expireSeconds, TimeUnit.SECONDS);
        }
    
        public void setObject(K key, HV value, int expireSecond) {
            ValueOperations<K, HV> valueOperate = redisTemplate.opsForValue();
            valueOperate.set(key, value);
            redisTemplate.expire(key, expireSecond, TimeUnit.SECONDS);
        }
    
        @Override
        public void setObject(K key, HV value) {
            setObject(key,value,DEFAULT_EXPIRED_TIME);
        }
    
        public HV getObject(K key) {
            ValueOperations<K, HV> valueOperate = redisTemplate.opsForValue();
            return valueOperate.get(key);
        }
    }

spring-bean配置文件

<?xml version="1.0" encoding="UTF-8" standalone="no"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:context="http://www.springframework.org/schema/context"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd">
        #开启@Component和@Service注解
        <context:component-scan base-package="com.cweeyii.**"/>
        #指定配置文件的位置
        <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
            <property name="locations">
                <list>
                    <value>classpath:redis.properties</value>
                </list>
            </property>
        </bean>
        #redis-cluster的具体配置
        #客户端链接池配置
        <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
            <property name="maxIdle" value="${redis.maxIdle}"/>
            <property name="maxTotal" value="${redis.maxTotal}"/>
            <property name="maxWaitMillis" value="${redis.maxWaitMillis}"/>
            <property name="testOnBorrow" value="${redis.testOnBorrow}"/>
            <property name="testOnReturn" value="${redis.testOnReturn}"/>
        </bean>
        #redis-cluster集群地址
        <bean id="redisCluterConfig" class="org.springframework.data.redis.connection.RedisClusterConfiguration">
            <constructor-arg index="0">
                <set>
                    <value>${redis.host_and_port1}</value>
                    <value>${redis.host_and_port2}</value>
                    <value>${redis.host_and_port3}</value>
                    <value>${redis.host_and_port4}</value>
                    <value>${redis.host_and_port5}</value>
                    <value>${redis.host_and_port6}</value>
                </set>
            </constructor-arg>
        </bean>
        #redis-client与redis-cluster的链接配置
        <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
            <constructor-arg index="0" ref="redisCluterConfig"/>
            <constructor-arg index="1" ref="poolConfig"/>
        </bean>
        #spring-data-redis包装，指定key，value, hkey，hvaue序列化和反序列类
        <bean id="stringRedisSerializer" class="org.springframework.data.redis.serializer.StringRedisSerializer"/>
        <bean id="valueRedisSerializer" class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>
        <bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
            <property name="connectionFactory" ref="jedisConnectionFactory"/>
            <property name="keySerializer" ref="stringRedisSerializer"/>
            <property name="hashKeySerializer" ref="stringRedisSerializer"/>
    
            <property name="valueSerializer" ref="valueRedisSerializer"/>
            <property name="hashValueSerializer" ref="valueRedisSerializer"/>
        </bean>

redis相关配置

redis.host=192.168.31.88
    redis.port=6379
    redis.maxIdle=200
    redis.maxTotal=1000
    redis.maxWaitMillis=2000
    redis.testOnBorrow=true
    redis.testOnReturn=true
    
    redis.host1=192.168.31.88
    redis.port1=6379
    redis.host2=192.168.31.88
    redis.port2=6380
    redis.host3=192.168.31.234
    redis.port3=6379
    redis.host4=192.168.31.234
    redis.port4=6380
    redis.host5=192.168.31.186
    redis.port5=6379
    redis.host6=192.168.31.186
    redis.port6=6380
    
    redis.host_and_port1=192.168.31.88:6379
    redis.host_and_port2=192.168.31.88:6380
    redis.host_and_port3=192.168.31.234:6379
    redis.host_and_port4=192.168.31.234:6380
    redis.host_and_port5=192.168.31.186:6379
    redis.host_and_port6=192.168.31.186:6380

spring测试程序

@Ignore
    @RunWith(SpringJUnit4ClassRunner.class)
    @ContextConfiguration({
       "classpath:applicationContext-redis.xml"})
    public class BaseTest { 
        private static final Logger LOGGER = LoggerFactory.getLogger(BaseTest.class);
    
        @BeforeClass
        public static void setUpBeforeClass() throws Exception {
            LOGGER.info("run setUpBeforeClass");
        }
    
        @AfterClass
        public static void tearDownAfterClass() throws Exception {
            LOGGER.info("run tearDownAfterClass");
        }
    
        @Test
        public void doNothing() {
            LOGGER.info("run doNothing");
        }
    }

public class RedisClientTest extends BaseTest { 
        @Resource
        private IRedis iRedis;
    
        @Test
        public void testSetObject() {
            for (int i = 0; i < 1000; i++) {
                String key = "firstKey" + i;
                String value = "firstValue" + i;
                iRedis.setObject(key, value, DateUtils.getRandomExpireDays(21, 7) * 24 * 3600);
            }
    
            for (int i = 0; i < 10; i++) {
                String key = "firstKey" + i;
                String value = (String) iRedis.getObject(key);
                System.out.println(value);
            }
        }
    
        @Test
        public void testHash() {
            Map<String, Integer> multiValueMap = new HashMap<>();
            for (int i = 0; i < 1000; i++) {
                String hkey = "firstKey" + i;
                multiValueMap.put(hkey, i);
            }
            String key = "key";
            iRedis.setHashObject(key, multiValueMap);
            List<String> hKeyList = new ArrayList<>();
            for (int i = 0; i < 10; i++) {
                hKeyList.add("firstKey" + i);
            }
            Map<String, Integer> valueMap = iRedis.getHashObject(key, hKeyList);
            System.out.print(valueMap);
        }
    }

输出结果  
setObject

firstValue0
    firstValue1
    firstValue2
    firstValue3
    firstValue4
    firstValue5
    firstValue6
    firstValue7
    firstValue8
    firstValue9

setHashObject

{firstKey8=8, firstKey7=7, firstKey9=9, firstKey0=0, firstKey2=2, firstKey1=1, firstKey4=4, firstKey3=3, firstKey6=6, firstKey5=5}

[http_blog.csdn.net_cweeyii_article_details_71298905]: http://blog.csdn.net/cweeyii/article/details/71298905
[https_github.com_cweeyii_redis-parent]: https://github.com/cweeyii/redis-parent