跨多个WebService管理Session

renxiao2003 发表于 2011-12-21 08:44

<DIV>
<A class=postTitle2 id=ctl02_TitleUrl href="http://www.cnblogs.com/hoojo/archive/2011/03/16/1985704.html">六、跨多个WebService管理Session</A>
<DIV id=cnblogs_post_body>
当多个WebService的时候，我们要管理它的Session。这个时候我们得依靠ServiceGroupContext保存session信息；然后在发布WebService的时候，services.xml文件的的service表情的scope就不再说request或是transportsession了，而是application；最后同样要开启对session的管理，即options.setManageSession(true);
1、首先多个WebService的session管理的代码如下：
<DIV class=cnblogs_code><IMG id=Code_Closed_Image_963053 style="DISPLAY: none" .click="this.style.display='none'; document.getElementById('Code_Closed_Text_963053').style.display='none'; document.getElementById('Code_Open_Image_963053').style.display='inline'; document.getElementById('Code_Open_Text_963053').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ContractedBlock.gif" width=11 align=top><IMG id=Code_Open_Image_963053 style="DISPLAY: inline" .click="this.style.display='none'; document.getElementById('Code_Open_Text_963053').style.display='none'; getElementById('Code_Closed_Image_963053').style.display='inline'; getElementById('Code_Closed_Text_963053').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ExpandedBlockStart.gif" width=11 align=top>代码package com.hoo.service;

import org.apache.axis2.context.MessageContext;
import org.apache.axis2.context.ServiceGroupContext;

/**
* function:管理多个会话Session信息
* @author hoojo
* @createDate 2011-3-9 下午05:11:07
* @file LoginSessionService.java
* @package com.hoo.service
* @project Axis2WebService
* @blog http://blog.csdn.net/IBM_hoojo
* @email hoojo_@126.com
* @version 1.0
*/
public class LoginSessionService {
public boolean login(String userName, String password) {
MessageContext context = MessageContext.getCurrentMessageContext();
ServiceGroupContext ctx = context.getServiceGroupContext();
if ("admin".equals(userName) && "123456".equals(password)) {
ctx.setProperty("userName", userName);
ctx.setProperty("password", password);
ctx.setProperty("msg", "登陆成功");
return true;
}
ctx.setProperty("msg", "登陆失败");
return false;
}

public String getLoginMessage() {
MessageContext context = MessageContext.getCurrentMessageContext();
ServiceGroupContext ctx = context.getServiceGroupContext();
return ctx.getProperty("userName") + "#" + ctx.getProperty("msg");
}
}</DIV> 

和上面的Session一样的操作，只不过是用ServiceGroupContext上下文来存取session信息
另外还需要用一个Service来查询session的信息，SearchService的代码如下：

<DIV class=cnblogs_code><IMG id=Code_Closed_Image_275271 .click="this.style.display='none'; document.getElementById('Code_Closed_Text_275271').style.display='none'; document.getElementById('Code_Open_Image_275271').style.display='inline'; document.getElementById('Code_Open_Text_275271').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ContractedBlock.gif" width=11 align=top><IMG id=Code_Open_Image_275271 style="DISPLAY: none" .click="this.style.display='none'; document.getElementById('Code_Open_Text_275271').style.display='none'; getElementById('Code_Closed_Image_275271').style.display='inline'; getElementById('Code_Closed_Text_275271').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ExpandedBlockStart.gif" width=11 align=top>代码package com.hoo.service;

import org.apache.axis2.context.MessageContext;
import org.apache.axis2.context.ServiceGroupContext;

