Axis2之webservice超详细教程

Axis2是一套崭新的WebService引擎，该版本是对Axis1.x重新设计的产物。Axis2不仅支持SOAP1.1和SOAP1.2，还集成了非常流行的REST WebService，同时还支持Spring、JSON等技术，本教程是主要阐述如何构建一个基本的Axis2 webservice应用，里面的许多环节高手可直接略过，本教程完全针对新手。

一、环境安装

安装myeclipse

下载地址: http://www.xlpan.com/file/4238159/48030981-6b56-40a4-a93b-8f424ee4f33a

安装mysql

下载地址：http://www.xlpan.com/file/4238159/de64cf2f-4217-4e11-bb98-8e6c5dd24155

安装mysql-workbench(mysql可视化工具)

下载地址：http://www.xlpan.com/file/4238159/becf913f-56a6-4d68-b248-134113b73535

安装tomcat

下载地址:

http://www.xlpan.com/file/4238159/ec6a2250-99ff-464e-a978-be184c96e4e7

下载Axis2服务包

下载地址: http://www.xlpan.com/file/4238159/bb3db6e3-2f7d-4343-b472-c1fa714dba95

下载Axis2开发插件包

下载地址: http://www.xlpan.com/file/4238159/aa39505f-079b-43be-9479-15a2d3e98cbb

安装jdk

下载地址: http://www.xlpan.com/file/4238159/7ba342f9-277f-4b9c-b5e7-b0c5b7dfc151

二、环境配置

1)     Java环境配置

a)     设置JAVA_HOME

图1.

图2

设置JAVA_HOME= D:\Program Files\Java\jdk1.6.0_10

* D:\Program Files\Java\jdk1.6.0_10为笔者本机的JDK安装目录，请开发者根据实际安装路径来填写,注意环境变量最后面不能加分号，D:\Program Files\Java\jdk1.6.0_10；这么写是错误的。

b)     设置CLASSPATH

图1

设置CLASSPATH= .;%JAVA_HOME%\lib;%JAVA_HOME%\lib\tools.jar

* 要加.表示当前路径

c)      设置path

设置path=%JAVA_HOME%\bin;%JAVA_HOME%\jre\bin

2)     tomcat环境配置

a)      设置CATALINA_HOME

CATALINA_HOME=F:\apache-tomcat-6.0.30

* F:\apache-tomcat-6.0.30为笔者本机的JDK安装目录，请开发者根据实际安装路径来填写。

b)     测试Axis2服务包

将axis2服务包（axis2.war）放入F:\apache-tomcat-6.0.30\webapps下

点击F:\apache-tomcat-6.0.30\bin下的startup.bat文件

在浏览器中输入 http://localhost:8080/axis2/

若出现图中所示页面，那么说明axis2的服务包已经发布成功了；

在F:\apache-tomcat-6.0.30\webapps目录下会自动生成一个axis2文件夹，这个留待后面的说明中一并叙述，下面继续配置。

3)     myeclipse环境配置

a)      配置axis2插件包

将axis2插件包下的Axis2_Codegen_Wizard_1.3.0和Axis2_Service_Archiver_1.3.0文件夹拷贝至Myeclipse8.5\dropins 目录下

点击FileàNewàOther

若出现图中2个高亮显示的插件名，那么说明Axis2开发插件已经安装成功。

b)     myeclipse下的tomcat配置

点击WindowàPreferences

点击MyEclipseàServersàTomcat, 选择Configure Tomcat 6.x

按照图中所示配置tomcat

c)      myeclipse下的jre配置

点击JavaàInstalledJREs,点击Search按钮,选择D:\Program Files\Java\jdk1.6.0_10路径（开发者根据实际路径自己调整）

如图中所示进行配置，点击OK

4)     Mysql数据配置

a)      数据库安装配置

实例配置时,笔者选择的是服务器。

服务器字符集选择的是utf-8

数据库连接设置为：

用户名：root

密码:123456

b)     测试数据库建立

笔者采用的是可视化工具建库（mysql-workbench-gpl-5.2.37-win32）

打开mysql-workbench

点击图中标注的按钮，新建一个库

