WebSocket是HTML5新增的协议，它的目的是在浏览器和服务器之间建立一个不受限的双向通信的通道，比如说，服务器可以在任意时刻发送消息给浏览器。
这里介绍使用Quartz的调度功能和WebSock在服务端向浏览器端推送消息
浏览器交互页面
webSockpage.html文件
WebSock测试var websocket = null;
//判断当前浏览器是否支持WebSocket
if ('WebSocket' in window) {
websocket = new WebSocket("ws://localhost:8080/photoOne/websocket");
}
else {
alert("当前浏览器 Not support websocket");
}
//连接发生错误的回调方法
websocket.onerror = function () {
setMessageInnerHTML("WebSocket连接发生错误");
};
//连接成功建立的回调方法
websocket.onopen = function () {
setMessageInnerHTML("WebSocket连接成功");
}
//接收到消息的回调方法
websocket.onmessage = function (event) {
setMessageInnerHTML(event.data);
}
//连接关闭的回调方法
websocket.onclose = function () {
setMessageInnerHTML("WebSocket连接关闭");
}
//监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。
window.onbeforeunload = function () {
closeWebSocket();
}
//将消息显示在网页上
function setMessageInnerHTML(innerHTML) {
document.getElementById("d1").innerHTML += innerHTML + "
";
}
//关闭WebSocket连接
function closeWebSocket() {
websocket.close();
}
/*//发送消息
function send() {
var message = document.getElementById("text").value;
websocket.send(message);
}*/
WebSock接收后台推送的消息...
WebSock服务端
WebSockServer.java文件
package cn.hpc.ssm.controller;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.CopyOnWriteArraySet;
import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
/**
* @ServerEndpoint 注解是一个类层次的注解，它的功能主要是将目前的类定义成一个websocket服务器端,
* 注解的值将被用于监听用户连接的终端访问URL地址,客户端可以通过这个URL来连接到WebSocket服务器端
*/
@ServerEndpoint("/websocket")
public class WebSocketServer {
//静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。
private static int onlineCount = 0;
//concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。若要实现服务端与单一客户端通信的话，可以使用Map来存放，其中Key可以为用户标识
private static CopyOnWriteArraySet webSocketSet = new CopyOnWriteArraySet();
//与某个客户端的连接会话，需要通过它来给客户端发送数据
private Session session;
/**
* 连接建立成功调用的方法
* @param session 可选的参数。session为与某个客户端的连接会话，需要通过它来给客户端发送数据
* @throws IOException
*/
@OnOpen
public void onOpen(Session session) throws IOException{
this.session = session;
webSocketSet.add(this);//加入set中
addOnlineCount(); //在线数加1
System.out.println("有新连接加入！当前在线人数为" + getOnlineCount());
this.sendMessage("连接成功！！！");
}
/**
* 连接关闭调用的方法
*/
@OnClose
public void onClose(){
webSocketSet.remove(this); //从set中删除
subOnlineCount(); //在线数减1
System.out.println("有一连接关闭！当前在线人数为" + getOnlineCount());
}
/**
* 收到客户端消息后调用的方法
* @param message 客户端发送过来的消息
* @param session 可选的参数
*/
@OnMessage
public void onMessage(String message, Session session) {
Map map = session.getPathParameters();
System.out.println("来自客户端用户"+map.get("userId")+"的消息:" + message);
//群发消息
for(WebSocketServer item: webSocketSet){
try {
item.sendMessage(message);
} catch (IOException e) {
e.printStackTrace();
continue;
}
}
}
// public void sendMessageTo(String message, String To) throws IOException {
// for (WebSocket item : clients.values()) {
// if (item.username.equals(To) )
// item.session.getAsyncRemote().sendText(message);
// }
// }
//
// public void sendMessageAll(String message) throws IOException {
// for (WebSocket item : clients.values()) {
// item.session.getAsyncRemote().sendText(message);
// }
// }
/**
* 发生错误时调用
* @param session
* @param error
*/
@OnError
public void one rror(Session session, Throwable error){
System.out.println("发生错误");
error.printStackTrace();
}
/**
* 这个方法与上面几个方法不一样。没有用注解，是根据自己需要添加的方法。
* @param message
* @throws IOException
*/
public void sendMessage(String message) throws IOException{
this.session.getBasicRemote().sendText(message);
//this.session.getAsyncRemote().sendText(message);
}
public static synchronized int getOnlineCount() {
return onlineCount;
}
public static synchronized void addOnlineCount() {
WebSocketServer.onlineCount++;
}
public static synchronized void subOnlineCount() {
WebSocketServer.onlineCount--;
}
public static CopyOnWriteArraySet getWebSocketSet() {
return webSocketSet;
}
public static void setWebSocketSet(
CopyOnWriteArraySet webSocketSet) {
WebSocketServer.webSocketSet = webSocketSet;
}
public Session getSession() {
return session;
}
public void setSession(Session session) {
this.session = session;
}
}
这里使用Springmvc结构，先把浏览器端和服务器端WebSock连通，运行结果
接下来使用Quartz定时执行并调用WebSock服务器进行消息推送
首先在spring的xml配置文件中集成定时调度功能，这里是主要功能代码。Quartz和Spring的集成参考
..............
.............
可以看到TriggersRunClass为定时执行的任务类，runMethod方法为调度任务的执行方法。
在TriggersRunClass类的runMethod方法中调用WebSock对象的向客户端推送消息的方法
TriggersRunClass类文件
package cn.hpc.ssm.controller;
import java.io.IOException;
import java.util.Date;
import java.util.concurrent.CopyOnWriteArraySet;
public class TriggersRunClass {
//定时执行的方法
public void runMethod() {
//获取WebSocketServer对象的映射。
CopyOnWriteArraySet webSocketSet = WebSocketServer.getWebSocketSet();
if (webSocketSet.size() != 0){
for (WebSocketServer item : webSocketSet) {
try {
//向客户端推送消息
item.getSession().getBasicRemote().sendText("每隔5秒,向客户端推送一次数据,本地时间："+new Date().toLocaleString());
}catch (IOException e){
e.printStackTrace();
}
}
}else {
System.out.println("WebSocket未连接");
}
}
}
运行结果
可以看到每5秒执行一次调度方法并调用WebSock服务端推送消息
注意：需要引入Quartz的jar(quartz-1.5.2.jar)和javaee的jar(javaee-api-8.0.jar)
标签：浏览器,Websocket,session,void,websocket,message,推送,public,客户端
来源： https://blog.csdn.net/weixin_35654814/article/details/102733218