/**
* function:查找多服务Session会话中的消息
* @author hoojo
* @createDate 2011-3-9 下午05:22:39
* @file SearchSessionServcie.java
* @package com.hoo.service
* @project Axis2WebService
* @blog http://blog.csdn.net/IBM_hoojo
* @email hoojo_@126.com
* @version 1.0
*/
public class SearchSessionServcie {
public String findSessionMessage(String key) {
 MessageContext mc = MessageContext.getCurrentMessageContext();
 ServiceGroupContext ctx =mc.getServiceGroupContext();
 if (ctx.getProperty(key) != null) {
 return "找到的数据<" + key + ", " + ctx.getProperty(key) + ">";
 } else {
 return "没有找到<" + key + ">的数据";
 }
}
}</DIV> 
2、编写services.xml来发布这2个服务，还以前不一样的。这一次是用一个services.xml文件配置2个service，同时发布2个服务。Xml代码如下：
<DIV class=cnblogs_code><IMG id=Code_Closed_Image_816457 .click="this.style.display='none'; document.getElementById('Code_Closed_Text_816457').style.display='none'; document.getElementById('Code_Open_Image_816457').style.display='inline'; document.getElementById('Code_Open_Text_816457').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ContractedBlock.gif" width=11 align=top><IMG id=Code_Open_Image_816457 style="DISPLAY: none" .click="this.style.display='none'; document.getElementById('Code_Open_Text_816457').style.display='none'; getElementById('Code_Closed_Image_816457').style.display='inline'; getElementById('Code_Closed_Text_816457').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ExpandedBlockStart.gif" width=11 align=top>代码<serviceGroup>
<service name="LoginSessionService" scope="application">
<description>
Web Service Session例子
</description>
<parameter name="ServiceClass">
com.hoo.service.LoginSessionService
</parameter>
<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>

<service name="SearchSessionService" scope="application">
<description>
Web Service Search Session例子
</description>
<parameter name="ServiceClass">
com.hoo.service.SearchSessionServcie
</parameter>
<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></DIV> 

3、发布完成后，可以通过<a href="http://localhost:8080/axis2/services/listServices" target="_blank">http://localhost:8080/axis2/services/listServices</A>查看发布的WebService服务，编写客户端的测试代码，code如下：
<DIV class=cnblogs_code><IMG id=Code_Closed_Image_168966 .click="this.style.display='none'; document.getElementById('Code_Closed_Text_168966').style.display='none'; document.getElementById('Code_Open_Image_168966').style.display='inline'; document.getElementById('Code_Open_Text_168966').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ContractedBlock.gif" width=11 align=top><IMG id=Code_Open_Image_168966 style="DISPLAY: none" .click="this.style.display='none'; document.getElementById('Code_Open_Text_168966').style.display='none'; getElementById('Code_Closed_Image_168966').style.display='inline'; getElementById('Code_Closed_Text_168966').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ExpandedBlockStart.gif" width=11 align=top>代码package com.hoo.service;

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;

/**
* function:多会话Session管理，WebService客户端请求代码
* @author hoojo
* @createDate 2011-3-9 下午05:17:15
* @file LoginSessionServiceClient.java
* @package com.hoo.service
* @project Axis2WebService
* @blog http://blog.csdn.net/IBM_hoojo
* @email hoojo_@126.com
* @version 1.0
*/
public class LoginSessionServiceClient {

public static void main(String[] args) throws AxisFault {
String target = "http://localhost:8080/axis2/services/LoginSessionService";
RPCServiceClient client = new RPCServiceClient();
Options options = client.getOptions();
options.setManageSession(true);

EndpointReference epr = new EndpointReference(target);
options.setTo(epr);

QName qname = new QName("http://service.hoo.com", "login");
//指定调用的方法和传递参数数据，及设置返回值的类型
Object[] result = client.invokeBlocking(qname, new Object[] { "admin", "123456" }, new Class[] { boolean.class });
System.out.println(result);

qname = new QName("http://service.hoo.com", "getLoginMessage");
result = client.invokeBlocking(qname, new Object[] { null }, new Class[] { String.class });
System.out.println(result);

target = "http://localhost:8080/axis2/services/SearchSessionService";
epr = new EndpointReference(target);
options.setTo(epr);

qname = new QName("http://service.hoo.com", "findSessionMessage");
result = client.invokeBlocking(qname, new Object[] { "userName" }, new Class[] { String.class });
System.out.println(result);
qname = new QName("http://service.hoo.com", "findSessionMessage");
result = client.invokeBlocking(qname, new Object[] { "msg" }, new Class[] { String.class });
System.out.println(result);

qname = new QName("http://service.hoo.com", "findSessionMessage");
result = client.invokeBlocking(qname, new Object[] { "password" }, new Class[] { String.class });
System.out.println(result);
}
}</DIV> 

运行后结果如下：
true
admin#登陆成功
找到的数据<userName, admin>
找到的数据<msg, 登陆成功>
找到的数据<password, 123456>
4、如果将services.xml文件<service name="SearchSessionService" scope="application">的内容改成scope=transportsession，看看什么情况。是不是找不到session中的内容。</DIV></DIV>

页: [1]

Chinaunix's Archiver

跨多个WebService管理Session