新建库名为webservice

新建student表,建表语句如下

DROP TABLE IF EXISTS `student`;

CREATE TABLE `student` (

`id` int(11) NOT NULL AUTO_INCREMENT,

`number` int(11) DEFAULT NULL,

`name` varchar(45) DEFAULT NULL,

`tel` varchar(45) DEFAULT NULL,

`address` varchar(45) DEFAULT NULL,

PRIMARY KEY (`id`)

) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8;

LOCK TABLES `student` WRITE;

INSERT INTO `student` VALUES (1,1,'小明','119','南京'),(2,2,'小郭','110','西藏'),(3,NULL,'坤哥','117','朝鲜');

UNLOCK TABLES;

双击左侧webservice库名，将其设为默认库，默认库的名字会加粗显示，如果不设置默认库，会影响下面的数据导入。

将建表语句复制进来，执行；

数据导入成功。

三、         正式开发

1)     服务端开发

a)      工程建立

打开myeclipse

点击NewàWeb Project新建一个Web工程

新建工程名为myservice,一直默认执行。

右键点击工程，右键菜单里选择Properties,将工程编码设置为UTF-8

b)     编写mysql数据库访问功能模块

将mysql的连接驱动包（mysql-connector-java-5.1.7-bin.jar）拷贝至WebRoot\WEB-INF\lib下

在src目录下新建一个database包,分别录入以下4个类，因为牵涉到jdbc封装类的开发，这里就不详细阐述，仅贴出源代码。

(一) ConnectionFactory.java  (连接工厂类)

package database;

import java.sql.Connection;

import java.sql.DriverManager;

import java.util.ResourceBundle;

/** 类名：ConnectionFactory<br>

* 作用：产生数据库连接对象<br>

* 属性：<br>

* 方法：Connection getConnection()<br>

*        作用：返回数据库连接对象<br>

*        参数：无<br>

*        返回：数据库连接对象<br>

* 其它：返回的aConnection不会自动提交JDBC事务<br>

* 创建人：陶尚明<br>

* */

public abstract class ConnectionFactory {

/** 数据库系统的属性文件名:

*/

private static final String propertiesFileName = "using_which_dbms";

/** 获取Connection对象

*

* @return Connection对象

* @throws Exception SqlException异常 */

static synchronized public Connection getConnection() throws Exception {

String dbSystem=null;

Connection aConnection;

ResourceBundle db = ResourceBundle.getBundle("dbsystem");  //读取配置文件

dbSystem=db.getString(propertiesFileName);

ResourceBundle rb = ResourceBundle.getBundle(dbSystem);  //读取配置文件

Class.forName(rb.getString("database.driver")).newInstance();

aConnection = DriverManager.getConnection(rb.getString("database.url"),rb.getString("database.username"),rb.getString("database.password"));  //创建aConnection对象

aConnection.setAutoCommit(false);  //设置不自动提交事务

return aConnection;  //返回aConnection对象

}

/** 当前使用的数据库系统名称

*

* @param echoable 如果启用回显将在控制台输出描述当前数据库系统的信息

* @return dbSystem 数据库系统名称 */

public static String getCurrentDBMS(boolean echoable) {

String dbSystem=null;

ResourceBundle rb = ResourceBundle.getBundle("dbsystem");  //读取配置文件

dbSystem=rb.getString(propertiesFileName);

if (echoable)System.out.println("the database system what you using are "+dbSystem);

return dbSystem;

}

}

(二) IOperationCore.java（数据库操作接口)

/**

 * 数据库常用操作封装

 */

package database;

 

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.Collection;

 

/** 类名：IOperationCore<br>

 *

 * 作用: 该接口封装了数据库操作的大部分方法<br>

 *

 * 创建人：陶尚明<br>

 */

public interface IOperationCore {

   /** sql更新语句

    *

    * @param queryString 查询语句

    * @return 返回一个<code>ResultSet</code>结果集

    *

    * @exception SQLException */

   ResultSet executeQuery(String queryString) throws SQLException;

   /** 

    * sql更新语句

    *

    * @param updateString 数据库更新语句

    * @return 更新数据库影响行数

    *

    * @exception SQLException */

