conference spark默認(rèn)的是臨時(shí)的，就是用戶點(diǎn)擊后才能加入到群組里面，關(guān)閉后從群組里退出。
要修改spark的這個(gè)功能，提供以下思路（原創(chuàng)）
一、 spark用戶在登陸的時(shí)候 ，在openfire 進(jìn)行SessionEventListener，通過(guò)插件的形式進(jìn)行監(jiān)聽(tīng)，在sessionCreated的時(shí)候進(jìn)行，登陸用戶的joinRoom ，從數(shù)據(jù)庫(kù)取出他所在的groupname 然后進(jìn)行joinroom。
作法; 在openfire寫(xiě)一個(gè)插件，插件主要代碼如下：
private JID serverAddress;
private JoinGroupsSessionEventListener listener = new JoinGroupsSessionEventListener();
private XMPPServer server;
private MultiUserChatServiceImpl mucService;
private class JoinGroupsSessionEventListener implements SessionEventListener {
public void sessionCreated(Session session) {
System.out.println("a client connect!");
JID userJid=session.getAddress();
JoinGroups(userJid);
}public void sessionDestroyed(Session session) {
//ignore
JID userJid=session.getAddress();
LeaveGroups(userJid);
}public void resourceBound(Session session) {
// Do nothing.
}public void anonymousSessionCreated(Session session) {
//ignore
}public void anonymousSessionDestroyed(Session session) {
//ignore
}
}
@Override
public void initializePlugin(PluginManager manager, File pluginDirectory) {
// TODO Auto-generated method stub
server=XMPPServer.getInstance();
//mucService=server.getMultiUserChatManager().getMultiUserChatService(ser)
serverAddress = new JID(XMPPServer.getInstance().getServerInfo().getXMPPDomain());
SessionEventDispatcher.addListener(listener);
System.out.println("join groups plugin is running!");
}public void LeaveGroups(JID userJid) {
System.out.println(userJid.toBareJID()+" is leaving the room!");
List<String> roomIds=MUCPersistenceManager.getRoomIDsByUserJid(userJid.toBareJID());
for(String roomId:roomIds)
{
System.out.println("room id:"+roomId);
org.jivesoftware.openfire.muc.spi.RoomInfo rminf=MUCPersistenceManager.getRoomInfoByRoomId(roomId);
String serviceID=rminf.getServiceID();
mucService=(MultiUserChatServiceImpl)server.getMultiUserChatManager().getMultiUserChatService(Long.parseLong(rminf.getServiceID()));
System.out.println("service id:"+serviceID);
String roomName=rminf.getName();
System.out.println("room name:"+roomName);
LocalMUCRoom room=(LocalMUCRoom)mucService.getChatRoom(roomName);
//從數(shù)據(jù)庫(kù)中查詢他的姓名作為昵稱（得自己實(shí)現(xiàn)）
String nickname = MUCPersistenceManager.getNickNameByJId(userJid.toBareJID());
if(nickname == null)
{
if(userJid.getNode() != null)
{
nickname = userJid.getNode();
}
else
{
nickname = userJid.getResource();
}
}
// The user leaves the room 用戶離開(kāi)群
try {
if(!room.hasOccupant(nickname))
return;
LocalMUCRole role=(LocalMUCRole) room.getOccupant(nickname);
room.leaveRoom(role);
System.out.println("leaved!");
} catch (UserNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}public void JoinGroups(JID userJid) {
System.out.println(userJid.toBareJID()+" is joining the room!");
try{
List<String> roomIds=MUCPersistenceManager.getRoomIDsByUserJid(userJid.toBareJID());
for(String roomId:roomIds)
{
System.out.println("room id:"+roomId);
org.jivesoftware.openfire.muc.spi.RoomInfo rminf=MUCPersistenceManager.getRoomInfoByRoomId(roomId);
String serviceID=rminf.getServiceID();
mucService=(MultiUserChatServiceImpl)server.getMultiUserChatManager().getMultiUserChatService(Long.parseLong(rminf.getServiceID()));
System.out.println("service id:"+serviceID);
String roomName=rminf.getName();
System.out.println("room name:"+roomName);
LocalMUCRoom room=(LocalMUCRoom)mucService.getChatRoom(roomName);
//從數(shù)據(jù)庫(kù)中查詢他的姓名作為昵稱（得自己實(shí)現(xiàn)）
String nickname = MUCPersistenceManager.getNickNameByJId(userJid.toBareJID());
if(nickname == null)
{
if(userJid.getNode() != null)
{
nickname = userJid.getNode();
}
else
{
nickname = userJid.getResource();
}
}
HistoryRequest historyRequest = null;
String password = null;
//構(gòu)建成員進(jìn)入群的Presence
Presence presence = new Presence();
presence.setTo(room.getJID().toBareJID() + "/" + nickname);
presence.setFrom(userJid);
PacketExtension extension = new PacketExtension("x", " presence.addExtension(extension);
PacketRouter pr=server.getPacketRouter();
LocalMUCUser user=new LocalMUCUser(mucService, pr, userJid);
// The user joins the room 用戶進(jìn)入群
try {
LocalMUCRole role = room.joinRoom(nickname,
password,
historyRequest,
user,
presence);
System.out.println("joined!");
user.addRole(roomName, role);
} catch (UnauthorizedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (UserAlreadyExistsException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (RoomLockedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ForbiddenException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (RegistrationRequiredException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ConflictException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ServiceUnavailableException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (NotAcceptableException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}catch(Exception e)
{
e.printStackTrace();
}
}@Override
public void destroyPlugin() {
// TODO Auto-generated method stub
SessionEventDispatcher.removeListener(listener);
listener = null;
serverAddress = null;
server=null;
mucService=null;
}
在 MUCPersistenceManager 這個(gè)類(lèi)里 添加如下方法 ，用于上面的使用
// 石堅(jiān) 20120609
public static List<String> getRoomIDsByUserJid(String userJid) {
Connection con = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
List<String> roomIDs=new ArrayList<String>();
try {
con = DbConnectionManager.getConnection();
pstmt = con.prepareStatement(LOAD_ROOMIDS_BY_JID);
pstmt.setString(1, userJid);
rs = pstmt.executeQuery();
while(rs.next()) {
String roomId = rs.getString("roomID");
roomIDs.add(roomId);
}
}
catch (SQLException sqle) {
Log.error(sqle.getMessage(), sqle);
}
finally {
DbConnectionManager.closeConnection(rs, pstmt, con);
}
return roomIDs;
}
public static String getRoomNameByRoomId(String roomId) {
Connection con = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String roomName=null;
try {
con = DbConnectionManager.getConnection();
pstmt = con.prepareStatement(LOAD_ROOMNAME_BY_ROOMID);
pstmt.setString(1, roomId);
rs = pstmt.executeQuery();
if(rs.next()) {
roomName= rs.getString("name");
}
}
catch (SQLException sqle) {
Log.error(sqle.getMessage(), sqle);
}
finally {
DbConnectionManager.closeConnection(rs, pstmt, con);
}
return roomName;
}
public static String getServiceIdByRoomId(String roomId) {
Connection con = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String serviceID=null;
try {
con = DbConnectionManager.getConnection();
pstmt = con.prepareStatement(LOAD_SERVICEID_BY_ROOMID);
pstmt.setString(1, roomId);
rs = pstmt.executeQuery();
if(rs.next()) {
serviceID= rs.getString("serviceID");
}
}
catch (SQLException sqle) {
Log.error(sqle.getMessage(), sqle);
}
finally {
DbConnectionManager.closeConnection(rs, pstmt, con);
}
return serviceID;
}
public static String getNickNameByJId(String userJid) {
Connection con = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String nick=null;
try {
con = DbConnectionManager.getConnection();
pstmt = con.prepareStatement(LOAD_NICKNAME_BY_JID);
pstmt.setString(1, userJid);
rs = pstmt.executeQuery();
if(rs.next()) {
nick= rs.getString("nickname");
}
}
catch (SQLException sqle) {
Log.error(sqle.getMessage(), sqle);
}
finally {
DbConnectionManager.closeConnection(rs, pstmt, con);
}
return nick;
}
public static RoomInfo getRoomInfoByRoomId(String roomId) {
Connection con = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
RoomInfo rminf=null;
try {
con = DbConnectionManager.getConnection();
pstmt = con.prepareStatement(LOAD_ROOMINFO_BY_ROOMID);
pstmt.setString(1, roomId);
rs = pstmt.executeQuery();
if(rs.next()) {
String serviceID= rs.getString("serviceID");
String name= rs.getString("name");
String naturalName= rs.getString("naturalName");
String description=rs.getString("description");
rminf=new RoomInfo(serviceID, name, naturalName, description);
}
}
catch (SQLException sqle) {
Log.error(sqle.getMessage(), sqle);
}
finally {
DbConnectionManager.closeConnection(rs, pstmt, con);
}
return rminf;
}
public static List<String> getMembersByRoomId(String roomId) {
// TODO Auto-generated method stub
List<String> members=new ArrayList<String>();
Connection con = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try {
con = DbConnectionManager.getConnection();
pstmt = con.prepareStatement(LOAD_JIDS_BY_ROOMID);
pstmt.setString(1, roomId);
rs = pstmt.executeQuery();
while(rs.next()) {
String jid= rs.getString("jid");
members.add(jid);
}
}
catch (SQLException sqle) {
Log.error(sqle.getMessage(), sqle);
}
finally {
DbConnectionManager.closeConnection(rs, pstmt, con);
}
return members;
}
// end
二、用戶登陸了群，在進(jìn)行打開(kāi)chatroom的時(shí)候，spark默認(rèn)的是顯示的在線的用戶，要進(jìn)行修改 。增加一個(gè)可以發(fā)送離線用戶列表的方法：
private void sendOfflineUserList(LocalMUCRole joinRole){
// TODO Auto-generated method stub
String roomId=""+getID();
List<String> members=MUCPersistenceManager.getMembersByRoomId(roomId);
System.out.println("member count:"+members.size());
for(String jid:members)
{
JID userJid=new JID(jid);
System.out.println("jid:"+userJid.toBareJID());
MUCRole role=getOccupantByFullJID(userJid);
if(null==role) {
// TODO Auto-generated catch block
try{
System.out.println("member not found!");
String nickname = MUCPersistenceManager.getNickNameByJId(userJid.toBareJID());
if(nickname == null)
{
if(userJid.getNode() != null)
{
nickname = userJid.getNode();
}
else
{
nickname = userJid.getResource();
}
}
//構(gòu)建presence
Presence presence = new Presence();
String sjid=getJID().toBareJID() + "/" + nickname;
presence.setTo(sjid);
presence.setFrom(sjid);
PacketExtension extension = new PacketExtension("x", " presence.addExtension(extension);
Element frag=presence.getChildElement("x"," Element item=frag.addElement("item");
item.addAttribute("jid",userJid.toBareJID()+"/"+(userJid.getResource()==null?nickname:userJid.getResource()));
//item.addAttribute("affilication",userJid.toFullJID());
System.out.println("occupantPresence ：n"+presence.toXML()+"nn");
joinRole.send(presence);//發(fā)送presence
}catch(Exception e)
{
e.printStackTrace();
}
}
}
}
此方法要添加在Localmucroom 的sendinitialpresences 方法的末尾就可以。
//發(fā)送離線成員列表給新成員
sendOfflineUserList(joinRole);
第三步： 離線用戶發(fā)送到了 客戶端 但是顯示是有問(wèn)題，所以 進(jìn)行排序，讓在線的在前面
修改org.jivesoftware.spark.ui.conferences; 的 GroupChatParticipantList類(lèi)。修改如下
public int compare(JLabel item1, JLabel item2) {
int result=compareByPresence(item1.getIcon().toString(), item2.getIcon().toString());
if(0==result)
{
if (_localPreferences.isShowingRoleIcons()) {
return compareWithRole(item1, item2);
} else {
return compareWithoutRole(item1.getText(), item2.getText());
}
}
return result;
}
//通過(guò)在線狀態(tài)比較兩個(gè)列表項(xiàng)
//在線<離線 若狀態(tài)相同則按默認(rèn)排序規(guī)則進(jìn)行排序 返回 0 ，1 ，-1
private int compareByPresence(String s1, String s2) {
Icon iconAvaliable=SparkRes.getImageIcon(SparkRes.GREEN_BALL);
String iconStr=iconAvaliable.toString();
return s1.equals(s2)?0:s1.equals(iconStr)?-1:1;
}
private int compareWithoutRole(String s1, String s2) {
return (s1.toLowerCase().compareTo(s2.toLowerCase()));
}
/**
* Comparaes 2 items by their Role and Affiliation<br>
* affiliation > role<br>
* owner > admin > moderator > member > participant > visitor
* @param item1
* @param item2
* @return -1, 0 or 1
*/
private int compareWithRole(JLabel item1, JLabel item2) {
int user1 = 100;
int user2 = 100;
try {
// append Room-JID to UserLabel
String jid1 = chat.getRoom() + "/" + item1.getText();
String jid2 = chat.getRoom() + "/" + item2.getText();
user1 = getCompareValue(jid1);
user2 = getCompareValue(jid2);
} catch (Exception e) {
// Sometimes theres no Occupant with that jid, dunno why
}
int result = 0;
if (user1 == user2) {
result = compareWithoutRole(item1.getText(), item2.getText());
} else {
// a=owner,b=admin, m=moderator, n=member , p=participant, v=visitor
// a < b < m < n < p < v
if (user1 < user2)
result = -1;
if (user1 > user2)
result = 1;
}
return result;
}
聯(lián)系客服
