SpringBoot+WebSocket向前端推送消息的实现示例_Java

什么是websocket

websocket是一种在单个tcp连接上进行全双工通信的协议，允许服务器主动向客户端推送信息，同时也能从客户端接收信息。

websocket协议诞生于2008年，并在2011年成为国际标准。这种协议解决了传统http请求中需要不断轮询服务器的问题，通过建立持久化的连接，实现了高效的双向数据传输。具体如下：

基本特点：websocket建立在tcp协议之上，提供了一个全双工通信通道。这意味着服务器和客户端可以在一个连接上同时发送和接收信息，且数据交换更加高效。
协议兼容：虽然websocket是一个独立的协议，但它在握手阶段使用http协议，以确保与现有系统的兼容性。其默认端口也是80和443，使得它可以通过各种http代理服务器。
应用场景：websocket非常适合需要实时数据交互的应用，如聊天应用、在线游戏、实时通知等。
数据格式：websocket支持传输文本和二进制数据，并且数据格式轻量，开销小，性能高。
api使用：在开发中，可以使用websocket api轻松地创建和管理连接，并通过这些连接发送和接收数据。例如，在javascript中，可以这样创建和处理websocket连接：

// 创建websocket连接
var socket = new websocket('ws://localhost:8080');

// 连接成功触发
socket.addeventlistener('open', function (event) {
    socket.send('hello server!');
});

// 监听消息
socket.addeventlistener('message', function (event) {
    console.log('message from server ', event.data);
});

综上所述，websocket通过提供高效、低开销的双向通信协议，极大地改善了实时数据传输的体验，适用于需要频繁数据交互的应用场景。

实现

1、在你的pom.xml文件中添加以下依赖：

<dependency>
    <groupid>org.springframework.boot</groupid>
    <artifactid>spring-boot-starter-websocket</artifactid>
</dependency>

2、创建一个配置类，继承abstractwebsocketmessagebrokerconfigurer，并重写configuremessagebroker和registerstompendpoints方法。

import org.springframework.context.annotation.configuration;
import org.springframework.messaging.simp.config.messagebrokerregistry;
import org.springframework.web.socket.config.annotation.abstractwebsocketmessagebrokerconfigurer;
import org.springframework.web.socket.config.annotation.enablewebsocketmessagebroker;
import org.springframework.web.socket.config.annotation.stompendpointregistry;

@configuration
@enablewebsocketmessagebroker
public class websocketconfig extends abstractwebsocketmessagebrokerconfigurer {

    @override
    public void configuremessagebroker(messagebrokerregistry config) {
        config.enablesimplebroker("/topic");
        config.setapplicationdestinationprefixes("/app");
    }

    @override
    public void registerstompendpoints(stompendpointregistry registry) {
        registry.addendpoint("/websocket").withsockjs();
    }
}

3、创建一个类，用于处理客户端发送的消息和向客户端发送消息。

import org.springframework.messaging.handler.annotation.messagemapping;
import org.springframework.messaging.handler.annotation.sendto;
import org.springframework.stereotype.controller;

@controller
public class websocketcontroller {

    @messagemapping("/send")
    @sendto("/topic/messages")
    public string handlemessage(string message) {
        return "received: " + message;
    }
}

4、在前端，你需要使用sockjs和stomp.js库来连接websocket服务器并接收消息。首先，确保你已经在html文件中引入了这两个库：

<script src="https://cdnjs.cloudflare.com/ajax/libs/sockjs-client/1.5.0/sockjs.min.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/stomp.js/2.3.3/stomp.min.js"></script>

5、然后，你可以使用以下javascript代码连接到websocket服务器并接收消息：

// 建立连接
var socket = new sockjs('/websocket');
var stompclient = stomp.over(socket);

// 连接到服务器
stompclient.connect({}, function (frame) {
    console.log('connected: ' + frame);

    // 订阅消息
    stompclient.subscribe('/topic/messages', function (message) {
        console.log('received: ' + message.body);
    });
});

// 发送消息
function sendmessage() {
    var message = document.getelementbyid('message').value;
    stompclient.send("/app/send", {}, message);
}

现在，当你调用sendmessage函数时，它将通过websocket向后端发送消息，后端将处理该消息并将其广播到所有订阅了/topic/messages的客户端。

到此这篇关于springboot+websocket向前端推送消息的实现示例的文章就介绍到这了,更多相关springboot websocket推送消息内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！