   int executeUpdate(String updateString) throws SQLException;

   /**

    * 读取行个数

    *

    * @param queryString 查询语句

    * @return Transact-SQL 查询后的虚拟表的行数

    *

    * @exception SQLException */

   int getRowCount(String queryString) throws SQLException;

   /**

    * 读取列数个数

    *

    * @param queryString 查询语句

    * @return Transact-SQL 查询后的虚拟表的列数

    *

    * @exception SQLException */

   int getColumnCount(String queryString) throws SQLException;

   /**

    * 读取列名

    *

    * @param columIndex 列索引

    * @param queryString 提供ResultSet二维表的查询字符串

    * @return ResultSet表中的指定的列名

    *

    * @exception SQLException */

   String getColumnName(int columIndex, String queryString) throws SQLException;

   /**

    * 读取queryString查询结果集<code>ResultSet</code>表中的所有列名

    *

    * @param queryString 用于返回<code>ResultSet</code>结果集的语句

    * @return 表中的所有列名

    * @throws SQLException */

   Collection<String> getColumnNames(String queryString) throws SQLException;

   /**

    * 读取queryString查询结果集<code>ResultSet</code>表中的所有字段类型名称

    *

    * @param queryString 用于返回查询结果集的语句

    * @return 表中的所有字段类型名称

    * @throws SQLException */

   Collection<?> getColumnTypeNames(String queryString) throws SQLException;

   /**

    * 获取ResultSet二维表中指定位置的值,目前只支持mysql

    *

    * @param rowIndex 行索引

    * @param columnIndex 列索引

    * @param queryString 产生一个ResultSet结果集的查询语句

    * @return 指定位置的数据记录

    *

    * @exception SQLException */

   Object getValueAt(int rowIndex, int columnIndex, String queryString) throws SQLException;

   /**

    * 释放系统连接资源

    * <br>一旦关闭,数据库的操作将全部无效

    * @exception SQLException 如果关闭失败将抛出<code>SQLException</code>*/

   void dispose() throws SQLException;

 

}

(三) OperationCoreImpl.java（数据库操作接口实现)

package database;

import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.ResultSetMetaData;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.ArrayList;

import java.util.Collection;

/** 类名：OperationCoreImplements<br>

*

* 作用: 该类实现IOperationCore接口的所有方法<br>

*

* 创建人：陶尚明<br>

*

*/

