處理鏈處理WEB服務中的請求/響應消息

2019-11-18 12:31:26

字體：大中小

來源：轉載

供稿：網友

為什么使用處理鏈？

　　一個處理程序可以在客戶端或服務器端用來創建一個SOAP的請求消息和響應消息。例如一個使用消息處理程序的簡單例子，在SOAP消息中的實體部分對數據進行加密和解密，客戶端在他向WEB服務發送SOAP請求消息前必須使用消息處理程序對消息進行加密，WEB服務收到請求后，在它將數據發送到后臺實現WEB服務之前，必須使用消息處理程序對從客戶端發送過來的消息進行解密。與請求消息的傳輸方向相反，SOAP響應消息也要執行相同的步驟。

　　另外一個例子，在SOAP消息的頭部分訪問信息進行處理。SOAP頭經常用來存儲WEB服務具體說明信息并且使用消息處理程序來操作它。例如將用戶名和密碼可以放在SOAP消息的頭部分中來發送到驗證處理程序。

　　SOAP消息處理可以用來提高WEB服務的使用效率。這種方法的實現可以通過使用隊列緩沖SOAP響應的次序。處理程序可以使SOAP的請求信息生效并且將消息交互紀錄下來。

處理鏈：

　　處理鏈就是將每一個消息處理裝配成一個鏈表形式進行處理。在WEB服務中實現可能需要調用多個處理類，用來提供處理請求/響應前面或后面的服務。JAX-RPC運行環境中可以在鏈表中調用多個處理類。這種處理消息的概念稱為處理鏈。

處理鏈模型：

　　一個消息處理類功能主要在客戶服務器端通信中，盡可能的為終端服務和可以設置用來截取SOAP消息并且在以下幾種情況下對消息執行各種操作：

1）在客戶端，在SOAP請求被建立后并且在發送到WEB服務之前
2）在WEB服務端，在SOAP消息請求被WEB服務程序處理之前
3）在WEB服務端，在WEB服務發送SOAP消息響應之前
4）在客戶端，在JAX-RPC運行時處理從WEB服務中收到的SOAP響應之前
消息處理鏈可以使用后臺組件也可以不使用，下面主要針對各種處理情況?

處理鏈處理WEB服務中的請求/響應消息（圖一）

（圖1）
圖一描述了使用后臺組件進行處理鏈操作。當客戶端調用WEB服務時，SOAP請求到達處理鏈中的處理請求部分，一旦處理通過，處理程序將消息傳送到WEB服務中并且執行。處理響應程序被WEB服務調用并且將SOAP響應發送到客戶端。

處理鏈處理WEB服務中的請求/響應消息（圖二）

圖2使用后臺組件的處理鏈模型

舉例：

　　這個例子我們采用的服務為WEBLOGIC8.X，這里我們通過后臺組件提供查詢服務的驗證處理程序來具體說明。這里面的驗證內容主要是帳號和個人識別碼，它們被放在SOAP請求消息的頭部分中，消息處理程序將重新獲得帳號和個人識別碼并驗證，假如驗證通過，一旦通過驗證，后臺組件將會調用余額查詢來獲得此帳號的余額。

以下就是寫一個處理程序的步驟：
1）處理程序必須實現javax.xml.rpc.handler.Handler 接口或繼續Weblogic中的GenericHandler 類。
2）javax.xml.rpc.handler.Handler 接口包含了以下這些方法用來實現

init () 
destroy() 
getHeaders() 
handleRequest() 
handleResponse() 
handleFault()



　　假如使用weblogic.webservice.GenericHandler 類，只需要重寫必須的方法，
在這個例子中驗證處理程序重寫了handleRequest() 和handleResponse() 方法。
假如handleRequest()方法返回true,將會調用處理鏈中的下一個處理程序，
假如這個處理程序是處理鏈中最后一個元素，將會調用后臺的WEB服務程序。
假如  handleRequest()方法返回false，對應的handleResponse()方法將會被調用。
驗證處理程序中handleRequest() 將從SOAP的頭部分中重新獲得帳號和個人識別碼，
并且驗證后要返回true 或false結果。

AuthenticationHandler.java

import java.util.Map;
import java.util.Iterator;

import javax.xml.rpc.JAXRPCException;
import javax.xml.rpc.handler.soap.SOAPMessageContext;
import javax.xml.rpc.handler.HandlerInfo;
import javax.xml.rpc.handler.MessageContext;
import javax.xml.namespace.QName;
import javax.xml.soap.*;

import weblogic.webservice.GenericHandler;

public class AuthenticationHandler extends GenericHandler
{

   PRivate int me = System.identityHashCode(this);

