背景介绍：
项目中有一个通讯模块，本来是用websocket全双工技术实现的，但IE10以下不支持websocket，而国内的360、2345浏
览器封装的全部是IE10以下的内核，考虑到网站在国内的客户，不得不在不支持websocket时候也要提供通讯支持，于
是决定在不支持websocket的浏览器上用long-pulling技术替代。
可行性分析：
Servlet 3.0已经开始支持async，Spring MVC 3.2也开始对异步提供支持，于是结合DeferredResult来实现聊天技术。
具体实现：
1 文件配置：
假设你已经有了spring+springmvc框架，我们只需对配置文件做微小改动，要在web.xml中的所有的filter及servlet中需要声明使用async：
web.xml完整配置如下：true
文件配置搞定。contextConfigLocation classpath:spring-mybatis.xml encodingFilter org.springframework.web.filter.CharacterEncodingFilter true encoding UTF-8 encodingFilter /* org.springframework.web.context.ContextLoaderListener org.springframework.web.util.IntrospectorCleanupListener SpringMVC org.springframework.web.servlet.DispatcherServlet contextConfigLocation classpath:spring-mvc.xml 1 true SpringMVC / index. jsp
2 建立控制器Controller
/**
* @作者 yyp
* @文件名 ChatController.java
* @作用 处理聊天消息
* @Blog http://blog.csdn.net/gisredevelopment
*/
@Controller
public class ChatController {
//存放所有的用户请求
private final Map
> chatRequests = new ConcurrentHashMap
>(); //时间格式化 private final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); /** * @作者 yyp * @作用 登录 * @param name 用户名 * @param session 会话 * @return 聊天室页面 */ @RequestMapping(value = "/login", method = RequestMethod.POST) public String login(@RequestParam String name, HttpSession session){ session.setAttribute("user", name); Message msg = new Message(); msg.setUser("系统"); msg.setDate(sdf.format(new Date())); msg.setContent(name + "已加入"); //通知所有用户有人进入聊天室 processMessage(msg); return "room"; } /** * * @作者 yyp * @作用 读取最新消息 * @param session 会话 * @return DeferredResult
*/ @RequestMapping(value = "/getMessages", method = RequestMethod.GET) @ResponseBody public DeferredResult
getMessages(HttpSession session){ //取出当前登录用户 final String user = (String)session.getAttribute("user"); //创建DeferredResult
DeferredResult
dr = new DeferredResult
(); //若用户不存在则直接返回，否则将其放入用户请求列表中然后返回 if(null == user){ return dr; }else{ //当DeferredResult对客户端响应后将其从列表中移除 dr.onCompletion(new Runnable() { @Override public void run() { // TODO 自动生成的方法存根 chatRequests.remove(user); } }); chatRequests.put(user, dr); return dr; } } /** * @作者 yyp * @作用 接收客户端消息 * @param session 会话 * @param content 消息内容 * @return Map
*/ @RequestMapping(value = "/setMessage", method = RequestMethod.POST) @ResponseBody public Map
setMessage(HttpSession session, @RequestParam String content){ Message msg = new Message(); msg.setContent(content); msg.setDate(sdf.format(new Date())); msg.setUser((String)session.getAttribute("user")); //发布消息给所有用户 processMessage(msg); Map
map = new HashMap
(1); map.put("success", "true"); return map; } /** * @作者 yyp * @作用 退出聊天室 * @param session 会话 * @return Map
*/ @RequestMapping(value = "/logout", method = RequestMethod.GET) @ResponseBody public Map
logout(HttpSession session){ Message msg = new Message(); String user = (String)session.getAttribute("user"); msg.setContent("已离开"); msg.setDate(sdf.format(new Date())); msg.setUser(user); chatRequests.remove(user); //通知所有用户有人离开聊天室 processMessage(msg); Map
map = new HashMap
(1); map.put("success", "true"); return map; } /** * @作者 yyp * @作用 将消息信息发布给所有在线用户 * @para