SOA中springmvc中restful服务的数据权限加密方式分享

本文涉及的产品
密钥管理服务KMS,1000个密钥,100个凭据,1个月
简介: java、Spring Cloud

restful中数据权限加密方式有很多种,特别是针对于request json的方式加密,这里详细介绍了SOA中针对于get、post数据加密方式,保证数据传输中的安全性:

public class DataSignInterceptor implements MethodInterceptor {  
    @Autowired  
    private SoaServiceConfigService soaServiceConfigService;  
  
    @Autowired  
    private SoaAppSecretService soaAppSecretService;  
      
    @Autowired  
    private SoaServiceApplyService soaServiceApplyService;  
      
    public Object invoke(MethodInvocation mi) throws Throwable {  
        //TODO 此处应该先查询缓存  
        //获取所有未管控的服务列表  
        List<SoaServiceConfig> soaServiceConfigList = soaServiceConfigService.findNoSwitchList();  
        if(soaServiceConfigList != null){  
            //放入缓存  
        }  
        Object[] ars = mi.getArguments();  
  
        // 判断该方法是否加了DataSign 注解  
        if (mi.getMethod().isAnnotationPresent(DataSign.class)) {  
            // 获取拦截方法的请求参数  
            HttpServletRequest request = null;  
            JSONObject jsonBody = null;  
            Map<String, String> reqGetParamMap = null; // 客户端传递的参数信息  
            Map<String, String> reqPostParamMap = null; // 客户端传递的参数信息  
            Map<String, String> resultParamMap = new HashMap<String, String>();  
            for (Object obj : ars) {  
                if (obj instanceof HttpServletRequest) {  
                    request = (HttpServletRequest) obj;  
                    reqGetParamMap = (Map<String, String>) request.getParameterMap();  
                    Set keSet = reqGetParamMap.entrySet();  
                    for (Iterator itr = keSet.iterator(); itr.hasNext();) {  
                        Map.Entry me = (Map.Entry) itr.next();  
                        String key = me.getKey().toString();  
                        Object ov = me.getValue();  
                        String[] value =new String[1];    
                        if(ov instanceof String[]){    
                            value=(String[])ov;    
                        }else{    
                            value[0]=ov.toString();    
                        }    
                          
                        resultParamMap.put(key, value[0]);  
                    }  
                } else if (obj instanceof JSONObject) {  
                    jsonBody = (JSONObject) obj;  
                    ObjectMapper objMap = new ObjectMapper();  
                    reqPostParamMap = objMap.readValue(jsonBody.toString(), Map.class);  
                    resultParamMap = reqPostParamMap;  
                }  
            }  
              
            String serviceUrl = request.getServletPath();  
            if(StringUtils.isNotEmpty(serviceUrl)){  
                serviceUrl = serviceUrl.substring(serviceUrl.indexOf("/",2));  
            }  
              
            //TODO 应该从缓存取,当前先这样处理  
            //如果所有未管控的服务列表中包含用户请求的服务连接,则不需要再进行管控,直接放开服务控制权  
            if(soaServiceConfigList != null){  
                for(SoaServiceConfig soaServiceConfig : soaServiceConfigList){  
                    if(serviceUrl.equals(soaServiceConfig.getServiceUrl())){  
                        return mi.proceed();  
                    }  
                }  
            }  
              
            String reqSign = resultParamMap.get("sign");// 客户端传递的签名认证信息  
            // 验证签名不能为空  
            if (StringUtils.isEmpty(reqSign)) {  
                return new ResponseVO(DataSignEnum.SIGN_NOT_NULL.getCode(), DataSignEnum.SIGN_NOT_NULL.getMessage(),  
                        null);  
            }  
  
            String appname = resultParamMap.get("appname");  
            // 验证应用名不能为空  
            if (StringUtils.isEmpty(appname)) {  
                return new ResponseVO(DataSignEnum.APPNAME_NOT_NULL.getCode(),  
                        DataSignEnum.APPNAME_NOT_NULL.getMessage(), null);  
            }  
              
            SoaServiceApply soaServiceApply = soaServiceApplyService.getServiceApplyByAppname(serviceUrl, appname);  
            if(null == soaServiceApply){  
                return new ResponseVO(DataSignEnum.APPNAME_NOT_APPLY.getCode(),  
                        DataSignEnum.APPNAME_NOT_APPLY.getMessage(), null);  
            }  
              
            SoaAppSecret soaAppSecret = soaAppSecretService.findAppSecretByAppName(appname);  
            if(null == soaAppSecret){  
                return new ResponseVO(DataSignEnum.APPNAME_NOT_EXISTS.getCode(),  
                        DataSignEnum.APPNAME_NOT_EXISTS.getMessage(), null);  
                  
            }  
            // 根据参数重新生成新的签名sign(因为sign不能认为是业务参数,故将sign从map中移除后再加密)  
            resultParamMap.remove("sign");  
              
            resultParamMap.put("token", soaAppSecret.getToken());  
            String sign = MD5Utils.paramString(resultParamMap);  
  
            // 根据应用名获取应用名对应的秘钥(目的是和url请求的参数一起进行签名认证)  
            if (!StringUtils.equals(sign, reqSign)) {  
                return new ResponseVO(DataSignEnum.SIGN_NOT_MATCH.getCode(), DataSignEnum.SIGN_NOT_MATCH.getMessage(),  
                        null);  
            }  
        }  
        // 执行被拦截的方法,切记,如果此方法不调用,则被拦截的方法不会被执行。  
        return mi.proceed();  
    }  
  
