Spring Boot 集成 WebSocket 实战：从原生到 STOMP 全解析 | 极客日志

Java大前端java

Spring Boot 集成 WebSocket 实战：从原生到 STOMP 全解析

综述由AI生成Spring Boot WebSocket 集成方案涵盖原生接口与 STOMP 协议两种主流实现方式。内容涉及基础概念、配置步骤、安全鉴权、集群部署及性能优化等实战要点。通过原生 WebSocket 与 STOMP over WebSocket 的代码对比，展示了如何构建实时通知系统，解决传统 HTTP 轮询带来的延迟与资源浪费问题，适用于即时通讯、股票行情等实时性要求较高的应用场景。

落日余晖发布于 2026/4/10更新于 2026/5/2321 浏览

背景与动机

随着互联网应用对实时性要求的提升，传统的 HTTP 请求 - 响应模式在处理股票行情、即时消息等场景时显得力不从心。频繁轮询浪费资源，服务器也无法主动通知客户端。WebSocket 协议的出现完美解决了这一难题，它允许服务器主动向客户端推送数据，实现真正的双向通信。

Spring Boot 作为主流的 Java 微服务框架，对 WebSocket 提供了良好的支持。本文将深入浅出地讲解如何在 Spring Boot 中集成 WebSocket，涵盖原生 WebSocket、STOMP 协议、安全集成及集群部署等实战内容，帮助读者全面掌握这一技术。

WebSocket 基础

什么是 WebSocket？

WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议，由 IETF 定为标准 RFC 6455。它使得客户端和服务器之间的数据交换更加简单，服务端可以主动推送数据。

与 HTTP 的关系

WebSocket 建立连接时使用 HTTP 协议的 Upgrade 机制进行升级。客户端发起带有特殊头部的 HTTP 请求，服务器返回 101 状态码后，连接便切换到 WebSocket 协议。两者都基于 TCP，但 HTTP 是半双工且需频繁建立连接，而 WebSocket 连接一旦建立即可持续通信，开销更小。

工作流程

握手阶段：客户端发起 HTTP 请求，携带 Upgrade: websocket 头。
协议切换：服务器返回 101 状态码，同意切换。
数据传输：双方互相发送文本或二进制数据帧。
关闭连接：任意一方发送关闭帧，另一方响应后关闭 TCP。

Spring Boot 集成准备

Spring 框架从 4.0 开始引入 WebSocket 模块，Spring Boot 通过自动配置简化了过程。主要支持两种方式：

原生 WebSocket：基于 JSR-356，使用 @ServerEndpoint 注解。
STOMP over WebSocket：在 WebSocket 之上使用 STOMP 协议，提供类似消息队列的订阅发布模型。

创建一个基本 Spring Boot 项目，选择以下依赖：

<dependencies>
    <!-- Spring Boot WebSocket Starter -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-websocket</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web

相关免费在线工具

Keycode 信息
查找任何按下的键的javascript键代码、代码、位置和修饰符。在线工具，Keycode 信息在线工具，online
Escape 与 Native 编解码
JavaScript 字符串转义/反转义；Java 风格 \uXXXX（Native2Ascii）编码与解码。在线工具，Escape 与 Native 编解码在线工具，online
JavaScript / HTML 格式化
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。在线工具，JavaScript / HTML 格式化在线工具，online
JavaScript 压缩与混淆
Terser 压缩、变量名混淆，或 javascript-obfuscator 高强度混淆（体积会增大）。在线工具，JavaScript 压缩与混淆在线工具，online
Base64 字符串编码/解码
将字符串编码和解码为其 Base64 格式表示形式即可。在线工具，Base64 字符串编码/解码在线工具，online
Base64 文件转换器
将字符串、文件或图像转换为其 Base64 表示形式。在线工具，Base64 文件转换器在线工具，online

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;

@Configuration
public class WebSocketConfig {
    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter();
    }
}

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.concurrent.CopyOnWriteArraySet;

@ServerEndpoint("/ws/echo")
public class EchoWebSocket {
    private static final CopyOnWriteArraySet<Session> sessions = new CopyOnWriteArraySet<>();

    @OnOpen
    public void onOpen(Session session) {
        sessions.add(session);
        System.out.println("新连接加入，当前连接数：" + sessions.size());
        try {
            session.getBasicRemote().sendText("连接成功，欢迎！");
        } catch (IOException e) { e.printStackTrace(); }
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        System.out.println("收到消息：" + message);
        try {
            session.getBasicRemote().sendText("Echo: " + message);
        } catch (IOException e) { e.printStackTrace(); }
        broadcast("用户说：" + message);
    }

    @OnClose
    public void onClose(Session session) {
        sessions.remove(session);
        System.out.println("连接关闭，当前连接数：" + sessions.size());
    }

    @OnError
    public void onError(Session session, Throwable error) {
        error.printStackTrace();
    }

    public static void broadcast(String message) {
        for (Session session : sessions) {
            try {
                session.getBasicRemote().sendText(message);
            } catch (IOException e) { e.printStackTrace(); }
        }
    }
}

