使用webservice自定义注解处理参数加解密问题

webservice自定义注解处理参数加解密

前一段项目中用到了webservice，正好自己之前也了解过一点apache的cxf框架，所以就采用了cxf来实现webservice服务端，本身实现并没技术难点，但是项目为了保证安全性，采用了传输加密的过程，所以大部分请求参数需要加密，返回参数也需要加密，大致流程是：

• 请求参数对称加密+对称秘钥非对称加密
• 返回参数堆成加密+对称秘钥非对称加密

参数加密本身并不复杂，但是有些服务并不需要加密，有些则需要，加密工具类并不通用

string，datahandler等不能重用，虽然本质都是对字节数据加密，但是要写许多方法，还要方法参数，检查需要加解密处理的参数，然后寻找对应的类型处理方法调用.

逻辑很清晰，但是过程实现很恶心，最终这样实现了一版，但是并不合我的意.

如果能在拦截器中获取到参数列表，然后寻找对应的解码器解码，这样就比较简单了.但是难点是，如果标记参数，并指定被标记参数的解码器尼?

我想到了注解，注解就可以标记，参数，然后通过反射获取到注解，解析出内容.

本来想标记到参数上，但是一个个标记太麻烦，而且获取也不太方便，索性就放在方法上，用数组来接收.

问题解决.

代码实现

自定义注解：

import java.lang.annotation.elementtype;
import java.lang.annotation.retention;
import java.lang.annotation.retentionpolicy;
import java.lang.annotation.target;
/**
 * @author webservice请求参数自定义注解
 *
 */
@target(elementtype.method)
@retention(retentionpolicy.runtime)
public @interface requesthanleannotation {
    class[] handler() default {};
    int[] index() default {};
}

参数解码器接口

import java.util.map;
import java.util.concurrent.concurrenthashmap;
/**
 * @author taoyuan
 *参数处理器
 * @param <t>
 */
public abstract class  paramhandler<t> {
//解码器实例缓存
public static final map<class,paramhandler> hanlers=new concurrenthashmap<>();
//处理方法
     abstract t handle(t t);
}

解码器实现，这里并没有真正解码，只是在参数后面加了123

public class stringhandler extends paramhandler<string> {
    @override
    public string handle(string t) {
        return t+"123";
    }
}

服务方法注解使用

//表示第一个参数需要stringhandler处理
    @requesthanleannotation(index=0,handler=stringhandler.class)
    public string test(string test, string test2) throws exception {
        system.out.println(test);
        system.out.println(test2);
        return "cesshi";
    }

拦截器实现

import java.io.file;
import java.lang.reflect.method;
import java.util.map;
import org.apache.commons.io.fileutils;
import org.apache.cxf.binding.soap.soapmessage;
import org.apache.cxf.interceptor.fault;
import org.apache.cxf.message.messagecontentslist;
import org.apache.cxf.phase.abstractphaseinterceptor;
import org.apache.cxf.phase.phase;
import org.apache.log4j.logger;
import com.alibaba.fastjson.json;
import com.alibaba.fastjson.jsonobject;
/**
 * @author 都市桃源
 */
