WebService案例入门(基础篇)


[版权申明:本文系做者原创,转载请注明出处]
文章出处:http://blog.csdn.net/sdksdk0/article/details/52106690
做者:朱培 ID:sdksdk0 邮箱: zhupei@tianfang1314.cn java


1、简介

Webservice:跨语言跨平台的远程调用技术。Web service 即web服务,它是一种跨编程语言和跨操做系统平台的远程调用技术即跨平台远程调用技术。
JAVA 中共有三种WebService 规范,分别是JAX-WS(JAX-RPC)、JAXM&SAAJ、JAX-RS。
webService三要素:soap、wsdl、uddimysql

JAX-WS 的全称为 Java API for XML-Based Webservices ,早期的基于SOAP 的JAVA 的Web 服务规范JAX-RPC(Java API For XML-Remote Procedure Call).
JAXM(JAVA API For XML Message)主要定义了包含了发送和接收消息所需的API,SAAJ(SOAP With Attachment API For Java,JSR 67)是与JAXM 搭配使用的API,为构建SOAP 包和解析SOAP 包提供了重要的支持,支持附件传输等.
JAX-RS 是JAVA 针对REST(Representation State Transfer)风格制定的一套Web 服务规范.git

2、应用场景

在作企业总体信息化时,企业中通常都或多或少的存在一些既存系统,这些各类各样的系统不可能所有推翻,从新规划和开发,由于不少供应商在某一领域也作的很专业,博众家之长并进行集成应该是一个比较现实和可取的作法。各个系统之间经过WebService进行集成,不只缩短了开发周期,下降了风险,还减小了代码复杂度,并可以加强应用程序的可维护性,由于webservice支持跨平台且遵循标准协议(soap)。程序员

将一个软件的功能以webservice方式暴露出来,达到软件重用。例如上边分析的天气预报,将天气查询功能以webservice接口方式暴露出来很是容易集成在其它系统中;再好比一个第三方物流系统将快递查询、快递登记暴露出来,从而集成在电子商务系统中。github

3、soap协议

SOAP 是一种网络通讯协议
SOAP即Simple Object Access Protocol简易对象访问协议
SOAP 用于跨平台应用程序之间的通讯
SOAP 被设计用来经过因特网(http)进行通讯
SOAP = HTTP+XML,其实就是经过HTTP发xml数据
SOAP 很简单并可扩展支持面向对象
SOAP 容许您跨越防火墙web

Socket是全部通讯的基础也是语言个无关平台无关。
Socket使用的是tcp协议,传输效率高。适合传递大数据高并发场景,高并发的状况须要实现多线程而且使用到线程池,编码复杂。Sockt的高并发框架mina。
Socket只是流的传输,传输的格式须要程序员本身定义。sql

Webservice使用的是soap协议,soap协议基于http协议的应用层协议,本质就是http+xml。Soap协议是w3c标准,传输效率低。使用传输数据不是太大的场合,也是支持高并发的,受限于web容器。支持soap协议和wsdl二者都是国际通用标准,不须要自定义数据格式,只须要面向对象开发。数据库

4、WSDL

Webservice的使用说明书。描述了webservice的服务地址以及webservice服务接口、参数、返回值。
阅读方法:从下往上读。
这里写图片描述编程

  1. 先找service节点:每一个wsdl中,有且只有一个service节点。也叫服务视图节点。service中有port节点服务端端口。
  2. 根据port节点的binding属性找binding节点。根据binding节点的type属性找portType节点。
  3. portType节点就是咱们定义的SEI服务的接口类型。Prottype中的operation 节点就是方法名称。
  4. operation 节点的input就是参数的定义,output就是返回值的定义。
  5. Input有个属性叫作message,message属性对应message节点。其中有一个element,对应element节点。
  6. Element节点定义中xsd中。定义了数据的类型。参数和返回值都在其中定义。

5、天气查询系统(基础)

到这里,对于webservice的基本概念都已经了解了,那么就开始咱们愉快的编码步骤吧!这个的话咱们须要新建两个java工程,一个作服务端,一个做为客户端。源码能够经过文末的连接下载。浏览器

5.1 服务端

一、编写一个SEI,也就是一个接口

public interface WeatherInterface {

        String queryWeather(String cityName);
    }

二、编写一个SEI实现类,须要实现SEI接口,并且还须要在这个实现类上面添加一个@Webservice注解

@Webservice
    public class WeatherInterfaceImpl implements WeatherInterface {

        public String queryWeather(String cityName) {
            System.out.println("接收到客户端发送的城市名称:"+cityName);  
            String result="晴,高温预警";
            return result;
        }
    }

