一、准备工作
pom.xml引入
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
二、代码编写
创建名为WebSocketConfig的类
/**
* 开启websocket的支持
* @author lichao
* @date 2018-08-28
*
*/
@Configuration
public class WebSocketConfig {
@Bean
public ServerEndpointExporter serverEndpointExporter(){
return new ServerEndpointExporter();
}
}
创建名为WebSocketServer的类
@ServerEndpoint(value = "/websocket")
@Component // 此注解千万千万不要忘记，它的主要作用就是将这个监听器纳入到Spring容器中进行管理
public class WebSocketServer {
// 统计在线人数
private static int onlineCount = 0;
// 用本地线程保存session
private static ThreadLocal<Session> sessions = new ThreadLocal<Session>();
// 保存所有连接上的session
private static Map<String, Session> sessionMap = new ConcurrentHashMap<String, Session>();
public static synchronized int getOnlineCount() {
return onlineCount;
}
public static synchronized void addOnlineCount() {
onlineCount++;
}
public static synchronized void subOnlineCount() {
onlineCount--;
}
// 连接
@OnOpen
public void onOpen(Session session) {
sessions.set(session);
addOnlineCount();
sessionMap.put(session.getId(), session);
System.out.println("【" + session.getId() + "】连接上服务器======当前在线人数【" + getOnlineCount() + "】");
// 连接上后给客户端一个消息
sendMsg(session, "连接服务器成功！");
}
// 关闭
@OnClose
public void onClose(Session session) {
subOnlineCount();
sessionMap.remove(session.getId());
System.out.println("【" + session.getId() + "】退出了连接======当前在线人数【" + getOnlineCount() + "】");
}
// 接收消息 客户端发送过来的消息
@OnMessage
public void onMessage(String message, Session session) {
//message的格式可以包含sessionid, 格式[SID,内容XXX]：1,内容
System.out.println("【" + session.getId() + "】客户端的发送消息======内容【" + message + "】");
String[] split = message.split(",");
String sessionId = split[0];
Session ss = sessionMap.get(sessionId);
if (ss != null) {
String msgTo = "【" + session.getId() + "】发送给【您】的消息:\n【" + split[1] + "】";
String msgMe = "【我】发送消息给【" + ss.getId() + "】:\n" + split[1];
sendMsg(ss, msgTo);
sendMsg(session, msgMe);
} else {
for (Session s : sessionMap.values()) {
if (!s.getId().equals(session.getId())) {
sendMsg(s, "【" + session.getId() + "】发送给【您】的广播消息:\n【" + message + "】");
} else {
sendMsg(session, "【我】发送广播消息给大家\n" + message);
}
}
}
/*String sid = session.getId();
Session ss = sessionMap.get(sid);*/
}
// 异常
@OnError
public void onError(Session session, Throwable throwable) {
System.out.println("发生异常!");
throwable.printStackTrace();
}
// 统一的发送消息方法
public synchronized void sendMsg(Session session, String msg) {
try {
session.getBasicRemote().sendText(msg);
} catch (IOException e) {
e.printStackTrace();
}
}
}
创建前端页面
<!DOCTYPE HTML>
<html>
<head>
<title>My WebSocket</title>
</head>
<body>
Welcome<br/>
<input id="text" type="text" /><button onclick="send()">Send</button> <button onclick="closeWebSocket()">Close</button>
<div id="message">
</div>
</body>
<script type="text/javascript">
var websocket = null;
//判断当前浏览器是否支持WebSocket
if('WebSocket' in window){
websocket = new WebSocket("ws://192.168.1.78:8080/eboata-admin/websocket");
}
else{
alert('Not support websocket')
}
//连接发生错误的回调方法
websocket.onerror = function(){
setMessageInnerHTML("error");
};
//连接成功建立的回调方法
websocket.onopen = function(event){
setMessageInnerHTML("open");
}
//接收到消息的回调方法
websocket.onmessage = function(event){
setMessageInnerHTML(event.data);
}
//连接关闭的回调方法
websocket.onclose = function(){
setMessageInnerHTML("close");
}
//监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。
window.onbeforeunload = function(){
websocket.close();
}
//将消息显示在网页上
function setMessageInnerHTML(innerHTML){
document.getElementById('message').innerHTML += innerHTML + '<br/>';
}
//关闭连接
function closeWebSocket(){
websocket.close();
}
//发送消息
function send(){
var message = document.getElementById('text').value;
websocket.send(message);
}
</script>
</html>
相关推荐
如何使用Postman来发送数据到后端Spring Boot应用程序，并使用WebSocket建立实时通信通道，以便后端应用程序可以向Postman推送消息。 学会这个方法，就能缩短你的项目开发周期，以及提高你的开发效率。如果提出您的...
本项目提供的源代码展示了如何利用消息队列（Message Queue）、Spring Boot框架以及WebSocket技术来实现一个实时的消息推送模型。以下是关于这些关键技术的详细说明： 1. **消息队列**：消息队列是一种中间件，用于...
vue前端后端分离spring boot 2.0集成websocket，带身份认证实现消息推送功能
WebSocket是一种在单个TCP连接上进行全双工通信的协议，允许服务器主动向客户端推送数据，非常适合实时交互应用。 **1. 配置Spring Boot支持WebSocket** 在Spring Boot项目中，我们需要引入`spring-boot-starter-...
1、基于Spring Boot 实现的WebSocket实时数据通信Demo 2、结合Netty实现多客户端之间进行网络通信 3、在Web端建立多客户端之间的通信机制
2.SpringBoot如何集成websocket 3.SpringBoot中的定时任务调度 4.前后端分离项目的Cros跨域问题解决 阅读建议： 此资源以案例代入知识点的方式，让你快速上手websocket的相关学习，可针对项目本身向外扩展。
假设有这样一个场景：服务端的资源经常在更新，客户端需要...而有了 WebSocket 协议，就能很好地解决这些问题，WebSocket 可以反向通知的，通常向服务端订阅一类消息，服务端发现这类消息有更新就会不停地通知客户端。
概要：本文介绍如何使用 Spring Boot 3.X 和 WebSocket 实现消息推送，并动态开启、关闭和取消定时任务。通过WebSocket实现实时通信，结合定时任务管理，可实现灵活的消息推送和任务控制。 使用人群：适合有Spring ...
Spring Boot提供了一种方便的方式来集成WebSocket，但其底层实现可能不够高效，这时Netty就派上用场了。 Netty是一个高性能、异步事件驱动的网络应用框架，适用于开发服务器和客户端。Netty以其优秀的性能、低内存...
- 将WebSocket与Drools集成，例如，在接收到特定消息后，通过DroolsService执行规则判断，根据结果决定是否触发WebSocket推送。 - 如果Drools规则判断的结果需要更新前端数据，可以将结果封装为消息并发送给前端。...
本教程将详细介绍如何利用Spring Boot集成WebSocket，实现消息的主动推送，包括一对一的消息传递和广播给所有在线用户。 首先，我们需要在Spring Boot项目中添加WebSocket相关的依赖。在`pom.xml`文件中，引入`...
在本项目"spring-boot-websocket-study-master.zip"中，我们主要探讨的是如何利用Spring Boot框架集成WebSocket技术来实现一个实时的游戏公告系统。这个系统能够让游戏管理员在后台发布游戏公告，而所有在线的游戏...
WebSocket是一种在客户端和服务器之间建立长时间连接的协议，允许双向通信，即服务器可以主动向客户端推送数据，而不仅仅是响应客户端的请求。在Spring Boot中，可以通过`spring-websocket`模块实现WebSocket功能。...
通过以上步骤，我们可以利用“spring-boot-starter-websocket.zip”中的内容搭建起一个完整的站内信系统，实现实时的消息推送功能。这个压缩包提供的起步依赖简化了WebSocket在Spring Boot中的集成工作，让开发者...
本教程将深入探讨如何在SpringBoot 2.0版本中整合WebSocket，以实现服务器主动向前端推送数据，并且当消息到达时，前端能够进行声音提示和弹框提醒。 首先，我们需要理解WebSocket的基本概念。WebSocket是一种在...
分布式WebSocket推送服务，客户端向任意一个IM服务端发送消息，其他IM服务端都可接收到这条消息，并将消息推送给所有在线连接的同群组客户端（基于Redis订阅/发布功能及WebSocket连接实现）。 临时群聊快速搭建...
使用 Spring Boot 实现 WebSocket 实时通信 Spring Boot 是一个基于 Java 的框架，提供了强大的工具和功能来快速构建生产级别的应用程序。 WebSocket 是一种实时通信技术，允许服务器将消息推送到客户端，而不需要...
WebSocket是一种在单个TCP连接上进行全双工通信的协议，它允许服务器主动向客户端推送数据，常用于实时通信场景。在Spring Boot中，我们可以使用`@ServerEndpoint`注解来创建WebSocket端点，如下所示： ```java ...
Spring 框架为开发者提供了便捷地集成 WebSocket 的功能，下面将详细介绍 Spring 如何集成 WebSocket 及其实现站内消息实时推送。 1. **配置WebSocket支持** - 引入依赖：Spring Boot 的 WebSocket 支持通常需要 `...
如何使用Postman来发送数据到后端Spring Boot应用程序，并使用WebSocket建立实时通信通道，以便后端应用程序可以向Postman推送消息，并可动态开启、关闭和取消定时任务。 学会这个方法，就能缩短你的项目开发周期，...