org.jim.server.helper.redis

Class RedisMessageHelper

java.lang.Object

org.jim.server.helper.redis.RedisMessageHelper

All Implemented Interfaces:

Const, IMesssageHelper

public class RedisMessageHelper
extends Object
implements IMesssageHelper, Const

Redis获取持久化+同步消息助手;

Author:

WChao

Field Summary

Fields inherited from interface org.jim.common.Const

authkey, CHANNEL, CHARSET, CHAT, CHAT_QUEUE, CONVERTOR, FRIENDS, GROUP, HTTP_REQUEST, INFO, JIM, OFF, OFFLINE, ON, ONLINE, PACKET, PUSH, SERVER_PORT, STATUS, STORE, TERMINAL, TO, USER

Constructor Summary

Constructors

Constructor and Description
RedisMessageHelper()

Method Summary

Modifier and Type	Method and Description
void	addGroupUser(String userid, String group_id) 添加群组成员
List<Group>	getAllFriendUsers(String user_id, Integer type) 获取好友分组所有成员信息
List<Group>	getAllGroupUsers(String user_id, Integer type) 获取群组所有成员信息（在线+离线)
ImBindListener	getBindListener() 获取im群组、人员绑定监听器;
UserMessageData	getFriendHistoryMessage(String userid, String from_userid, Double beginTime, Double endTime, Integer offset, Integer count) 获取与指定用户历史消息;
UserMessageData	getFriendsOfflineMessage(String userid) 获取与所有用户离线消息;
UserMessageData	getFriendsOfflineMessage(String userid, String from_userid) 获取与指定用户离线消息;
Group	getFriendUsers(String user_id, String friend_group_id, Integer type) 获取好友分组所有成员信息
UserMessageData	getGroupHistoryMessage(String userid, String groupid, Double beginTime, Double endTime, Integer offset, Integer count) 获取与指定群组历史消息;
UserMessageData	getGroupOfflineMessage(String userid, String groupid) 获取用户指定群组离线消息;
List<String>	getGroups(String user_id) 获取用户拥有的群组;
List<String>	getGroupUsers(String group_id) 获取群组所有成员;
Group	getGroupUsers(String group_id, Integer type) 获取群组所有成员信息
User	getUserByType(String userid, Integer type) 根据在线类型获取用户信息;
void	initUserStatus(User user) 初始化用户在线状态;
boolean	isOnline(String userid) 判断用户是否在线
UserMessageData	putFriendsHistoryMessage(UserMessageData userMessage, List<ChatBody> messages, String friendId) 放入用户好友历史消息;
UserMessageData	putFriendsMessage(UserMessageData userMessage, List<ChatBody> messages) 放入用户好友消息;
UserMessageData	putGroupMessage(UserMessageData userMessage, List<ChatBody> messages) 放入用户群组消息;
void	removeGroupUser(String userid, String group_id) 移除群组用户
void	writeMessage(String timelineTable, String timelineId, ChatBody chatBody) 消息持久化写入

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RedisMessageHelper

public RedisMessageHelper()

Method Detail

getBindListener

public ImBindListener getBindListener()

Description copied from interface: IMesssageHelper

获取im群组、人员绑定监听器;

Specified by:

getBindListener in interface IMesssageHelper

Returns:

isOnline

public boolean isOnline(String userid)

Description copied from interface: IMesssageHelper

判断用户是否在线

Specified by:

isOnline in interface IMesssageHelper

Returns:

getGroupUsers

public List<String> getGroupUsers(String group_id)

Description copied from interface: IMesssageHelper

获取群组所有成员;

Specified by:

getGroupUsers in interface IMesssageHelper

Returns:

writeMessage

public void writeMessage(String timelineTable,
                         String timelineId,
                         ChatBody chatBody)

Description copied from interface: IMesssageHelper

消息持久化写入

Specified by:

writeMessage in interface IMesssageHelper

addGroupUser

public void addGroupUser(String userid,
                         String group_id)

Description copied from interface: IMesssageHelper

添加群组成员

Specified by:

addGroupUser in interface IMesssageHelper

removeGroupUser

public void removeGroupUser(String userid,
                            String group_id)

Description copied from interface: IMesssageHelper

移除群组用户

Specified by:

removeGroupUser in interface IMesssageHelper

