ExtJS 3.2 聊天室程序(类QQ群)

package com.javaeye.yourgame.action; import java.text.ParseException; import java.util.ArrayList; import java.util.Collection; import java.util.Date; import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.TreeMap; import javax.xml.registry.infomodel.User; import org.directwebremoting.ScriptSession; import org.directwebremoting.WebContext; import org.directwebremoting.WebContextFactory; import org.directwebremoting.proxy.ScriptProxy; import org.hibernate.criterion.DetachedCriteria; import com.javaeye.yourgame.core.BaseAction; import com.javaeye.yourgame.core.Page; import com.javaeye.yourgame.po.Message; import com.javaeye.yourgame.service.IMessageService; @SuppressWarnings("serial") public class MessageAction extends BaseAction { public static Map<String, TreeNode> onlineUsers = new TreeMap<String, TreeNode>(); private Map<String, Object> infos = new HashMap<String, Object>(); public static Map<Long, Message> messages = new TreeMap<Long, Message>(); private Message msg; private Page page; private IMessageService messageService; private boolean success; private User user; /** * 发送消息，在这个方法里面当聊天记录等于5条的时候自动保存到数据库，然后清空记录 * */ @SuppressWarnings("unchecked") public String addMessage(String text, String sender) throws Exception { if (text != null) { msg = new Message(); msg.setDate(new Date()); msg.setSender(sender); msg.setText(text); messages.put(msg.getId(), msg); if (messages.size() >= 5) { List list = new ArrayList(); list.addAll(messages.values()); messageService.saveMessages(list); messages.clear(); } WebContext wctx = WebContextFactory.get(); String currentPage = wctx.getCurrentPage(); Collection<ScriptSession> sessions = wctx.getScriptSessionsByPage(currentPage); ScriptProxy s = new ScriptProxy(sessions); s.addFunctionCall("receiveMessages", msg); } return NONE; } public String findChatHistory() throws ParseException { DetachedCriteria dc = DetachedCriteria.forClass(Message.class); page.setResult(dc); page = messageService.findByCriteria(page); return SUCCESS; } public String addUser() { TreeNode tn = new TreeNode(); tn.setId(java.util.UUID.randomUUID().toString()); tn.setText(getRequest().getParameter("userName")); onlineUsers.put(tn.getId(), tn); // 用户下线,则从map中移除 this.setSuccess(true); return SUCCESS; } public String getOnlineUsers() { this.jsonString = "["; for (Iterator it = onlineUsers.entrySet().iterator(); it.hasNext();) { Map.Entry en = (Map.Entry) it.next(); TreeNode tn = (TreeNode) en.getValue(); this.jsonString += "{id:'" + tn.getId() + "'"; this.jsonString += ",leaf:true,iconCls:'icon-user',"; this.jsonString += "text:'" + tn.getText() + "'}"; if (it.hasNext()) { this.jsonString += ","; } } this.jsonString += "]"; return SUCCESS; } public boolean isSuccess() { return success; } public User getUser() { return user; } public void setUser(User user) { this.user = user; } public void setSuccess(boolean success) { this.success = success; } public Page getPage() { return page; } public void setPage(Page page) { this.page = page; } public Map<String, Object> getInfos() { return infos; } public void setInfos(Map<String, Object> infos) { this.infos = infos; } public void setMessageService(IMessageService messageService) { this.messageService = messageService; } public static class TreeNode { public String id; public String text; public String getId() { return this.id; } public void setId(String id) { this.id = id; } public String getText() { return this.text; } public void setText(String text) { this.text = text; } } }