axis2 webservice学习笔记一

axis2 webservice axis ?包括以下几部分 消息子系统 传输框架子系统 数据编码子系统 下载axis2 地址如下： http://axis.apache.org/axis2/java/core/download.cgi 环境搭建 1 eclipse 新建工程axis2webservice 2 axis2-1.6.2-binaxis2-1.6.2webappaxis2-web整个文件夹放到webcontent目录下 3 添加servlet解析所用jar包 ? ? javax.servlet.jsp.jar ? ? servlet-api-2.5.jar 4 WEB-INF下新建service文件夹 5 repositorymodules目录放到WEB-INF目录下 service服务端 示例代码helloworld 1 /** ?* axis2webservice的service端 ?*? ?* @time 上午11:36:53 ?* @author retacn yue ?* @Email zhenhuayue@sina.com ?*/ public class HelloWorld { public OMElement sayHello(OMElement element) { element.build(); element.detach(); return element; } } 2 在service目录中新建与工程同名文件夹HelloWorld? ? 并在该目录下添加service.xml ? 示例代码如下： ? <service name="HelloWorld" > ? ? <parameter name="ServiceClass"? locked="xsd:false">cn.yue.axis2service</parameter> ? ? <operation name="sayHello">? ? ? ? ? <actionMapping>urn:sayHello</actionMapping> ? ? ? ? <messageReceiver? class="org.apache.axis2.receivers.RawXMLINOutMessageReceiver"/> ? ? </operation> </service> 3修改web.xml文件 ? ? <servlet> ? ? ? ? <servlet-name>AxisServlet</servlet-name> ? ? ? ? <servlet-class> ? ? ? ? ? ? org.apache.axis2.transport.http.AxisServlet ? ? ? ? </servlet-class> ? ? ? ? <load-on-startup>1</load-on-startup> ? ? </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>*.jws</url-pattern> ? ? </servlet-mapping> ? ? <servlet-mapping> ? ? ? ? <servlet-name>AxisServlet</servlet-name> ? ? ? ? <url-pattern>/services/*</url-pattern> ? ? </servlet-mapping> ? ?? ? ? <servlet> ? ? ? ? <servlet-name>AxisAdminServlet</servlet-name> ? ? ? ? <servlet-class>org.apache.axis2.transport.http.AxisAdminServlet</servlet- class> ? ? ? ? <load-on-startup>100</load-on-startup> ? ?</servlet> ? ?<servlet-mapping> ? ? ? ?<servlet-name>AxisAdminServlet</servlet-name> ? ? ? ?<url-pattern>/axis2-admin/*</url-pattern> ? ?</servlet-mapping> ? ?? 注： ?org.apache.axis2.transport.http.AxisAdminServlet找不到类 ?直接导原码 4将工程部署到tomcat ?http://localhost:8089/axis2-web/ 客户端 四种不同类型客户端 1 block 阻塞式客户端 ? /** ?* 传统客户端(阻塞式) ?*? ?* @time 下午1:49:52 ?* @author retacn yue ?* @Email zhenhuayue@sina.com ?*/ public class HelloWorldClient { private static EndpointReference endpointReference = new EndpointReference ("http://localhost:8089/services/HelloWorld"); public void sayHello() { Options options = new Options(); options.setAction("urn:sayHello"); options.setTo(endpointReference); ServiceClient sender = null; try { sender = new ServiceClient(); sender.setOptions(options); OMFactory factory = OMAbstractFactory.getOMFactory(); OMNamespace namespace = factory.createOMNamespace ("http://axis2service.yue.cn",""); OMElement method = factory.createOMElement("sayHello",? namespace); OMElement name = factory.createOMElement("name",namespace); name.setText("yue"); method.addChild(name); method.build(); OMElement response = sender.sendReceive(method); System.out.println(response); OMElement element = response.getFirstChildWithName(new? QName("http://axis2service.yue.cn","name")); System.out.println(element.getText()); } catch (AxisFault e) { System.out.println("error"); e.printStackTrace(); } } /** * @param args */ public static void main(String[] args) { HelloWorldClient client = new HelloWorldClient(); client.sayHello(); } } 2 non block 非阻塞式客户端 /** ?*? ?* @time 下午3:27:21 ?* @author retacn yue ?* @Email zhenhuayue@sina.com ?*/ public class HelloWorldNonBlockCB implements AxisCallback { private boolean complete = false; @Override public void onMessage(MessageContext msgContext) { System.out.println(msgContext.getEnvelope().getBody()); OMElement element = msgContext.getEnvelope().getBody ().getFirstElement(); OMElement result = element.getFirstChildWithName(new QName ("http://axis2service.yue.cn","name")); System.out.println(result.getText()); synchronized (this) { this.notify(); } } @Override public void onFault(MessageContext msgContext) { System.out.println(msgContext.getEnvelope().getBody().getFault ().toString()); synchronized (this) { this.notify(); } } @Override public void onError(Exception e) { e.printStackTrace(); synchronized (this) { this.notify(); } } @Override public void onComplete() { this.complete = true; synchronized (this) { this.notify(); } } public boolean isComplete() { return complete; } } /** ?* 非阻塞式 ?*? ?* @time 下午3:37:31 ?* @author retacn yue ?* @Email zhenhuayue@sina.com ?*/ public class HelloWorldClient2 { private static EndpointReference endpointReference = new EndpointReference ("http://localhost:8089/services/HelloWorld"); public void sayHello() { OMFactory factory = OMAbstractFactory.getOMFactory(); OMNamespace namespace = factory.createOMNamespace ("http://axis2service.yue.cn",""); OMElement method = factory.createOMElement("sayHello",namespace); OMElement name = factory.createOMElement("name",namespace); name.setText("zhenhua"); method.addChild(name); method.build(); Options options = new Options(); options.setTo(endpointReference); ServiceClient sender = null; try { HelloWorldNonBlockCB blockCB = new HelloWorldNonBlockCB(); sender = new ServiceClient(); sender.setOptions(options); sender.sendReceiveNonBlocking(method,blockCB); synchronized (blockCB) { try { blockCB.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } } catch (AxisFault e) { e.printStackTrace(); } finally { if (null != sender) { try { sender.cleanup(); } catch (AxisFault e) { e.printStackTrace(); } } } } public static void main(String[] args) { HelloWorldClient2 client2 = new HelloWorldClient2(); client2.sayHello(); } } ? ?? 4 双工非阻塞 ? 在客户端打开一个监听 ? 设置客户端为双工全开 ? 寻址 ? engageModule(Constants.MODULE_ADDRESSING); /** ?* 非阻塞全双工 ?*? ?* @time 下午4:04:55 ?* @author retacn yue ?* @Email zhenhuayue@sina.com ?*/ public class HelloWorldDualNonBlock { private static EndpointReference endpointReference = new EndpointReference ("http://localhost:8089/services/HelloWorld"); public void sayHello() { OMFactory factory = OMAbstractFactory.getOMFactory(); OMNamespace namespace = factory.createOMNamespace ("http://axis2service.yue.cn",namespace); name.setText("yuezhenhua"); method.addChild(name); method.build(); Options options = new Options(); options.setTo(endpointReference); //设置客户端为双工全开 options.setTransportInProtocol(Constants.TRANSPORT_HTTP); //在客户端打开一个监听 options.setUseSeparateListener(true); options.setAction("urn:sayHello"); ServiceClient sender = null; HelloWorldNonBlockCB blockCB = new HelloWorldNonBlockCB(); try { sender = new ServiceClient(); //寻址 sender.engageModule(Constants.MODULE_ADDRESSING); sender.setOptions(options); sender.sendReceiveNonBlocking(method,blockCB); synchronized (blockCB) { try { blockCB.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } } catch (AxisFault e) { e.printStackTrace(); } finally { try { if (null != sender) { sender.cleanup(); } } catch (AxisFault e) { e.printStackTrace(); } } } public static void main(String[] args) { HelloWorldDualNonBlock client = new HelloWorldDualNonBlock(); client.sayHello(); } } axis2-1.6.2-binaxis2-1.6.2conf目录下的axis2.xml文件放到service端的WEB-INF目录下