欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Spring?Boot?接口加解密功能實現(xiàn)

 更新時間:2023年04月29日 09:06:51   作者:mry6  
在我們?nèi)粘5腏ava開發(fā)中,免不了和其他系統(tǒng)的業(yè)務交互,或者微服務之間的接口調(diào)用;如果我們想保證數(shù)據(jù)傳輸?shù)陌踩?,對接口出參加密,入?yún)⒔饷?,這篇文章主要介紹了Spring?Boot?接口加解密功能實現(xiàn),需要的朋友可以參考下

介紹

在我們?nèi)粘5腏ava開發(fā)中,免不了和其他系統(tǒng)的業(yè)務交互,或者微服務之間的接口調(diào)用;如果我們想保證數(shù)據(jù)傳輸?shù)陌踩瑢涌诔鰠⒓用?,入?yún)⒔饷堋5遣幌雽懼貜痛a,我們可以提供一個通用starter,提供通用加密解密功能。

基礎知識

hutool-crypto加密解密工具

hutool-crypto提供了很多加密解密工具,包括對稱加密,非對稱加密,摘要加密等等,這不做詳細介紹。

request流只能讀取一次的問題

問題描述

在接口調(diào)用鏈中,request的請求流只能調(diào)用一次,處理之后,如果之后還需要用到請求流獲取數(shù)據(jù),就會發(fā)現(xiàn)數(shù)據(jù)為空。

比如使用了filter或者aop在接口處理之前,獲取了request中的數(shù)據(jù),對參數(shù)進行了校驗,那么之后就不能在獲取request請求流了。

解決辦法

繼承HttpServletRequestWrapper,將請求中的流copy一份,復寫getInputStream和getReader方法供外部使用。每次調(diào)用后的getInputStream方法都是從復制出來的二進制數(shù)組中進行獲取,這個二進制數(shù)組在對象存在期間一致存在。

使用Filter過濾器,在一開始,替換request為自己定義的可以多次讀取流的request。

下面這樣就實現(xiàn)了流的重復獲取:
工具類(InputStreamHttpServletRequestWrapper):

package com.mry.springboottools.validation;
import org.apache.commons.io.IOUtils;
import javax.servlet.ReadListener;
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletRequestWrapper;
import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
/**
 * 請求流支持多次獲取
 */
public class InputStreamHttpServletRequestWrapper extends HttpServletRequestWrapper {
    /**
     * 用于緩存輸入流
     */
    private ByteArrayOutputStream cachedBytes;
    public InputStreamHttpServletRequestWrapper(HttpServletRequest request) {
        super(request);
    }
    @Override
    public ServletInputStream getInputStream() throws IOException {
        if (cachedBytes == null) {
            // 首次獲取流時,將流放入 緩存輸入流 中
            cacheInputStream();
        }
        // 從 緩存輸入流 中獲取流并返回
        return new CachedServletInputStream(cachedBytes.toByteArray());
    }
    @Override
    public BufferedReader getReader() throws IOException {
        return new BufferedReader(new InputStreamReader(getInputStream()));
    }
    /**
     * 首次獲取流時,將流放入 緩存輸入流 中
     */
    private void cacheInputStream() throws IOException {
        // 緩存輸入流以便多次讀取。為了方便, 我使用 org.apache.commons IOUtils
        cachedBytes = new ByteArrayOutputStream();
        IOUtils.copy(super.getInputStream(), cachedBytes);
    }
    /**
     * 讀取緩存的請求正文的輸入流
     * <p>
     * 用于根據(jù) 緩存輸入流 創(chuàng)建一個可返回的
     */
    public static class CachedServletInputStream extends ServletInputStream {
        private final ByteArrayInputStream input;
        public CachedServletInputStream(byte[] buf) {
            // 從緩存的請求正文創(chuàng)建一個新的輸入流
            input = new ByteArrayInputStream(buf);
        }
        @Override
        public boolean isFinished() {
            return false;
        }
        @Override
        public boolean isReady() {
            return false;
        }
        @Override
        public void setReadListener(ReadListener listener) {
        }
        @Override
        public int read() throws IOException {
            return input.read();
        }
    }
}

