package com.fastbee.base.service;
|
|
|
import com.fastbee.base.session.Session;
|
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
|
/**
|
* 服务会话存储接口
|
* @author gsb
|
* @date 2022/10/14 14:16
|
*/
|
public interface ISessionStore {
|
/**
|
* session 会话存储
|
*
|
* @param clientId: 客户端标识
|
* @param session: session会话
|
|
*/
|
void storeSession(String clientId, Session session);
|
|
/**
|
* 根据客户端标识获取相应会话
|
*
|
* @param clientId: 客户端标识
|
*/
|
Session getSession(String clientId);
|
|
/**
|
* 清除历史会话状态
|
*
|
* @param clientId: 客户端标识
|
*/
|
void cleanSession(String clientId);
|
|
/**
|
* 根据客户端标识查看是否存在该会话
|
*
|
* @param clientId:
|
*/
|
boolean containsKey(String clientId);
|
|
/**
|
* 获取集合
|
* @return MAP
|
*/
|
ConcurrentHashMap<String, Session> getSessionMap();
|
|
/**
|
* map分页（从1开始）
|
*
|
* @param sourceMap 分页数据
|
* @param pageSize 页面大小
|
* @param currentPage 当前页面
|
*/
|
public Map<String, Session> listPage(Map<String, Session> sourceMap, int pageSize, int currentPage);
|
}
|
