B/S 结构的软件项目中有时客户端需要实时的获得服务器消息,但默认 HTTP 协议只支持请求响应模式,这样做可以简化 web 服务器,减少服务器的负担,加快响应速度,因为服务器不需要与客户端长时间建立一个通信链接,但不容易直接完成实时的消息推送功能,如聊天室、后台信息提示、实时更新数据等功能,但通过 polling、Long polling、长连接、Flash Socket 以及 html5 中定义的 WebSocket 能完成该功能需要。
Socket 又称 "套接字",应用程序通常通过 "套接字" 向网络发出请求或者应答网络请求。Socket 的英文原义是 "孔" 或 "插座",作为 UNIX 的进程通信机制。Socket 可以实现应用程序间网络通信。
Socket 可以使用 TCP/IP 协议或 UDP 协议。
TCP/IP 协议
TCP/IP 协议是目前应用最为广泛的协议,是构成 Internet 国际互联网协议的最为基础的协议, 由 TCP 和 IP 协议组成:
TCP 协议: 面向连接的、可靠的、基于字节流的传输层通信协议,负责数据的可靠性传输的问题。
IP 协议: 用于报文交换网络的一种面向数据的协议,主要负责给每台网络设备一个网络地址,保证数据传输到正确的目的地。
UDP 协议
UDP 特点:无连接、不可靠、基于报文的传输层协议,优点是发送后不用管,速度比 TCP 快。
B/S 架构的系统多使用 HTTP 协议,HTTP 协议的特点:
1 无状态协议
2 用于通过 Internet 发送请求消息和响应消息
3 使用端口接收和发送消息,默认为 80 端口
底层通信还是使用 Socket 完成。
HTTP 协议决定了服务器与客户端之间的连接方式,无法直接实现消息推送(F5 已坏), 一些变相的解决办法:
双向通信与消息推送
轮询:客户端定时向服务器发送 Ajax 请求,服务器接到请求后马上返回响应信息并关闭连接。 优点:后端程序编写比较容易。 缺点:请求中有大半是无用,浪费带宽和服务器资源。 实例:适于小型应用。
长轮询:客户端向服务器发送 Ajax 请求,服务器接到请求后 hold 住连接,直到有新消息才返回响应信息并关闭连接,客户端处理完响应信息后再向服务器发送新的请求。 优点:在无消息的情况下不会频繁的请求,耗费资小。 缺点:服务器 hold 连接会消耗资源,返回数据顺序无保证,难于管理维护。 Comet 异步的 ashx,实例:WebQQ、Hi 网页版、Facebook IM。
长连接:在页面里嵌入一个隐蔵 iframe,将这个隐蔵 iframe 的 src 属性设为对一个长连接的请求或是采用 xhr 请求,服务器端就能源源不断地往客户端输入数据。 优点:消息即时到达,不发无用请求;管理起来也相对便。 缺点:服务器维护一个长连接会增加开销。 实例:Gmail 聊天
Flash Socket:在页面中内嵌入一个使用了 Socket 类的 Flash 程序 JavaScript 通过调用此 Flash 程序提供的 Socket 接口与服务器端的 Socket 接口进行通信,JavaScript 在收到服务器端传送的信息后控制页面的显示。 优点:实现真正的即时通信,而不是伪即时。 缺点:客户端必须安装 Flash 插件;非 HTTP 协议,无法自动穿越防火墙。 实例:网络互动游戏。
Websocket:
WebSocket 是 HTML5 开始提供的一种浏览器与服务器间进行全双工通讯的网络技术。依靠这种技术可以实现客户端和服务器端的长连接,双向实时通信。
特点:
事件驱动
异步
使用 ws 或者 wss 协议的客户端 socket
能够实现真正意义上的推送功能
缺点:
少部分浏览器不支持,浏览器支持的程度与方式有区别。
websocket 允许通过 JavaScript 建立与远程服务器的连接,从而实现客户端与服务器间双向的通信。在 websocket 中有两个方法:
1、send() 向远程服务器发送数据
2、close() 关闭该 websocket 链接
websocket 同时还定义了几个监听函数
1、onopen 当网络连接建立时触发该事件
2、onerror 当网络发生错误时触发该事件
3、onclose 当 websocket 被关闭时触发该事件
4、onmessage 当 websocket 接收到服务器发来的消息的时触发的事件,也是通信中最重要的一个监听事件。msg.data
websocket 还定义了一个 readyState 属性,这个属性可以返回 websocket 所处的状态:
1、CONNECTING(0) websocket 正尝试与服务器建立连接
2、OPEN(1) websocket 与服务器已经建立连接
3、CLOSING(2) websocket 正在关闭与服务器的连接
4、CLOSED(3) websocket 已经关闭了与服务器的连接
websocket 的 url 开头是 ws,如果需要 ssl 加密可以使用 wss,当我们调用 websocket 的构造方法构建一个 websocket 对象(new WebSocket(url))的之后,就可以进行即时通信了。
- <!DOCTYPE html>
- <html>
- <head>
- <meta name="viewport" content="width=device-width" />
- <title>
- WebSocket 客户端
- </title>
- </head>
- <body>
- <div>
- <input type="button" id="btnConnection" value="连接" />
- <input type="button" id="btnClose" value="关闭" />
- <input type="button" id="btnSend" value="发送" />
- </div>
- <script src="js/jquery-1.11.1.min.js" type="text/javascript" charset="utf-8">
- </script>
- <script type="text/javascript">
- var socket;
- if (typeof(WebSocket) == "undefined") {
- alert("您的浏览器不支持WebSocket");
- return;
- }
- $("#btnConnection").click(function() {
- //实现化WebSocket对象,指定要连接的服务器地址与端口
- socket = new WebSocket("ws://192.168.1.2:8888");
- //打开事件
- socket.onopen = function() {
- alert("Socket 已打开");
- //socket.send("这是来自客户端的消息" + location.href + new Date());
- };
- //获得消息事件
- socket.onmessage = function(msg) {
- alert(msg.data);
- };
- //关闭事件
- socket.onclose = function() {
- alert("Socket已关闭");
- };
- //发生了错误事件
- socket.onerror = function() {
- alert("发生了错误");
- }
- });
- //发送消息
- $("#btnSend").click(function() {
- socket.send("这是来自客户端的消息" + location.href + new Date());
- });
- //关闭
- $("#btnClose").click(function() {
- socket.close();
- });
- </script>
- </body>
- </html>
JSR356 定义了 WebSocket 的规范,Tomcat7 中实现了该标准。JSR356 的 WebSocket 规范使用 javax.websocket.* 的 API,可以将一个普通 Java 对象(POJO)使用 @ServerEndpoint 注释作为 WebSocket 服务器的端点。
- @ServerEndpoint("/push") public class EchoEndpoint {@OnOpen public void onOpen(Session session) throws IOException {
- //以下代码省略...
- }
- @OnMessage public String onMessage(String message) {
- //以下代码省略...
- }@Message(maxMessageSize = 6) public void receiveMessage(String s) {
- //以下代码省略...
- }@OnError public void onError(Throwable t) {
- //以下代码省略...
- }
- @OnClose public void onClose(Session session, CloseReason reason) {
- //以下代码省略...
- }
- }
上面简洁代码即建立了一个 WebSocket 的服务端,@ServerEndpoint("/push") 的 annotation 注释端点表示将 WebSocket 服务端运行在 ws://[Server 端 IP 或域名]:[Server 端口]/ 项目 / push 的访问端点,客户端浏览器已经可以对 WebSocket 客户端 API 发起 HTTP 长连接了。
使用 ServerEndpoint 注释的类必须有一个公共的无参数构造函数,@onMessage 注解的 Java 方法用于接收传入的 WebSocket 信息,这个信息可以是文本格式,也可以是二进制格式。
OnOpen 在这个端点一个新的连接建立时被调用。参数提供了连接的另一端的更多细节。Session 表明两个 WebSocket 端点对话连接的另一端,可以理解为类似 HTTPSession 的概念。
OnClose 在连接被终止时调用。参数 closeReason 可封装更多细节,如为什么一个 WebSocket 连接关闭。
更高级的定制如 @Message 注释,MaxMessageSize 属性可以被用来定义消息字节最大限制,在示例程序中,如果超过 6 个字节的信息被接收,就报告错误和连接关闭。
- package action;
- import javax.websocket.CloseReason;
- import javax.websocket.OnClose;
- import javax.websocket.OnError;
- import javax.websocket.OnMessage;
- import javax.websocket.OnOpen;
- import javax.websocket.Session;
- import javax.websocket.server.PathParam;
- import javax.websocket.server.ServerEndpoint;
- //ws://127.0.0.1:8087/Demo1/ws/张三
- @ServerEndpoint("/ws/{user}") public class WSServer {
- private String currentUser;
- //连接打开时执行
- @OnOpen public void onOpen(@PathParam("user") String user, Session session) {
- currentUser = user;
- System.out.println("Connected ... " + session.getId());
- }
- //收到消息时执行
- @OnMessage public String onMessage(String message, Session session) {
- System.out.println(currentUser + ":" + message);
- return currentUser + ":" + message;
- }
- //连接关闭时执行
- @OnClose public void onClose(Session session, CloseReason closeReason) {
- System.out.println(String.format("Session %s closed because of %s", session.getId(), closeReason));
- }
- //连接错误时执行
- @OnError public void onError(Throwable t) {
- t.printStackTrace();
- }
- }
url 中的字符张三是的路径参数,响应请求的方法将自动映射。
Socket 在应用程序间通信被广泛使用,如果需要兼容低版本的浏览器,建议使用反向 ajax 或长链接实现;如果纯移动端或不需考虑非现代浏览器则可以直接使用 websocket。Flash 实现推送消息的方法不建议使用,因为依赖插件且手机端支持不好。关于反向 ajax 也有一些封装好的插件如 "Pushlet"
Pushlet 是一个开源的 Comet 框架, Pushlet 使用了观察者模型:客户端发送请求,订阅感兴趣的事件;服务器端为每个客户端分配一个会话 ID 作为标记,事件源会把新产生的事件以多播的方式发送到订阅者的事件队列里。
源码地址:
Pushlet 是一种 comet 实现:在 Servlet 机制下,数据从 server 端的 Java 对象直接推送(push)到(动态)HTML 页面,而无需任何 Javaapplet 或者插件的帮助。它使 server 端可以周期性地更新 client 的 web 页面,这与传统的 request/response 方式相悖。浏览器 client 为兼容 JavaScript1.4 版本以上的浏览器(如 InternetExplorer、FireFox),并使用 JavaScript/DynamicHTML 特性。而底层实现使用一个 servlet 通过 Http 连接到 JavaScript 所在的浏览器,并将数据推送到后者。
SignalR 是一个 ASP .NET 下的类库,可以在 ASP .NET 的 Web 项目中实现实时通信。在 Web 网页与服务器端间建立 Socket 连接,当 WebSockets 可用时(即浏览器支持 Html5)SignalR 使用 WebSockets,当不支持时 SignalR 将使用长轮询来保证达到相同效果。
官网:
源码:
来源: http://www.cnblogs.com/best/p/5695570.html