Filter過濾器(HttpServletRequestInputStreamFilter):

package com.mry.springboottools.validation;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;
import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import static org.springframework.core.Ordered.HIGHEST_PRECEDENCE;
/**
 * @author
 * @description: 請求流轉換為多次讀取的請求流 過濾器
 */
@Component
@Order(HIGHEST_PRECEDENCE + 1)  // 優(yōu)先級最高
public class HttpServletRequestInputStreamFilter implements Filter {
    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
        // 轉換為可以多次獲取流的request
        HttpServletRequest httpServletRequest = (HttpServletRequest) request;
        InputStreamHttpServletRequestWrapper inputStreamHttpServletRequestWrapper = new InputStreamHttpServletRequestWrapper(httpServletRequest);
        // 放行
        chain.doFilter(inputStreamHttpServletRequestWrapper, response);
    }
}

SpringBoot的參數(shù)校驗validation

為了減少接口中,業(yè)務代碼之前的大量冗余的參數(shù)校驗代碼

SpringBoot-validation提供了優(yōu)雅的參數(shù)校驗,入?yún)⒍际菍嶓w類,在實體類字段上加上對應注解,就可以在進入方法之前,進行參數(shù)校驗,如果參數(shù)錯誤,會拋出錯誤BindException,是不會進入方法的。

這種方法,必須要求在接口參數(shù)上加注解@Validated或者是@Valid

但是很多清空下,我們希望在代碼中調(diào)用某個實體類的校驗功能,所以需要如下工具類。

package com.mry.springboottools.validation;
import javax.validation.ConstraintViolation;
import javax.validation.Validation;
import javax.validation.Validator;
import java.util.LinkedList;
import java.util.List;
import java.util.Set;
/**
 * @author
 * @description 驗證工具類
 */
public class ValidationUtils {
    private static final Validator VALIDATOR = Validation.buildDefaultValidatorFactory().getValidator();
    /**
     * 驗證數(shù)據(jù)
     * @param object 數(shù)據(jù)
     */
    public static void validate(Object object) throws CustomizeException {
        Set<ConstraintViolation<Object>> validate = VALIDATOR.validate(object);
        // 驗證結果異常
        throwParamException(validate);
    }
    /**
     * 驗證數(shù)據(jù)(分組)
     * @param object 數(shù)據(jù)
     * @param groups 所在組
     */
    public static void validate(Object object, Class<?> ... groups) throws CustomizeException {
        Set<ConstraintViolation<Object>> validate = VALIDATOR.validate(object, groups);
        // 驗證結果異常
        throwParamException(validate);
    }
    /**
     * 驗證數(shù)據(jù)中的某個字段(分組)
     * @param object 數(shù)據(jù)
     * @param propertyName 字段名稱
     */
    public static void validate(Object object, String propertyName) throws CustomizeException {
        Set<ConstraintViolation<Object>> validate = VALIDATOR.validateProperty(object, propertyName);
        // 驗證結果異常
        throwParamException(validate);
    }
    /**
     * 驗證數(shù)據(jù)中的某個字段(分組)
     * @param object 數(shù)據(jù)
     * @param propertyName 字段名稱
     * @param groups 所在組
     */
    public static void validate(Object object, String propertyName, Class<?> ... groups) throws CustomizeException {
        Set<ConstraintViolation<Object>> validate = VALIDATOR.validateProperty(object, propertyName, groups);
        // 驗證結果異常
        throwParamException(validate);
    }
    /**
     * 驗證結果異常
     * @param validate 驗證結果
     */
    private static void throwParamException(Set<ConstraintViolation<Object>> validate) throws CustomizeException {
        if (validate.size() > 0) {
            List<String> fieldList = new LinkedList<>();
            List<String> msgList = new LinkedList<>();
            for (ConstraintViolation<Object> next : validate) {
                fieldList.add(next.getPropertyPath().toString());
                msgList.add(next.getMessage());
            }
            throw new ParamException(fieldList, msgList);
        }
    }
}

