前言

Github:https://github.com/HealerJean

博客:http://blog.healerjean.com

一、高效使用枚举

1、低效现状

枚举在系统中的地位不言而喻,状态、类型、场景、标识等等,少则十几个多则上百个,相信以下这段代码很常见,而且类似的代码到处都是,目标:消除这类冗余代码。

/**
 * 根据枚举代码获取枚举
 * 
 */
public static OrderStatus getByCode(String code){
    for (OrderStatus v : values()) {
        if (v.getCode().equals(code)) {
            return v;
        }
    }
    return null;
}

/**
 * 根据枚举名称获取枚举
 * 当枚举内的实例数越多时性能越差
 */
public static OrderStatus getByName(String name){
    for (OrderStatus v : values()) {
        if (v.name().equals(name)) {
            return v;
        }
    }
    return null;
}

2、枚举缓存

1)目标

⬤ 减少代码冗余,代码简洁

⬤ 去掉for循环,性能稳定高效

2)模块设计

image-20230612095244930

image-20230612095253286

3)缓存结构

image-20230612095329545

4)代码实现

a、缓存 EnumCache

package com.hlj.util.z036_枚举;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * EnumCache 枚举缓存
 * @author zhangyujin
 * @date 2023/6/12  09:48
 */
public class EnumCache {

    /**
     * 以枚举任意值构建的缓存结构
     **/
    static final Map<Class<? extends Enum>, Map<Object, Enum>> CACHE_BY_VALUE = new ConcurrentHashMap<>();

    /**
     * 以枚举名称构建的缓存结构
     **/
    static final Map<Class<? extends Enum>, Map<Object, Enum>> CACHE_BY_NAME = new ConcurrentHashMap<>();

    /**
     * 枚举静态块加载标识缓存结构
     */
    static final Map<Class<? extends Enum>, Boolean> LOADED = new ConcurrentHashMap<>();


    /**
     * 以枚举名称构建缓存,在枚举的静态块里面调用
     *
     * @param clazz clazz
     * @param es    es
     * @param <E>   Enum
     */
    public static <E extends Enum> void registerByName(Class<E> clazz, E[] es) {
        Map<Object, Enum> map = new ConcurrentHashMap<>(16);
        for (E e : es) {
            map.put(e.name(), e);
        }
        CACHE_BY_NAME.put(clazz, map);
    }

    /**
     * 以枚举转换出的任意值构建缓存,在枚举的静态块里面调用
     *
     * @param clazz       clazz
     * @param es          es
     * @param enumMapping enumMapping
     * @param <E>         <E>
     */
    public static <E extends Enum> void registerByValue(Class<E> clazz, E[] es, EnumMapping<E> enumMapping) {
        if (CACHE_BY_VALUE.containsKey(clazz)) {
            throw new RuntimeException(String.format("枚举%s已经构建过value缓存,不允许重复构建", clazz.getSimpleName()));
        }
        Map<Object, Enum> map = new ConcurrentHashMap<>(16);
        for (E e : es) {
            Object value = enumMapping.value(e);
            if (map.containsKey(value)) {
                throw new RuntimeException(String.format("枚举%s存在相同的值%s映射同一个枚举%s.%s", clazz.getSimpleName(), value, clazz.getSimpleName(), e));
            }
            map.put(value, e);
        }
        CACHE_BY_VALUE.put(clazz, map);
    }

    /**
     * 从以枚举名称构建的缓存中通过枚举名获取枚举
     *
     * @param clazz       clazz
     * @param name        name
     * @param defaultEnum defaultEnum
     * @param <E>         <E>
     * @return Enum
     */
    public static <E extends Enum> E findByName(Class<E> clazz, String name, E defaultEnum) {
        return find(clazz, name, CACHE_BY_NAME, defaultEnum);
    }

    /**
     * 从以枚举名称构建的缓存中通过枚举名获取枚举
     *
     * @param clazz clazz
     * @param name  name
     * @param <E>   <E>
     * @return Enum
     */
    public static <E extends Enum> E findByName(Class<E> clazz, String name) {
        return find(clazz, name, CACHE_BY_NAME, null);
    }

    /**
     * 从以枚举转换值构建的缓存中通过枚举转换值获取枚举
     *
     * @param clazz       clazz
     * @param value       value
     * @param defaultEnum defaultEnum
     * @param <E>         <E>
     * @return Enum
     */
    public static <E extends Enum> E findByValue(Class<E> clazz, Object value, E defaultEnum) {
        return find(clazz, value, CACHE_BY_VALUE, defaultEnum);
    }

    /**
     * 从以枚举转换值构建的缓存中通过枚举转换值获取枚举
     *
     * @param clazz       clazz
     * @param value       value
     * @param <E>         <E>
     * @return Enum
     */
    public static <E extends Enum> E findByValue(Class<E> clazz, Object value) {
        return find(clazz, value, CACHE_BY_VALUE, null);
    }


