枚举+链对缓存实现以读取为主的请求接口

news/2024/5/19 0:29:33 标签: 缓存, 链对缓存, 枚举

一、需求背景

      需要给一份问卷进行授权,授权的角色固定为4类,分别是: 农户、企业、金融机构、政府用户,这4类角色定义在字典里面,并且很少改动。这4类角色下面,可能有多个角色,这些角色通过字典的key关联到上述4个类型中的一个;
      在新增、编辑问卷的时候,需要把这4类所有的角色都展示出来,供管理员选择。

二、需求分析

      由于涉及到的数据很少改动,且主要以查询为主,于是第一想法就是通过 枚举+链对实现,具体实现如下:

三、实现过程

1. 枚举

import lombok.Getter;
import lombok.Setter;

import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Consumer;
import java.util.stream.Stream;

import static com.xxx.xxx.utils.StreamUtil.forEachIfPresent;

/**
 * Author:   wxz
 * Date:     2023.11.29 10:35
 * Description: 问卷调查授权枚举
 */
public enum PaperAuthorRoleEnum {
    ANONYMITY("un-limit", "不限", Collections.singletonList("")),
    AGRICULTURAL("member", "农户",Collections.singletonList("member")),
    ENTERPRISE("enterprises", "企业", Collections.singletonList("agricultural-enterprises")),
    FINANCIAL_INSTITUTION("finance", "金融机构",FinanceRoleKeys()),
    GOVERNMENT_USERS("government", "政府用户", GovernmentRoleKeys()),
    ;
    /**
     * 角色类型
     */
    @Getter
    private final String type;
    /**
     * 角色类型名称
     */
    @Getter
    private final String typeName;

    /**
     * 角色id集合
     */
    @Getter
    private final List<String> roleKeys;

    /**
     * 角色列表
     */
    @Getter
    private final List<PaperRole> paperRoleList;
    /**
     * 角色缓存数据
     */
    private static Map<String, SysRole> roleCache = new ConcurrentHashMap<>();


    PaperAuthorRoleEnum(String type, String typeName, List<String> roleKeys) {
        this.type = type;
        this.typeName = typeName;
        this.roleKeys = roleKeys;
        this.paperRoleList = getRolesFromCache(roleKeys);
    }

    /**
     * 根据角色类型查找枚举
     * @param type 角色类型
     * @return 类型枚举
     */
    public static PaperAuthorRoleEnum of(String type) {
        if (type == null) {
            return null;
        }
        PaperAuthorRoleEnum[] values = PaperAuthorRoleEnum.values();
        for (PaperAuthorRoleEnum a : values) {
            if (a.type.equals(type)) {
                return a;
            }
        }
        return null;
    }

    /**
     * 金融机构角色keys
     */
    private static List<String> FinanceRoleKeys() {
        List<String> list = new ArrayList<>();
        //银行机构有5个等级
        for (int i = 1; i < 5; i++) {
            list.add("bank_level_" + i);
        }
        return list;
    }

    /**
     * 政府角色keys
     */
    private static List<String> GovernmentRoleKeys() {
        return new ArrayList<>(Arrays.asList("collector","government","government-role"));
    }

    /**
     * 获取所有枚举的keys
     * @return
     */
    private List<String> getAllRolKeys() {
        List<String> roleKeys = new ArrayList<>();
        roleKeys.addAll(Collections.singletonList("member"));
        roleKeys.addAll(Collections.singletonList("agricultural-enterprises"));
        roleKeys.addAll(FinanceRoleKeys());
        roleKeys.addAll(GovernmentRoleKeys());
        return roleKeys;
    }

    /**
     * 从缓存中获取角色列表
     * @param roleKeys
     * @return
     */
    private  List<PaperRole> getRolesFromCache(List<String> roleKeys) {
        List<PaperRole> paperRoles = new ArrayList<>();
        Set<String> notExitKeys = new HashSet<>();
        boolean sign = (roleCache == null);
        //如果已经存在缓存里面,则优先从缓存里面获取
        if (sign) {
            notExitKeys.addAll(getAllRolKeys());
            roleCache = new ConcurrentHashMap<>();
        } else {
            roleKeys.forEach(key -> {
                if (!roleCache.containsKey(key)) {
                    notExitKeys.add(key);
                } else {
                    PaperRole paperRole =
                            new PaperRole().setRoleId(roleCache.get(key).getRoleId()).setRoleName(roleCache.get(key).getRoleName());
                    paperRoles.add(paperRole);
                }
            });
        }
        //不存在于缓存的数据,重新从数据库里面查询出来,放在缓存里面
        if (notExitKeys.size() > 0) {
            Optional<List<SysRole>> sysRoles =
                    Optional.ofNullable(SpringUtils.getBean(SysRoleMapper.class).selectListByRoleKeys(new ArrayList<>(notExitKeys)));
           // forEachIfPresent()方法参考:  https://blog.csdn.net/qq_37844454/article/details/134964619
            forEachIfPresent(sysRoles,item->{
                roleCache.put(item.getRoleKey(), item);
                PaperRole paperRole = new PaperRole().setRoleId(item.getRoleId()).setRoleName(item.getRoleName());
                paperRoles.add(paperRole);
            });
        }
        return paperRoles;
    }
    /**
     * 获取所有的枚举
     */
    public static PaperAuthorRoleEnum[] getValues() {
        return new PaperAuthorRoleEnum[]{AGRICULTURAL, ENTERPRISE, FINANCIAL_INSTITUTION, GOVERNMENT_USERS};
    }
}

