码迷,mamicode.com
首页 > 其他好文 > 详细

Axis2基础

时间:2016-04-16 16:40:40      阅读:439      评论:0      收藏:0      [点我收藏+]

标签:

本章主要介绍如何使用axis2开发webservice接口。

以下以一个实例程序讲解如何编写一个axis2的服务端和客户端。

axis2版本:axis2-1.5.4-bin.zip

目录结构:

技术分享

关键代码:

技术分享
package com.alfred.check;

import java.util.Iterator;
import org.apache.axiom.om.OMElement;
import org.apache.axis2.AxisFault;
import org.apache.axis2.context.MessageContext;

public class AccessCheck {
	public static void checkUserPwd() throws AxisFault {
		MessageContext msgContext = MessageContext.getCurrentMessageContext();
		// 获取Head
		Iterator list = (Iterator) msgContext.getEnvelope().getHeader()
				.getFirstElement().getChildren();
		String username = "";
		String password = "";
		while (list.hasNext()) {
			OMElement element = (OMElement) list.next();
			if (element.getLocalName().equals("username")) {
				username = element.getText();
			}
			if (element.getLocalName().equals("password")) {
				password = element.getText();
			}
		}
		if (!username.equals("admin") || !password.equals("123456")) {
			throw new AxisFault(
					" Authentication Fail! Check username/password ");
		}
	}
}
AccessCheck.java
技术分享
package com.alfred.service;

import org.apache.axis2.AxisFault;

import com.alfred.check.AccessCheck;

public class SoapService {
	public String sayHello(String name) throws AxisFault {
		// 以下是添加axis2访问头部验证
		// AccessCheck.checkUserPwd();
		return "Hello," + name;
	}

	public String getWorld() {
		return "Hello,World";
	}
}
SoapService.java
技术分享
package com.alfred.client;

import javax.xml.namespace.QName;
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.rpc.client.RPCServiceClient;

import org.apache.axiom.om.OMAbstractFactory;
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMFactory;
import org.apache.axiom.om.OMNamespace;

public class ServiceClient {
	public static void main(String args[]) throws AxisFault {
		sendAxis2();
	}

	/**
	 * 添加Header头部验证信息
	 *
	 * @return
	 */
	public static OMElement createHeaderOMElement() {
		OMFactory factory = OMAbstractFactory.getOMFactory();
		OMNamespace SecurityElementNamespace = factory.createOMNamespace(
				"http://handler.com", "wsse");
		OMElement authenticationOM = factory.createOMElement("Authentication",
				SecurityElementNamespace);
		OMElement usernameOM = factory.createOMElement("username",
				SecurityElementNamespace);
		OMElement passwordOM = factory.createOMElement("password",
				SecurityElementNamespace);
		usernameOM.setText("admin");
		passwordOM.setText("123456");
		authenticationOM.addChild(usernameOM);
		authenticationOM.addChild(passwordOM);
		return authenticationOM;
	}

	/**
	 * 发送axis2的接口信息
	 * @throws AxisFault
	 */
	private static void sendAxis2() throws AxisFault {
		// 使用RPC方式调用WebService
		RPCServiceClient serviceClient = new RPCServiceClient();

		// 向Soap Header中添加校验信息
		serviceClient.addHeader(createHeaderOMElement());

		Options options = serviceClient.getOptions();
		// 指定调用WebService的URL
		EndpointReference targetEPR = new EndpointReference(
				"http://127.0.0.1:8080/aw/services/mySoapService");
		options.setTo(targetEPR);
		// 指定sayHello方法的参数值,如果有多个,继续往后面增加即可
		Object[] opAddEntryArgs = new Object[] { "alfred" };
		// 指定sayHello方法返回值的数据类型的Class对象
		Class[] classes = new Class[] { String.class };
		// 在创建QName对象时,QName类的构造方法的第一个参数表示WSDL,文件的命名空间名,也就是<wsdl:definitions>元素的targetNamespace属性值
		// 第二个参数是要调用的方法名
		QName opAddEntry = new QName("http://service.alfred.com", "sayHello");
		// 返回参数类型,这个和axis1有点区别
		// invokeBlocking方法有三个参数:
		// 第一个参数的类型是QName对象,表示要调用的方法名;
		// 第二个参数表示要调用的WebService方法的参数值,参数类型为Object[];
		// 第三个参数表示WebService方法的返回值类型的Class对象,参数类型为Class[];
		// 当方法没有参数时,invokeBlocking方法的第二个参数值不能是null,而要使用new Object[]{}
		// 如果被调用的WebService方法没有返回值,应使用RPCServiceClient类的invokeRobust方法,
		// 该方法只有两个参数,它们的含义与invokeBlocking方法的前两个参数的含义相同
		Object ret = serviceClient.invokeBlocking(opAddEntry, opAddEntryArgs,
				classes)[0];
		System.out.println(ret);
	}

}
ServiceClient.java
技术分享
<?xml version="1.0" encoding="UTF-8"?>
<serviceGroup>
	<!-- 可以指定发布多个service -->
	<service name="mySoapService">
	    <description>
	        axis2 example
	    </description>
	    <!-- 指定接口类地址 -->
	    <parameter name="ServiceClass">
	        com.alfred.service.SoapService
	    </parameter>
	    <!-- Operation级消息接收器:可以为不同的操作指定不同的消息接收器
	    <operation name="sayHello">
        	<messageReceiver class="org.apache.axis2.rpc.receivers.RPCMessageReceiver" />
    	</operation>
	    <operation name="getWorld">
        	<messageReceiver class="org.apache.axis2.rpc.receivers.RPCMessageReceiver" />
    	</operation>
	     -->
	    <!-- 服务级消息接收器 -->
	    <messageReceivers>
	        <messageReceiver mep="http://www.w3.org/2004/08/wsdl/in-out"
	            class="org.apache.axis2.rpc.receivers.RPCMessageReceiver" />
	        <messageReceiver mep="http://www.w3.org/2004/08/wsdl/in-only"
	            class="org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver" />
	    </messageReceivers>
	</service>
