springboot整合websocket进行 推送文件

我们很高兴能回答您的问题。要使用Spring Boot整合WebSocket进行文件推送，您可以按照以下步骤操作：

1. 引入WebSocket依赖
在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

2. 配置WebSocket配置类
创建WebSocket配置类，用于配置WebSocket相应的参数：

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(myHandler(), "/ws").setAllowedOrigins("*");
    }

    @Bean
    public WebSocketHandler myHandler() {
        return new MyHandler();
    }
}

3. 编写WebSocket处理器
创建一个WebSocketHandler的实现类，用于处理WebSocket连接和消息的传输：

public class MyHandler implements WebSocketHandler {

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        System.out.println("Connection established: " + session);
    }

    @Override
    public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
        if (message instanceof BinaryMessage) {
            // 接收二进制文件，并将其保存到指定路径
            BinaryMessage binaryMessage = (BinaryMessage) message;
            byte[] data = binaryMessage.getPayload().array();
            FileOutputStream fos = new FileOutputStream("/path/to/save/file");
            fos.write(data);
            fos.close();
        }
    }

    @Override
    public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
        System.out.println("Transport error: " + exception);
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
        System.out.println("Connection closed: " + closeStatus);
    }

    @Override
    public boolean supportsPartialMessages() {
        return false;
    }
}

4. 前端连接WebSocket
在前端代码中连接WebSocket，用于向服务端发送文件：

var ws = new WebSocket("ws://localhost:8080/ws");

function sendFile(file) {
    var reader = new FileReader();
    reader.onload = function(e) {
        var arrayBuffer = e.target.result;
        var binaryMessage = new Blob([arrayBuffer], {type: file.type});
        ws.send(binaryMessage);
    };
    reader.readAsArrayBuffer(file);
}

注：上述代码仅作为示例，请根据具体需要进行修改。

希望这个答案可以帮助到您！