public class ecrininterceptor extends abstractphaseinterceptor<soapmessage>{
    private logger log = logger.getlogger(contractlogicimpl.class);
      public ecrininterceptor(){
            // 在调用方法之前调用拦截器
            super(phase.pre_invoke);
        }
    @override
    public void handlemessage(soapmessage msg) throws fault {
    /*获取请求ip,拦截器中可以做下统一日志处理 
    httpservletrequest httprequest = (httpservletrequest)msg.get(abstracthttpdestination.http_request);
        *
        */
        //获取正在执行的方法
         method method = msgutil.getsoapmethod(msg);
         //解析注解,并处理参数
         messagecontentslist contentslist = messagecontentslist.getcontentslist(msg);
         msgutil.handle(method,contentslist);
    }
    @override
    public void handlefault(soapmessage message) {
    super.handlefault(message);
    }

注解解析工具类实现

import java.lang.reflect.method;
import java.util.hashmap;
import java.util.map;
import org.apache.cxf.binding.soap.soapmessage;
import org.apache.cxf.message.exchange;
import org.apache.cxf.message.messagecontentslist;
import org.apache.cxf.service.service;
import org.apache.cxf.service.invoker.methoddispatcher;
import org.apache.cxf.service.model.bindingoperationinfo;
/**
 * @author ll
 * 获取方法名称
 *
 */
public class msgutil {
    /**根据消息获取调用方法
     * @param msg
     * @return
     */
    public static method getsoapmethod(soapmessage msg){
         exchange exchange = msg.getexchange();  
            bindingoperationinfo bop = exchange.get(bindingoperationinfo.class);  
            methoddispatcher md = (methoddispatcher) exchange.get(service.class)  
                    .get(methoddispatcher.class.getname());  
            method method = md.getmethod(bop);
            return method; 
    }
    public static void handle(method method, messagecontentslist contentslist) {
        if(method==null)return;
        requesthanleannotation reqanno= method.getannotation(requesthanleannotation.class);
        int[] indexs = reqanno.index();
        if(indexs==null||indexs.length==0)return;
        class[] handlers = reqanno.handler();
        try {
            //处理器实例
            paramhandler handler=null;
        for(int i=0,len=indexs.length;i<len;i++){
                //获取需要处理的参数
                object obj = contentslist.get(indexs[i]);
                //从缓存中获取处理器实例
                handler=paramhandler.hanlers.get(handlers[i]);
                if(handler==null){
                    //创建处理器实例
                    handler=(paramhandler) handlers[i].newinstance();
                    //缓存处理器实例
                    paramhandler.hanlers.put(handlers[i], handler);
                }
                 contentslist.set(indexs[i], handler.handle(obj));
        }
        }catch (exception e) {
            e.printstacktrace();
        }
    }
}

返回参数同样也可以注解实现，这里就不在赘述了，实现也比较简单.

**需要注意的是,拦截器拦截顺序不一样
拦截器统一继承
abstractphaseinterceptor类,
请求拦截 :super(phase.pre_invoke);
返回拦截: super(phase.pre_stream);**

webservice注解汇总

@webservice

• servicename：对外发布的服务名，指定 web service 的服务名称：wsdl:service。缺省值为 java 类的简单名称 + service。（字符串）
• endpointinterface：服务接口全路径, 指定做sei（service endpoint interface）服务端点接口
• name：此属性的值包含xml web service的名称。在默认情况下，该值是实现xml web service的类的名称，wsdl:porttype 的名称。缺省值为 java 类或接口的非限定名称。（字符串
• portname：wsdl:portname。缺省值为 webservice.name+port。
• targetnamespace：指定你想要的名称空间，默认是使用接口实现类的包名的反序
• wsdllocation：指定用于定义 web service 的 wsdl 文档的 web 地址。web 地址可以是相对路径或绝对路径。（字符串）注意：实现类上可以不添加webservice注解

@webmethod

注释表示作为一项 web service 操作的方法，将此注释应用于客户机或服务器服务端点接口（sei）上的方法，或者应用于 javabeans 端点的服务器端点实现类。

要点：

仅支持在使用 @webservice 注释来注释的类上使用 @webmethod 注释

• operationname：指定与此方法相匹配的wsdl:operation 的名称。缺省值为 java 方法的名称。（字符串）
• action：定义此操作的行为。对于 soap 绑定，此值将确定 soapaction 头的值。缺省值为 java 方法的名称。（字符串）
• exclude：指定是否从 web service 中排除某一方法。缺省值为 false。（布尔值）

@oneway

注释将一个方法表示为只有输入消息而没有输出消息的 web service 单向操作。

将此注释应用于客户机或服务器服务端点接口（sei）上的方法，或者应用于 javabeans 端点的服务器端点实现类

@webparam

注释用于定制从单个参数至 web service 消息部件和 xml 元素的映射。

将此注释应用于客户机或服务器服务端点接口（sei）上的方法，或者应用于 javabeans 端点的服务器端点实现类。

• name：参数的名称。如果操作是远程过程调用（rpc）类型并且未指定partname 属性，那么这是用于表示参数的 wsdl:part 属性的名称。如果操作是文档类型或者参数映射至某个头，那么 -name 是用于表示该参数的 xml 元素的局部名称。如果操作是文档类型、参数类型为 bare 并且方式为 out 或 inout，那么必须指定此属性。（字符串）
• partname：定义用于表示此参数的 wsdl:part属性的名称。仅当操作类型为 rpc 或者操作是文档类型并且参数类型为bare 时才使用此参数。（字符串）
• targetnamespace：指定参数的 xml 元素的 xml 名称空间。当属性映射至 xml 元素时，仅应用于文档绑定。缺省值为 web service的targetnamespace。（字符串）
• mode：此值表示此方法的参数流的方向。有效值为 in、inout 和 out。（字符串）
• header：指定参数是在消息头还是消息体中。缺省值为 false。（布尔值）

@webresult

注释用于定制从返回值至 wsdl 部件或 xml 元素的映射。将此注释应用于客户机或服务器服务端点接口（sei）上的方法，或者应用于 javabeans 端点的服务器端点实现类。

• name：当返回值列示在 wsdl 文件中并且在连接上的消息中找到该返回值时，指定该返回值的名称。对于 rpc 绑定，这是用于表示返回值的 wsdl:part属性的名称。对于文档绑定，-name参数是用于表示返回值的 xml 元素的局部名。对于 rpc 和 document/wrapped 绑定，缺省值为 return。对于 document/bare 绑定，缺省值为方法名 + response。（字符串）
• targetnamespace：指定返回值的 xml 名称空间。仅当操作类型为 rpc 或者操作是文档类型并且参数类型为 bare 时才使用此参数。（字符串）
• header：指定头中是否附带结果。缺省值为false。（布尔值）
• partname：指定 rpc 或 document/bare 操作的结果的部件名称。缺省值为@webresult.name。（字符串）

@handlerchain

注释用于使 web service 与外部定义的处理程序链相关联。只能通过对 sei 或实现类使用 @handlerchain 注释来配置服务器端的处理程序。但是可以使用多种方法来配置客户端的处理程序。可以通过对生成的服务类或者 sei 使用 @handlerchain 注释来配置客户端的处理程序。此外，可以按程序在服务上注册您自己的 handlerresolver 接口实现，或者按程序在绑定对象上设置处理程序链。

• file：指定处理程序链文件所在的位置。文件位置可以是采用外部格式的绝对 java.net.url，也可以是类文件中的相对路径。（字符串）
• name：指定配置文件中处理程序链的名称。

以上为个人经验，希望能给大家一个参考，也希望大家多多支持。