我们需要ServiceGroupContext保存跨越多个webservice的session信息&＃xff1b;同时需要设置services.xml文件的中service的scope属性为application
一、编写两个webservice&＃xff1a;
LoginServiceApplication.java代码如下:
package com.hoo.service;import org.apache.axis2.context.MessageContext;
import org.apache.axis2.context.ServiceGroupContext;public class LoginServiceApplication {//登陆方法public boolean login(String userName,String password){MessageContext context &＃61; MessageContext.getCurrentMessageContext();//跨越多个WebService管理session第一步是实例化一个ServiceGroupContext对象&＃xff0c;而不是ServiceContextServiceGroupContext ctx &＃61; context.getServiceGroupContext();if("admin".equals(userName)&&"123456".equals(password)){ctx.setProperty("username", userName);ctx.setProperty("password", password);ctx.setProperty("msg","登陆成功");return true;}else{ctx.setProperty("msg", "登陆失败");return false;}}public String getLoginMessage(){MessageContext context &＃61; MessageContext.getCurrentMessageContext();ServiceGroupContext ctx &＃61; context.getServiceGroupContext();String msg &＃61; ctx.getProperty("username")&＃43;","&＃43;ctx.getProperty("msg");return msg;}}
SearchSessionService.java代码如下&＃xff1a;
package com.hoo.service;import org.apache.axis2.context.MessageContext;
import org.apache.axis2.context.ServiceGroupContext;public class SearchSessionService {public String findSessionMessage(String key){MessageContext context &＃61; MessageContext.getCurrentMessageContext();ServiceGroupContext ctx &＃61; context.getServiceGroupContext();if(ctx.getProperty(key)!&＃61;null){return "找到session&＃xff1a;" &＃43; key &＃43; "," &＃43;ctx.getProperty(key);}else{return "没有找到<" &＃43; key &＃43; ">的数据";}}
}
上面两个webservice都用到了ServiceGroupContext的对象。
二、 编写services.xml&＃xff0c;同时发布2个webservice&＃xff0c;并且将scope设为application&＃xff0c;services.xml的内容如下&＃xff1a;
<serviceGroup><service name&＃61;"LoginSessionService" scope&＃61;"application"><description>Web Service Session例子description><parameter name&＃61;"ServiceClass">com.hoo.service.LoginServiceApplicationparameter><messageReceivers><messageReceiver mep&＃61;"http://www.w3.org/2004/08/wsdl/in-out"class&＃61;"org.apache.axis2.rpc.receivers.RPCMessageReceiver" /><messageReceiver mep&＃61;"http://www.w3.org/2004/08/wsdl/in-only"class&＃61;"org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver" />messageReceivers>service><service name&＃61;"SearchSessionService" scope&＃61;"application"><description>Web Service Search Session例子description><parameter name&＃61;"ServiceClass">com.hoo.service.SearchSessionService parameter><messageReceivers><messageReceiver mep&＃61;"http://www.w3.org/2004/08/wsdl/in-out"class&＃61;"org.apache.axis2.rpc.receivers.RPCMessageReceiver" /><messageReceiver mep&＃61;"http://www.w3.org/2004/08/wsdl/in-only"class&＃61;"org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver" />messageReceivers>service>
serviceGroup>
在eclipse里面&＃xff0c;file->new->other->axis2 service archiver->next
选择webservice的class文件存放路径&＃xff0c;一般选到bin文件夹就行了
然后&＃xff0c;next->next->next&＃xff0c;出现选择XML的界面&＃xff1a;
取消勾选“generate the service XML automatically”&＃xff0c;在上面的文件浏览框中选中刚才保存的services.xml文件&＃xff0c;next
选择输出路径和文件名&＃xff08;这里的文件名和webservice的名字没有关系&＃xff0c;webservice的名字在XML文件中定义&＃xff09;&＃xff0c;next->finish,出现创建成功的提示即可
然后利用前面教程中的方法将此AAR文件发不成webservice即可
三、编写客户端代码&＃xff1a;
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;public class LoginSessionServiceClient {public static void main(String[] args) throws AxisFault {String target &＃61; "http://localhost:8080/axis2/services/LoginSessionService";RPCServiceClient client &＃61; new RPCServiceClient();Options options &＃61; client.getOptions();//打开对session的支持options.setManageSession(true);EndpointReference epr &＃61; new EndpointReference(target);options.setTo(epr);QName qname &＃61; new QName("http://service.hoo.com", "login");//指定调用的方法和传递参数数据&＃xff0c;及设置返回值的类型Object[] result &＃61; client.invokeBlocking(qname, new Object[] { "admin", "123456" }, new Class[] { boolean.class });System.out.println(result[0]);qname &＃61; new QName("http://service.hoo.com", "getLoginMessage");result &＃61; client.invokeBlocking(qname, new Object[] { null }, new Class[] { String.class });System.out.println(result[0]);target &＃61; "http://localhost:8080/axis2/services/SearchSessionService";epr &＃61; new EndpointReference(target);options.setTo(epr);qname &＃61; new QName("http://service.hoo.com", "findSessionMessage");result &＃61; client.invokeBlocking(qname, new Object[] { "username" }, new Class[] { String.class });System.out.println(result[0]);qname &＃61; new QName("http://service.hoo.com", "findSessionMessage");result &＃61; client.invokeBlocking(qname, new Object[] { "msg" }, new Class[] { String.class });System.out.println(result[0]);qname &＃61; new QName("http://service.hoo.com", "findSessionMessage");result &＃61; client.invokeBlocking(qname, new Object[] { "password" }, new Class[] { String.class });System.out.println(result[0]);}
}
运行后结果如下&＃xff1a;
true
admin,登陆成功
找到session&＃xff1a;username,admin
找到session&＃xff1a;msg,登陆成功
找到session&＃xff1a;password,123456
如果将services.xml文件
京公网安备 11010802041100号