Spring Boot实现前后端实时通信 WebSocket SSE Long Polling

谁借莪１个温暖的怀抱￠ 2023-09-29 23:37 15阅读 0赞

#### Spring Boot实现前后端实时通信 ####

*  WebSocket
 *  SSE
 *  Long Polling

Spring Boot是一款非常流行的Java Web框架，而前后端实时通信是现代Web应用程序的重要组成部分。本文将介绍几种Spring Boot整合前后端实时通信的方案。

![在这里插入图片描述][e3a2e51e808241e6bf0b0de305d8ba41.png]

## WebSocket ##

WebSocket是HTML5标准中一种新型的通信协议，它可以实现双向通信，使得服务器可以主动向客户端发送数据，而不必等待客户端请求。Spring Boot通过Spring WebSocket模块提供了对WebSocket的支持。在Spring Boot中使用WebSocket非常简单，只需要在服务器端定义一个WebSocket处理器，然后在客户端使用JavaScript API即可实现实时通信。下面是一个简单的示例：

首先在服务器端定义一个WebSocket处理器：

@Configuration
    @EnableWebSocket
    public class WebSocketConfig implements WebSocketConfigurer {
        
    
        @Override
        public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        
            registry.addHandler(myWebSocketHandler(), "/ws").setAllowedOrigins("*");
        }
    
        @Bean
        public WebSocketHandler myWebSocketHandler() {
        
            return new MyWebSocketHandler();
        }
    }
    
    public class MyWebSocketHandler extends TextWebSocketHandler {
        
        @Override
        protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        
            String payload = message.getPayload();
            // 处理收到的消息
            session.sendMessage(new TextMessage("Hello, client"));
        }
    }

在客户端使用JavaScript API：

var ws = new WebSocket("ws://localhost:8080/ws");
    ws.onopen = function() {
        
      console.log("WebSocket connected");
    };
    ws.onmessage = function(event) {
        
      console.log("Received message: " + event.data);
    };
    ws.send("Hello, server");

## SSE ##

SSE（Server-Sent Events）是一种基于HTTP的实时通信协议，它允许服务器向客户端发送持久性的数据流。与WebSocket不同的是，SSE是单向通信，只能由服务器向客户端发送数据。Spring Boot通过Spring WebFlux模块提供了对SSE的支持。下面是一个简单的示例：

首先在服务器端定义一个SSE控制器：

@RestController
    public class MySseController {
        
        @GetMapping(value = "/sse", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
        public Flux<String> sse() {
        
            return Flux.interval(Duration.ofSeconds(1))
                    .map(sequence -> "Server sent event " + sequence);
        }
    }

在客户端使用JavaScript API：

var source = new EventSource("/sse");
    source.onmessage = function(event) {
        
      console.log("Received message: " + event.data);
    };

## Long Polling ##

Long Polling是一种基于HTTP的实时通信协议，它允许客户端向服务器发送请求，并且服务器可以保持响应不返回，直到有数据可用或者超时为止。Spring Boot中可以使用Spring WebFlux模块提供的WebClient来实现Long Polling。下面是一个简单的示例：

在服务器端定义一个REST控制器：

@RestController
    public class MyRestController {
        
        @GetMapping("/poll")
        public Mono<String> poll() {
        
        	return Mono.just("Hello, client");
    	}
    }

在客户端使用JavaScript API：

以上三种方案都可以用于Spring Boot整合前后端实时通信，每种方案都有其适用的场景和优缺点。WebSocket适用于双向通信，可以实现实时聊天和游戏等应用；SSE适用于单向通信，可以实现实时推送和事件通知等应用；Long Polling适用于低频数据交换，可以实现实时更新和轮询等应用。开发者可以根据具体场景选择最合适的方案。

[e3a2e51e808241e6bf0b0de305d8ba41.png]: https://img-blog.csdnimg.cn/e3a2e51e808241e6bf0b0de305d8ba41.png