getFriendsOfflineMessage

public UserMessageData getFriendsOfflineMessage(String userid,
                                                String from_userid)

Description copied from interface: IMesssageHelper

获取与指定用户离线消息;

Specified by:

getFriendsOfflineMessage in interface IMesssageHelper

Returns:

getFriendsOfflineMessage

public UserMessageData getFriendsOfflineMessage(String userid)

Description copied from interface: IMesssageHelper

获取与所有用户离线消息;

Specified by:

getFriendsOfflineMessage in interface IMesssageHelper

Returns:

getGroupOfflineMessage

public UserMessageData getGroupOfflineMessage(String userid,
                                              String groupid)

Description copied from interface: IMesssageHelper

获取用户指定群组离线消息;

Specified by:

getGroupOfflineMessage in interface IMesssageHelper

Returns:

getFriendHistoryMessage

public UserMessageData getFriendHistoryMessage(String userid,
                                               String from_userid,
                                               Double beginTime,
                                               Double endTime,
                                               Integer offset,
                                               Integer count)

Description copied from interface: IMesssageHelper

获取与指定用户历史消息;

Specified by:

getFriendHistoryMessage in interface IMesssageHelper

beginTime - 消息区间开始时间

endTime - 消息区间结束时间

offset - 分页偏移量

count - 数量

Returns:

getGroupHistoryMessage

public UserMessageData getGroupHistoryMessage(String userid,
                                              String groupid,
                                              Double beginTime,
                                              Double endTime,
                                              Integer offset,
                                              Integer count)

Description copied from interface: IMesssageHelper

获取与指定群组历史消息;

Specified by:

getGroupHistoryMessage in interface IMesssageHelper

beginTime - 消息区间开始时间

endTime - 消息区间结束时间

offset - 分页偏移量

count - 数量

Returns:

putGroupMessage

public UserMessageData putGroupMessage(UserMessageData userMessage,
                                       List<ChatBody> messages)

放入用户群组消息;

Parameters:

userMessage -

messages -

putFriendsMessage

public UserMessageData putFriendsMessage(UserMessageData userMessage,
                                         List<ChatBody> messages)

放入用户好友消息;

Parameters:

userMessage -

messages -

putFriendsHistoryMessage

public UserMessageData putFriendsHistoryMessage(UserMessageData userMessage,
                                                List<ChatBody> messages,
                                                String friendId)

放入用户好友历史消息;

Parameters:

userMessage -

messages -

getGroupUsers

public Group getGroupUsers(String group_id,
                           Integer type)

获取群组所有成员信息

Specified by:

getGroupUsers in interface IMesssageHelper

Parameters:

group_id -

type(0:所有在线用户,1:所有离线用户,2:所有用户[在线+离线]) -

Returns:

getUserByType

public User getUserByType(String userid,
                          Integer type)

根据在线类型获取用户信息;

Specified by:

getUserByType in interface IMesssageHelper

Parameters:

userid -

type -

Returns:

getFriendUsers

public Group getFriendUsers(String user_id,
                            String friend_group_id,
                            Integer type)

获取好友分组所有成员信息

Specified by:

getFriendUsers in interface IMesssageHelper

Parameters:

friend_group_id -

type(0:所有在线用户,1:所有离线用户,2:所有用户[在线+离线]) -

Returns:

initUserStatus

public void initUserStatus(User user)

初始化用户在线状态;

Parameters:

user -

getAllFriendUsers

public List<Group> getAllFriendUsers(String user_id,
                                     Integer type)

获取好友分组所有成员信息

Specified by:

getAllFriendUsers in interface IMesssageHelper

Parameters:

user_id -

type(0:所有在线用户,1:所有离线用户,2:所有用户[在线+离线]) -

Returns:

getAllGroupUsers

public List<Group> getAllGroupUsers(String user_id,
                                    Integer type)

获取群组所有成员信息（在线+离线)

Specified by:

getAllGroupUsers in interface IMesssageHelper

Parameters:

user_id -

type(0:所有在线用户,1:所有离线用户,2:所有用户[在线+离线]) -

Returns:

getGroups

public List<String> getGroups(String user_id)

获取用户拥有的群组;

Specified by:

getGroups in interface IMesssageHelper

Parameters:

user_id -

Returns: