Java版WebSocket 实现消息推送

# web socket是什么?

WebSocket协议是基于TCP的一种新的网络协议。

它实现了浏览器与服务器全双工(full-duplex)通信,允许服务器主动发送信息给客户端

## 用途

实时Web应用的解决方案,实现Web的实时通信。

说的再直白点,html的消息推送

假如你有一个页面,数据不定期更改,通常的做法就是轮询,客户端不停地向服务器请求最新的数据。

当有了web socket,数据变动时 让服务器通知客户端,启不是很美妙?

## 请求示例

(1) 默认端口是80和443(ssl)。

(2) 协议标识符是ws和ws(ssl)。

(3) 请求报文示例

Java版WebSocket 实现消息推送

General -------------------------------------------- Request URL:ws://localhost:8080/j2ee-websocket/websocket/1 Request Method:GET Status Code:101 Switching Protocols --------------------------------------------- Response Headers --------------------------------------------- Connection:upgrade Date:Tue, 05 Dec 2017 01:22:45 GMT Sec-WebSocket-Accept:cRxT/XcOpnsleDb1KdydWXOw+us= Sec-WebSocket-Extensions:permessage-deflate;client_max_window_bits=15 Server:Apache-Coyote/1.1 Upgrade:websocket

web socket request

# 代码实现

代码分为3个部分:Javax.websocket api实现,使用观察者模式增强,google/jquery-websocket代码库。

完整代码地址,开箱即用。github:j2ee-websocket

## 服务端 java代码 

jar -- 引入javax.websocket,或引入javaee-api。

这里只展示api接口特性。

/** *Web Socket api implement *参数以URL路径参数传递 */ @ServerEndpoint(value = "/websocket/{principal}") public class DefaultWebSocket { /** Web Socket连接建立成功的回调方法 */ @OnOpen public void onOpen(@PathParam("principal") String principal, Session session) {
    //... }
/** 服务端收到客户端发来的消息 */ @OnMessage public void onMessage(@PathParam("principal") String principal, String message, Session session) {     //... } @OnClose public void onClose(@PathParam("principal") String principal, Session session) {
    //... } @OnError
public void onError(@PathParam("principal") String principal, Session session, Throwable error) { //... } } 

## 服务端推送消息至客户端 java代码

这里使用了 观察者模式,对websocket进行了增强,详见完整代码:github:j2ee-websocket

     /**服务端向客户端推送消息*/ public void notifyTest() { String principal = "1"; String type = "radio"; JSONObject data = new JSONObject(); data.put("title", "test web socket"); data.put("content", "Have you recieve this msg?--this msg from server."); WebSocketSubject subject = WebSocketSubject.Holder.getSubject(principal); subject.notify(type, data.toJSONString()); }

## 客户端 javascript代码

普通js代码

<script type="text/javascript"> var websocket = null; var principal = '1'; var socketURL = 'ws://' + window.location.host + '/j2ee-websocket/websocket/' + principal; //判断当前浏览器是否支持WebSocket if('WebSocket' in window){ websocket = new WebSocket(socketURL); } else{ alert('Not support websocket'); } //连接发生错误的回调方法 websocket.onerror = function(event){ alert("error"); }; //连接成功建立的回调方法 websocket.onopen = function(){ alert("open"); } //接收到消息的回调方法 websocket.onmessage = function(event){ alert('recive : ' + event.data); } //连接关闭的回调方法 websocket.onclose = function(event){ alert("close"); } //发送消息 function send(message){ websocket.send(message); } </script>

web socket js

推荐:google/jquery-websocket代码 ()

google/jquery-websocket增加了消息的类型,将消息拆分为{"type":"","message":""}。

这样更灵活,可以根据业务类型,定义type,如:通知,公告,广播,发文等...

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/9d8fb5dee824e42997d1a72aa041f97f.html