   private HandlerInfo handlerInfo = null;
   String accountNo                = null;
   String pin                      = null;

   public void init(HandlerInfo handlerInfo)
   {
      this.handlerInfo = handlerInfo;
   }
   public boolean handleRequest(MessageContext messageContext)
   {
      System.err.println("** handleRequest called in: "+me);
      try
      {
         SOAPMessageContext sctx = (SOAPMessageContext)messageContext;
         SOAPMessage message     = sctx.getMessage();
         SOAPPart sp             = message.getSOAPPart();
         SOAPEnvelope senv       = sp.getEnvelope();
         SOAPHeader sh           = senv.getHeader();

         Iterator iter =  sh.getChildElements();
         if(iter.hasNext())
         {
            iter.next();                 //skip text
            Object obj = iter.next();    //account details
            SOAPElement elt = (SOAPElement)obj;
            iter = elt.getChildElements();
            iter.next();                 //skip text node
            obj = iter.next();
            elt = (SOAPElement)obj;
            accountNo = elt.getValue();
            iter.next();                 //skip text node
            obj = iter.next();
            elt = (SOAPElement)obj;
            pin = elt.getValue();
         }
      }
      catch (Exception e)
      {
         e.printStackTrace();
         throw new JAXRPCException(e);
      }
      if(accountNo.equals("12345") && pin.equals("6789"))
         return true;
      else
         return false;
   }
   public boolean handleResponse(MessageContext messageContext)
   {
      System.out.println("Inside HandleResponse");
      return true;

   }
   public QName[] getHeaders()
   {
      return handlerInfo.getHeaders();
   }
}

以下就是余額查詢的代碼，是一個非常簡單的服務返回給出已知帳號的余額。
BalanceEnquiryService.java

public class BalanceEnquiryService
{
   public float getBalance(String accountNo)
   {
      if(accountNo.equals("12345"))
         return 5000f;
      else
         return 100f;
   }
}

　　WEB服務中的web-service.xml 必須要修改為包含處理鏈的描述，下面幾個部分需要在web-service.xml 中修改的：

1）在的根元素中創建一個子元素，在這個子元素中包含了WEB服務中一系列處理鏈程序的定義。
2)創建的子元素，在這個子元素中，顯示了所有處理鏈中的處理程序。對于每一個處理程序，使用類名必須指定 java類的全限定名以便實現處理程序。使用元素來指定處理程序的初始化參數。

3.使用（它本身是的子元素）的子元素元素，來具體說明處理鏈是WEB服務中的一個操作?！?br />
　注重：處理鏈只是自執行的，沒有后臺組件參與執行，在這中情況下，只要使用處理鏈屬性中的元素并且并不需要指定組件或方法的屬性，就像下面所選其中的一部分：


   
      <OperaTION name="chainService" 
                 handler-chain="myChain" />

這里有一個完整的WEB.xml的例子：
web-service.xml


   
                   uri="/BalanceEnquiryService"
                targetNamespace="http://www.bea.com">
      
                              class-name="BalanceEnquiryService">
         
      
      
                             handler-chain="AuthenticationHandlerChain"
                    component="jccomp0">
            
                                              style="in" type="xsd:string" />
                                            class-name="java.lang.Float"
                                           type="xsd:float" />
            
  
　　這里面處理鏈的名字叫做AuthenticationHandlerChain，
這里面包含了一個AuthenticationHandler處理程序，注重，
在操作中包含了操作屬性handler-chain="AuthenticationHandlerChain".
　　這里給出了ant腳本build.xml用來打包EAR,注重在打包之前必須有Web.xml 和 application.xml 
build.xml
























                          destdir="${build}/WEB-INF/classes" />

　　ant腳本在創建WAR文件的同時也進行EAR打包，在WEBLOGIC服務器上部署打包好的EAR文件，
下面是客戶端調用余額查詢的程序：
Client.java

import org.apache.axis.client.Call;
import org.apache.axis.client.ServiceFactory;
import org.apache.axis.client.Service;
import org.apache.axis.MessageContext;
import org.apache.axis.attachments.Attachments;
import org.apache.axis.message.SOAPEnvelope;

import javax.xml.namespace.QName;
import javax.xml.soap.SOAPBody;
import javax.xml.soap.SOAPBodyElement;
import javax.xml.soap.SOAPConnection;
import javax.xml.soap.SOAPConnectionFactory;
import javax.xml.soap.SOAPElement;
import javax.xml.soap.SOAPHeader;
import javax.xml.soap.SOAPHeaderElement;
import javax.xml.soap.SOAPMessage;
import javax.xml.soap.SOAPPart;
import javax.xml.namespace.QName;
import javax.xml.rpc.ParameterMode;
import javax.xml.soap.AttachmentPart;
import javax.xml.soap.MessageFactory;
import javax.xml.soap.Name;
import javax.xml.rpc.ParameterMode;

