WebSocket 实例
服务端回送的消息：
是的，WebSocket 客户端编程就是这么简单，不管你信不信，反正我是信了。通过 onmessage 方法随时准备接收服务端发过来的消息，通过 send 方法直接发送消息 服务端支持 由于 WebSocket 目前仅仅是草稿阶段，所以服务端的支持还不是很完善，也没有统 一的规范接口，各自做各自的，希望不久的将来这点能有所改观 php - http://code.google.com/p/phpwebsocket/ jetty - http://jetty.codehaus.org/jetty/ (版本 7 才开始支持 websocket) netty - http://www.jboss.org/netty ruby - http://github.com/gimite/web-socket-ruby Kaazing - http://www.kaazing.org/confluence/display/KAAZING/Home Node.js - http://nodejs.org/ 服务端 DEMO 这里我采用的是 jetty-hightide-8.0.0.M2 做为服务器，代码如下 package org.qxh.ws.web; import javax.servlet.http.HttpServletRequest; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.eclipse.jetty.websocket.WebSocket; import org.eclipse.jetty.websocket.WebSocketServlet; import java.io.IOException; /** * @author qinxiaohui01 */ public class EchoWebSocketServlet extends WebSocketServlet { private final static Log log = LogFactory.getLog(EchoWebSocketServlet.class); protected WebSocket doWebSocketConnect(HttpServletRequest request, String protocol) { //用一个 WebSocket 来处理浏览器的请求 return new MyWebSocket(); } public class MyWebSocket implements WebSocket { Outbound outbound; public MyWebSocket() { super(); } public void onConnect(Outbound outbound) { //建立连接时的处理方法 this.outbound = outbound; System.out.println("onConnect"); } public void onDisconnect() { //断开连接时的处理方法 System.out.println("onDisconnect"); } public void onMessage(final byte frame, String data) { //接到客户端消息时的处理方法 System.out.println("onMessage"); try { this.outbound.sendMessage(frame,"Your message is:"+data); } catch (IOException e) { log.error(e); } } public void onMessage(byte frame, byte[] arg1, int arg2, int arg3) { onMessage(frame, new String(arg1, arg2, arg3)); } public void onFragment(boolean arg0, byte arg1, byte[] arg2, int arg3, int arg4) { System.out.println("onFragment"); } } } 编译这个 servlet 的 jar 在 jetty 根目录下的 lib 目录下都可以找到，要不给大家看一 下我的部分依赖吧：
