的ID，则此方法返回的值为真。
*/
public boolean equalsMemory(Memory m) {
return (m instanceof SessionWrapper
&& _id != null
&& _id.equals(((SessionWrapper)m)._id));
}
/**
* 得到HttpSession的信息。
*/
public HttpSession getSession() {
return _sess;
}
}
分布式对话服务器的管理(6)
时间:2010-12-26
SessionWrapper类执行了Memory的界面，因此，HttpSession对象的ID可以与远程对话的ID进行比较。
最后需要创建read()、write()和delete()，以对远程对话进行管理。我们向SessionManager类添加三个静态类：
/**
* 从在初始化时建立的Mnemosyne中得到HttpSession信息。
*/
public static HttpSession getSession(String id)
throws RemoteException
{
try {
SessionWrapper result
= (SessionWrapper)_Mnemosyne.read(new SessionWrapper(id),
null);
return result.getSession();
} catch (TransactionException ex) {
// 由于没有处理事物，因此不会有事务意外被放弃。
ex.printStackTrace();
}
return null;
}
/**
* 在初始化时指定的Mnemosyne中保存对话信息。
*/
public static void saveSession(HttpSession sess)
throws RemoteException
{
try {
_Mnemosyne.write(new SessionWrapper(sess), null);
} catch (TransactionException ex) {
file://由于没有处理事物，因此不会有事务意外被放弃。
ex.printStackTrace();
}
}
/**
* 从在初始化时指定的Mnemosyne中删除一个对话。
*/
public static void removeSession(String id)
throws RemoteException
{
try {
_Mnemosyne.take(new SessionWrapper(id), null);
} catch (TransactionException ex) {
// /由于没有处理事物，因此不会有事务意外被放弃。
ex.printStackTrace();
}
}
在servlet中，可以以如下方式管理对话：
public void init(ServletConfig conf) throws ServletException {
// 调用一个方法得到指示对话服务器位置的RMI URL清单
// 例如：//server1.foo.com/MnemosyneImpl, //server2.foo.com/MnemosyneImpl，等
String[] urls = getURLs(conf); // Method to get the URLs from properties for the session servers
SessionManager.initializeMnemosyne(urls)
}
public void doGet(HttpServletRequest req, HttpServletResponse rsp) throws IOException {
file:// 得到存贮在cookie中的对话，仅仅是为了得到其ID。
HttpSession baseSess = req.getSession()
file://根据得到的ID，从Mnemosyne中得到真正的对话
HttpSession realSess = SessionManager.getSession(base.getId());
SessionManager.saveSession(realSess);
}
结论
尽管这篇文章讨论了一个分布式对话管理的例子，但我们可以将这一技术用于管理必须容忍任一节点出错的分布式内存管理系统中。Mnemosyne还可以用在成员不断加入和离开的P2P应用中。通过使用Mnemosyne，任何一个成员都可以与系统进行快速同步，而无需要求为保持系统有效而必须保证某一结点不出故障。 |
