码迷,mamicode.com
首页 > 数据库 > 详细

基于Jax-WS和Mysql数据库的WEB服务开发

时间:2016-06-13 17:16:51      阅读:222      评论:0      收藏:0      [点我收藏+]

标签:

基于Jax-WS和Mysql数据库的WEB服务开发

1 简介

近几年来,SOA,EAI等架构体系的日渐成熟,Webservice越来越炽手可热,尤其是在企业做异质平台整合时成为了首选的技术。Java的Webservice技术更是层出不穷,比较流行的有:Axis2,XFire以及JaxWS。
JAXWS适合几乎所有Webservice客户端的调用,因此不少巨头型的厂商如:IBM,Weblogic等,在他们的产品上都使用了以JAXWS为标准的Webservice接口。
另外,由于实验室的项目目前采用JaxWS作为Wevservice框架,同时JaxWS也是目前最标准,需要额外第三方插件最少,配置最少最灵活的webservice,故对其进行研习。


2 案例驱动学习

编写查询员工信息的Web服务(员工信息存储在数据库中)。
第一个Web服务:输入员工号,返回该员工号的员工的基本信息,包括员工号、员工名称、所在部门、出生日期、职位、职称、入职日期等信息。
第二个Web服务:输入部门、职称,返回该部门具有该职称的所有员工的基本信息,员工基本信息与上面相同。分别针对上述两个Web服务,分别编写调用这两个Web服务的程序(或网页)。
要求在输入界面上输入待查询数据,调用Web服务,并将Web服务返回的员工信息查询结果显示到输出界面上。
数据库表:

属性 含义 数据类型
ID 员工号 Int(11)
name 员工名 Varchar(20)
dept 部门 Varchar(20)
title 职称 Varchar(20)
position 职位 Varchar(20)
birthday 出生日期 Varchar(20)
dateIn 入职日期 Varchar(20)

这样的web服务如何用jax-ws实现呢?


3 开发流程

我们使用JAX-WS开发WebService只需要很简单的几个步骤:写接口和实现=>发布=>生成客户端(测试或使用)。
而在开发阶段我们也不需要导入外部jar包,因为这些api都是现成的。首先是接口的编写(接口中只需要把类注明为@WebService,把要暴露给客户端的方法注明为@WebMethod即可,其余如@WebResult、@WebParam等都不是必要的,而客户端和服务端的通信用RPC和Message-Oriented)。
开发采用Eclipse Indigo和JDK6


4 服务端开发

JAVA JDK1.6中JAX-WS规范定义了如何发布一个WebService服务。与Web服务相关的类都位于Javax.jws.*包中。其中:
@WebService——此注解用在类上指定将此类发布成一个WebService, targetNamespace属性定义了自己的命名空间,serviceName则定义了< definitions >标签和标签的name属性。
EndPoint——此类为端点服务类,其中publish()方法用于将一个已经添加了 @WebService注解的Web服务(类)绑定到一个地址的端口上,用于发布。
@WebMethod定义Web Service运作的方法。
@SOAPBinding标签定义了WSDL文档中SOAP的消息协议,其中style属 性对应SOAP的文档类型,可选的有RPC和DOCUMENT。

实现思路:
服务器端编写服务接口类、服务实现类、服务发布类,以及自定义复杂数据类型Userbean。服务器端通过调用API中的Endpoint.publish()方法发布服务,客户端通过service.getPort()方法提取服务端口,远程调用服务端的服务。服务器端和客户端传输数据采用的是复杂数据类型ArrayList,保存了Userbean类型的数据。

代码实现:

代码片1:服务接口设计
package webservice;
import java.sql.SQLException;
import java.util.ArrayList;
import javax.jws.WebMethod;
import javax.jws.WebService;

/**
 * @author 孟政宇
 * @Time 2016-6-10 22:23:29
 * 接口 声明方法
 */

@WebService
public interface WebServiceI {
    // 使用@WebMethod注解标注WebServiceI接口中的方法

    @WebMethod
    ArrayList<Userbean> getInfoByID(int ID) throws Exception;
    //web服务1
    @WebMethod
    ArrayList<Userbean> getInfoByDD(String Dept,String rank) throws Exception;
    //web服务2
    @WebMethod
    String soa(String name);
    //测试
    @WebMethod
    boolean sayHello(String name);
//测试
}
代码片2:服务接口实现

package webservice;

import java.io.IOException;
import java.lang.reflect.Array;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

import javax.jws.WebMethod;
import javax.jws.WebService;

