• redis开发帮助组件


    组件编码 hzero-starter-redis

    一、简介

    1.1 概述

    hzero-starter-redis redis开发帮助组件,是从原hzero-starter-core辅助开发组件抽离出来的组件,解决了辅助开发包对redis的强依赖。

    1.2 组件坐标

    <dependency>
        <groupId>org.hzero.starter</groupId>
        <artifactId>hzero-starter-redis</artifactId>
        <version>${hzero.starter.version}</version>
    </dependency>
    

    1.3 特性

    二、使用指南

    2.1 redis

    2.2 cache

    cache下主要提供了一个功能,使用注解根据配置从缓存中获取值。

    public class DemoDTO implements Cacheable {
    
        private Long createdBy; // 创建人ID
    
        @CacheValue(key = HZeroCacheKey.USER, primaryKey = "createdBy", searchKey = "realName",
                structure = CacheValue.DataStructure.MAP_OBJECT)
        private String createdUserName; // 创建人姓名
    
        // getter/setter
    }
    

    2.3 消息队列

    配置:

    hzero:
      redis:
        # 开启消息队列, 默认值false
        redis-queue: true
        # 消息队列默认使用的db, 默认值1
        queue-db: 1
    

    生产者产生消息:调用org.hzero.core.redis.RedisQueueHelperpush``pushAll方法,可以将消息推送到消息队列。其中key是消息队列的消息分组标识,需要全局唯一。
    消息者消费消息:

    @QueueHandler("demo")
    public class DemoListener implements IQueueHandler {
    
        @Override
        public void process(String message) {
            System.out.println(message);
        }
    }
    
    @QueueHandler("demo")
    public class DemoListener implements IBatchQueueHandler {
    
        @Override
        public void process(List<String> messages) {
            for (String message : messages) {
                System.out.println(message);
            }
        }
    }
    

    三、版本更新日志