1.创建接口
package org.soap.service;
import java.util.List;
import javax.jws.WebParam;
import javax.jws.WebResult;
import javax.jws.WebService;
@WebService
public interface IMyService {
@WebResult(name="addResult")
public int add(@WebParam(name="a")int a,@WebParam(name="b")int b);
@WebResult(name="user")
public User addUser(@WebParam(name="user")User user);
@WebResult(name="user")
public User login(@WebParam(name="username")String username,
@WebParam(name="password")String password)throws UserException;
@WebResult(name="user")
public List<User> list(@WebParam(header=true,name="authInfo")String authInfo);
}
2.创建实现类
package org.soap.service;
import java.util.ArrayList;
import java.util.List;
import javax.jws.WebService;
@WebService(endpointInterface="org.soap.service.IMyService")
public class MyServiceImpl implements IMyService {
private static List<User> users = new ArrayList<User>();
//@HandlerChain(file="handler-chain.xml")
public MyServiceImpl() {
users.add(new User(1,"admin","wxh","111111"));
}
@Override
public int add(int a, int b) {
System.out.println("a+b="+(a+b));
return a+b;
}
@Override
public User addUser(User user) {
users.add(user);
return user;
}
@Override
public User login(String username, String password) throws UserException{
for(User user:users) {
if(username.equals(user.getUsername())&&password.equals(user.getPassword()))
return user;
}
throw new UserException("用户不存在");
}
@Override
public List<User> list(String authInfo) {
System.out.println(authInfo);
return users;
}
}
3.开启服务
package org.soap.service;
import javax.xml.ws.Endpoint;
public class MyServer {
public static void main(String[] args) {
Endpoint.publish("http://localhost:8889/ns", new MyServiceImpl());
}
}
4.SOAP 消息的建立
private String ns = "http://service.soap.org/";
private String wsdlUrl = "http://localhost:8889/ns?wsdl";
@Test
public void test01() {
try {
//1、创建消息工厂
MessageFactory factory = MessageFactory.newInstance();
//2、根据消息工厂创建SoapMessage
SOAPMessage message = factory.createMessage();
//3、创建SOAPPart
SOAPPart part = message.getSOAPPart();
//4、获取SOAPENvelope
SOAPEnvelope envelope = part.getEnvelope();
//5、可以通过SoapEnvelope有效的获取相应的Body和Header等信息
SOAPBody body = envelope.getBody();
//6、根据Qname创建相应的节点(QName就是一个带有命名空间的)
QName qname = new QName("http://java.soap.third.cn/webservice",
"add","ns");//<ns:add xmlns="http://java.soap.third.cn/webservice"/>
//如果使用以下方式进行设置，会见<>转换为<和>
//body.addBodyElement(qname).setValue("<a>1</a><b>2</b>");
SOAPBodyElement ele = body.addBodyElement(qname);
ele.addChildElement("a").setValue("22");
ele.addChildElement("b").setValue("33");
//打印消息信息
message.writeTo(System.out);
} catch (SOAPException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
5.SOAP显示打印消息
<SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/"><SOAP-ENV:Header/><SOAP-ENV:Body><ns:add xmlns:ns="http://java.soap.third.cn/webservice"><a>22</a><b>33</b></ns:add></SOAP-ENV:Body></SOAP-ENV:Envelope>
6.SOAP消息的创建与服务器端进行交互MESSAGE方式
@Test
public void test02() {
try {
//1、创建服务(Service)
URL url = new URL(wsdlUrl);
QName sname = new QName(ns,"MyServiceImplService");
Service service = Service.create(url,sname);
//2、创建Dispatch
Dispatch<SOAPMessage> dispatch = service.createDispatch(new QName(ns,"MyServiceImplPort"),
SOAPMessage.class, Service.Mode.MESSAGE);
//3、创建SOAPMessage
SOAPMessage msg = MessageFactory.newInstance().createMessage();
SOAPEnvelope envelope = msg.getSOAPPart().getEnvelope();
SOAPBody body = envelope.getBody();
//4、创建QName来指定消息中传递数据
QName ename = new QName(ns,"add","nn");//<nn:add xmlns="xx"/>
SOAPBodyElement ele = body.addBodyElement(ename);
ele.addChildElement("a").setValue("22");
ele.addChildElement("b").setValue("33");
msg.writeTo(System.out);
System.out.println("\n invoking.....");
//5、通过Dispatch传递消息,会返回响应消息
SOAPMessage response = dispatch.invoke(msg);
response.writeTo(System.out);
System.out.println();
//将响应的消息转换为dom对象
Document doc = response.getSOAPPart().getEnvelope().getBody().extractContentAsDocument();
String str = doc.getElementsByTagName("addResult").item(0).getTextContent();
System.out.println(str);
} catch (SOAPException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
7.显示打印信息
<SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/"><SOAP-ENV:Header/><SOAP-ENV:Body><nn:add xmlns:nn="http://service.soap.org/"><a>22</a><b>33</b></nn:add></SOAP-ENV:Body></SOAP-ENV:Envelope>
invoking.....
<S:Envelope xmlns:S="http://schemas.xmlsoap.org/soap/envelope/"><S:Header/><S:Body><ns2:addResponse xmlns:ns2="http://service.soap.org/"><addResult>55</addResult></ns2:addResponse></S:Body></S:Envelope>
55
8.SOAP消息的创建与服务器端进行交互PAYLOAD方式
@Test
public void test03() {
try {
//1、创建服务(Service)
URL url = new URL(wsdlUrl);
QName sname = new QName(ns,"MyServiceImplService");
Service service = Service.create(url,sname);
//2、创建Dispatch(通过源数据的方式传递)
Dispatch<Source> dispatch = service.createDispatch(new QName(ns,"MyServiceImplPort"),
Source.class, Service.Mode.PAYLOAD);
//3、根据用户对象创建相应的xml
User user = new User(3,"zs","wr","11111");
JAXBContext ctx = JAXBContext.newInstance(User.class);
Marshaller mar = ctx.createMarshaller();
mar.setProperty(Marshaller.JAXB_FRAGMENT, true);
StringWriter writer= new StringWriter();
mar.marshal(user, writer);
//4、封装相应的part addUser
String payload = "<nn:addUser xmlns:nn=\""+ns+"\">"+writer.toString()+"</nn:addUser>";
System.out.println(payload);
StreamSource rs = new StreamSource(new StringReader(payload));
//5、通过dispatch传递payload
Source response = (Source)dispatch.invoke(rs);
//6、将Source转化为DOM进行操作，使用Transform对象转换
Transformer tran = TransformerFactory.newInstance().newTransformer();
DOMResult result = new DOMResult();
tran.transform(response, result);
//7、处理相应信息(通过xpath处理)
XPath xpath = XPathFactory.newInstance().newXPath();
NodeList nl = (NodeList)xpath.evaluate("//user", result.getNode(),XPathConstants.NODESET);
User ru = (User)ctx.createUnmarshaller().unmarshal(nl.item(0));
System.out.println(ru.getNickname());
} catch (IOException e) {
e.printStackTrace();
} catch (JAXBException e) {
e.printStackTrace();
} catch (TransformerConfigurationException e) {
e.printStackTrace();
} catch (TransformerFactoryConfigurationError e) {
e.printStackTrace();
} catch (TransformerException e) {
e.printStackTrace();
} catch (XPathExpressionException e) {
e.printStackTrace();
}
}
9.SOAP消息的创建与服务器端进行交互MESSAGE方式,增加head信息
@Test
public void test04() {
try {
//1、创建服务(Service)
URL url = new URL(wsdlUrl);
QName sname = new QName(ns,"MyServiceImplService");
Service service = Service.create(url,sname);
//2、创建Dispatch
Dispatch<SOAPMessage> dispatch = service.createDispatch(new QName(ns,"MyServiceImplPort"),
SOAPMessage.class, Service.Mode.MESSAGE);
//3、创建SOAPMessage
SOAPMessage msg = MessageFactory.newInstance().createMessage();
SOAPEnvelope envelope = msg.getSOAPPart().getEnvelope();
SOAPBody body = envelope.getBody();
//3.2、处理header信息
SOAPHeader header = envelope.getHeader();
if(header==null) header = envelope.addHeader();
QName hname = new QName(ns,"authInfo","nn");
header.addHeaderElement(hname).setValue("wxh");
//4、创建QName来指定消息中传递数据
QName ename = new QName(ns,"list","nn");//<nn:add xmlns="xx"/>
body.addBodyElement(ename);
msg.writeTo(System.out);
System.out.println("\n invoking.....");
//5、通过Dispatch传递消息,会返回响应消息
SOAPMessage response = dispatch.invoke(msg);
response.writeTo(System.out);
System.out.println();
//将响应的消息转换为dom对象
Document doc = response.getSOAPBody().extractContentAsDocument();
NodeList nl = doc.getElementsByTagName("user");
JAXBContext ctx = JAXBContext.newInstance(User.class);
for(int i=0;i<nl.getLength();i++) {
Node n = nl.item(i);
User u = (User)ctx.createUnmarshaller().unmarshal(n);
System.out.println(u.getNickname());
}
} catch (SOAPException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} catch (JAXBException e) {
e.printStackTrace();
}
}
10SOAP消息的创建与服务器端进行交互MESSAGE方式,异常信息
@Test
public void test05() {
try {
//1、创建服务(Service)
URL url = new URL(wsdlUrl);
QName sname = new QName(ns,"MyServiceImplService");
Service service = Service.create(url,sname);
//2、创建Dispatch
Dispatch<SOAPMessage> dispatch = service.createDispatch(new QName(ns,"MyServiceImplPort"),
SOAPMessage.class, Service.Mode.MESSAGE);
//3、创建SOAPMessage
SOAPMessage msg = MessageFactory.newInstance().createMessage();
SOAPEnvelope envelope = msg.getSOAPPart().getEnvelope();
SOAPBody body = envelope.getBody();
//4、创建QName来指定消息中传递数据
QName ename = new QName(ns,"login","nn");//<nn:add xmlns="xx"/>
SOAPBodyElement ele = body.addBodyElement(ename);
ele.addChildElement("username").setValue("ss");
ele.addChildElement("password").setValue("dd");
msg.writeTo(System.out);
System.out.println("\n invoking.....");
//5、通过Dispatch传递消息,会返回响应消息
SOAPMessage response = dispatch.invoke(msg);
response.writeTo(System.out);
System.out.println();
} catch(SOAPFaultException e){
System.out.println(e.getMessage());
} catch (SOAPException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
分享到：
相关推荐
总结，金蝶通过SOAP调用第三方Webservice接口的过程主要包括：创建服务、创建Dispatch、构造SOAP消息、调用服务并处理响应以及解析响应数据。这个过程展示了不同系统间集成的基本步骤，对于理解和实现类似的集成工作...
- Java中可以通过`java.net.HttpURLConnection`或者第三方库如Apache HttpClient来发送SOAP请求。 - 构建SOAP消息的方式与VB.NET类似，但需要注意字符串转义的不同，例如在Java中XML的双引号需要用`\"`来表示。 -...
综上所述，本案例涉及的知识点包括WebService的基本原理、SOAP协议的应用、调用第三方服务的方法以及安全性和性能优化的考量。通过学习和实践这个案例，开发者将能更好地理解和运用WebService技术来实现跨系统的数据...
3. **SOAP消息处理**：服务端需要解析接收到的SOAP消息，并执行相应的方法。同样，服务也需要生成SOAP响应消息。 4. **客户端调用**：在Demo的客户端部分，你可能看到如何使用WSDL文件生成代理类，这使得客户端能够...
C#开发核心代码，用拼接XML方式，调用封装了实体类的SOAP接口
通常，你可以访问Apache官方仓库或者第三方软件分发平台获取不同版本的Apache SOAP库。 总结来说，Apache SOAP是Java Web服务开发的重要工具，它提供了一套完整的框架，支持SOAP协议的实现，包括XML解析、RPC调用...
注意，由于SOAP响应通常也是XML格式，可能需要使用如`org.xmlpull.v1.XmlPullParser`或第三方库（如`jsoup`）来解析XML。 通过这个示例，我们可以看到如何利用Retrofit2、OkHttp3和RxJava构建一个Android客户端，...
【SOAP与CXF开发WebService】 本讲主要探讨了如何使用SOAP（Simple Object Access Protocol）和Apache CXF框架来开发Web服务。SOAP是一种基于XML的通信协议，它旨在解决互联网中分布式计算的互操作性问题，通过HTTP...
3. SOAP消息结构：一个SOAP消息由三部分组成：SOAP Envelope（定义消息结构）、SOAP Header（包含可选的元信息）和SOAP Body（包含实际的数据或请求）。 4. HTTP作为传输协议：SOAP通常利用HTTP协议进行传输，因为...
##### 第三步：实现接口和方法 3. **创建实现类单元**： - 生成一个新的单元文件。 - 定义实现类（继承自 `TInvokableClass` 并实现 `IWebTest` 接口）。 **示例代码**： ```pascal unit Unit2; interface...
在实际开发中，为了简化流程，还可以使用第三方库，如gSOAP或Apache Axis C++，它们提供了更方便的SOAP客户端API，可以自动处理XML编码、解码和网络通信。 需要注意的是，进行SOAP通信时，必须确保与Web服务的版本...
本项目以"webservice 第一个小项目"为主题，将带你入门Java实现的WebService技术。 首先，我们需要了解WebService的基本概念。WebService是一种基于开放标准（如XML、SOAP、WSDL和UDDI）的互联网协议，它能够使应用...
"webservice soap wsdl" Web Service 是一种网络接口，为应用程序提供了交互和分布式处理的效果，与平台、开发语言无关。Web Service 的核心是 WSDL（Web Services Description Language），它是一种用于描述 Web ...
在VB6.0中调用Web服务，特别是WebService，是一个重要的技术点，它允许传统的VB6应用程序利用基于网络的服务来扩展其功能。由于VB.NET的普及，很多开发者更倾向于使用.NET框架，但考虑到VB6的广泛使用和某些特定场景...
第十讲至第十三讲：Web服务的安全性 涵盖Web服务安全的关键议题，如HTTPS、SOAP消息安全、WS-Security标准以及身份验证和授权策略。 第十四讲至第十五讲：Web服务的版本控制与互操作性 介绍如何处理服务升级和版本...
最近项目中遇到需要去掉老系统的webservice服务中的insert方法，找了很久，发现这样最简单，实测有效！！！
它允许开发者通过Java调用第三方提供的Webservice，使得不同系统间的数据交换变得简单。本文将详细介绍如何使用Java Axis调用第三方Webservice，并提供一个简单的示例。 一、Java Axis调用第三方Webservice的准备...