自定義參數(shù)異常:

package com.mry.springboottools.validation;
import lombok.Getter;
import org.springframework.util.CollectionUtils;
import java.util.List;
/**
 * @author
 * @description 自定義參數(shù)異常
 */
@Getter
public class ParamException extends CustomizeException {
    private List<String> fieldList;
    private List<String> msgList;
    public ParamException(String message) {
        super(message);
    }
    public ParamException(String message, Throwable cause) {
        super(message, cause);
    }
    public ParamException(List<String> fieldList, List<String> msgList) throws CustomizeException {
        super(generatorMessage(fieldList, msgList));
        this.fieldList = fieldList;
        this.msgList = msgList;
    }
    public ParamException(List<String> fieldList, List<String> msgList, Exception ex) throws CustomizeException {
        super(generatorMessage(fieldList, msgList), ex);
        this.fieldList = fieldList;
        this.msgList = msgList;
    }
    private static String generatorMessage(List<String> fieldList, List<String> msgList) throws CustomizeException {
        if (CollectionUtils.isEmpty(fieldList) || CollectionUtils.isEmpty(msgList) || fieldList.size() != msgList.size()) {
            return "參數(shù)錯誤";
        }
        StringBuilder message = new StringBuilder();
        for (int i = 0; i < fieldList.size(); i++) {
            String field = fieldList.get(i);
            String msg = msgList.get(i);
            if (i == fieldList.size() - 1) {
                message.append(field).append(":").append(msg);
            } else {
                message.append(field).append(":").append(msg).append(",");
            }
        }
        return message.toString();
    }
}

自定義異常:

package com.mry.springboottools.validation;
/**
 * @author
 * @description: 自定義異常
 */
public class CustomizeException extends Exception {
    public CustomizeException(String message, Throwable cause) {
        super(message, cause);
    }
    public CustomizeException(String message) {
        super(message);
    }
}

自定義starter

自定義starter步驟:
1.創(chuàng)建工廠,編寫功能代碼;
2.聲明自動配置類,把需要對外提供的對象創(chuàng)建好,通過配置類統(tǒng)一向外暴露;
3.在resource目錄下準備一個名為spring/spring.factories的文件,以org.springframework.boot.autoconfigure.EnableAutoConfiguration為key,自動配置類為value列表,進行注冊;

RequestBodyAdvice和ResponseBodyAdvice

1.RequestBodyAdvice是對請求的json串進行處理, 一般使用環(huán)境是處理接口參數(shù)的自動解密;
2.ResponseBodyAdvice是對請求響應的json傳進行處理,一般用于相應結果的加密;

功能介紹

接口數(shù)據(jù)的時候,返回的是加密之后的數(shù)據(jù) 接口入?yún)⒌臅r候,接收的是解密之后的數(shù)據(jù),但是在進入接口之前,加密的會自動解密,取得對應的數(shù)據(jù)。

功能細節(jié)

加密解密使用對稱加密的AES算法,使用hutool-crypto模塊進行實現(xiàn)

所有的實體類提取一個公共父類,包含屬性時間戳,用于加密數(shù)據(jù)返回之后的實效性,如果超過60分鐘,那么其他接口將不進行處理。

如果接口加了加密注解EncryptionAnnotation,并且返回統(tǒng)一的json數(shù)據(jù)Result類,則自動對數(shù)據(jù)進行加密。如果是繼承了統(tǒng)一父類RequestBase的數(shù)據(jù),自動注入時間戳,確保數(shù)據(jù)的時效性。

