import javax.xml.ws.handler.Handler;
时间: 2024-06-07 11:11:09 浏览: 8
这是Java中的一个import语句,用于导入javax.xml.ws.handler.Handler类。这个类是Java API for XML Web Services (JAX-WS)中的一部分,它提供了处理SOAP消息的机制。SOAP是一种基于XML的协议,用于在Web应用程序之间进行交互。Handler类允许开发人员定义SOAP消息处理程序,以便在消息传输期间对其进行修改或拦截。
相关问题
使用java提供的handler机制在客户端对SOAP请求包注入header,在服务端对SOAP请求包进行解析,获得头部,并展示出头部的信息
在Java中,可以使用JAX-WS API来创建SOAP客户端和服务端。下面是一个示例代码,演示如何在客户端使用handler机制注入SOAP头部,以及如何在服务端使用handler机制解析SOAP头部。
首先,我们需要定义一个SOAPHandler类,用于处理SOAP消息头部。在客户端,我们可以在SOAP消息发送前,将需要注入的头部信息写入SOAP消息的Header中;在服务端,我们可以在SOAP消息接收后,从SOAP消息的Header中读取我们需要的头部信息。
以下是一个SOAPHandler的示例代码:
```java
import java.util.Set;
import javax.xml.namespace.QName;
import javax.xml.soap.SOAPElement;
import javax.xml.soap.SOAPEnvelope;
import javax.xml.soap.SOAPFactory;
import javax.xml.soap.SOAPHeader;
import javax.xml.soap.SOAPHeaderElement;
import javax.xml.ws.handler.MessageContext;
import javax.xml.ws.handler.soap.SOAPHandler;
import javax.xml.ws.handler.soap.SOAPMessageContext;
public class MyHandler implements SOAPHandler<SOAPMessageContext> {
private static final String MY_HEADER_NS = "http://example.com/myheader";
private static final String MY_HEADER_NAME = "MyHeader";
@Override
public boolean handleMessage(SOAPMessageContext context) {
Boolean isOutbound = (Boolean) context.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);
if (isOutbound) {
// 客户端处理逻辑,将需要注入的头部信息写入SOAP消息的Header中
try {
SOAPEnvelope envelope = context.getMessage().getSOAPPart().getEnvelope();
SOAPFactory factory = SOAPFactory.newInstance();
SOAPHeader header = envelope.getHeader();
if (header == null) {
header = envelope.addHeader();
}
SOAPHeaderElement myHeaderElement = header.addHeaderElement(new QName(MY_HEADER_NS, MY_HEADER_NAME, "my"));
SOAPElement child = myHeaderElement.addChildElement("MyValue");
child.addTextNode("Hello World!");
context.getMessage().saveChanges();
} catch (Exception e) {
e.printStackTrace();
}
} else {
// 服务端处理逻辑,从SOAP消息的Header中读取我们需要的头部信息
try {
SOAPEnvelope envelope = context.getMessage().getSOAPPart().getEnvelope();
SOAPHeader header = envelope.getHeader();
if (header != null) {
SOAPHeaderElement myHeaderElement = (SOAPHeaderElement) header.getChildElements(new QName(MY_HEADER_NS, MY_HEADER_NAME, "my")).next();
String myValue = myHeaderElement.getElementsByTagName("MyValue").item(0).getTextContent();
System.out.println("Received MyValue from client: " + myValue);
}
} catch (Exception e) {
e.printStackTrace();
}
}
return true;
}
@Override
public Set<QName> getHeaders() {
return null;
}
@Override
public boolean handleFault(SOAPMessageContext context) {
return true;
}
@Override
public void close(MessageContext context) {
}
}
```
在客户端,我们需要将SOAPHandler注册到SOAP请求的处理链中。以下是一个客户端的示例代码:
```java
import java.net.URL;
import javax.xml.namespace.QName;
import javax.xml.ws.BindingProvider;
import javax.xml.ws.Service;
public class MyClient {
private static final String SERVICE_URL = "http://localhost:8080/MyService?wsdl";
public static void main(String[] args) throws Exception {
URL url = new URL(SERVICE_URL);
QName qname = new QName("http://example.com/myservice", "MyService");
Service service = Service.create(url, qname);
MyService port = service.getPort(MyService.class);
// 注册SOAPHandler
BindingProvider bp = (BindingProvider) port;
bp.getBinding().getHandlerChain().add(new MyHandler());
// 调用服务
port.sayHello();
}
}
```
在服务端,我们也需要将SOAPHandler注册到SOAP请求的处理链中。以下是一个服务端的示例代码:
```java
import javax.xml.ws.Endpoint;
import javax.xml.ws.handler.Handler;
import javax.xml.ws.handler.HandlerResolver;
import javax.xml.ws.handler.PortInfo;
public class MyServer {
public static void main(String[] args) throws Exception {
Endpoint endpoint = Endpoint.publish("http://localhost:8080/MyService", new MyServiceImpl());
// 注册SOAPHandler
endpoint.getBinding().setHandlerChain(new HandlerResolver() {
@Override
public Handler<?>[] getHandlerChain(PortInfo portInfo) {
return new Handler<?>[]{new MyHandler()};
}
});
System.out.println("MyService started.");
}
}
```
注意,在使用handler机制时,必须在SOAP请求处理链中注册handler,以便让SOAP消息在处理过程中经过handler的处理。另外,由于SOAP消息头部的格式是自定义的,因此在实际应用中,需要根据具体的业务需求,设计合适的SOAP头部格式。
调用http://10.50.0.105:4968/daws/services/DAService?wsdl 接口 java 包含jar包
要调用 SOAP 接口,你需要使用 Java 的 SOAP 客户端库。其中比较常用的有 Apache Axis 和 Apache CXF。在使用之前,你需要先下载相关的 jar 包,然后将其添加到你的项目中。
对于 Apache Axis,你可以从官网上下载最新版本的二进制包。下载后,解压缩得到一个 axis-x.x 目录。里面包含了一些 jar 包,其中最重要的是 axis.jar 和 commons-discovery.jar。你需要将这些 jar 包添加到你的项目中,并将其设置为 classpath。
对于 Apache CXF,你可以从官网上下载最新版本的二进制包。下载后,解压缩得到一个 apache-cxf-x.x.x 目录。里面包含了一些 jar 包,其中最重要的是 cxf-core.jar 和 cxf-rt-bindings-soap.jar。你需要将这些 jar 包添加到你的项目中,并将其设置为 classpath。
完成 jar 包的准备工作后,你就可以开始编写 Java 代码来调用 SOAP 接口了。具体的步骤如下:
1. 创建一个 Service 对象。Service 对象用于访问 WSDL 文件,并从中获取相关的服务信息。
```java
import javax.xml.namespace.QName;
import javax.xml.ws.Service;
import java.net.URL;
URL wsdlUrl = new URL("http://10.50.0.105:4968/daws/services/DAService?wsdl");
QName serviceName = new QName("http://example.com/wsdl", "DAService");
Service service = Service.create(wsdlUrl, serviceName);
```
2. 创建一个 Dispatch 对象。Dispatch 对象用于发送 SOAP 请求,并接收 SOAP 响应。Dispatch 对象有两种类型:Message 和 Payload。前者用于处理 SOAP 消息,后者用于处理 SOAP 负载。
```java
import javax.xml.bind.JAXBContext;
import javax.xml.bind.JAXBElement;
import javax.xml.bind.Unmarshaller;
import javax.xml.namespace.QName;
import javax.xml.soap.MessageFactory;
import javax.xml.soap.SOAPConstants;
import javax.xml.soap.SOAPMessage;
import javax.xml.transform.dom.DOMSource;
import javax.xml.ws.Dispatch;
import javax.xml.ws.Service;
import javax.xml.ws.Service.Mode;
import javax.xml.ws.handler.MessageContext;
import javax.xml.ws.http.HTTPBinding;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.util.HashMap;
import java.util.Map;
QName portName = new QName("http://example.com/wsdl", "DAServicePort");
Dispatch<SOAPMessage> dispatch = service.createDispatch(portName, SOAPMessage.class, Mode.MESSAGE);
MessageFactory messageFactory = MessageFactory.newInstance(SOAPConstants.SOAP_1_2_PROTOCOL);
SOAPMessage request = messageFactory.createMessage();
request.setProperty(MessageContext.HTTP_REQUEST_HEADERS, new HashMap<String, Object>());
request.setProperty(MessageContext.HTTP_RESPONSE_HEADERS, new HashMap<String, Object>());
request.setProperty(MessageContext.HTTP_RESPONSE_CODE, 200);
ByteArrayOutputStream out = new ByteArrayOutputStream();
request.writeTo(out);
InputStream in = new ByteArrayInputStream(out.toByteArray());
SOAPMessage soapMessage = messageFactory.createMessage(null, in);
```
3. 发送 SOAP 请求,并接收 SOAP 响应。在发送请求之前,你需要根据 WSDL 文件中定义的 SOAP 操作,构造一个合法的 SOAP 消息。在接收响应之后,你需要对响应进行解析,并提取出其中的有效数据。
```java
import javax.xml.bind.JAXBContext;
import javax.xml.bind.JAXBElement;
import javax.xml.bind.Unmarshaller;
import javax.xml.namespace.QName;
import javax.xml.soap.MessageFactory;
import javax.xml.soap.SOAPConstants;
import javax.xml.soap.SOAPMessage;
import javax.xml.transform.dom.DOMSource;
import javax.xml.ws.Dispatch;
import javax.xml.ws.Service;
import javax.xml.ws.Service.Mode;
import javax.xml.ws.handler.MessageContext;
import javax.xml.ws.http.HTTPBinding;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.InputStream;
import java.util.HashMap;
import java.util.Map;
// 构造 SOAP 消息
QName operationName = new QName("http://example.com/wsdl", "getWeather");
JAXBContext jaxbContext = JAXBContext.newInstance(GetWeather.class);
Marshaller marshaller = jaxbContext.createMarshaller();
GetWeather request = new GetWeather();
request.setCity("Beijing");
JAXBElement<GetWeather> payload = new JAXBElement<GetWeather>(operationName, GetWeather.class, request);
marshaller.marshal(payload, soapMessage.getSOAPBody());
// 发送 SOAP 请求,并接收 SOAP 响应
SOAPMessage response = dispatch.invoke(soapMessage);
Unmarshaller unmarshaller = jaxbContext.createUnmarshaller();
DOMSource source = new DOMSource(response.getSOAPBody().getFirstChild());
JAXBElement<GetWeatherResponse> result = unmarshaller.unmarshal(source, GetWeatherResponse.class);
GetWeatherResponse weatherResponse = result.getValue();
System.out.println(weatherResponse.getWeather());
```
以上就是调用 SOAP 接口的基本步骤。需要注意的是,具体实现可能会有所不同,具体要根据 WSDL 文件的内容来进行调整。
相关推荐
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![rar](https://img-home.csdnimg.cn/images/20210720083606.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![rar](https://img-home.csdnimg.cn/images/20210720083606.png)
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![jar](https://img-home.csdnimg.cn/images/20210720083455.png)