Tomcat版本:Tomcat7.0.27及其以上
浏览器:Mozilla Firefox,Chromium等,不支持IE
WebSockets简介
WebSocket是下一代web通信的协议,他有以下特点:
    ·整页重新加载
    ·使用Ajax处理重新加载组件
    · Comet 通信
    类似于AJAX,但在服务器上不长时间持有线程。 
    TCP双向通信
    上面罗列的每一种特性都有优点和缺点,Tomcat6使用Comet处理机制通过HTTP实现了双向通信。这种实现允许异步事件驱动和双向通信,但是这种实现有一些限制:
    ·由于HTTP是基于请求/相应的,不是一个双向协议,代理和其他的中介机制可能无法正常运行,而且在任何特定的时间点,只能单向传输。
    ·对于服务器端开发者来说,引入多线程开发模型会变得更加困难。
    ·由于不是标准的API,会导致没有统一接口。
    Servlet3.0引入了一个新的功能叫做异步servletServlet 接收到请求之后,可能首先需要对请求携带的数据进行一些预处理;接着,Servlet 线程将请求转交给一个异步线程来执行业务处理,线程本身返回至容器,此时 Servlet 还没有生成响应数据,异步线程处理完业务以后,可以直接生成响应数据(异步线程拥有 ServletRequest ServletResponse 对象的引用),或者将请求继续转发给其它 Servlet。如此一来, Servlet 线程不再是一直处于阻塞状态以等待业务逻辑的处理,而是启动异步线程之后可以立即返回。 
    这个特性要比tomcatcomet处理机制强大。而这是一个标准的Servlet API,在其基础上建立通用开发框架是非常容易的。
    异步的servlet虽然解决了一部分网络通信的需求,但是由于其缺乏双向通信的支持,使其
的适用范围仍然有限。
    WebSocket是另外一种尝试通过HTTP支持异步、事件驱动和双向通信的规范协议。其标准化的一个形式是JavaScript API。现在缺乏一个标准的服务器端APIServlet3.1的专家小组正在积极的研究对此的一些基层的支持,这也是我写这篇文章的原因。
WebSocket 是否将演变成一个完整完备的WebSocket API仍有待观察。在此期间主要的的Servlet容器都只是支持非标准的APITomcat也不例外。
示例
 在Tomcat7.0.27版本中,apache给出了WebSocket的实现,这项功能是很多Tomcat用户一直期望的,而如今,这项功能有了。
第一个类,需要一个Servlet来处理WebSocket请求:
MyWebSocketServlet.Java
package kj.websocket;
import javax.servlet.http.HttpServletRequest;
import org.apache.catalina.websocket.StreamInbound;
import org.apache.catalina.websocket.WebSocketServlet;
public class MyWebSocketServlet extends WebSocketServlet {
/*与7.0.27不同的,Tomcat7.0.29改变了createWebSocketInbound方法的定义,增加了一个HttpServletRequest参数,这样我们也可以从request参数中获取更多请求方的信息*/
    @Override
    protected StreamInbound createWebSocketInbound(String arg0) {
        System.out.println(">>");
        return new MyMessageInbound();
    }
}
这个Servlet继承自WebSocketServlet,实现createWebSocketInbound方法。该方法返回第二个类的实例。
第二个类,处理每一次具体的WebSocket任务:
MyMessageInbound.java
package kj.websocket;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import org.apache.catalina.websocket.MessageInbound;
import org.apache.catalina.websocket.WsOutbound;
// 实现下面四个事件处理函数(其实onCloseonOpen有缺省实现)
public class MyMessageInbound extends MessageInbound { 
    // 有二进制消息数据到达,
    @Override 
    protected void onBinaryMessage(ByteBuffer arg0) throws IOException { 
        // TODO Auto-generated method stub 
         
    } 
  // 有文本消息数据到达
    @Override 
    protected void onTextMessage(CharBuffer msg) throws IOException { 
        for (MessageInbound messageInbound : InitServlet.getSocketList()) { 
            CharBuffer buffer = CharBuffer.wrap(msg); 
            WsOutbound outbound = WsOutbound();
// getWsOutbound可以返回当前的WsOutbound,通过他向客户端回传数据,这里采用的是nioCharBuffer 
            outbound.writeTextMessage(buffer); 
            outbound.flush(); 
        } 
         
    } 
  // WebSocket关闭事件,参数status应该来自org.apache.catalina.websocket.Constants
定义的几个常量,可以参考文档或者核对一下Tomcat的源码
    @Override 
    protected void onClose(int status) { 
        InitServlet.getSocketList().remove(this); 
        super.onClose(status); 
    } 
  // WebSocket握手完成,创建完毕,WsOutbound用于向客户端发送数据
    @Override 
    protected void onOpen(WsOutbound outbound) { 
        super.onOpen(outbound); 
        InitServlet.getSocketList().add(this); 
    } 
    }
这个类继承自MessageInbound类,必须实现onBinaryMessage和onTextMessage方法。
还要一个初始化的Servlet
InitServlet.java
package kj.websocket;
import java.util.ArrayList;
import java.util.List;
import javax.servlet.ServletConfig;
import javax.servlet.ServletException;websocket和socket
import javax.servlet.http.HttpServlet;
import org.apache.catalina.websocket.MessageInbound;
public class InitServlet extends HttpServlet { 
           
    private static List<MessageInbound> socketList;   
     
    public void init(ServletConfig config) throws ServletException {   
        InitServlet.socketList = new ArrayList<MessageInbound>();   
        super.init(config);   
        System.out.println("Server start============");   
    }   
       
    public static List<MessageInbound> getSocketList() {   
        return InitServlet.socketList;   
    }   
最后,l中进行一下Servlet的配置。
<servlet>
    <servlet-name>mywebsocket</servlet-name>
    <servlet-class>kj.websocket.MyWebSocketServlet</servlet-class>

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。