如果接口加了解密注解DecryptionAnnotation,并且參數(shù)使用RequestBody注解標注,傳入json使用統(tǒng)一格式RequestData類,并且內(nèi)容是繼承了包含時間長的父類RequestBase,則自動解密,并且轉為對應的數(shù)據(jù)類型。

功能提供Springboot的starter,實現(xiàn)開箱即用。

代碼實現(xiàn)

項目結構

在這里插入圖片描述

crypto-common

在這里插入圖片描述

crypto-spring-boot-starter 代碼結構

在這里插入圖片描述

核心代碼

crypto.properties AES需要的參數(shù)配置

# \u6A21\u5F0F cn.hutool.crypto.Mode
crypto.mode=CTS
# \u8865\u7801\u65B9\u5F0F cn.hutool.crypto.Mode
crypto.padding=PKCS5Padding
# \u79D8\u94A5
crypto.key=testkey123456789
# \u76D0
crypto.iv=testiv1234567890

spring.factories 自動配置文件

org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
com.mry.crypto.config.AppConfig

CryptConfig AES需要的配置參數(shù)

package com.mry.crypto.config;
import cn.hutool.crypto.Mode;
import cn.hutool.crypto.Padding;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.Getter;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import java.io.Serializable;
/**
 * @author
 * @description: AES需要的配置參數(shù)
 */
@Configuration
@ConfigurationProperties(prefix = "crypto")
@PropertySource("classpath:crypto.properties")
@Data
@EqualsAndHashCode
@Getter
public class CryptConfig implements Serializable {
    private Mode mode;
    private Padding padding;
    private String key;
    private String iv;
}

AppConfig 自動配置類

package com.mry.crypto.config;
import cn.hutool.crypto.symmetric.AES;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.annotation.Resource;
import java.nio.charset.StandardCharsets;
/**
 * @author
 * @description: 自動配置類
 */
@Configuration
public class AppConfig {
    @Resource
    private CryptConfig cryptConfig;
    @Bean
    public AES aes() {
        return new AES(cryptConfig.getMode(), cryptConfig.getPadding(), cryptConfig.getKey().getBytes(StandardCharsets.UTF_8), cryptConfig.getIv().getBytes(StandardCharsets.UTF_8));
    }
}
package com.mry.crypto.config;
import cn.hutool.crypto.symmetric.AES;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.annotation.Resource;
import java.nio.charset.StandardCharsets;
/**
 * @author
 * @description: 自動配置類
 */
@Configuration
public class AppConfig {
    @Resource
    private CryptConfig cryptConfig;
    @Bean
    public AES aes() {
        return new AES(cryptConfig.getMode(), cryptConfig.getPadding(), cryptConfig.getKey().getBytes(StandardCharsets.UTF_8), cryptConfig.getIv().getBytes(StandardCharsets.UTF_8));
    }
}

DecryptRequestBodyAdvice 請求自動解密

package com.mry.crypto.advice;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.mry.crypto.annotation.DecryptionAnnotation;
import com.mry.crypto.common.exception.ParamException;
import com.mry.crypto.constant.CryptoConstant;
import com.mry.crypto.entity.RequestBase;
import com.mry.crypto.entity.RequestData;
import com.mry.crypto.util.AESUtil;
import lombok.SneakyThrows;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.MethodParameter;
import org.springframework.http.HttpInputMessage;
import org.springframework.http.converter.HttpMessageConverter;
import org.springframework.web.bind.annotation.ControllerAdvice;
import org.springframework.web.context.request.RequestAttributes;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import org.springframework.web.servlet.mvc.method.annotation.RequestBodyAdvice;
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.lang.reflect.Type;
/**
 * @author
 * @description: requestBody 自動解密
 */
