目录
- webservice自定义注解处理参数加解密
- 代码实现
- webservice注解汇总
- @webservice
- @webmethod
- @oneway
- @webparam
- @webresult
- @handlerchain
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
:指定配置文件中处理程序链的名称。
以上为个人经验,希望能给大家一个参考,也希望大家多多支持www.887551.com。