处理链处理WEB服务中的请求/响应消息
2007-10-08 16:00
169 查看
一个处理程序可以在客户端或服务器端用来创建一个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响应之前
消息处理链可以使用后台组件也可以不使用,下面主要针对各种处理情况?(图1)
图一描述了使用后台组件进行处理链操作。当客户端调用WEB服务时,SOAP请求到达处理链中的处理请求部分,一旦处理通过,处理程序将消息传送到WEB服务中并且执行。处理响应程序被WEB服务调用并且将SOAP响应发送到客户端。图2使用后台组件的处理链模型举例:
这个例子我们采用的服务为WEBLOGIC8.X,这里我们通过后台组件提供查询服务的验证处理程序来详细说明。这里面的验证内容主要是帐号和个人识别码,它们被放在SOAP请求消息的头部分中,消息处理程序将重新获得帐号和个人识别码并验证,如果验证通过,一旦通过验证,后台组件将会调用余额查询来获得此帐号的余额。以下就是写一个处理程序的步骤:
1)处理程序必须实现javax.xml.rpc.handler.Handler 接口或继承Weblogic中的GenericHandler 类。
2)javax.xml.rpc.handler.Handler 接口包含了以下这些方法用来实现
BalanceEnquiryService.java
2)创建的子元素 ,在这个子元素中,显示了所有处理链中的处理程序。对于每一个处理程序,使用类名必须指定 java类的全限定名以便实现处理程序。使用元素来指定处理程序的初始化参数。3.使用(它本身是 的子元素)的子元素元素,来详细说明处理链是WEB服务中的一个操作。 注意:处理链只是自执行的,没有后台组件参与执行,在这中情况下,只要使用处理链属性中的元素并且并不需要指定组件或方法的属性,就像下面所选其中的一部分:
web-service.xml
ant脚本在创建WAR文件的同时也进行EAR打包,在WEBLOGIC服务器上部署打包好的EAR文件,
下面是客户端调用余额查询的程序:
Client.java
(1)导入import javax.xml.rpc.handler.HandlerInfo;
import javax.xml.rpc.handler.HandlerRegistry;两个类。(2)在call().invoke前面加:
处理链就是将每一个消息处理装配成一个链表形式进行处理。在WEB服务中实现可能需要调用多个处理类,用来提供处理请求/响应前面或后面的服务。JAX-RPC运行环境中可以在链表中调用多个处理类。这种处理消息的概念称为处理链。处理链模型:
一个消息处理类功能主要在客户服务器端通信中,尽可能的为终端服务和可以设置用来截取SOAP消息并且在以下几种情况下对消息执行各种操作:1)在客户端,在SOAP请求被建立后并且在发送到WEB服务之前
2)在WEB服务端,在SOAP消息请求被WEB服务程序处理之前
3)在WEB服务端,在WEB服务发送SOAP消息响应之前
4)在客户端,在JAX-RPC运行时处理从WEB服务中收到的SOAP响应之前
消息处理链可以使用后台组件也可以不使用,下面主要针对各种处理情况?(图1)
图一描述了使用后台组件进行处理链操作。当客户端调用WEB服务时,SOAP请求到达处理链中的处理请求部分,一旦处理通过,处理程序将消息传送到WEB服务中并且执行。处理响应程序被WEB服务调用并且将SOAP响应发送到客户端。图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服务中的一个操作。 注意:处理链只是自执行的,没有后台组件参与执行,在这中情况下,只要使用处理链属性中的元素并且并不需要指定组件或方法的属性,就像下面所选其中的一部分:
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.xmldestdir="${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服务中。
相关文章推荐
- “一切都是消息”--MSF(消息服务框架)之【请求-响应】模式(点对点)
- XenApp 6.5 中的Citrix XML服务不响应请求:其之一
- 关于SQL Server 2005 Management Studio Express的“无法连接”和“该服务未及时响应启动请求或控制请求 ... ”等解决方案
- Axis Web Service开发之旅 (九) --使用soapmonitor模块监视soap请求与响应消息
- HTTP的请求消息Request和响应消息Response
- ArcIMS地图配置文件,地图服务,请求和响应之间的关系(转)
- SQL2008无法启动SQL Server 请求失败或服务未及时响应
- Http请求消息与响应消息
- http请求消息头与响应消息头
- 接收对 http://192.168.1.18:8001/ObtainData/Service 的 HTTP 响应时发生错误。这可能是由于服务终结点绑定未使用 HTTP 协议造成的。这还可能是由于服务器中止了 HTTP 请求上下文(可能由于服务关闭)所致。
- 2. [netty-RPC]--消息的请求、响应与接口和实现的映射容器
- 请求失败或服务未及时响应 有关详细信息
- IIS无法启动,提示“服务没有及时响应启动或控制请求”
- 服务没有及时响应启动或控制请求
- sql server配置管理器请求失败或服务未及时响应
- vc windows 服务问题:服务没有及时响应启动或控制请求
- Akka学习笔记:Actor消息处理-请求和响应(1)
- IOS 在不打开电话服务的时候,可以响应服务器的推送消息,从而接收服务器的推送消息
- WebService大讲堂之Axis2(10):使用soapmonitor模块监视soap请求与响应消息
- IIS“服务没有及时响应启动或控制请求”错误解决