@ControllerAdvice
public class DecryptRequestBodyAdvice implements RequestBodyAdvice {
    @Autowired
    private ObjectMapper objectMapper;
    /**
     * 方法上有DecryptionAnnotation注解的,進入此攔截器
     * @param methodParameter 方法參數(shù)對象
     * @param targetType 參數(shù)的類型
     * @param converterType 消息轉換器
     * @return true,進入,false,跳過
     */
    @Override
    public boolean supports(MethodParameter methodParameter, Type targetType, Class<? extends HttpMessageConverter<?>> converterType) {
        return methodParameter.hasMethodAnnotation(DecryptionAnnotation.class);
    }
    @Override
    public HttpInputMessage beforeBodyRead(HttpInputMessage inputMessage, MethodParameter parameter, Type targetType, Class<? extends HttpMessageConverter<?>> converterType) throws IOException {
        return inputMessage;
    }
    /**
     * 轉換之后,執(zhí)行此方法,解密,賦值
     * @param body spring解析完的參數(shù)
     * @param inputMessage 輸入?yún)?shù)
     * @param parameter 參數(shù)對象
     * @param targetType 參數(shù)類型
     * @param converterType 消息轉換類型
     * @return 真實的參數(shù)
     */
    @SneakyThrows
    @Override
    public Object afterBodyRead(Object body, HttpInputMessage inputMessage, MethodParameter parameter, Type targetType, Class<? extends HttpMessageConverter<?>> converterType) {
        // 獲取request
        RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
        ServletRequestAttributes servletRequestAttributes = (ServletRequestAttributes) requestAttributes;
        if (servletRequestAttributes == null) {
            throw new ParamException("request錯誤");
        }
        HttpServletRequest request = servletRequestAttributes.getRequest();
        // 獲取數(shù)據(jù)
        ServletInputStream inputStream = request.getInputStream();
        RequestData requestData = objectMapper.readValue(inputStream, RequestData.class);
        if (requestData == null || StringUtils.isBlank(requestData.getText())) {
            throw new ParamException("參數(shù)錯誤");
        }
        // 獲取加密的數(shù)據(jù)
        String text = requestData.getText();
        // 放入解密之前的數(shù)據(jù)
        request.setAttribute(CryptoConstant.INPUT_ORIGINAL_DATA, text);
        // 解密
        String decryptText = null;
        try {
            decryptText = AESUtil.decrypt(text);
        } catch (Exception e) {
            throw new ParamException("解密失敗");
        }
        if (StringUtils.isBlank(decryptText)) {
            throw new ParamException("解密失敗");
        }
        // 放入解密之后的數(shù)據(jù)
        request.setAttribute(CryptoConstant.INPUT_DECRYPT_DATA, decryptText);
        // 獲取結果
        Object result = objectMapper.readValue(decryptText, body.getClass());
        // 強制所有實體類必須繼承RequestBase類,設置時間戳
        if (result instanceof RequestBase) {
            // 獲取時間戳
            Long currentTimeMillis = ((RequestBase) result).getCurrentTimeMillis();
            // 有效期 60秒
            long effective = 60*1000;
            // 時間差
            long expire = System.currentTimeMillis() - currentTimeMillis;
            // 是否在有效期內(nèi)
            if (Math.abs(expire) > effective) {
                throw new ParamException("時間戳不合法");
            }
            // 返回解密之后的數(shù)據(jù)
            return result;
        } else {
            throw new ParamException(String.format("請求參數(shù)類型:%s 未繼承:%s", result.getClass().getName(), RequestBase.class.getName()));
        }
    }
    /**
     * 如果body為空,轉為空對象
     * @param body spring解析完的參數(shù)
     * @param inputMessage 輸入?yún)?shù)
     * @param parameter 參數(shù)對象
     * @param targetType 參數(shù)類型
     * @param converterType 消息轉換類型
     * @return 真實的參數(shù)
     */
    @SneakyThrows
    @Override
    public Object handleEmptyBody(Object body, HttpInputMessage inputMessage, MethodParameter parameter, Type targetType, Class<? extends HttpMessageConverter<?>> converterType) {
        String typeName = targetType.getTypeName();
        Class<?> bodyClass = Class.forName(typeName);
        return bodyClass.newInstance();
    }
}