import cn.edu.neu.dinner.app.WMMP.factory.MinaClient;
import cn.edu.neu.dinner.app.WMMP.factory.NotifyObject;
import cn.edu.neu.dinner.app.WMMP.factory.TransObject;

/**
 * @author 孟政宇 SEI的具体实现 Service endpoint interface
 */
// 使用@WebService注解标注WebServiceI接口的实现类WebServiceImpl

@WebService
public class ServiceDemoImpl implements WebServiceI {

    @Override
    public String soa(String name) {
        System.out.println("测试调用");
        return ("你的名字:" + name);
    }

    @Override
    public ArrayList<Userbean> getInfoByID(int id) throws Exception {
        // 通过ID查询
        System.out.println("调用方法成功yeah!");
        Class.forName("com.mysql.jdbc.Driver");
        java.sql.Connection conn = DriverManager
            .getConnection("jdbc:mysql://localhost:3306/soa?user=root&password=123456");
        java.sql.Statement sql = conn.createStatement();
        StringBuffer sb = new StringBuffer();
        sb.append("SELECT *");
        sb.append(" FROM  ");
        sb.append(" user ");
        sb.append(" WHERE ID =");
        java.sql.ResultSet rs = sql
                .executeQuery(sb.toString() + "‘" + id + "‘");
        ArrayList<Userbean> list = new ArrayList<Userbean>();
        Userbean ub = new Userbean();
        while (rs.next()) {
            ub.setId(rs.getString(1));
            ub.setName(rs.getString(2));
            ub.setDept(rs.getString(3));
            ub.setBirthday(rs.getString(4));
            ub.setLocation(rs.getString(5));
            ub.setRank(rs.getString(6));
            ub.setDateIn(rs.getString(7));
            list.add(ub);
        }
        return list;
    }

    @Override
    public ArrayList<Userbean> getInfoByDD(String Dept, String rank) throws Exception  {
        // 联合查询
                System.out.println("调用方法成功yeah!");
                Class.forName("com.mysql.jdbc.Driver");
                java.sql.Connection conn = DriverManager
                        .getConnection("jdbc:mysql://localhost:3306/soa?user=root&password=123456");
                java.sql.Statement sql = conn.createStatement();
                StringBuffer sb = new StringBuffer();
                sb.append("SELECT *");
                sb.append(" FROM  ");
                sb.append(" user ");
                sb.append(" WHERE  dept=");
                java.sql.ResultSet rs = sql
                        .executeQuery(sb.toString() + "‘" + Dept + "‘"+ "and rank=" +"‘"+rank+"‘");  
                ArrayList<Userbean> list = new ArrayList<Userbean>();
                while (rs.next()) {
                    Userbean ub = new Userbean();
                    ub.setId(rs.getString(1));
                    ub.setName(rs.getString(2));
                    ub.setDept(rs.getString(3));
                    ub.setBirthday(rs.getString(4));
                    ub.setLocation(rs.getString(5));
                    ub.setRank(rs.getString(6));
                    ub.setDateIn(rs.getString(7));
                    list.add(ub);
                }
                return list;
    }