</serviceGroup>
services.xml
技术分享
<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
	http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">

	<!--Axis2 config start-->
	<display-name>Apache-Axis2</display-name>
    <servlet>
        <servlet-name>AxisServlet</servlet-name>
        <servlet-class>org.apache.axis2.transport.http.AxisServlet</servlet-class>
        <!--<init-param>-->
        <!--<param-name>axis2.xml.path</param-name>-->
        <!--<param-value>/WEB-INF/conf/axis2.xml</param-value>-->
        <!--<param-name>axis2.xml.url</param-name>-->
        <!--<param-value>http://localhost/myrepo/axis2.xml</param-value>-->
        <!--<param-name>axis2.repository.path</param-name>-->
        <!--<param-value>/WEB-INF</param-value>-->
        <!--<param-name>axis2.repository.url</param-name>-->
        <!--<param-value>http://localhost/myrepo</param-value>-->
        <!--</init-param>-->
        <load-on-startup>1</load-on-startup>
    </servlet>
    <servlet>
        <servlet-name>AxisAdminServlet</servlet-name>
        <servlet-class>
            org.apache.axis2.webapp.AxisAdminServlet</servlet-class>
    </servlet>

    <servlet-mapping>
        <servlet-name>AxisServlet</servlet-name>
        <url-pattern>/servlet/AxisServlet</url-pattern>
    </servlet-mapping>

    <servlet-mapping>
        <servlet-name>AxisServlet</servlet-name>
        <url-pattern>/services/*</url-pattern>
    </servlet-mapping>

    <servlet-mapping>
        <servlet-name>AxisServlet</servlet-name>
        <url-pattern>*.jws</url-pattern>
    </servlet-mapping>
	<!--Axis2  end-->

	<welcome-file-list>
		<welcome-file>index.jsp</welcome-file>
	</welcome-file-list>
</web-app>
web.xml

在浏览器地址栏输入地址:http://127.0.0.1:8080/aw/services/mySoapService?wsdl(使用tomcat服务器,项目名为aw),可以看到显示出webservice的wsdl信息,说明部署成功。

在ServiceClient中,调用sayHello,打印信息:

技术分享

需要注意的一点就是services.xml文件的存放位置是固定的:WEB-INF/services/任意名字的文件夹/META-INF/services.xml

axis2访问验证

axis2接口可以通过向信息头部(Header)中添加验证信息,对接口调用者的身份进行验证。具体配置步骤是:

1、服务端在想要进行访问验证的接口方法中(sayHello),添加验证模块(AccessCheck.checkUserPwd());

2、验证模块通过获取webservice访问信息头部,提取验证信息,对客户端传递的验证信息进行进行检查判断;

3、客户端调用接口时,加入访问验证信息;

// 向Soap Header中添加校验信息
serviceClient.addHeader(createHeaderOMElement());

axis2的https访问

axis2如果需要进行https访问,需要加入全局配置文件axis2.xml(Axis2下提供了三种配置文件,第一种是整个系统的全局配置axis2.xml,第二种是服务配置services.xml,第三种是模块配置module.xml),默认该文件是存储在/WEB-INF/conf/axis2.xml。axis2.xml文件可以在axis2的开发包下获取。

在axis2.xml中加入一段:

<transportReceiver name="https" class="org.apache.axis2.transport.http.AxisServletListener">
    <parameter name="port">443</parameter>
</transportReceiver>

配置完成后访问https://127.0.0.1/aw/services/mySoapService?wsdl显示出webservice的wsdl信息,说明配置成功。

客户端如果想要访问https的服务端,需将服务端证书加入系统属性中

//指定服务端证书
System.setProperty("javax.net.ssl.keyStore",ProjConf.SERVER_KEYSTORE);
System.setProperty("javax.net.ssl.keyStorePassword",ProjConf.SERVER_KEYSTORE_PASSWORD);

System.setProperty("javax.net.ssl.trustStore",ProjConf.SERVER_TRUSTSTORE);
System.setProperty("javax.net.ssl.trustStorePassword",ProjConf.SERVER_TRUSTSTORE_PASSWORD);

如果想要手动指定axis2.xml文件路径(例如改为config文件夹下),可以在web.xml中配置(见上方web.xml)

<init-param>
        <param-name>axis2.xml.path</param-name>
        <param-value>/WEB-INF/config/axis2.xml</param-value>
</init-param>

常见错误

1、javax.servlet.ServletException: org.apache.axis2.AxisFault: The system is attempting to engage a module that is not available: addressing

解决方法:到axis2.xml中查找

<!-- Comment this to disable Addressing -->
<module ref="addressing"/>

将addressing的引用注释掉。

2、https is forbidden

解决方法:核实axis2.xml文件位置是否正确,默认是在WEB-INF/conf/axis2.xml,以及axis2.xml中是否配置了https。

3、unable to find valid certification path to requested target

解决方法:核实客户端访问https是否将证书加入系统属性。

最后,项目的结构如下:

技术分享

Axis2基础

标签:

原文地址:http://www.cnblogs.com/alfredinchange/p/5389657.html

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