    /**
     * find
     *
     * @param clazz       clazz
     * @param obj         obj
     * @param cache       cache
     * @param defaultEnum defaultEnum
     * @param <E>         <E>
     * @return Enum
     */
    private static <E extends Enum> E find(Class<E> clazz, Object obj, Map<Class<? extends Enum>, Map<Object, Enum>> cache, E defaultEnum) {
        Map<Object, Enum> map;
        if ((map = cache.get(clazz)) == null) {
            // 触发枚举静态块执行
            executeEnumStatic(clazz);
            // 执行枚举静态块后重新获取缓存
            map = cache.get(clazz);
        }
        if (map == null) {
            String msg = null;
            if (cache == CACHE_BY_NAME) {
                msg = String.format(
                        "枚举%s还没有注册到枚举缓存中,请在%s.static代码块中加入如下代码 : EnumCache.registerByName(%s.class, %s.values());",
                        clazz.getSimpleName(),
                        clazz.getSimpleName(),
                        clazz.getSimpleName(),
                        clazz.getSimpleName()
                );
            }
            if (cache == CACHE_BY_VALUE) {
                msg = String.format(
                        "枚举%s还没有注册到枚举缓存中,请在%s.static代码块中加入如下代码 : EnumCache.registerByValue(%s.class, %s.values(), %s::getXxx);",
                        clazz.getSimpleName(),
                        clazz.getSimpleName(),
                        clazz.getSimpleName(),
                        clazz.getSimpleName(),
                        clazz.getSimpleName()
                );
            }
            throw new RuntimeException(msg);
        }
        if (obj == null) {
            return defaultEnum;
        }
        Enum result = map.get(obj);
        return result == null ? defaultEnum : (E) result;
    }


    /**
     * executeEnumStatic
     *
     * @param clazz clazz
     * @param <E>   <E>
     */
    private static <E extends Enum> void executeEnumStatic(Class<E> clazz) {
        if (!LOADED.containsKey(clazz)) {
            synchronized (clazz) {
                if (!LOADED.containsKey(clazz)) {
                    try {
                        // 目的是让枚举类的static块运行,static块没有执行完是会阻塞在此的
                        Class.forName(clazz.getName());
                        LOADED.put(clazz, true);
                    } catch (Exception e) {
                        throw new RuntimeException(e);
                    }
                }
            }
        }
    }

    /**
     * 枚举缓存映射器函数式接口
     */
    @FunctionalInterface
    public interface EnumMapping<E extends Enum> {
        /**
         * 自定义映射器
         *
         * @param e 枚举
         * @return 映射关系,最终体现到缓存中
         */
        Object value(E e);
    }

}

b、枚举 StatusEnum

public enum StatusEnum {


    INIT("I", "初始化"),
    PROCESSING("P", "处理中"),
    SUCCESS("S", "成功"),
    FAIL("F", "失败");

    private final String code;
    private final String desc;

    StatusEnum(String code, String desc) {
        this.code = code;
        this.desc = desc;
    }

    public String getCode() {
        return code;
    }

    public String getDesc() {
        return desc;
    }

    static {
        // 通过名称构建缓存,通过EnumCache.findByName(StatusEnum.class,"SUCCESS",null);调用能获取枚举
        EnumCache.registerByName(StatusEnum.class, StatusEnum.values());

        // 通过code构建缓存,通过EnumCache.findByValue(StatusEnum.class,"S",null);调用能获取枚举
        EnumCache.registerByValue(StatusEnum.class, StatusEnum.values(), StatusEnum::getCode);
    }


}

c、测试

@Test
public void test() {
  System.out.println(EnumCache.findByName(StatusEnum.class, "SUCCESS"));
  // 返回默认值StatusEnum.SUCCESS
  System.out.println(EnumCache.findByName(StatusEnum.class, "SUCCESS", null));
  // 返回默认值StatusEnum.SUCCESS
  System.out.println(EnumCache.findByName(StatusEnum.class, null, StatusEnum.INIT));
  // 返回默认值StatusEnum.INIT
  System.out.println(EnumCache.findByName(StatusEnum.class, "ERROR", StatusEnum.INIT));
  // 返回默认值StatusEnum.INIT


  System.out.println(EnumCache.findByValue(StatusEnum.class, "S"));
  // 返回默认值StatusEnum.SUCCESS
  System.out.println(EnumCache.findByValue(StatusEnum.class, "S", null));
  // 返回默认值StatusEnum.SUCCESS
  System.out.println(EnumCache.findByValue(StatusEnum.class, null, StatusEnum.INIT));
  // 返回默认值StatusEnum.INIT
  System.out.println(EnumCache.findByValue(StatusEnum.class, "ERROR", StatusEnum.INIT));
  // 返回默认值StatusEnum.INIT
}

ContactAuthor