使用WebSocket推送服务器消息

以前做项目的时候常常会有客户端提醒的功能,使用的是ajax长轮询的方式,这中方式对服务器端压力比较大,无论有没有通知都会发送心跳请求,最近看了一下html5以及tomcat对websocket支持的相关文章,自己做了个小东东,仅供大家分享.

demo实现的小功能: 客户端A发送请求,通过服务器,直达客户端B

演示效果如图所示

代码的目录结构

package com.bw.websocket.api;import java.io.IOException;
import java.util.HashMap;
import java.util.Map;import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;import com.bw.websocket.servlet.CallCenterMessageInBound;@Controller
public class MessageAPI {/*** 向客户端推送消息* */@ResponseBody@RequestMapping(value = "/api/send.action")public Map<String, String> send(@RequestParam String clientId,@RequestParam String message) {Map<String, String> result = new HashMap<String, String>();try {CallCenterMessageInBound.send(clientId, message);result.put("message", "success");} catch (IOException e) {result.put("message", e.getLocalizedMessage());e.printStackTrace();}return result;}
}

package com.bw.websocket.servlet;import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.util.HashMap;
import java.util.Map;import org.apache.catalina.websocket.MessageInbound;
import org.apache.catalina.websocket.WsOutbound;public class CallCenterMessageInBound extends MessageInbound {private String clientId;public static final Map<String, MessageInbound> socketList = new HashMap<String, MessageInbound>();public static void send(String clientId, String message) throws IOException {MessageInbound messageInbound = socketList.get(clientId);messageInbound.getWsOutbound().writeTextMessage(CharBuffer.wrap(message));messageInbound.getWsOutbound().flush();}public CallCenterMessageInBound(String clientId) {this.clientId = clientId;}@Overrideprotected void onBinaryMessage(ByteBuffer message) throws IOException {}@Overrideprotected void onTextMessage(CharBuffer message) throws IOException {}@Overrideprotected void onOpen(WsOutbound outbound) {socketList.put(clientId, this);}@Overrideprotected void onClose(int status) {socketList.remove(clientId);}
}

package com.bw.websocket.servlet;import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.util.HashMap;
import java.util.Map;import org.apache.catalina.websocket.MessageInbound;
import org.apache.catalina.websocket.WsOutbound;public class CallCenterMessageInBound extends MessageInbound {private String clientId;public static final Map<String, MessageInbound> socketList = new HashMap<String, MessageInbound>();public static void send(String clientId, String message) throws IOException {MessageInbound messageInbound = socketList.get(clientId);messageInbound.getWsOutbound().writeTextMessage(CharBuffer.wrap(message));messageInbound.getWsOutbound().flush();}public CallCenterMessageInBound(String clientId) {this.clientId = clientId;}@Overrideprotected void onBinaryMessage(ByteBuffer message) throws IOException {}@Overrideprotected void onTextMessage(CharBuffer message) throws IOException {}@Overrideprotected void onOpen(WsOutbound outbound) {socketList.put(clientId, this);}@Overrideprotected void onClose(int status) {socketList.remove(clientId);}
}

<%@ page language="java" contentType="text/html; charset=utf-8"pageEncoding="utf-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8">
<title>Insert title here</title>
<script type="text/javascript" src="js/jquery-2.0.2.min.js"></script>
<script type="text/javascript">
var clientId =Math.random();
var url = 'ws://localhost:8080/websocket/WebSocket?clientId='+clientId;
document.write("Current ClientId:"+clientId);
var CallCenter = {init:function(url){var _websocket = new WebSocket(url);_websocket.onopen = function(evt) {console.log("Connected to WebSocket server.");};_websocket.onclose = function(evt) {console.log("Disconnected");};_websocket.onmessage = function(evt) {eval(evt.data);};_websocket.onerror = function(evt) {console.log('Error occured: ' + evt);};}
};
CallCenter.init(url);$(document).ready(function(){$("#send").bind("click",function(){$.ajax({type: "get",url: "api/send.action",data: "clientId="+$("#clientId").val()+"&message="+$("#message").val(),success: function(msg){alert(msg.message);}});});
});
</script>
</head>
<body>
<br/>
To ClientId:<input type="text" id="clientId" /><br /> Message:<input type="text" id="message" /><input type="button" id="send" value="send">
</body>
</html>