import java.net.URL;
import java.util.Iterator;


public class Client
{
   private static String TARGET_NAMESPACE = "http://www.bea.com";
   private static QName xsdFloat = new
                  QName("http://www.w3.org/2001/XMLSchema", "float");
   public static org.apache.axis.message.SOAPEnvelope env = null;
   public static SOAPMessage message = null;
   public static void main(String[] argv) throws Exception
   {
      Client client = new Client();
      env = client.constrUCtSOAPEnvelope();
      client.constructHeader(env);
      client.constructBody(env);
      System.setProperty( "javax.xml.rpc.ServiceFactory",
                          "org.apache.axis.client.ServiceFactory" );

      String url =
     "http://localhost:7001/BalanceEnquiry/BalanceEnquiryService";
     ServiceFactory factory =
         (org.apache.axis.client.ServiceFactory)ServiceFactory.
              newInstance();
      QName serviceName   = new QName(TARGET_NAMESPACE,
         "BalanceEnquiryService");

      Service service = 
         (org.apache.axis.client.Service)factory.
          createService(serviceName);
      Call call = (org.apache.axis.client.Call)service.createCall();
      call.setTargetEndpointAddress(url);
      SOAPEnvelope result = call.invoke(env);
      System.out.println(result);
   }
   public SOAPEnvelope constructSOAPEnvelope() throws Exception
   {
      org.apache.axis.message.SOAPEnvelope env = new
         org.apache.axis.message.SOAPEnvelope();
      return env;
   }
   public void constructHeader(SOAPEnvelope envelope) throws Exception
   {
      SOAPHeader header = envelope.getHeader();
      Name headerElementName =
         envelope.createName("AccountDetails","",
                             "http://schemas.xmlsoap.org/soap/
                                     envelope/");
      SOAPHeaderElement headerElement =
         header.addHeaderElement(headerElementName);
      headerElement.setMustUnderstand(false);
      headerElement.addNamespaceDeclaration("soap",
         "http://schemas.xmlsoap.org/soap/envelope/");
      SOAPElement accNo = headerElement.addChildElement("accountNo");
      accNo.addTextNode("12345");
      SOAPElement pinNo = headerElement.addChildElement("pin");
      pinNo.addTextNode("6789");
   }

   public void constructBody(SOAPEnvelope envelope) throws Exception
   {
      SOAPBody body = envelope.getBody();
      Name bodyRootElementName =
         envelope.createName("getBalance","",
                             "http://schemas.xmlsoap.org/soap/
                                     encoding/");
      SOAPBodyElement bodyRootElement =
         body.addBodyElement(bodyRootElementName);
      SOAPElement bodyElement =
         bodyRootElement.addChildElement("param0");
      bodyElement.addAttribute(envelope.createName("xsi:type"),
                                                   "xsd:string");
      bodyElement.addTextNode("12");
   }
}

假如在客戶端也有一個處理程序，以下部分要發生變化：
（1）導入import javax.xml.rpc.handler.HandlerInfo;
import javax.xml.rpc.handler.HandlerRegistry;兩個類。

（2）在call().invoke前面加：

QName portName = new QName( "http://bea.com/", 
                            "HelloWorldServicePort");
HandlerRegistry registry = service.getHandlerRegistry();
List handlerList = new ArrayList();
handlerList.add( new HandlerInfo( ClientHandler.class, null,null ) );
registry.setHandlerChain( portName, handlerList );



結論：
　　我們希望能讓大家更多的了解關于處理鏈機制并且應用到WEB服務中。

上一篇：JSF實例：組件顯示(隱藏)與數據排序

下一篇：基于Servlet的Google Earth之旅

學習交流

索泰發布一款GTX 1070 Mini迷你版本:小機

索泰發布一款GTX 1070 Mini迷你版本:小機箱大愛...

熱門圖片

猜你喜歡的新聞

猜你喜歡的關注

新聞熱點

榮耀總裁趙明烏鎮演講：榮耀首款5G手機V30下月發布

2019-10-23 09:17:05

搜狐張朝陽：回歸媒體是搜狐重新崛起的關鍵

2019-10-21 09:20:02

華為輪值董事長郭平：虛擬技術創造現實價值

2019-10-21 09:00:12

滴滴英文服務上線兩周年用戶已超200萬

2019-09-26 08:57:12

華為推出全球至快AI訓練集群Atlas900

2019-09-25 08:46:36

馬斯克：特斯拉正組建中國技術團隊

2019-09-25 08:15:43

疑難解答

圖片精選

網友關注