public class OperationCoreImpl implements IOperationCore {

protected Connection aConnection = null;

protected Statement aStatement = null;

protected ResultSet aResultSet = null;

protected ResultSetMetaData rsmd = null;

protected static OperationCoreImpl m_instance = null;

/** Singleton 即单例(态)模式,用来生成对象唯一实例的方法

*

* @return OperationCoreImplements的一个实例

* @throws Exception */

public static OperationCoreImpl createFactory() throws Exception {

if(m_instance==null)

m_instance=new OperationCoreImpl();

return m_instance;

}

/** @exception Exception */

private OperationCoreImpl() throws Exception {

init();

}

/**

* 负责初始化Connection连接

* @throws Exception

*/

private void init() throws Exception{

aConnection=ConnectionFactory.getConnection();

}

/**

* 释放系统连接资源

*<br>一旦关闭,数据库的操作将全部无效

*/

public void dispose() {

try {

if(aResultSet!=null)

aResultSet.close();

} catch (SQLException e) {

e.printStackTrace();

}

try {

if(aStatement!=null)

aStatement.close();

} catch (SQLException e) {

e.printStackTrace();

}

try {

if(aConnection!=null)

aConnection.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

/** sql更新语句

*

* @param queryString 查询语句

* @return 返回一个<code>ResultSet</code>结果集

*

* @exception SQLException */

public ResultSet executeQuery(String queryString) {

try {

aStatement = aConnection.createStatement();

aResultSet = aStatement.executeQuery(queryString);

} catch (SQLException e) {

aResultSet=null;

e.printStackTrace();

}

return aResultSet;

}

/**

* sql更新语句

*

* @param updateString 数据库更新语句

* @return 更新数据库影响行数

*

* @exception SQLException */

public int executeUpdate(String updateString) {

int effectedRows=0;

try{

aConnection.setAutoCommit(false);

aStatement = aConnection.createStatement();

effectedRows = aStatement.executeUpdate(updateString);

aConnection.commit();

}catch(SQLException ex){

System.out.println("数据库写操作失败!");

if(aConnection!=null)

{

try {

aConnection.rollback();

System.out.println("JDBC事务回滚成功");

} catch (SQLException e) {

System.out.println("JDBC事务回滚失败");

e.printStackTrace();

}

}

}

return effectedRows;

}

/**

* 读取queryString查询结果集<code>ResultSet</code>表中的所有列名

*

* @param queryString 用于返回<code>ResultSet</code>结果集的语句

* @return 表中的所有列名

* @throws SQLException */

public Collection<String> getColumnNames(String queryString) {

ArrayList<String> ColumnNames=new ArrayList<String>();

try {

aResultSet=executeQuery(queryString);

ResultSetMetaData rsmd=aResultSet.getMetaData();

int j=rsmd.getColumnCount();

for(int k=0;k<j;k++){

ColumnNames.add(rsmd.getColumnName(k+1));

}

} catch (SQLException e) {

ColumnNames=null;

e.printStackTrace();

}

return ColumnNames;

}

/**

* 读取queryString查询结果集<code>ResultSet</code>表中的所有字段类型名称

*

* @param queryString 用于返回查询结果集的语句

* @return 表中的所有字段类型名称

* @throws SQLException */

public Collection<String> getColumnTypeNames(String queryString) {

ArrayList<String> ColumnNames=new ArrayList<String>();

try {

aResultSet=executeQuery(queryString);

ResultSetMetaData rsmd=aResultSet.getMetaData();

int j=rsmd.getColumnCount();

for(int k=0;k<j;k++){

ColumnNames.add(rsmd.getColumnTypeName(k+1));

}

} catch (SQLException e) {

ColumnNames=null;

e.printStackTrace();

}

return ColumnNames;

}

/**

* 读取列名

*

* @param columIndex 列索引

* @param queryString 提供ResultSet二维表的查询字符串

* @return ResultSet表中的指定的列名

*

* @exception SQLException */

public String getColumnName(int columIndex, String queryString)       {

String columnName=null;

try {

aResultSet=executeQuery(queryString);

rsmd=aResultSet.getMetaData();

columnName=rsmd.getColumnName(columIndex + 1);

} catch (SQLException e) {

e.printStackTrace();

}

return columnName;

}

/**

* 读取列数个数

*

* @param queryString 查询语句

* @return Transact-SQL 查询后的虚拟表的列数

*

* @exception SQLException */

public int getColumnCount(String queryString) {

int columnCount=0;

try {

aResultSet=executeQuery(queryString);

ResultSetMetaData rsmd=aResultSet.getMetaData();

columnCount = rsmd.getColumnCount();

} catch (SQLException e) {

e.printStackTrace();

}

return columnCount;

}

/**

* 读取行个数

*

* @param queryString 查询语句

* @return Transact-SQL 查询后的虚拟表的行数

*

* @exception SQLException */

public int getRowCount(String queryString) {

int rowCount=0;

try {

aResultSet=executeQuery(queryString);

while(aResultSet.next())

rowCount=aResultSet.getInt(1);

} catch (SQLException e) {

e.printStackTrace();

}

return rowCount;

}

/**

* 获取ResultSet二维表中指定位置的值,目前只支持mysql

*

* @param rowIndex 行索引

* @param columnIndex 列索引

* @param queryString 产生一个ResultSet结果集的查询语句

* @return 指定位置的数据记录

*

* @exception SQLException */

public Object getValueAt(int rowIndex, int columnIndex, String queryString)    {

Object values=null;

try {

aResultSet=executeQuery(queryString);

//指针下移一行

aResultSet.absolute(rowIndex + 1);

values=aResultSet.getObject(columnIndex + 1);

} catch (SQLException e) {

e.printStackTrace();

}

return values;

}

}

(四) DBOperationAdapter.java (对用户透明的数据库操作类)

package database;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.Collection;

/** 类名：DBOperationAdapter<br>

* 作用: <b>该类中的所有方法对用户透明,提供数据库操作的常用方法</b><br>

*

* 说明：该类使用了<b>Adapter</b> 模式与 <b>Singleton</b> 模式,<br/>

* 类自身为Adpater,OperationCoreImplements为Adapte类;<br>

* 实例化类自生对象的时候用到了Singleton模式,<br>

* 即<code>DBOperationAdapter.getInstance()</code><br>

* 创建人：陶尚明<br>

*/

public class DBOperationAdapter extends ConnectionFactory {

private static IOperationCore objIOperationCore = null;

private static DBOperationAdapter m_instance = null;

private DBOperationAdapter() {

try {

objIOperationCore=OperationCoreImpl.createFactory();

} catch (Exception e) {

e.printStackTrace();

}

}

public static DBOperationAdapter getInstance() {

if(m_instance==null)

m_instance=new DBOperationAdapter();

return m_instance;

}

/** sql更新语句

*

* @param queryString 查询语句

* @return 返回一个<code>ResultSet</code>结果集

*

* @exception SQLException */

public ResultSet executeQuery(String queryString) throws SQLException {

return objIOperationCore.executeQuery(queryString);

}

/**  sql更新语句

*

* @param updateString 数据库更新语句

* @return 更新数据库影响行数

*

* @exception SQLException */

public int executeUpdate(String updateString) throws SQLException {

return objIOperationCore.executeUpdate(updateString);

}

/**  sql删除语句:updateString

*

* @param deleteString 数据库插入语句

* @return 删除数据影响行数

*

* @exception SQLException */

public int executeDelete(String deleteString) throws SQLException {

return objIOperationCore.executeUpdate(deleteString);

}

/**  sql插入语句:insertString

*

* @param insertString 数据库插入语句

* @return 插入数据影响行数

*

* @exception SQLException */

public int executeInsert(String insertString) throws SQLException {

return objIOperationCore.executeUpdate(insertString);

}

/**

* 读取行个数

*

* @param queryString 查询语句

* @return Transact-SQL 查询后的虚拟表的行数

*

* @exception SQLException */

public int getRowCount(String queryString) throws SQLException {

return objIOperationCore.getRowCount(queryString);

}

/** 读取列数个数

*

* @param queryString 查询语句

* @return Transact-SQL 查询后的虚拟表的列数

*

* @exception SQLException */

public int getColumnCount(String queryString) throws SQLException {

return objIOperationCore.getColumnCount(queryString);

}

/**

* 读取列名

*

* @param columIndex 列索引

* @param queryString 提供ResultSet二维表的查询字符串

* @return ResultSet表中的指定的列名

*

* @exception SQLException */

public String getColumnName(int columIndex, String queryString) throws SQLException {

return objIOperationCore.getColumnName(columIndex, queryString);

}

/**

* 读取queryString查询结果集<code>ResultSet</code>表中的所有字段类型名称

*

* @param queryString 用于返回查询结果集的语句

* @return 表中的所有字段类型名称

* @throws SQLException */

public Collection<?> getColumnTypeNames(String queryString) throws SQLException {

return objIOperationCore.getColumnTypeNames(queryString);

}

/**

* 读取queryString查询结果集<code>ResultSet</code>表中的所有列名

*

* @param queryString 用于返回<code>ResultSet</code>结果集的语句

* @return 表中的所有列名

* @throws SQLException */

public Collection<String> getColumnNames(String queryString) throws SQLException {

return objIOperationCore.getColumnNames(queryString);

}

/**

* 获取ResultSet二维表中指定位置的值,目前只支持mysql

*

* @param rowIndex 行索引

* @param columnIndex 列索引

* @param queryString 产生一个ResultSet结果集的查询语句

* @return 指定位置的数据记录

*

* @exception SQLException */

public Object getValueAt(int rowIndex, int columnIndex, String queryString) throws SQLException {

return objIOperationCore.getValueAt(rowIndex, columnIndex,queryString);

}

/**

* 释放系统连接资源

* <br>一旦关闭,数据库的操作将全部无效

* @exception SQLException 如果关闭失败将抛出<code>SQLException</code>*/

public void dispose() throws SQLException {

objIOperationCore.dispose();

}

}

(五) 编写数据库配置属性文件

dbsystem.properties

using_which_dbms=mysql

mysql.properties

# mysql Configuration Parameters

# DB System requirement:mysql 5.0 or upon

#=================================================

database.driver=com.mysql.jdbc.Driver

database.url=jdbc:mysql://127.0.0.1:3306/webservice

database.username=root

database.password=123456

其中数据库连接地址请各位根据实际情况酌情修改

如上图所示，数据库访问功能模块至此已经编写完毕。

c)      编写业务模块

(一) 简单java实体类的建立

在src目录下新建一个entity包,下面有一个Student类，与数据库中的student表对应起来

Student.java

package entity;

import java.io.Serializable;

/*

* 学生实体对象

*

*/

public class Student implements Serializable{

private static final long serialVersionUID = 677484458789332877L;

private int id;

private int number;

private String name;

private String tel;

private String address;

/**

* @return the id

*/

public int getId() {

return id;

}

/**

* @param id the id to set

*/

public void setId(int id) {

this.id = id;

}

/**

* @return the number

*/

public int getNumber() {

return number;

}

/**

* @param number the number to set

*/

public void setNumber(int number) {

this.number = number;

}

/**

* @return the name

*/

public String getName() {

return name;

}

/**

* @param name the name to set

*/

public void setName(String name) {

this.name = name;

}

/**

* @return the tel

*/

public String getTel() {

return tel;

}

/**

* @param tel the tel to set

*/

public void setTel(String tel) {

this.tel = tel;

}

/**

* @return the address

*/

public String getAddress() {

return address;

}

/**

* @param address the address to set

*/

public void setAddress(String address) {

this.address = address;

}

/**

* @return the serialversionuid

*/

public static long getSerialversionuid() {

return serialVersionUID;

}

public String toString()

{

return this.id +"#"+this.number+"#"+ this.name +"#"+this.tel+"#"+this.address;

}

}

注意此Student类实现了可序列化接口，否则无法正常传输至客户端

(二)Service发布类的编写（核心部分！！！！！！）

在src目录下新建一个entity包,下面有一个TestService类

TestService.java

package service;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.List;

import database.DBOperationAdapter;

import entity.Student;

/*

* WebService测试类

*/

public class TestService {

//返回学生列表信息

public Student[] queryStudents()

{

DBOperationAdapter dbtools=DBOperationAdapter.getInstance();

Student st = null;

List<Student> retList = new ArrayList();

try {

ResultSet rs=dbtools.executeQuery("select * from student");

while(rs.next()){

st = new Student();

st.setId(rs.getInt(1));//设置学生ID

st.setNumber(rs.getInt(2));//设置学生学号

st.setName(rs.getString(3));//设置学生姓名

st.setTel(rs.getString(4));//设置学生电话

st.setAddress(rs.getString(5));//设置学生住址

retList.add(st);

}

} catch (SQLException e) {

e.printStackTrace();

}

return retList.toArray(new Student[0]);

}

//测试欢迎方法

public String getGreeting(String name)

{

return "你好"+name;

}

}

这个类是专门用来发布服务的，对外开放了2个接口方法：queryStudents和getGreeting方法，

其中特别注意queryStudents方法返回值是自定义对象类型（Student）的对象数组，因为webservice不支持

复杂的集合类传递，譬如list和map,需要转化为数组类型或者axis2里的axiom对象模型。这里是转化为

数组类型，axiom对象模型感兴趣的同学可搜索资料进一步学习，这里篇幅所限，不再进行赘述。

d)     发布服务