    /** 
     * 数据签名枚举 
     *  
     * @author Administrator 
     */  
    public enum DataSignEnum {  
        SIGN_NOT_NULL(2001, "签名不能为空."),   
        SIGN_NOT_MATCH(2002, "签名不匹配,传递的数据被篡改过."),   
        APPNAME_NOT_NULL(2003, "应用名不能为空."),  
        APPNAME_NOT_EXISTS(2004, "应用名不存在."),  
        APPNAME_NOT_APPLY(2005, "当前应用没有权限访问此服务,请联系管理员进行服务申请.");  
  
        // 成员变量  
        private int code; // 状态码  
        private String message; // 返回消息  
        // 构造方法  
  
        private DataSignEnum(int code, String message) {  
            this.code = code;  
            this.message = message;  
        }  
  
        public int getCode() {  
            return code;  
        }  
  
        public void setCode(int code) {  
            this.code = code;  
        }  
  
        public String getMessage() {  
            return message;  
        }  
  
        public void setMessage(String message) {  
            this.message = message;  
        }  
    }  
  
}  
目录
相关文章
|
4月前
|
存储 缓存 NoSQL
【Azure Redis 缓存】关于Azure Cache for Redis 服务在传输和存储键值对(Key/Value)的加密问题
【Azure Redis 缓存】关于Azure Cache for Redis 服务在传输和存储键值对(Key/Value)的加密问题
|
6天前
|
设计模式 前端开发 Java
步步深入SpringMvc DispatcherServlet源码掌握springmvc全流程原理
通过对 `DispatcherServlet`源码的深入剖析,我们了解了SpringMVC请求处理的全流程。`DispatcherServlet`作为前端控制器,负责请求的接收和分发,处理器映射和适配负责将请求分派到具体的处理器方法,视图解析器负责生成和渲染视图。理解这些核心组件及其交互原理,有助于开发者更好地使用和扩展SpringMVC框架。
22 4
|
4月前
|
缓存 弹性计算 API
用 Go 快速开发一个 RESTful API 服务
用 Go 快速开发一个 RESTful API 服务
|
23天前
|
前端开发 Java 开发者
Spring MVC中的请求映射:@RequestMapping注解深度解析
在Spring MVC框架中,`@RequestMapping`注解是实现请求映射的关键,它将HTTP请求映射到相应的处理器方法上。本文将深入探讨`@RequestMapping`注解的工作原理、使用方法以及最佳实践,为开发者提供一份详尽的技术干货。
69 2
|
29天前
|
JSON 关系型数据库 测试技术
使用Python和Flask构建RESTful API服务
使用Python和Flask构建RESTful API服务
|
2月前
|
JSON 前端开发 Java
SSM:SpringMVC
本文介绍了SpringMVC的依赖配置、请求参数处理、注解开发、JSON处理、拦截器、文件上传下载以及相关注意事项。首先,需要在`pom.xml`中添加必要的依赖,包括Servlet、JSTL、Spring Web MVC等。接着,在`web.xml`中配置DispatcherServlet,并设置Spring MVC的相关配置,如组件扫描、默认Servlet处理器等。然后,通过`@RequestMapping`等注解处理请求参数,使用`@ResponseBody`返回JSON数据。此外,还介绍了如何创建和配置拦截器、文件上传下载的功能,并强调了JSP文件的放置位置,避免404错误。
|
2月前
|
前端开发 Java 应用服务中间件
【Spring】Spring MVC的项目准备和连接建立
【Spring】Spring MVC的项目准备和连接建立
64 2
|
3月前
|
缓存 前端开发 Java
【Java面试题汇总】Spring,SpringBoot,SpringMVC,Mybatis,JavaWeb篇(2023版)
Soring Boot的起步依赖、启动流程、自动装配、常用的注解、Spring MVC的执行流程、对MVC的理解、RestFull风格、为什么service层要写接口、MyBatis的缓存机制、$和#有什么区别、resultType和resultMap区别、cookie和session的区别是什么?session的工作原理
【Java面试题汇总】Spring,SpringBoot,SpringMVC,Mybatis,JavaWeb篇(2023版)
|
2月前
|
XML 前端开发 Java
Spring,SpringBoot和SpringMVC的关系以及区别 —— 超准确,可当面试题!!!也可供零基础学习
本文阐述了Spring、Spring Boot和Spring MVC的关系与区别,指出Spring是一个轻量级、一站式、模块化的应用程序开发框架,Spring MVC是Spring的一个子框架,专注于Web应用和网络接口开发,而Spring Boot则是对Spring的封装,用于简化Spring应用的开发。
180 0
Spring,SpringBoot和SpringMVC的关系以及区别 —— 超准确,可当面试题!!!也可供零基础学习
|
3月前
|
XML 缓存 前端开发
springMVC02,restful风格,请求转发和重定向
文章介绍了RESTful风格的基本概念和特点,并展示了如何使用SpringMVC实现RESTful风格的请求处理。同时,文章还讨论了SpringMVC中的请求转发和重定向的实现方式,并通过具体代码示例进行了说明。
springMVC02,restful风格,请求转发和重定向