<!DOCTYPE html>
<html>
<head><title>WebSocket Echo Test</title></head>
<body>
<input type="text" id="messageInput" placeholder="输入消息" />
<button onclick="sendMessage()">发送</button>
<div id="messages"></div>
<script>
var ws = new WebSocket("ws://localhost:8080/ws/echo");
ws.onopen = function() { appendMessage("连接已建立"); };
ws.onmessage = function(event) { appendMessage("收到：" + event.data); };
ws.onclose = function() { appendMessage("连接关闭"); };
function sendMessage() {
    var msg = document.getElementById("messageInput").value;
    ws.send(msg);
    appendMessage("发送：" + msg);
    document.getElementById("messageInput").value = '';
}
function appendMessage(msg) {
    var div = document.getElementById("messages");
    div.innerHTML += "<p>" + msg + "</p>";
}
</script>
</body>
</html>

import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;

@Configuration
@EnableWebSocketMessageBroker
public class StompWebSocketConfig implements WebSocketMessageBrokerConfigurer {
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws-stomp")
                .setAllowedOrigins("*")
                .withSockJS(); // 启用 SockJS 降级方案
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.setApplicationDestinationPrefixes("/app");
        registry.enableSimpleBroker("/topic", "/queue");
        registry.setUserDestinationPrefix("/user");
    }
}

import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Controller;

@Controller
public class WebSocketController {
    @MessageMapping("/hello")
    @SendTo("/topic/greetings")
    public Greeting greeting(HelloMessage message) throws Exception {
        Thread.sleep(1000);
        return new Greeting("Hello, " + message.getName() + "!");
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.simp.SimpMessagingTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class PushController {
    @Autowired
    private SimpMessagingTemplate messagingTemplate;

    @GetMapping("/push")
    public String pushToAll() {
        messagingTemplate.convertAndSend("/topic/news", "突发新闻：Spring Boot 3.0 发布！");
        return "推送成功";
    }

    @GetMapping("/push/user")
    public String pushToUser(String userId) {
        messagingTemplate.convertAndSendToUser(userId, "/message", "您有一条私信");
        return "私信推送成功";
    }
}

<script src="https://cdnjs.cloudflare.com/ajax/libs/sockjs-client/1.6.1/sockjs.min.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/stomp.js/2.3.3/stomp.min.js"></script>
<script>
var stompClient = null;
function connect() {
    var socket = new SockJS('/ws-stomp');
    stompClient = Stomp.over(socket);
    stompClient.connect({}, function(frame) {
        console.log('连接成功：' + frame);
        stompClient.subscribe('/topic/greetings', function(greeting) {
            showGreeting(JSON.parse(greeting.body).content);
        });
        stompClient.subscribe('/user/message', function(message) {
            showGreeting("私信：" + message.body);
        });
    }, function(error) {
        console.log('连接失败：' + error);
    });
}
function sendName() {
    var name = document.getElementById('name').value;
    stompClient.send("/app/hello", {}, JSON.stringify({ 'name': name }));
}
window.onload = connect;
</script>

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.security.config.annotation.web.builders.HttpSecurity;
import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
import org.springframework.security.web.SecurityFilterChain;

@Configuration
@EnableWebSecurity
public class SecurityConfig {
    @Bean
    public SecurityFilterChain filterChain(HttpSecurity http) throws Exception {
        http.authorizeRequests()
            .antMatchers("/ws-stomp/**").authenticated()
            .anyRequest().permitAll()
            .and().formLogin().permitAll()
            .and().logout().permitAll()
            .and().csrf().disable();
        return http.build();
    }
}

@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
    registry.setApplicationDestinationPrefixes("/app");
    registry.enableStompBrokerRelay("/topic", "/queue")
            .setRelayHost("localhost")
            .setRelayPort(61613)
            .setClientLogin("guest")
            .setClientPasscode("guest");
    registry.setUserDestinationPrefix("/user");
}

Spring Boot 集成 WebSocket 实战：从原生到 STOMP 全解析

背景与动机

WebSocket 基础

什么是 WebSocket？

与 HTTP 的关系

工作流程

Spring Boot 集成准备

更多推荐文章

相关免费在线工具

原生 WebSocket 实现

配置处理器

编写处理类

前端测试

基于 STOMP 的实现

配置消息代理

Controller 处理消息

灵活推送消息

前端接入

安全集成

配置 Security

获取用户信息

集群环境下的 WebSocket

解决方案

性能优化与最佳实践

常见问题

总结

更多推荐文章

相关免费在线工具

Spring Boot 集成 WebSocket 实战：从原生到 STOMP 全解析

背景与动机

WebSocket 基础

什么是 WebSocket？

与 HTTP 的关系

工作流程

Spring Boot 集成准备

微信扫一扫，关注极客日志

更多推荐文章

相关免费在线工具

原生 WebSocket 实现

配置处理器

编写处理类

前端测试

基于 STOMP 的实现

配置消息代理

Controller 处理消息

灵活推送消息

前端接入

安全集成

配置 Security

获取用户信息

集群环境下的 WebSocket

解决方案

性能优化与最佳实践

常见问题

总结

微信扫一扫，关注极客日志

更多推荐文章

相关免费在线工具