在左侧视图点击鼠标右键，选择NewàOther

选择Axis2 Service Archiver

打包编译文件选择myservice工程下\myservice\WebRoot\WEB-INF\classes目录，记得红色标记处的勾选取消掉。

略过wsdl文件选择

将\myservice\WebRoot\WEB-INF\lib 目录下的mysql-connector-java-5.1.7-bin.jar文件

一并打包进来，否则服务无法正常访问mysql数据库

自动设置service.xml配置文件

填写需要发布的webservice名称以及对外开放的服务类名称，服务类名称前面要带包名，

勾选Search declared method only，可以在下面的列表框中看见我们对外发布的方法名。

将打好的aar包发布至tomcat的\webapps\axis2\WEB-INF\services下

点击Run Server启动Tomcat服务

在浏览器中输入：http://localhost:8080/axis2/services/listServices  出现如上图所示页面，红色标注的就是我们自己发布的服务，

点击MyService链接

显示发布服务的wsdl文件

浏览器中输入：http://localhost:8080/axis2/services/MyService/getGreeting?name=guoxingquan 调用getGreeting方法，并传入一个

字符参数，返回欢迎语。

浏览器中输入：http://localhost:8080/axis2/services/MyService/queryStudents 调用queryStudents方法，从数据库中查询学生列表信息

