cxf与xfire互相调用，并且加验证机制

最近做的项目要完成与第三方系统进行webservice对接。首先我系统成为A系统，第三方系统成为B系统。A系统用的是xfire，只有xfire的jar包，B系统用的是cxf，只有cxf的jar包。

首先A系统调用B系统，使用一个公用客户端程序，

public static Object[] callCxfWebSrv(String url,String methodName,Object[] obj) {
Client client = null;
try {
URL _url = new URL(null,url,new sun.net.www.protocol.http.Handler());
HttpURLConnection httpconnection = (HttpURLConnection) _url.openConnection();
httpconnection.setReadTimeout(Constants.WEBSERVICE_TIMEOUT);// 设置http连接的读超时,单位是毫秒


httpconnection.connect();
client = new Client(httpconnection.getInputStream(),null);
client.addOutHandler(new ClienterCxfSqHander());
client.setProperty(CommonsHttpMessageSender.HTTP_TIMEOUT,
String.valueOf(Constants.WEBSERVICE_TIMEOUT));// 设置发送的超时限制,单位是毫秒;
client.setProperty(CommonsHttpMessageSender.disABLE_KEEP_ALIVE,"true");
client.setProperty(CommonsHttpMessageSender.disABLE_EXPECT_CONTINUE,"true");
Object[] objects = client.invoke(methodName,obj);
client.close();
client = null;
return objects;
} catch (Exception e) {
if (client != null) {
client.close();
client = null;
}
return null;
}
}

上面client.addOutHandler(new ClienterCxfSqHander());就是客户端加验证机制的过程。其中ClienterCxfSqHander类的实现方式如下：

public class ClienterCxfSqHander extends AbstractHandler {

public ClienterCxfSqHander() {
// Todo Auto-generated constructor stub
}

@Override
public void invoke(MessageContext context) throws Exception {
Element el = new Element("header"); 
        context.getoutMessage().setHeader(el); 
        Element auth = new Element("AuthenticationToken"); 
        Element ip_el = new Element("SERVER"); 
        ip_el.addContent(new DESEncrypt("asit").encode("CXDNS")); 
        auth.addContent(ip_el); 
        el.addContent(auth);
}

}

当A系统请求B系统时，加上了上面的 验证机制。B系统按如下方式进行解析

public class AuthorInterceptor extends AbstractPhaseInterceptor<SoapMessage>{


private saajInInterceptor saa = new saajInInterceptor(); 
public AuthorInterceptor() {
super(Phase.PRE_PROTOCOL);  
        getAfter().add(saajInInterceptor.class.getName());
}


/**
* 客户端请求时，此方法进行验证，可是客户端的消息头是否与服务器端规定的相同
*/
public void handleMessage(SoapMessage message) throws Fault {
System.out.println("come in ServicesAuthorInterceptor ");  
        SOAPMessage mess = message.getContent(SOAPMessage.class);  
        if (mess == null) {               
             saa.handleMessage(message);  
             mess = message.getContent(SOAPMessage.class);  
            }  
            SOAPHeader head = null;  
            try {  
             head = mess.getSOAPHeader();  
            } catch (Exception e) {  
             e.printstacktrace();  
            }  
            if (head == null) {  
             return;  
            }  
            NodeList token = head.getElementsByTagName("AuthenticationToken");  
            if(token==null){
            SOAPException soapExc = new SOAPException("认证错误");  
                throw new Fault(soapExc); 
            }
            NodeList node2 = token.item(0).getChildNodes();
            if(node2==null){
            SOAPException soapExc = new SOAPException("认证错误");  
                throw new Fault(soapExc);
            }
            String dq = node2.item(0).getTextContent();
    DESEncrypt encrypt = new DESEncrypt("111");//加密机制，可以不用
    try {
dq = encrypt.decode(dq);
} catch (Exception e) {
e.printstacktrace();
}
    if (!dq.equals("111")){
    SOAPException soapExc = new SOAPException("认证错误");  
                throw new Fault(soapExc); 
    }else{
    System.out.println("认证成功");
    }
           }  


}

当然上面的拦截器是配置在 B系统的 cxf服务端的。

cxf客户端调用xfire服务端的过程类似，cxf的前身就是xfire，所以内核机制是一样的。

我在项目过程中 cxf调用xfire的过程中一直报 命名空间的错误javax.xml.bind.UnmarshalException: unexpected element (uri:"http://",local:"out"). Expected elements are(local:"out").。问题找了很久。原来是A系统与B系统的webservcie程序的包名空间一样，导致冲突。改了B系统的package的名称，再次调用，调用成功。

以上是我做程序员以来第一篇文章，写的不好，见谅。仅此记录我的工作经历与成果。