在这一步,若是你由于webservice的添加注解系统报错的话,能够先按照报错提示的先转变为jase-1.5,而后本身再去build path中从新变回你原来许须要的java1.7或者1.8.

三、发布服务。使用Endpoint的静态方法publish。

public class WeatherServer {


        public static void main(String[] args) {
            //发布服务
            Endpoint.publish("http://127.0.0.1:11111/weather", new WeatherInterfaceImpl());
        }

    }

访问地址:http://127.0.0.1:11111/weather
这里写图片描述

http://127.0.0.1:11111/weather?wsdl中看到portType。
这里写图片描述

看到效果则说明启动成功了。

5.2 客户端

对于客户端,咱们可利用只用java中的wsimport来自动生成客户端代码。

使用Wsimport生成客户端调用代码,
在jdk的安装目录的bin目录中,有一个wsimport命令。

能够根据wsdl文档生成客户端调用代码。

新建一个java工程WebServiceClient,而后到这个工程的src目录下面,在src目录下经过cmd运行如下命令:(注意空格)

wsimport -s . http://127.0.0.1:11111/weather?wsdl

这里写图片描述
生成好以后咱们就能够直接调用了:

一、建立一个服务视图对象
二、从服务试图得到porttype(SEI)对象
三、调用服务端方法
四、打印结果

public class WeatherClient {


    public static void main(String[] args) {
        WeatherInterfaceImplService  service=new WeatherInterfaceImplService();
        WeatherInterfaceImpl portType=service.getWeatherInterfaceImplPort();
        String result=portType.queryWeather("衡阳");
        System.out.println(result);

    }
    }

这里写图片描述

6、天气查询(公网)

刚才使用的方法是咱们本身定义了,可是每每生活中,咱们须要时时更新的天气信息,因此这个时候咱们就能够调用公网来处理了,和前面的同样,咱们也须要服务端和客户端。

6.1 服务端

服务端使用第三方的,导入其已经生成好的多个类,cn.com.webxml.这个能够在我提供的源码中直接下载。
这里写图片描述

6.2 客户端

public static void main(String[] args) {
        //建立服务视图
        //WeatherWebService service=new WeatherWebService();

        URL url = null;
        try {
            url = new URL("http://www.webxml.com.cn/WebServices/WeatherWebService.asmx?WSDL");
        } catch (MalformedURLException e) {
            e.printStackTrace();
        }
        QName qName=new QName("http://WebXml.com.cn/", "WeatherWebService");

        Service service=Service.create(url,qName);
        WeatherWebServiceSoap  portType=service.getPort(WeatherWebServiceSoap.class);
                //service.getWeatherWebServiceSoap();

        ArrayOfString arrayOfString=portType.getWeatherbyCityName("衡阳");
        for (String string : arrayOfString.getString()) {
            System.out.println(string);
        }
    }

这里写图片描述

7、区域查询系统

建立区域查询服务系统,对外发布WebService服务,供客户端调用,根据parentid查询区域信息。客户端向服务端传递xml格式数据,服务端向客户端响应xml格式数据。

传递xml数据的缘由:

  • 一、跨语言时可能会花费不少时间去调试,若是直接传递xml会节省调试的时间。参数和返回值都是字符串类型,很是简单。
  • 二、若是参数发生变化后,能够不要修改接口,不能从新生成客户端代码。
  • 三、xml格式的数据是跨平台的。

这里写图片描述

实现步骤

- 建立一个java工程。
- 导入mysql数据库驱动及其相关的jar包。
- 建立一个SEI。
- 建立一个SEI实现类,调用dao查询区域列表。
- 发布服务,使用Endpoint的publish方法发布服务。

客户端:

  • 生成客户端调用代码
  • 建立服务视图
  • 从服务视图得到portType
  • 调用服务端方法

7.1 服务端

一、新建一个区域信息接口,AreaModel .java
private String areaid;
private String areaname;
private String parentid;
private String arealevel;
实现其get\set方法

二、新建一个AreaDao.java,用于访问mysql数据库中的区域信息,这个数据库的sql脚本已放到源码中,读者可自行下载。就是一个链接数据库的功能。