2)     客户端开发

客户端开发使用了一个struts2工程，struts2工程如何建立不再赘述，我们直接导入myclient工程

源代码下载地址请参考教程的最后部分的附件一览。

导入myclient工程

上图中高亮显示的几个文件是需要重点说明的

a)      Wsdl文件生成

在左侧视图中点击NewàOther,选择上图所示高亮部分选项

如上图选择

填入之前我们服务端开放的类名，包括包路径，点击Add Folder,将服务端工程的编译文件输出文件夹

加入进来，点击Test Class Loading,继续下一步

注意我们之前发布的服务名称为MyService,请填写正确，继续下一步

继续下一步，完毕

b)     根据Wsdl文件生成客户端用户存根

在左侧视图中点击NewàOther,选择上图所示高亮部分选项

继续下一步

选择我们刚才生成wsdl文件，注意路径正确

注意红色部分，自动生成的代码会直接放在service包下

如上图进行选择

直接下一步，配置完毕

自动生成的代码为MyServiceCallbackHandler.java和MyServiceStub.java,其中我们这个工程里用到的只有

MyServiceStub.java，这个是根据服务器端在客户端生成的存根代码，自动封装了一系列远程调用配置，以及

对象类型以及方法的转换，大大节约了开发人员的工作量；MyServiceCallbackHandler.java主要牵涉到一系列回调，