    @Override
    public boolean sayHello(String name) {

        System.out.println("WebService sayHello " + name);
        return true;

    }
代码片3:自定义复杂类型(必须实现序列化)

package webservice;

import java.io.*;
public class Userbean implements Serializable{
    private String id;
    private String name;
    private String dept;
    private String birthday;
    private String location;
    private String rank;
    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getDept() {
        return dept;
    }
    public void setDept(String dept) {
        this.dept = dept;
    }
    public String getBirthday() {
        return birthday;
    }
    public void setBirthday(String birthday) {
        this.birthday = birthday;
    }
    public String getLocation() {
        return location;
    }
    public void setLocation(String location) {
        this.location = location;
    }
    public String getRank() {
        return rank;
    }
    public void setRank(String rank) {
        this.rank = rank;
    }
    public String getDateIn() {
        return dateIn;
    }
    public void setDateIn(String dateIn) {
        this.dateIn = dateIn;
    }
    private String dateIn;
}
代码片4:服务发布类

package webservice;

import javax.xml.ws.BindingType;
import javax.xml.ws.Endpoint;

/**
 * @author 孟政宇
 *
 * 发布Web Service
 */
@BindingType("http://java.sun.com/xml/ns/jaxws/2003/05/soap/bindings/HTTP/")
public class WebServicePublish {
    public static void main(String[] args) {
        //定义WebService的发布地址,这个地址就是提供给外界访问Webervice的URL地址,URL地址格式为:http://ip:端口号/xxxx
        String address = "http://127.0.0.1:8989/hdfs/webservice";
        //使用Endpoint类提供的publish方法发布WebService,发布时要保证使用的端口号没有被其他应用程序占用
        /**
         *参数1:服务的发布地址 
         *参数2:服务的实现者
         */
        Endpoint.publish(address , new ServiceDemoImpl());
        System.out.println("发布webservice成功!");
    }
}

技术分享


5 客户端开发

实现思路:
为了验证服务端是否发布成功,我们可以采用三种方式来验证。
一.采用jdk自带工具wsimport来生成客户端,并编写客户端程序测试。
二.使用诸如MyEclipse(Eclipse for Jave EE也可以)创建一个Web Service Client的项目
三.本地编程实现,这里我采用编程实现。即编写client类,由于服务已经发布,故可以通过指定服务的URI和服务类对象,创建service对象调用getPort方法访问服务端口,并调用远端服务。

实现代码:

//服务器起来后,调用服务
//在客户端需要将wsimport导出的文件夹和Userbean考到客户端目录,且不能
//更改文件名
package webservice;
import javax.xml.namespace.QName;
import javax.xml.ws.Service;
import java.net.URL;
import java.net.MalformedURLException;
import java.util.ArrayList;
import java.util.Scanner;


public class client {
    public static void main(String[] args) throws Exception_Exception, MalformedURLException  {
        URL url = new URL("http://127.0.0.1:8989/hdfs/webservice?wsdl");
        // 第一个参数是服务的URI
        // 第二个参数是在WSDL发布的服务名
        QName qname = new QName("http://webservice/","ServiceDemoImplService");
        // 创建服务
        Service service = Service.create(url, qname);
        ServiceDemoImpl sd = service.getPort(ServiceDemoImpl.class);

        System.out.println("**********************web服务1测试**********************");
        System.out.println("根据ID查询信息,请输入ID编号:");
        Scanner scanner=new Scanner(System.in);
        String ID=scanner.nextLine();
        ArrayList<Userbean> list = new ArrayList<Userbean>();
        list  = (ArrayList<Userbean>)sd.getInfoByID(ID);

        System.out.println("查询结果:");
        for(int i=0 ; i< list.size() ; i++){
            System.out.print("员工号:" + list.get(i).getId() + "     ");
            System.out.print("员工名称:" + list.get(i).getName() + "     ");
            System.out.print("所在部门:" + list.get(i).getDept() + "     ");
            System.out.println("出生日期:" + list.get(i).getBirthday() + "     ");
            System.out.print("职位:" + list.get(i).getLocation() + "     ");
            System.out.print("职称:" + list.get(i).getRank() + "     ");
            System.out.println("入职日期:" + list.get(i).getDateIn() + "     ");
        }
        System.out.println("**********************web服务1测试**********************");

//      System.out.println("**********************web服务2测试**********************");
//      System.out.println("根据部门、职称查询信息,请输入参数:");
//      Scanner scanner=new Scanner(System.in);
//      String dept=scanner.nextLine();
//      String rank=scanner.nextLine();
//      ArrayList<Userbean> list = new ArrayList<Userbean>();
//      list  = (ArrayList<Userbean>)sd.getInfoByDD(dept,rank);
//      
//      System.out.println("查询结果:");
//      for(int i=0 ; i< list.size() ; i++){
//          System.out.print("员工号:" + list.get(i).getId() + "     ");
//          System.out.print("员工名称:" + list.get(i).getName() + "     ");
//          System.out.print("所在部门:" + list.get(i).getDept() + "     ");
//          System.out.println("出生日期:" + list.get(i).getBirthday() + "     ");
//          System.out.print("职位:" + list.get(i).getLocation() + "     ");
//          System.out.print("职称:" + list.get(i).getRank() + "     ");
//          System.out.println("入职日期:" + list.get(i).getDateIn() + "     ");
//      }
//      System.out.println("**********************web服务2测试**********************");
//  
//  }
}}

结果展示:
Web服务1测试:客户端通过输入员工的ID编号,传递参数到服务端,服务端调用服务getInfoByID并返回一个ArrayList类型的参数,客户端获取参数解析并显示,如图所示。
技术分享
Web服务2测试:客户端通过输入员工的部门和职称两个参数,服务端调用服务getInfoByDD,并返回一个ArrayList类型的参数,客户端获取参数解析并显示,如图所示。
技术分享

6 遇到的问题

问题:服务器向客户端传递的list为object无法解析为自定义的Userbean
解决方法:采用序列化的方式,在自定义的Javabean类实现Serializable即可

基于Jax-WS和Mysql数据库的WEB服务开发

标签:

原文地址:http://blog.csdn.net/mengzhengyu1025/article/details/51656241

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!