java实现简单的webservice方式

 更新时间:2017年05月12日 14:17:56   作者:梦想如歌!  
这篇文章主要为大家详细介绍了java实现简单的webservice方式,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

本文实例为大家分享了java实现webservice方式的具体代码,供大家参考,具体内容如下

经过测试 jdk1.6.10以下会出现bug 建议使用10以上版本

1、定义接口

package org.enson.chan;
 
import javax.jws.WebService;
import javax.jws.soap.SOAPBinding;
 
@WebService
@SOAPBinding(style=SOAPBinding.Style.RPC)
public interface IMyService {
 public int add(int a , int b);
 
 public int max(int a , int b);
}

2、实现接口

package org.enson.chan;
import javax.jws.WebService;

@WebService(endpointInterface="org.enson.chan.IMyService")
public class MyServiceImpl implements IMyService {

 public int add(int a, int b) {
 System.out.println(a+"+"+b+"="+(a+b));
 return a+b;
 }

 public int max(int a, int b) {
 System.out.println("a与b比较大小,取大值"+((a>b)?a:b));
 return (a>b)?a:b;
 }

}

3、定义服务

package org.enson.chan;
 
import javax.xml.ws.Endpoint;
 
public class MyServer {
 
 public static void main(String[] args) {
 String address = "http://localhost:8090/ns";
 Endpoint.publish(address, new MyServiceImpl());
 }
}

4、测试服务

package org.enson.chan;

import java.net.MalformedURLException;
import java.net.URL;

import javax.xml.namespace.QName;
import javax.xml.ws.Service;

public class TestClient {

 public static void main(String[] args) {
 try {
  URL url = new URL("http://localhost:8090/ns?wsdl");
  QName sname = new QName("http://chan.enson.org/", "MyServiceImplService");
  //创建服务
  Service service = Service.create(url,sname);
  //实现接口
  IMyService ms = service.getPort(IMyService.class);
  System.out.println(ms.add(12,33));
  //以上服务有问题,依然依赖于IMyServie接口
 } catch (MalformedURLException e) {
  // TODO Auto-generated catch block
  e.printStackTrace();
 }
 }

}

5、TestSoap

import java.io.IOException;
import java.io.StringReader;
import java.io.StringWriter;
import java.net.URL;

import javax.xml.bind.JAXBContext;
import javax.xml.bind.JAXBException;
import javax.xml.bind.Marshaller;
import javax.xml.namespace.QName;
import javax.xml.soap.MessageFactory;
import javax.xml.soap.SOAPBody;
import javax.xml.soap.SOAPBodyElement;
import javax.xml.soap.SOAPEnvelope;
import javax.xml.soap.SOAPException;
import javax.xml.soap.SOAPHeader;
import javax.xml.soap.SOAPMessage;
import javax.xml.soap.SOAPPart;
import javax.xml.transform.Source;
import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerConfigurationException;
import javax.xml.transform.TransformerException;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.TransformerFactoryConfigurationError;
import javax.xml.transform.dom.DOMResult;
import javax.xml.transform.stream.StreamSource;
import javax.xml.ws.Dispatch;
import javax.xml.ws.Service;
import javax.xml.ws.soap.SOAPFaultException;
import javax.xml.xpath.XPath;
import javax.xml.xpath.XPathConstants;
import javax.xml.xpath.XPathExpressionException;
import javax.xml.xpath.XPathFactory;

import org.junit.Test;
import org.soap.service.User;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;


public class TestSoap {
 
 private String ns = "http://service.soap.org/";
 private String wsdlUrl = "http://localhost:8989/ms?wsdl";

 @Test
 public void test01() {
 try {

  MessageFactory factory = MessageFactory.newInstance();
  
  SOAPMessage message = factory.createMessage();

  SOAPPart part = message.getSOAPPart();

  SOAPEnvelope envelope = part.getEnvelope();

  SOAPBody body = envelope.getBody();

  QName qname = new QName("http://java.zttc.edu.cn/webservice", 
   "add","ns");//<ns:add xmlns="http://java.zttc.edu.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();
 }
 }
 
 @Test
 public void test02() {
 try {
  URL url = new URL(wsdlUrl);
  QName sname = new QName(ns,"MyServiceImplService");
  Service service = Service.create(url,sname);
  
  Dispatch<SOAPMessage> dispatch = service.createDispatch(new QName(ns,"MyServiceImplPort"),
   SOAPMessage.class, Service.Mode.MESSAGE);
  
  SOAPMessage msg = MessageFactory.newInstance().createMessage();
  SOAPEnvelope envelope = msg.getSOAPPart().getEnvelope();
  SOAPBody body = envelope.getBody();
  
  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.....");
  
  
  SOAPMessage response = dispatch.invoke(msg);
  response.writeTo(System.out);
  System.out.println();
  
  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();
 }
 }
 
