Java分析讲解序列化与字典功能的序列化
作者：java爱好者 发布时间：2021-11-12 11:19:25
标签：Java,序列化,字典功能
两种解决方案
前端查询字典数据然后前端转码
后端查询字典值，然后再转码返回给前段。
本文及时针对方案2 进行的改进
目标：
在需要返回给前段的字段上添加指定的注解例如：@DictDesc 则根据该字段定义的值结合注解配置生成 xxxDesc字段并自动赋值为注解属性值所对应的字典描述；
具体使用的技术涉及到jackson序列化与反序列化，其他JSON工具包也类型的效果;
字典注解定义
/**
* 字典类型字段自动生成Desc描述字段
*/
@Inherited
@Target(ElementType.FIELD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@JacksonAnnotationsInside
@JsonSerialize(using = DictDescSerializer.class)
@JsonDeserialize(using = DictDescDeserializer.class)
public @interface DictDesc {
/**
* 枚举类型的class
* 取值：getValue, getCode, getStatus, name
* 描述：getDesc
*
* @return 字典类型
*/
Class<? extends Enum<? extends DictEnum>>[] enumType() default {};
/**
* 字典类型分组
*
* @return 字典类型
*/
String[] dictType() default {};
/**
* 字典转换失败时默认值
*
* @return String 默认值
*/
String defaultValue() default "";
/**
* 是否抛出异常，默认不抛出异常，返回默认值
*
* @return true 转换失败则抛出异常，false 异常返回默认值
*/
boolean throwException() default false;
}
该注解中定义了解析该注解需要序列化器与返序列化器：
@JsonSerialize(using = DictDescSerializer.class)
@JsonDeserialize(using = DictDescDeserializer.class)
字典序列化与返序列化器的实现
import com.fasterxml.jackson.core.JacksonException;
import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.databind.BeanProperty;
import com.fasterxml.jackson.databind.DeserializationContext;
import com.fasterxml.jackson.databind.JsonDeserializer;
import com.fasterxml.jackson.databind.JsonMappingException;
import com.fasterxml.jackson.databind.deser.ContextualDeserializer;
import com.aimilin.common.dict.annotation.DictDesc;
import com.aimilin.common.dict.service.impl.DictDescSerializerUtils;
import lombok.NoArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.core.convert.ConversionService;
import org.springframework.core.convert.support.DefaultConversionService;
import java.beans.PropertyDescriptor;
import java.io.IOException;
import java.lang.reflect.Method;
import java.util.Objects;
/**
* 字典类型返序列化器
*
* @author liujunguang1
* @version V1.0
* @date 2022/5/20 21:08
*/
@Slf4j
@NoArgsConstructor
public class DictDescDeserializer extends JsonDeserializer<Object> implements ContextualDeserializer {
/**
* 生成序列化字段后缀
*/
private static final String LABEL_SUFFIX = "Desc";
/**
* 参数类型
*/
private Class<?> rawClass;
/**
* 默认转换器
*/
private ConversionService converter;
/**
* 设置方法
*/
private Method writeMethod;
/**
* 字典配置信息
*/
private DictDesc dict;
public DictDescDeserializer(DictDesc dict, BeanProperty property) {
this.dict = dict;
this.rawClass = property.getType().getRawClass();
this.converter = new DefaultConversionService();
Class<?> targetClass = property.getMember().getDeclaringClass();
String writeField = property.getName() + LABEL_SUFFIX;
PropertyDescriptor propertyDescriptor = BeanUtils.getPropertyDescriptor(targetClass, writeField);
this.writeMethod = Objects.isNull(propertyDescriptor) ? null : propertyDescriptor.getWriteMethod();
if (Objects.isNull(this.writeMethod)) {
log.info("类：{}，字典属性：{}，没有写入方法：{}，不设置值！", targetClass.getName(), property.getName(), writeField);
}
}
@Override
public JsonDeserializer<?> createContextual(DeserializationContext ctxt, BeanProperty property) throws JsonMappingException {
DictDesc dict = property.getAnnotation(DictDesc.class);
if (dict != null) {
return new DictDescDeserializer(dict, property);
}
return this;
}
@Override
public Object deserialize(JsonParser p, DeserializationContext ctxt) throws IOException, JacksonException {
Object result = this.getValue(p.getText());
this.setDictDesc(result, p.getCurrentName(), p.getCurrentValue());
return result;
}
/**
* 将数据类型转换为目标类型
*
* @param value 字符串值
* @return 目标类型值
* @throws IOException
*/
public Object getValue(String value) throws IOException {
return converter.convert(value, this.rawClass);
}
/**
* 设置字典会限制
*
* @param result 字典value
* @param currentName 当前属性名称
* @param currentValue 当前对象
*/
private void setDictDesc(Object result, String currentName, Object currentValue) {
try {
if (this.writeMethod != null) {
writeMethod.invoke(currentValue, DictDescSerializerUtils.getDesc(this.dict, currentName, result));
}
} catch (Exception e) {
log.error("类：{}，字典属性：{}，回显异常：{}", currentValue.getClass(), currentName, e.getMessage(), e);
}
}
}
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.databind.BeanProperty;
import com.fasterxml.jackson.databind.JsonMappingException;
import com.fasterxml.jackson.databind.JsonSerializer;
import com.fasterxml.jackson.databind.SerializerProvider;
import com.fasterxml.jackson.databind.ser.ContextualSerializer;
import com.aimilin.common.dict.annotation.DictDesc;
import com.aimilin.common.dict.service.impl.DictDescSerializerUtils;
import lombok.NoArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import java.io.IOException;
/**
* 字典序列化器
*
* @author liujunguang1
* @version V1.0
* @date 2022/5/20 20:48
*/
@Slf4j
@NoArgsConstructor
public class DictDescSerializer extends JsonSerializer<Object> implements ContextualSerializer {
/**
* 生成序列化字段后缀
*/
private static final String LABEL_SUFFIX = "Desc";
/**
* 字典配置信息
*/
private DictDesc dict;
/**
* 构造方法
*
* @param dict 字典描述
*/
public DictDescSerializer(DictDesc dict) {
this.dict = dict;
}
@Override
public JsonSerializer<?> createContextual(SerializerProvider prov, BeanProperty property) throws JsonMappingException {
DictDesc dict = property.getAnnotation(DictDesc.class);
if (dict != null) {
return new DictDescSerializer(dict);
}
return this;
}
/**
* Method that can be called to ask implementation to serialize
* values of type this serializer handles.
*
* @param value Value to serialize; can <b>not</b> be null.
* @param gen Generator used to output resulting Json content
* @param provider Provider that can be used to get serializers for
* serializing Objects value contains, if any.
*/
@Override
public void serialize(Object value, JsonGenerator gen, SerializerProvider provider) throws IOException {
provider.defaultSerializeValue(value, gen);
if (dict != null) {
String fieldName = gen.getOutputContext().getCurrentName();
// 添加转换之后的字段：xxxDesc
gen.writeStringField(fieldName.concat(LABEL_SUFFIX), DictDescSerializerUtils.getDesc(dict, fieldName, value));
}
}
}
字典序列化与反序列工具类
import cn.hutool.extra.spring.SpringUtil;
import com.aimilin.common.core.pojo.system.SysDict;
import com.aimilin.common.dict.annotation.DictDesc;
import com.aimilin.common.dict.annotation.DictEnum;
import com.aimilin.common.dict.exception.DictException;
import com.aimilin.common.dict.exception.enums.DictExceptionEnum;
import com.aimilin.common.dict.service.SysDictService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.ArrayUtils;
import org.apache.commons.lang3.StringUtils;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.util.Arrays;
import java.util.List;
import java.util.Objects;
/**
* 字典转换工具类
*
* @author liujunguang1
* @version V1.0
* @date 2022/5/20 23:19
*/
@Slf4j
public class DictDescSerializerUtils {
/**
* 获取字典信息
*
* @param dict 字典对象
* @param value 字典值
* @return
*/
public static String getDesc(DictDesc dict, String field, Object value) {
if (ArrayUtils.isEmpty(dict.dictType()) && ArrayUtils.isEmpty(dict.enumType())) {
throw new DictException(DictExceptionEnum.REQUEST_DICT_TYPE, field);
}
try {
if (value == null) {
throw new DictException(DictExceptionEnum.REQUEST_NOT_NULL, field);
}
if (ArrayUtils.isNotEmpty(dict.enumType())) {
return getEnumDesc(dict, field, value);
}
return getDictDesc(dict, field, value);
} catch (Exception e) {
log.error("字典转换异常, field:{}, enumType:{}, dictType:{}, 值：{}, 异常：{}",
field, dict.enumType(), dict.dictType(), value, e.getMessage(), e);
if (dict.throwException()) {
throw e instanceof DictException ? (DictException) e : new DictException(DictExceptionEnum.DICT_EXCEPTION, e);
}
return dict.defaultValue();
}
}
/**
* 获取枚举类型的描述信息
*
* @param dict 字典
* @param value 值
* @return 枚举desc字段
*/
public static String getEnumDesc(DictDesc dict, String field, Object value) throws NoSuchMethodException, InvocationTargetException, IllegalAccessException {
for (Class<? extends Enum<? extends DictEnum>> dictEnum : dict.enumType()) {
Method getCode = dictEnum.getMethod("getCode");
Method getMessage = dictEnum.getMethod("getMessage");
for (Enum<? extends DictEnum> e : dictEnum.getEnumConstants()) {
if (value.equals(getCode.invoke(e))) {
return Objects.toString(getMessage.invoke(e));
}
}
}
throw new DictException(DictExceptionEnum.UNKNOWN_ENUM_DICT_VALUE,
String.format("Field:％s, EnumType: ％s, Value: ％s", field, Arrays.toString(dict.enumType()), value));
}
/**
* 获取字典中的值
*
* @param dict 字典注解
* @param value 属性值
* @return 字典名称
*/
public static String getDictDesc(DictDesc dict, String field, Object value) {
if (ArrayUtils.isEmpty(dict.dictType())) {
throw new DictException(DictExceptionEnum.REQUEST_DICT_TYPE, field);
}
List<SysDict> sysDictList = SpringUtil.getBean(SysDictService.class).getDictByDictTypeCode(dict.dictType());
if (CollectionUtils.isEmpty(sysDictList)) {
throw new DictException(DictExceptionEnum.NO_DICT_DATA, field, Arrays.toString(dict.dictType()));
}
for (SysDict sysDict : sysDictList) {
if (StringUtils.equals(sysDict.getCode(), Objects.toString(value))) {
return sysDict.getValue();
}
}
throw new DictException(DictExceptionEnum.UNKNOWN_DICT_VALUE, field, Arrays.toString(dict.dictType()));
}
}
字典转换服务类
/**
* 字典服务类
*
* @author liujunguang1
* @version V1.0
* @date 2022/5/20 16:03
*/
public interface SysDictService {
/**
* 根据字典类型code获取字典列表
*
* @param dictTypeCodes 字典类型code
* @return List<SysDict>
*/
public List<SysDict> getDictByDictTypeCode(String... dictTypeCodes);
}
服务实现类：
/**
* 系统字典服务实现类
*
* @author liujunguang1
* @version V1.0
* @date 2022/5/20 16:13
*/
@Service
public class SysDictServiceImpl implements SysDictService {
@Resource
private SystemContextServiceApi systemContextServiceApi;
@Resource
private SysDictCache sysDictCache;
/**
* 根据字典类型编码获取字典数据
*
* @param dictTypeCodes 字典类型编码值
* @return List<SysDict>
*/
@Override
public List<SysDict> getDictByDictTypeCode(String... dictTypeCodes) {
List<SysDict> dictTypeCache = sysDictCache.getDictTypeCache(dictTypeCodes);
if (CollectionUtils.isNotEmpty(dictTypeCache)) {
return dictTypeCache;
}
return systemContextServiceApi.getDictByDictTypeCode(dictTypeCodes).getData();
}
}
字典缓存服务
可以修改为使用本地缓存方式
/**
* 字典缓存服务
*
* @version V1.0
* @date 2022/5/19 12:13
*/
@Slf4j
@Service
public class SysDictCache {
@Resource
private RedisService redisService;
/**
* 获取字典类型缓存
*
* @param dictTypes 字典类型
* @return 字典列表
*/
public List<SysDict> getDictTypeCache(String... dictTypes) {
if (Objects.isNull(redisService)) {
log.info("redisService 为空，不使用字典缓存");
return null;
}
List<List<SysDict>> dictValues = redisService.getMultiCacheMapValue(CommonConstant.DICT_CACHE_KEY, Arrays.asList(dictTypes));
if (CollectionUtils.isEmpty(dictValues)) {
return null;
}
List<SysDict> result = new ArrayList<>();
dictValues.stream().filter(Objects::nonNull).forEach(result::addAll);
log.debug("查询字典缓存，dictTypes:{}, 结果：{}", dictTypes, result);
return result;
}
/**
* 清空字典类型缓存
*
* @param dictTypes 字典类型
*/
public void cleanDictTypeCache(String... dictTypes) {
if (Objects.isNull(redisService)) {
return;
}
redisService.deleteCacheMapValue(CommonConstant.DICT_CACHE_KEY, dictTypes);
log.info("清除字典缓存，dictTypes:{}", StringUtils.join(dictTypes));
}
/**
* 添加缓存
*
* @param sysDictList 系统字典列表
*/
public void putDictTypeCache(List<SysDict> sysDictList) {
if (Objects.isNull(redisService) || CollectionUtils.isEmpty(sysDictList)) {
return;
}
Map<String, List<SysDict>> collect = sysDictList.stream().collect(Collectors.groupingBy(SysDict::getTypeCode));
for (Map.Entry<String, List<SysDict>> entry : collect.entrySet()) {
redisService.setCacheMapValue(CommonConstant.DICT_CACHE_KEY, entry.getKey(), entry.getValue());
log.info("设置字典缓存，dictType：{}，结果：{}", entry.getKey(), entry.getValue());
}
}
}
来源：https://lliujg.blog.csdn.net/article/details/125136181
0
投稿猜你喜欢
MyBatis的前身叫iBatis，本是apache的一个开源项目, 2010年这个项目由apache software foundatio- 在Servlet 3.0之前都是使用web.xml文件进行配置，需要增加Servlet、Filter或者Listener都需要在web.xm
- 前言：前面几篇讲了自定义控件绘制原理Android自定义控件基本原理详解（一） ，Android自定义控件之自定义属性（二） ，Androi
- 简介JSON Web Token（缩写 JWT）是目前最流行的跨域认证解决方案。JSON Web Token 入门教程 这篇文章可以帮你了解
- startJVM是加载jvm用的方法。在JPype，apache mod等等很多地方都用到。但凡要用其他语言来加载jvm进程，就要用到这个。
- 介绍随着当今处理器中可用的核心数量的增加， 随着对实现更高吞吐量的需求的不断增长，多线程 API 变得非常流行。 Java 提供了自己的多线
- 修改加密和验证方法/** * 生成BCryptPasswordEncoder密码 *
- 本文实例讲述了C#实现利用泛型将DataSet转为Model的方法。分享给大家供大家参考。具体如下：因为网站需要用C#开发，习惯了java的
- 之前一直在Android应用层上做工作，最近开始研究Android平台上的东东了，主要是在Android Frameworks层和系统库层进
- 背景公司的一个服务需要做类似于分片的逻辑，一开始服务基于传统部署方式通过本地配置文件配置的方式就可以指定该机器服务的分片内容如：0,1,2,
- 实际上，HashSet 和 HashMap 之间有很多相似之处，对于 HashSet 而言，系统采用 Hash 算法决定集合元素的存储位置，
- 教你一步一步用 java 设计生成二维码在物联网的时代，二维码是个很重要的东西了，现在无论什么东西都要搞个二维码标志，唯恐落伍，就差人没有用
- SwipeRefreshLayout是Android官方的下拉刷新控件，使用简单，界面美观，不熟悉的朋友可以随便搜索了解一下，这里就不废话了
- SpringBatch介绍：SpringBatch 是一个大数据量的并行处理框架。通常用于数据的离线迁移，和数据处理，⽀持事务、并发、流程、
- 简介一个APP如果没有页面跳转那么是没有灵魂的，页面跳转的一个常用说法就是Navigator,flutter作为一个最为优秀的前端框架，Na
- 1.super介绍我们可以通过super关键字来实现对父类成员的访问，用来引用当前对象的父类。用于访问父类的属性，方法，构造器2.super
- 下面是利用Java实现读写文件功能的示例代码读文件TextRead.javaimport java.io.BufferedReader;im
- 延迟加载(lazy loading) 设计模式是为了避免一些无谓的性能开销而提出来的，所谓延迟加载就是当在真正需要数据(读取属性值)的时候，
- 本文实例讲述了Android列表控件Spinner简单用法。分享给大家供大家参考，具体如下：Android的Spinner控件用来显示列表项
- 介绍try-with-resources是Java中的环绕语句之一，旨在减轻开发人员释放try块中使用的资源的义务。它最初在Java 7中引