EncryptResponseBodyAdvice 相應自動加密

package com.mry.crypto.advice;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.mry.crypto.annotation.DecryptionAnnotation;
import com.mry.crypto.common.exception.ParamException;
import com.mry.crypto.constant.CryptoConstant;
import com.mry.crypto.entity.RequestBase;
import com.mry.crypto.entity.RequestData;
import com.mry.crypto.util.AESUtil;
import lombok.SneakyThrows;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.MethodParameter;
import org.springframework.http.HttpInputMessage;
import org.springframework.http.converter.HttpMessageConverter;
import org.springframework.web.bind.annotation.ControllerAdvice;
import org.springframework.web.context.request.RequestAttributes;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import org.springframework.web.servlet.mvc.method.annotation.RequestBodyAdvice;
import javax.servlet.ServletInputStream;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.lang.reflect.Type;
/**
 * @author
 * @description: requestBody 自動解密
 */
@ControllerAdvice
public class DecryptRequestBodyAdvice implements RequestBodyAdvice {
    @Autowired
    private ObjectMapper objectMapper;
    /**
     * 方法上有DecryptionAnnotation注解的,進入此攔截器
     * @param methodParameter 方法參數(shù)對象
     * @param targetType 參數(shù)的類型
     * @param converterType 消息轉換器
     * @return true,進入,false,跳過
     */
    @Override
    public boolean supports(MethodParameter methodParameter, Type targetType, Class<? extends HttpMessageConverter<?>> converterType) {
        return methodParameter.hasMethodAnnotation(DecryptionAnnotation.class);
    }
    @Override
    public HttpInputMessage beforeBodyRead(HttpInputMessage inputMessage, MethodParameter parameter, Type targetType, Class<? extends HttpMessageConverter<?>> converterType) throws IOException {
        return inputMessage;
    }
    /**
     * 轉換之后,執(zhí)行此方法,解密,賦值
     * @param body spring解析完的參數(shù)
     * @param inputMessage 輸入?yún)?shù)
     * @param parameter 參數(shù)對象
     * @param targetType 參數(shù)類型
     * @param converterType 消息轉換類型
     * @return 真實的參數(shù)
     */
    @SneakyThrows
    @Override
    public Object afterBodyRead(Object body, HttpInputMessage inputMessage, MethodParameter parameter, Type targetType, Class<? extends HttpMessageConverter<?>> converterType) {
        // 獲取request
        RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
        ServletRequestAttributes servletRequestAttributes = (ServletRequestAttributes) requestAttributes;
        if (servletRequestAttributes == null) {
            throw new ParamException("request錯誤");
        }
        HttpServletRequest request = servletRequestAttributes.getRequest();
        // 獲取數(shù)據(jù)
        ServletInputStream inputStream = request.getInputStream();
        RequestData requestData = objectMapper.readValue(inputStream, RequestData.class);
        if (requestData == null || StringUtils.isBlank(requestData.getText())) {
            throw new ParamException("參數(shù)錯誤");
        }
        // 獲取加密的數(shù)據(jù)
        String text = requestData.getText();
        // 放入解密之前的數(shù)據(jù)
        request.setAttribute(CryptoConstant.INPUT_ORIGINAL_DATA, text);
        // 解密
        String decryptText = null;
        try {
            decryptText = AESUtil.decrypt(text);
        } catch (Exception e) {
            throw new ParamException("解密失敗");
        }
        if (StringUtils.isBlank(decryptText)) {
            throw new ParamException("解密失敗");
        }
        // 放入解密之后的數(shù)據(jù)
        request.setAttribute(CryptoConstant.INPUT_DECRYPT_DATA, decryptText);
        // 獲取結果
        Object result = objectMapper.readValue(decryptText, body.getClass());
        // 強制所有實體類必須繼承RequestBase類,設置時間戳
        if (result instanceof RequestBase) {
            // 獲取時間戳
            Long currentTimeMillis = ((RequestBase) result).getCurrentTimeMillis();
            // 有效期 60秒
            long effective = 60*1000;
            // 時間差
            long expire = System.currentTimeMillis() - currentTimeMillis;
            // 是否在有效期內(nèi)
            if (Math.abs(expire) > effective) {
                throw new ParamException("時間戳不合法");
            }
            // 返回解密之后的數(shù)據(jù)
            return result;
        } else {
            throw new ParamException(String.format("請求參數(shù)類型:%s 未繼承:%s", result.getClass().getName(), RequestBase.class.getName()));
        }
    }
    /**
     * 如果body為空,轉為空對象
     * @param body spring解析完的參數(shù)
     * @param inputMessage 輸入?yún)?shù)
     * @param parameter 參數(shù)對象
     * @param targetType 參數(shù)類型
     * @param converterType 消息轉換類型
     * @return 真實的參數(shù)
     */
    @SneakyThrows
    @Override
    public Object handleEmptyBody(Object body, HttpInputMessage inputMessage, MethodParameter parameter, Type targetType, Class<? extends HttpMessageConverter<?>> converterType) {
        String typeName = targetType.getTypeName();
        Class<?> bodyClass = Class.forName(typeName);
        return bodyClass.newInstance();
    }
}

