ajax+"服务器推送"简单web聊天

package test; import java.io.UnsupportedEncodingException; import java.net.URLDecoder; import java.util.Date; import java.util.Iterator; import java.util.Map; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; /*** * 用户发送消息 * @author Administrator * */ public class MessageAcceptServlet extends HttpServlet { public void service(HttpServletRequest request,HttpServletResponse response){ try { request.setCharacterEncoding("utf-8"); response.setCharacterEncoding("utf-8"); } catch (UnsupportedEncodingException e1) { e1.printStackTrace(); } String message = request.getParameter("message"); try { message = URLDecoder.decode(message,"utf-8"); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } //得到sessionID String sessionId = request.getSession().getId(); Map<String,User> map = RegisterManager.user; if(map.containsKey(sessionId)){ User user = map.get(sessionId); //向氖用户发消息 Iterator it = map.entrySet().iterator(); while (it.hasNext()) { Map.Entry entry = (Map.Entry) it.next(); String key = (String)entry.getKey(); User value = (User)entry.getValue(); //得到单个用户 //查看用户状态 Date date = value.getDate(); Date now = new Date(); if(now.getTime()-date.getTime()>180000){//时间超过3分钟就将用户删除 map.remove(key); }else{//向用户发消息 Push push = new Push(value,message,user.getName()); Thread thread1 = new Thread(push); thread1.start(); try { Thread.currentThread().sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } } } }else{ //session过期了提示重新来 } } }