public List<AreaModel> queryArea(String parentid, int start, int end) {
        Connection connection = null;
        PreparedStatement pstmt = null;
        ResultSet resultSet = null;
        List<AreaModel> areaList = new ArrayList<>();
        try {
            //加载数据库驱动
            Class.forName("com.mysql.jdbc.Driver");
            //得到connection
            connection = DriverManager.getConnection("jdbc:mysql:///day15", "zp", "a");
            String sql="select *from area where parentid=? limit ?,? ";
            pstmt=connection.prepareStatement(sql);

            pstmt.setString(1,parentid);
            pstmt.setInt(2, start-1);
            pstmt.setInt(3, end-start-1);

            resultSet=pstmt.executeQuery();



            while(resultSet.next()){

                AreaModel model=new AreaModel();
                model.setAreaid(resultSet.getString("areaid"));
                model.setAreaname(resultSet.getString("areaname"));
                model.setArealevel(resultSet.getString("arealevel"));
                model.setParentid(resultSet.getString("parentid"));
                //添加到区域列表
                areaList.add(model);

            }

        }catch(Exception e){
            e.printStackTrace();
        }finally{
            try {
                resultSet.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            try {
                pstmt.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            try {
                connection.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        return areaList;

    }

三、写一个区域查询SEI

public interface AreaInterface {

    String queryArea(String area);

}

四、实现其Sei的dao方法。

@WebService
public class AreaInterfaceImpl implements AreaInterface {

    @Override
    public String queryArea(String area) {

        //解析xml查询条件
        AreaModel model = null;
        try {
            model = parseXml(area);
        } catch (DocumentException e) {
            e.printStackTrace();
        }
        AreaDao dao=new AreaDao();
        List<AreaModel> list=dao.queryArea(model.getParentid(), model.getStart(), model.getEnd());
        String result = null;
        try {
            result = list2xml(list);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }



        return result;
    }

    private AreaModel parseXml(String xml) throws DocumentException{

        Document document=DocumentHelper.parseText(xml);
        String parentid=document.selectSingleNode("/queryarea/parentid").getText();
        String start=document.selectSingleNode("/queryarea/start").getText();
        String end=document.selectSingleNode("/queryarea/end").getText();

        AreaModel model=new AreaModel();
        model.setParentid(parentid);
        model.setStart(Integer.parseInt(start));
        model.setEnd(Integer.parseInt(end));
        return model;

    }
    private String list2xml(List<AreaModel> list) throws Exception {
        Document document = DocumentHelper.createDocument();
        //添加以根节点
        Element root = document.addElement("areas");

        for (AreaModel areaModel : list) {
            Element area = root.addElement("area");
            area.addElement("areaid").setText(areaModel.getAreaid());
            area.addElement("areaname").setText(areaModel.getAreaname());
            area.addElement("arealevel").setText(areaModel.getArealevel());
            area.addElement("parentid").setText(areaModel.getParentid());
        }

        return document.asXML();
    }


}

五、发布服务

public class AreaServer {

    public static void main(String[] args) {
        Endpoint.publish("http://127.0.0.1:11111/area", new AreaInterfaceImpl());
    }
}

经过浏览器访问看到这个界面就说明运行成功了。
这里写图片描述

7.2 客户端

和以前一样的方法,使用wsimport来自动生成客户端代码。
在java工程的src目录中运行cmd。
wsimport -s . http://127.0.0.1:11111/area?wsdl

生成好以后以下所示:
这里写图片描述

客户端进行调用

public class AreaClient {

    public static void main(String[] args) {
        AreaInterfaceImplService service=new AreaInterfaceImplService();

        AreaInterfaceImpl portType=service.getAreaInterfaceImplPort();
        String result=portType.queryArea(getQueryXml("1.1.",1,10));
        System.out.println(result);
    }

    private static String getQueryXml(String parentid,int start,int end){
        String  xml="<?xml version=\"1.1\" encoding=\"utf-8\"?>\n" +
                "<queryarea>\n"+
                "<parentid>"+parentid+"</parentid>\n"+
                "<start>"+start+"</start>\n"+
                "<end>"+end+"</end>\n"+
                "</queryarea>";
        return  xml;        
    }
}

输出结果:
这里写图片描述

总结:本篇文章关于webservice的内容都是很是很是基础的,里面涉及到的一些协议或者使用方法估计有些人是不知道的,咱们一方面须要扩展本身的视野,了解更多的新东西,心里不要对一些本身不是很常见的东西去抵触,有的朋友会说“嗯,你讲的这些东西都太基础了,咱们在实际项目中要如何应用”,有的直接是调用第三方的url和参考文档就搞定了,实际上是比较方便的,那么咱们在使用别人的东西的时候有没有考虑过其底层的实现原理,深刻到其骨髓才是真的掌握了,否则咱们依然是那种只会复制黏贴、只会盲目的调用各类第三方API来的人了。共勉!下次会带来更加实用的cxf实现jax-ws。欢迎关注!

源码下载:
https://github.com/sdksdk0/WebWeather-BaseDemo-
https://github.com/sdksdk0/AreaWebService

相关文章
相关标签/搜索