 @Test
 public void test03() {
 try {
  URL url = new URL(wsdlUrl);
  QName sname = new QName(ns,"MyServiceImplService");
  Service service = Service.create(url,sname);
  
  Dispatch<Source> dispatch = service.createDispatch(new QName(ns,"MyServiceImplPort"),
   Source.class, Service.Mode.PAYLOAD);
  
  User user = new User(3,"zs","张三","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);
  
  String payload = "<nn:addUser xmlns:nn=\""+ns+"\">"+writer.toString()+"</nn:addUser>";
  System.out.println(payload);
  StreamSource rs = new StreamSource(new StringReader(payload));
  
  Source response = (Source)dispatch.invoke(rs);
  
  Transformer tran = TransformerFactory.newInstance().newTransformer();
  DOMResult result = new DOMResult();
  tran.transform(response, result);
  
  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();
 }
 }
 
 @Test
 public void test04() {
 try {
  URL url = new URL(wsdlUrl);
  QName sname = new QName(ns,"MyServiceImplService");
  Service service = Service.create(url,sname);
  
  Dispatch<SOAPMessage> dispatch = service.createDispatch(new QName(ns,"MyServiceImplPort"),
   SOAPMessage.class, Service.Mode.MESSAGE);
  
  SOAPMessage msg = MessageFactory.newInstance().createMessage();
  SOAPEnvelope envelope = msg.getSOAPPart().getEnvelope();
  SOAPBody body = envelope.getBody();
  
  SOAPHeader header = envelope.getHeader();
  if(header==null) header = envelope.addHeader();
  QName hname = new QName(ns,"authInfo","nn");
  header.addHeaderElement(hname).setValue("aabbccdd");
  
  QName ename = new QName(ns,"list","nn");//<nn:add xmlns="xx"/>
  body.addBodyElement(ename);
  msg.writeTo(System.out);
  System.out.println("\n invoking.....");
  
  
  SOAPMessage response = dispatch.invoke(msg);
  response.writeTo(System.out);
  System.out.println();
  
  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();
 }
 }
 
 @Test
 public void test05() {
 try {
  URL url = new URL(wsdlUrl);
  QName sname = new QName(ns,"MyServiceImplService");
  Service service = Service.create(url,sname);
  
  Dispatch<SOAPMessage> dispatch = service.createDispatch(new QName(ns,"MyServiceImplPort"),
   SOAPMessage.class, Service.Mode.MESSAGE);
  
  SOAPMessage msg = MessageFactory.newInstance().createMessage();
  SOAPEnvelope envelope = msg.getSOAPPart().getEnvelope();
  SOAPBody body = envelope.getBody();
  
  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.....");
  
  
  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();
 } 
 }
}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • Java多线程之锁学习(增强版)

    Java多线程之锁学习(增强版)

    这篇文章主要为大家详细介绍了Java多线程中锁的相关知识,文中的示例代码讲解详细,对我们了解线程有一定帮助,需要的可以参考一下
    2023-02-02
  • Springboot使用Spring Data JPA实现数据库操作

    Springboot使用Spring Data JPA实现数据库操作

    Spring Data JPA 是 Spring 基于 Spring Data 框架、在JPA 规范的基础上开发的一个框架,使用 Spring Data JPA 可以极大地简化JPA 的写法,本章我们将详细介绍在Springboot中使用 Spring Data JPA 来实现对数据库的操作
    2021-06-06
  • spring中@Autowire和@Resource的区别在哪里(推荐)

    spring中@Autowire和@Resource的区别在哪里(推荐)

    这篇文章主要介绍了spring中@Autowire和@Resource的区别在哪里?本文结合实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2023-02-02
  • IDEA集成Gitee码云的实现步骤

    IDEA集成Gitee码云的实现步骤

    本文主要介绍了IDEA集成Gitee码云的实现步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-07-07
  • SpringSecurityOAuth2实现微信授权登录

    SpringSecurityOAuth2实现微信授权登录

    微信的登录功能是用户注册和使用微信的必经之路之一,而微信授权登录更是方便了用户的登录操作,本文主要介绍了SpringSecurityOAuth2实现微信授权登录,感兴趣的可以了解一下
    2023-09-09
  • 新手入门Jvm--Jvm垃圾回收

    新手入门Jvm--Jvm垃圾回收

    JVM是Java Virtual Machine(Java虚拟机)的缩写,JVM是一种用于计算设备的规范,它是一个虚构出来的计算机,是通过在实际的计算机上仿真模拟各种计算机功能来实现的
    2021-06-06
  • 基于Jenkins搭建.NET Core持续集成环境过程图解

    基于Jenkins搭建.NET Core持续集成环境过程图解

    这篇文章主要介绍了基于Jenkins搭建.NET Core持续集成环境过程图解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-08-08
  • 实例讲解Java中random.nextInt()与Math.random()的基础用法

    实例讲解Java中random.nextInt()与Math.random()的基础用法

    今天小编就为大家分享一篇关于实例讲解Java中random.nextInt()与Math.random()的基础用法,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
    2019-02-02
  • maven仓库repositories和mirrors的配置及区别详解

    maven仓库repositories和mirrors的配置及区别详解

    这篇文章主要介绍了maven仓库repositories和mirrors的配置及区别详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-07-07
  • idea中springboot项目创建后追加依赖

    idea中springboot项目创建后追加依赖

    在项目创建的时候选择好依赖创建项目,之后追加依赖不是很方便,本文就来介绍一下idea中springboot项目创建后追加依赖,具有一定的参考价值,感兴趣的可以了解一下
    2024-03-03

最新评论