感兴趣的同学可以进一步研究，这里不再进行说明。

c)      业务调用代码

FindstudentsAction.java

package com;

import java.rmi.RemoteException;

import service.MyServiceStub;

import service.MyServiceStub.Student;

import com.opensymphony.xwork2.ActionContext;

import com.opensymphony.xwork2.ActionSupport;

public class FindstudentsAction extends ActionSupport {

public String execute() throws Exception {

//设置远程服务调用地址

String target = "http://127.0.0.1:8080/axis2/services/MyService";

try {

//根据地址构造用户存根

MyServiceStub stub = new MyServiceStub(target);

//调用查询学生列表方法

MyServiceStub.QueryStudentsResponse qsr = stub.queryStudents();

//返回学生类型对象数组

Student[] sts = qsr.get_return();

//将数组输出至前台页面

ActionContext.getContext().getSession().put("sts", sts);

} catch (RemoteException e) {

e.printStackTrace();

} catch (Exception e) {

e.printStackTrace();

}

return SUCCESS;

}

}

d)     运行代码

选择Add Deployment发布服务

选择myclient来进行发布

点击Run Server来启动服务

在浏览器中输入：http://localhost:8080/myclient/   点击学生

客户端调用学生查询方法成功。

四、        附件一览

webservice源代码下载地址：

http://www.xlpan.com/file/4238159/cb8cd3f2-1110-4e46-a036-d0cb32a4856e

转载于:https://www.cnblogs.com/soulaz/p/5567060.html

