API_CHM\DWR实例.rar

package cn.netjava.dwr; import java.io.PrintWriter; import java.util.Collection; import java.util.LinkedList; import java.util.List; import org.directwebremoting.ScriptSession; import org.directwebremoting.WebContext; import org.directwebremoting.WebContextFactory; import org.directwebremoting.proxy.dwr.Util; public class ChatWithSamePage { private LinkedList messages = new LinkedList(); public void sendWebMessage(String text){ System.out.println("text===================================="+text); WebContext wctx = WebContextFactory.get(); //获取ip地址 String remoteAdd = wctx.getHttpServletRequest().getRemoteAddr(); text = "来自"+remoteAdd+"的朋友说："+text; if(text!=null&&text.trim().length()>0){ messages.addFirst(new WebMessage(text)); while(messages.size()>20){ //只保留前10行的缓存 messages.removeLast(); } } //将队列中的消息通知到所有客户端 notifyAllClient(wctx, messages); } public void notifyAllClient(WebContext wctx,List msgQueue){ //获得当前页的相对路径 /netjavaDWR/MyJsp.jsp String currentPage = wctx.getCurrentPage(); System.out.println("currentPage=========================================="+currentPage); //清除掉浏览器中输入文本域 在当前页释放掉 Util utilThis = new Util(wctx.getScriptSession()); utilThis.setValue("text", ""); //成为所有浏览器中当前页的结果 Collection<ScriptSession> sessions = wctx.getScriptSessionsByPage(currentPage); Util utilAll = new Util(sessions); //清楚列表，添加新的信息 utilAll.removeAllOptions("chatlog"); utilAll.addOptions("chatlog", messages,"text"); } }