crypto-test 代碼結構

在這里插入圖片描述

核心代碼

application.yml 配置文件

spring:
  mvc:
    format:
      date-time: yyyy-MM-dd HH:mm:ss
      date: yyyy-MM-dd
  # 日期格式化
  jackson:
    date-format: yyyy-MM-dd HH:mm:ss
    time-zone: GMT+8
server:
  port: 9999

Teacher 實體類

package com.mry.crypto.entity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import org.hibernate.validator.constraints.Range;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
import java.io.Serializable;
import java.util.Date;
/**
 * @author
 * @description: Teacher實體類,使用SpringBoot的validation校驗
 */
@Data
@NoArgsConstructor
@AllArgsConstructor
@EqualsAndHashCode(callSuper = true)
public class Teacher extends RequestBase implements Serializable {
    @NotBlank(message = "姓名不能為空")
    private String name;
    @NotNull(message = "年齡不能為空")
    @Range(min = 0, max = 150, message = "年齡不合法")
    private Integer age;
    @NotNull(message = "生日不能為空")
    private Date birthday;
}

TestController 測試Controller

package com.mry.crypto.controller;
import com.mry.crypto.annotation.DecryptionAnnotation;
import com.mry.crypto.annotation.EncryptionAnnotation;
import com.mry.crypto.common.entity.Result;
import com.mry.crypto.common.entity.ResultBuilder;
import com.mry.crypto.entity.Teacher;
import org.springframework.http.ResponseEntity;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
/**
 * @author
 * @description: 測試Controller
 */
@RestController
public class TestController implements ResultBuilder {
    /**
     * 直接返回對象,不加密
     * @param teacher Teacher對象
     * @return 不加密的對象
     */
    @PostMapping("/get")
    public ResponseEntity<Result<?>> get(@Validated @RequestBody Teacher teacher) {
        return success(teacher);
    }
    /**
     * 返回加密后的數(shù)據(jù)
     * @param teacher Teacher對象
     * @return 返回加密后的數(shù)據(jù) ResponseBody<Result>格式
     */
    @PostMapping("/encrypt")
    @EncryptionAnnotation
    public ResponseEntity<Result<?>> encrypt(@Validated @RequestBody Teacher teacher) {
        return success(teacher);
    }
    /**
     * 返回加密后的數(shù)據(jù)
     * @param teacher Teacher對象
     * @return 返回加密后的數(shù)據(jù) Result格式
     */
    @PostMapping("/encrypt1")
    @EncryptionAnnotation
    public Result<?> encrypt1(@Validated @RequestBody Teacher teacher) {
        return success(teacher).getBody();
    }
    /**
     * 返回解密后的數(shù)據(jù)
     * @param teacher Teacher對象
     * @return 返回解密后的數(shù)據(jù)
     */
    @PostMapping("/decrypt")
    @DecryptionAnnotation
    public ResponseEntity<Result<?>> decrypt(@Validated @RequestBody Teacher teacher) {
        return success(teacher);
    }
}

