axis2 学习（rpc）

刚开始学习时，可不必考虑某些包的功能。我当前是把所有的包都导进classpath中。

把下载下来的axis2-bin文件解压后，需要另外配置一个AXIS2_HOME 的环境变量。因为在AXIS2_HOME/bin 目录下面的脚本文件需要用到这个环境变量。

 

服务端的Pojo类：Bus.java

package axis2test;

public class Bus {

    private String number;
    private String firstStation;
    private String lastStation;

    /**
     * @return the number
     */
    public String getNumber() {
        return number;
    }

    /**
     * @param number
     *            the number to set
     */
    public void setNumber(String number) {
        this.number = number;
    }

    /**
     * @return the firstStation
     */
    public String getFirstStation() {
        return firstStation;
    }

    /**
     * @param firstStation
     *            the firstStation to set
     */
    public void setFirstStation(String firstStation) {
        this.firstStation = firstStation;
    }

    /**
     * @return the lastStation
     */
    public String getLastStation() {
        return lastStation;
    }

    /**
     * @param lastStation
     *            the lastStation to set
     */
    public void setLastStation(String lastStation) {
        this.lastStation = lastStation;
    }

}

 服务端的Service类：BusService.java

package axis2test;

public class BusService {

    private Bus bus;

    /**
     * @return the bus
     */
    public Bus getBus() {
        return bus;
    }

    /**
     * @param bus the bus to set
     */
    public void setBus(Bus bus) {
        this.bus = bus;
    }
}

  创建一个资源（resources）文件夹，在该文件夹下创建元数据信息文件夹（META-INF），最后创建一个service.xml文件，其内容为：

<service name="BusService" scope="application">
	<description>
		Bus POJO Service
    </description>
	<messageReceivers>
		<messageReceiver mep="http://www.w3.org/2004/08/wsdl/in-only"
			class="org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver" />
		<messageReceiver mep="http://www.w3.org/2004/08/wsdl/in-out"
			class="org.apache.axis2.rpc.receivers.RPCMessageReceiver" />
	</messageReceivers>
	<parameter name="ServiceClass">
		axis2test.BusService
    </parameter>
</service>

 

dd

package test;

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 axis2test.Bus;

public class MyTest {

    public static void main(String[] args) throws AxisFault {
        RPCServiceClient serverClient = new RPCServiceClient();
        Options option = serverClient.getOptions();
        EndpointReference endPoint = new EndpointReference(
                "http://localhost:8080/axis2/services/BusService");
        option.setTo(endPoint);
        QName busName = new QName("http://axis2test", "setBus");
        Bus bus = new Bus();
        bus.setFirstStation("铁心桥");
        bus.setLastStation("花神家具港");
        bus.setNumber("171");
        Object[] arg = new Object[] { bus };
        serverClient.invokeRobust(busName, arg);
        QName getBus = new QName("http://axis2test", "getBus");
        Object[] getBusArgs = new Object[] {};
        Class[] retTypes = new Class[] { Bus.class };
        Object[] response = serverClient.invokeBlocking(getBus, getBusArgs,
                retTypes);
        Bus retBus = (Bus) response[0];
        if (null != response) {
            System.out.println("起点站：" + retBus.getFirstStation());
            System.out.println("终点站：" + retBus.getLastStation());
            System.out.println("公交车号：：" + retBus.getNumber());
        }
    }
}

 

dfd