axis2之webservice相关推荐

  1. 使用axis2进行WebService的开发

    使用axis2进行WebService的开发 Apache Axis2 是 Apache Axis SOAP 项目的后继项目.此项目是 Web 服务核心引擎的重要改进,目标是成为 Web 服务和面向服 ...

  2. Axis2搭建WebService服务

    使用Axis2搭建WebService服务 文章目录 一.服务端部署 1.1 在web.xml配置文件中添加映射路径: 2. 创建目录及文件 3. 新建服务接口 4. 新建接口实现类 5. 发布服务 ...

  3. java使用axis2调用webservice接口实例

    说明:我目前的项目环境是struts2+spring+mybatis+oracle,以下代码是java使用axis2调用webservice接口实例. import javax.xml.namespa ...

  4. Spring boot集成axis2开发webservice 服务

    Spring boot集成axis2开发webservice 服务 1.新建Spring boot 项目 此处省略... 项目结构如下: 2.添加Axis2依赖 <!--axis2版本信息--& ...

  5. MyEclipse10 + Axis2 开发webservice

    最近准备用Axis2做WebService的开发,期间也碰到一些坑爹的问题,在MyEclipse10下安装最新的Axis2插件,不知道是不是人品问题还是插件的兼容性不太给力都没有成功,只能使用低版本的 ...

  6. SpringBoot+Axis2搭建WebService服务端

    SpringBoot+Axis2搭建WebService服务端 之前用过Spring + Axis2搭建过WebService项目,网上也有很多资料教程,最近需要在一个SpringBoot项目中添加A ...

  7. Axis2学习第一篇：Axis2开发WebService之发布和调用

    一.关于Axis2 Axis2是目前比较流行的WebService引擎.适用于开发RPC风格的程序. 二.使用Axis2开发WebService 下载与安装 下载地址:http://axis.apac ...

  8. axis2 默认端口_使用axis2创建webservice

    这个方式创建的webservice可以和web项目放到同一个工程下. 创建webservice服务,所需要的jar包如下: axiom-api-1.2.8.jar axiom-impl-1.2.8.j ...

  9. axis2开发webservice之编写Axis2模块（Module）

    axis2中的模块化开发.能够让开发者自由的加入自己所需的模块.提高开发效率,减少开发的难度. Axis2能够通过模块(Module)进行扩展. Axis2模块至少须要有两个类,这两个类分别实现了Mo ...

最新文章

  1. linux ll一页一页,Linux使用技巧33则
  2. 抖音用户规模达5.18亿，数据解读抖音支付背后逻辑？
  3. 日志库EasyLogging++学习系列（5）—— 辅助配置功能
  4. python循环语句for计数_Bash For循环(递增计数)与for循环用法详解
  5. Opencv 图片 读取，显示，保存基本操作
  6. mysql mvcc undo_Mysql Innodb中undo-log和MVCC多版本一致性读 的实现
  7. 删除修改docker网络环境
  8. 《Android 应用案例开发大全（第3版）》——第1.2节掀起Android的盖头来
  9. 计算机远程桌面连接命令行,远程桌面连接命令,小编教你win7远程桌面连接命令的使用教程...
  10. Python之pip的安装和使用详细教程
  11. 推荐一款Mac远程桌面工具——Parallels Client（免费）
  12. 在线培训-虚拟演播室嵌入网页直播
  13. YOLO-zht训练-未完待续
  14. 如何看懂论文公式：LaTex数学公式分析
  15. 【旧文集】一生伏首拜阳明-记于2017
  16. 计算机假期计划内容,2019寒假计划，超详细学习计划表
  17. Java注解是怎么成功上位的？
  18. HPX-H1、HPX-NT1、HPX-NT3、HPX-T1
  19. vs2017编译使用jsoncpp
  20. 收到字节跳动的面试邀请，我却掉了链子

热门文章

  1. 南阳理工acm71 独木舟上的旅行（贪心简单题）
  2. 农历大小月的确定方法
  3. Linux内存uncache区域拷贝优化
  4. X64dbg-插件开发-字符编码-常用插件函数-回调结构
  5. Plugin工具类-Unreal4源码拆解-UnrealBuildTool功能流程解析
  6. 什么是SEO,为什么要做SEO?
  7. 获取微信运动 php,微信运动数据抓取(PHP语言)
  8. 腾讯全民wifi驱动无法安装
  9. 阿里IOT用AMQP在服务端订阅消息，踩坑
  10. mongo connect error no reachable servers