gitee/cim
1
0
Fork 0
mirror of https://gitee.com/farsunset/cim.git synced 2025-07-26 18:10:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update ClusterSessionManager.java

Browse Source
This commit is contained in:
远方夕阳 2016-09-06 18:09:49 +08:00
parent 2dfbde26bd
commit ccb0875613
1 changed files with 81 additions and 80 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

161
cim_for_netty/cim-server/src/main/java/com/farsunset/cim/session/ClusterSessionManager.java
View File

@ -1,80 +1,81 @@
/** /**
* probject:cim * probject:cim
* @version 2.0 * @version 2.0
* *
* @author 3979434@qq.com * @author 3979434@qq.com
*/ */
package com.farsunset.cim.session; package com.farsunset.cim.session;
import java.util.List; import java.util.List;
import com.farsunset.cim.sdk.server.session.CIMSession; import com.farsunset.cim.sdk.server.session.CIMSession;
import com.farsunset.cim.sdk.server.session.SessionManager; import com.farsunset.cim.sdk.server.session.SessionManager;
import com.farsunset.cim.sdk.server.launcher.CIMNioSocketAcceptor;
/**
* 集群 session管理实现示例， 各位可以自行实现 AbstractSessionManager接口来实现自己的 session管理 /**
*服务器集群时 须要将CIMSession 信息存入数据库或者nosql 等 第三方存储空间中，便于所有服务器都可以访问 * 集群 session管理实现示例， 各位可以自行实现 AbstractSessionManager接口来实现自己的 session管理
*/ *服务器集群时 须要将CIMSession 信息存入数据库或者nosql 等 第三方存储空间中，便于所有服务器都可以访问
public class ClusterSessionManager implements SessionManager{ */
public class ClusterSessionManager implements SessionManager{
public void addSession(String account,CIMSession session) {
public void addSession(String account,CIMSession session) {
/**
* 下面 将session 存入数据库 /**
*/ * 下面 将session 存入数据库
*/
}
}
public CIMSession get(String account) {
public CIMSession get(String account) {
//这里查询数据库
/*CIMSession session = database.getSession(account); //这里查询数据库
session.setIoSession(((NioSocketAcceptor) ContextHolder.getBean("serverAcceptor")).getManagedSessions().get(session.getNid())); /*CIMSession session = database.getSession(account);
return session;*/ session.setIoSession(ContextHolder.getBean(CIMNioSocketAcceptor.class).getManagedSessions().get(session.getNid()));
return null; return session;*/
} return null;
}
@Override
public List<CIMSession> queryAll() { @Override
/*//这里查询数据库 public List<CIMSession> queryAll() {
return database.getSessions();*/ /*//这里查询数据库
return null; return database.getSessions();*/
} return null;
}
@Override
public void remove(String account) { @Override
public void remove(String account) {
//database.removeSession(account);*/
//database.removeSession(account);*/
}
}
@Override
public void setState(String account, int state) { @Override
// TODO Auto-generated method stub public void setState(String account, int state) {
// TODO Auto-generated method stub
}
}
@Override
public void update(CIMSession session) { @Override
public void update(CIMSession session) {
}
}
@Override
public void add(String account, CIMSession session) { @Override
// TODO Auto-generated method stub public void add(String account, CIMSession session) {
// TODO Auto-generated method stub
}
}
}
}