Java版WebSocket 达成消息推送
发布时间：2021-12-07 13:31:59 所属栏目：教程 来源：互联网
导读：# web socket是什么? WebSocket协议是基于TCP的一种新的网络协议。 它实现了浏览器与服务器全双工(full-duplex)通信，允许服务器主动发送信息给客户端。 ## 用途 实时Web应用的解决方案，实现Web的实时通信。 说的再直白点，html的消息推送。 假如你有一个页
|
# web socket是什么? WebSocket协议是基于TCP的一种新的网络协议。 它实现了浏览器与服务器全双工(full-duplex)通信，允许服务器主动发送信息给客户端。 ## 用途 实时Web应用的解决方案，实现Web的实时通信。 说的再直白点，html的消息推送。 假如你有一个页面，数据不定期更改，通常的做法就是轮询，客户端不停地向服务器请求最新的数据。 当有了web socket，数据变动时 让服务器通知客户端，启不是很美妙？ ## 请求示例 (1) 默认端口是80和443(ssl)。 (2) 协议标识符是ws和ws(ssl)。 (3) 请求报文示例 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 # 代码实现 代码分为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> 推荐：google/jquery-websocket代码 (http://code.google.com/p/jquery-websocket) google/jquery-websocket增加了消息的类型，将消息拆分为{"type":"","message":""}。 这样更灵活，可以根据业务类型，定义type，如：通知，公告，广播，发文等... <script type="text/javascript"> var principal = '1'; var socketURL = 'ws://' + window.location.host + '/j2ee-websocket/websocket/' + principal; websocket = $.websocket(socketURL, { open : function() { // when the socket opens alert("open"); }, close : function() { // when the socket closes alert("close"); }, //收到服务端推送的消息处理 events : { 'radio' : function(event) { console.info($.parseJSON(event.data)); }, 'notice' : function(event) { console.info($.parseJSON(event.data)); }, //... more custom type of message } }); //发送消息 function send() { websocket.send('radio', " hello,this msg from client request"); } </script>  （编辑：牡丹江站长网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
站长推荐