home.jsp 监控客户端连接

<%@page import="com.bw.websocket.servlet.CallCenterMessageInBound"%>
<%@page import="java.util.Iterator"%>
<%@page import="org.apache.catalina.websocket.MessageInbound"%>
<%@ page language="java" contentType="text/html; charset=ISO-8859-1"pageEncoding="ISO-8859-1"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=ISO-8859-1">
<title>Insert title here</title>
</head>
<body>
<%for(Iterator<String> it = CallCenterMessageInBound.socketList.keySet().iterator();it.hasNext();){String key = it.next();out.println(key+":"+CallCenterMessageInBound.socketList.get(key)+"<br/>");}
%>
this home page
</body>
</html>

上述方法只对高版本的浏览器使用,也就是支持websocket的浏览器适用

考虑到浏览器的兼容性问题,我们还可以使用flash socket的方式进行消息推送,通过flex javascript bridge来执行服务器端推送信息.

使用WebSocket推送服务器消息相关推荐

抓取WebSocket推送的消息
介绍很多直播或对数据及时性要求比较高的网站,使用了WebSocket.这种数据要怎么抓呢? 我们这里以socket.io为例,我们可以查看网站网页源代码看使用的H5的WebSocket还是socke ...
Springboot整合Websocket(推送消息通知)
在手机上相信都有来自服务器的推送消息,比如一些及时的新闻信息,这篇文章主要就是实现这个功能,只演示一个基本的案例.使用的是websocket技术. 一.什么是websocket WebSocket协议 ...
Asp.net webApi 通过WebSocket推送消息给客户端，搭建一个即是服务端又是客户端的服务
Asp.net webApi 通过WebSocket推送消息给客户端,搭建一个即是服务端又是客户端的服务_IT_ziliang的博客-CSDN博客 WebSocket是一种在单个TCP连接上进行全双工 ...
消息推送服务器推pc,PC浏览器消息实时推送的解决方案 ——EPush推送平台
原标题:PC浏览器消息实时推送的解决方案 --EPush推送平台陈华研发工程师,2014入职去哪儿网.参与研发的EPush推送平台,增强了订单推送的时效性,提高了酒店自助订单处理率.最近负责CEQ ...
mpush 搭建消息服务器,MPUSH消息推送服务器搭建
MPUSH消息推送服务器搭建安装JDK 1.8 wget /jdk-8u121-linux-x64.tar.gz tar -zxvf jdk-8u121-linux-x64.tar.gz vim / ...
win10消息推送服务器,怎么让win10推送
近有Win7系统用户反映,自Win10版本发布以来,身边的朋友都已经升级了Win10了,可是自己至今都没收到Win10升级的推送通知,今天学习啦小编给大家介绍下怎么让win10推送通知吧. 让win1 ...
netty多台服务器推送消息,基于Netty的消息推送服务器集群设计与实现
徐龙光何顶新摘要:消息推送是当前移动应用中十分必要的一项技术,服务者需要使用消息推送以保持用户活跃度,提高应用存留率.为了满足消息推送的需求和增强推送系统的性能,采用Netty网络编程框架并搭建 ...
【苹果推IM，苹果iMessage相册推】当Apple APNS推送服务器从您的应用程序接吸取注册消息时，它将为您回到一串devicetoken（很是重要）
推荐内容IMESSGAE相关作者✈️@IMEAE推荐内容 iMessage苹果推软件 *** 点击即可查看作者要求内容信息作者✈️@IMEAE推荐内容 1.家庭推内容 *** 点击即可查看作者要求 ...
iOS 推送手机消息背后的技术
作者:allenzzhao,腾讯 IEG运营开发工程师消息推送我们几乎每天都会用到,但你知道iOS中的消息推送是如何实现的吗?本文将从推送权限申请,到本地和远程消息推送,再到App对推送消息的处理 ...

使用WebSocket推送服务器消息

使用WebSocket推送服务器消息相关推荐

最新文章

热门文章