2. 控制器调用

    //使用线程安装的链对做缓存,避免读多写少的数据频繁请求数据库
    private static ConcurrentLinkedQueue<PaperAuthorTypeDTO> dtoQueue = new ConcurrentLinkedQueue<>();
    
    @GetMapping(value = "/getRoleList")
    public AjaxResult getRoleList() {
        if (CollectionUtils.isEmpty(dtoQueue)) {
            dtoQueue = new ConcurrentLinkedQueue<>();
            Arrays.stream(PaperAuthorRoleEnum.getValues()).forEach(anEnum->{
                dtoQueue.offer(new PaperAuthorTypeDTO().setRoleId(anEnum.getType()).setRoleName(anEnum.getTypeName()));
            });
        }
        return AjaxResult.success(dtoQueue);
    }

http://www.niftyadmin.cn/n/5261502.html

相关文章

<JavaEE> 文件IO -- File类和文件操作

目录 一、文件的概念 二、文件系统 三、文件类型 四、使用 File 类进行文件操作 4.1 File 类中的 pathSeparator 属性 4.2 File 类构造方法 4.3 File 类常用方法 一、文件的概念 什么是文件&#xff1f; 广义上的“文件”是指抽象化的操作系统中的硬件设备和软件资源&a…

大数据CloudSim应用实践

CloudSimExampleA.java 1准备 1.1操作系统 本实验在Windows 7 或Windows 10系统运行均可。 1.2软件 cloudsim-3.0.3.zip&#xff1b; commons-math3-3.2-bin.zip&#xff1b; jdk-8u152-windows-x64.exe&#xff1b; eclipse-jee-neon-3-win32-x86_64 所需资料链接&#xff1…

Github、Gitee优秀的开源项目分享

先赞后看&#xff0c;养成习惯&#xff01;&#xff01;&#xff01;❤️ ❤️ ❤️ 资源收集不易&#xff0c;如果喜欢可以关注我哦&#xff01; ​如果本篇内容对你有所启发&#xff0c;欢迎访问我的个人博客了解更多内容&#xff1a;链接地址 ​ Java 项目 javacore - Java …

ArkTS的状态管理机制(State)

什么是ArkTS的状态管理机制 声明式UI中&#xff0c;是以状态(State)来驱动视图更新的(View)。 状态是指驱动视图更新的数据(被装饰器标记的变量)。 视图是指UI描述渲染得到的用户页面。 互动事件可以改变状态的值。状态改变以后&#xff0c;又会触发事件&#xff0c;渲染页面。…

CentOS 7 部署frp穿透内网

本文将介绍如何在CentOS 7.9上部署frp&#xff0c;并通过示例展示如何配置和测试内网穿透。 文章目录 &#xff08;1&#xff09;引言&#xff08;2&#xff09;准备工作&#xff08;4&#xff09;frps服务器端配置&#xff08;5&#xff09;frpc客户端配置&#xff08;6&#…

使用 Timm 库替换 RT-DETR 主干网络 | 1000+ 主干融合RT-DETR

文章目录 前言版本差异说明替换方法parse_moedl( ) 方法_predict_once( ) 方法修改 yaml ,加载主干论文引用timm 是一个包含最先进计算机视觉模型、层、工具、优化器、调度器、数据加载器、数据增强和训练/评估脚本的库。 该库内置了 700 多个预训练模型,并且设计灵活易用。…

Android13适配所有文件管理权限

Android13适配所有文件管理权限 前言&#xff1a; 很早之前在Android11上面就适配过所有文件管理权限&#xff0c;这次是海外版升级到Android13&#xff0c;由于选择相册用的是第三方库&#xff0c;组内的同事没有上架Google的经验直接就提交代码&#xff0c;虽然功能没有问题…

[论文精读] 使用扩散模型生成真实感视频 - 【李飞飞团队新作,文生视频 新基准】

论文导读: 论文背景:2023年12月11日&#xff0c;AI科学家李飞飞团队与谷歌合作&#xff0c;推出了视频生成模型W.A.L.T&#xff08;Window Attention Latent Transformer&#xff09;——一个在共享潜在空间中训练图像和视频生成的、基于Transformer架构的扩散模型。李飞飞是华…