首先，无图无真相，先上图：

这是一个基于Comet实现的聊天室Demo，功能类似于QQ群聊。聊天过程中如果有新想消息，那么就需要服务器推送消息到浏览器，所以这里可以使用Comet技术。

Comet一般有两种实现方式：长轮询（long-polling）、流（streaming）。而本文中的这个Demo的实现方式是基于流（streaming），前端使用了一个隐藏的iframe，这也是比较常用的一种方式。不过由于使用iframe流，导致浏览器上面的进度一直在转，这是因为iframe一直在加载的原因，先不要在意这些细节。

Tomcat提供了Comet相关的API，用Servlet实现CometProcessor接口就可以很简单的实现Comet了。

1、准备工作

1.1、首先，需要配置Tomcat连接为NIO，否则无法使用Tomcat Comet。

Tomcat目录下conf/server.xml，protocol更改为org.apache.coyote.http11.Http11NioProtocol：

配置好后启动Tomcat应该是这样：

1.2、在开发过程中，需要用到Tomcat的catalina.jar包，在Tomcat的lib目录下。程序在Tomcat中运行时再去掉。

2、Java后台

2.1、CometServlet

这个Servlet是处理Comet Http长连接的Servlet，这个Servlet实现Tomcat提供的CometProcessor接口，通过event方法来处理Http长连接周期内的多种事件：

BEGIN事件：有新的HTTP连接；
END事件：连接关闭，例如浏览器关闭；
ERROR事件：连接错误，例如timeout。

有关事件更详细介绍在Tomcat官方文档中有：http://tomcat.apache.org/tomcat-7.0-doc/aio.html

public class CometServlet extends HttpServlet implements CometProcessor {
	
	// 所有正在等待响应的HTTP长连接
	private ArrayList
  
    connections = null;
	
	// 用于发送消息的线程
	private MessageSender messageSender = null;
	
	// 启动消息处理线程
	public void init() {
		connections = new ArrayList
   
    (); messageSender = new MessageSender(connections); Thread messageSenderThread = new Thread(messageSender); messageSenderThread.start(); } public void event(CometEvent event) throws IOException, ServletException { HttpServletResponse response = event.getHttpServletResponse(); response.setCharacterEncoding("UTF-8"); if (event.getEventType() == CometEvent.EventType.BEGIN) { System.out.println("BEGIN"); // 一段大于1024的字符串，针对某些浏览器缓存 PrintWriter out = response.getWriter(); StringBuilder sb = new StringBuilder(); for(int i = 0; i < 1024; i++) { sb.append('a'); } out.println("
    "); // 注意加上HTML注释 out.flush(); synchronized(connections) { connections.add(response); System.out.println("当前在线用户：" + connections.size()); } } else if (event.getEventType() == CometEvent.EventType.ERROR) { System.out.println("ERROR"); synchronized(connections) { connections.remove(response); System.out.println("当前在线用户：" + connections.size()); } event.close(); } else if (event.getEventType() == CometEvent.EventType.END) { System.out.println("END"); synchronized(connections) { connections.remove(response); System.out.println("当前在线用户：" + connections.size()); } event.close(); } } }
   
  

public class MessageSender implements Runnable {
	
	// 所有正在等待响应的HTTP长连接
	private ArrayList
   
     connections;
	
	// 未发送给客户端的消息集合
	public static ArrayBlockingQueue
    
      messages = new ArrayBlockingQueue
     
      (10); public MessageSender(ArrayList
      
        connections) { this.connections = connections; } public void run() { while(true) { // 消息阻塞队列中获取一条消息，如果队列为空则阻塞 String message = null; try { message = messages.take(); } catch (InterruptedException e) { e.printStackTrace(); } // 给每个客户端发送消息 synchronized (connections) { for(HttpServletResponse response : connections) { try { PrintWriter out = response.getWriter(); // 输出一段脚本，调用JS将消息显示在页面上 out.println("<script>parent.addMsg('" + message + "
       
')"); out.flush(); } catch (IOException e) { e.printStackTrace(); } } } } } }