驗證

加密:

在這里插入圖片描述

解密:

在這里插入圖片描述

到此這篇關于Spring Boot 接口加解密的文章就介紹到這了,更多相關Spring Boot 接口加解密內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!

相關文章

  • Jenkins源代碼管理SVN實現(xiàn)步驟解析

    Jenkins源代碼管理SVN實現(xiàn)步驟解析

    這篇文章主要介紹了Jenkins源代碼管理SVN實現(xiàn)步驟解析,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-09-09
  • Spring?Boot中的JdbcClient與JdbcTemplate使用對比分析

    Spring?Boot中的JdbcClient與JdbcTemplate使用對比分析

    這篇文章主要介紹了Spring Boot中的JdbcClient與JdbcTemplate使用對比分析,一起看看Spring Boot 中 JdbcClient 和 JdbcTemplate 之間的差異
    2024-01-01
  • 詳解java中&和&&的區(qū)別

    詳解java中&和&&的區(qū)別

    這篇文章主要介紹了java中&和&&的區(qū)別,在java中比較常見的運算符:&&(短路與)、&、||(短路或)、|,需要的朋友可以參考下
    2015-07-07
  • java.lang.NumberFormatException異常解決方案詳解

    java.lang.NumberFormatException異常解決方案詳解

    這篇文章主要介紹了java.lang.NumberFormatException異常解決方案詳解,本篇文章通過簡要的案例,講解了該項技術的了解與使用,以下就是詳細內(nèi)容,需要的朋友可以參考下
    2021-08-08
  • Spring Boot 配置文件詳解(小結)

    Spring Boot 配置文件詳解(小結)

    Spring Boot提供了兩種常用的配置文件,分別是properties文件和yml文件。本章重點介紹yml的語法和從配置文件中取值。小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2018-04-04
  • 在ssm中使用ModelAndView跳轉頁面失效的解決

    在ssm中使用ModelAndView跳轉頁面失效的解決

    這篇文章主要介紹了在ssm中使用ModelAndView跳轉頁面失效的解決,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2022-05-05
  • 深入解析Java編程中final關鍵字的使用

    深入解析Java編程中final關鍵字的使用

    這篇文章主要介紹了Java編程中final關鍵字的使用,是Java入門學習中的基礎知識,需要的朋友可以參考下
    2016-01-01
  • 自己動手寫一個java版簡單云相冊

    自己動手寫一個java版簡單云相冊

    這篇文章主要為大家分享了自己動手寫的一個java版簡單云相冊,具有一定的參考價值,感興趣的小伙伴們可以參考一下
    2016-07-07
  • 子類繼承父類時構造函數(shù)相關問題解析

    子類繼承父類時構造函數(shù)相關問題解析

    這篇文章主要介紹了子類繼承父類時構造函數(shù)相關問題解析,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-11-11
  • springboot+vue實現(xiàn)登錄功能的最新方法整理

    springboot+vue實現(xiàn)登錄功能的最新方法整理

    最近做項目時使用到了springboot+vue實現(xiàn)登錄功能的技術,所以下面這篇文章主要給大家介紹了關于springboot+vue實現(xiàn)登錄功能的相關資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下
    2022-06-06

最新評論