spring-boot - 没有 SockJS 的 Spring 启动 Websocket

Question

我已经为此挣扎了至少两个星期。我对 websockets 很陌生。我对休息端点有很好的经验。
我的用例很简单。客户端启动一个 websocket 连接，向服务器发送一些信息，服务器使用该信息，并以固定的时间间隔(例如每 5 秒)向客户端发送一些信息。
我按照这里的教程 - https://spring.io/guides/gs/messaging-stomp-websocket/
正如解释的那样，它完美地工作。
根据上面的教程，客户端发起一个 http 请求，该请求被升级为 websocket。
就我而言，前端是一个 angular 10 应用程序，前端开发人员更喜欢使用 rxjs/websocket并且不想使用 SockJS client ，因为他确信我们不必支持任何旧版浏览器，这就是我感到震惊的地方。
显然 rxjs/websocket需要网址 ws://协议(protocol)。
从以下片段中，我认为我的等效 ws 协议(protocol)是ws://localhost:8080/test但是，它似乎不起作用。我不确定出了什么问题。任何帮助是极大的赞赏!

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer
{

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config)
    {
        config.enableSimpleBroker("/topic");
        config.setApplicationDestinationPrefixes("/ws/");
    

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry)
    {
        registry.addEndpoint("/test");
    }

}

从教程，我改了app.js ，如下进行测试。

function connect() {
    // var socket = new SockJS('http://localhost:8080/test'); This works perfectly
    // stompClient = Stomp.over(socket);
    ws = new WebSocket('ws://localhost:8080/test');
    stompClient = Stomp.client(ws);

    stompClient.connect({}, function (frame) {
        setConnected(true);
        console.log('Connected: ' + frame);
        stompClient.subscribe('/topic/' + $("#site").val(), function (message) {
            showMessageSentFromServer(JSON.stringify(message.body));
        });
    });
}

当我打开 chrome 的开发者工具并检查时，我看到 websocket 连接已经建立和升级，或者我看到的就是这样。但是，在控制台中，我看到如下错误日志。我不确定出了什么问题。
网络截图:

控制台故障日志:

stomp.min.js:8 Uncaught DOMException: Failed to construct 'WebSocket': The URL '[object WebSocket]' is invalid.
    at Object.client (http://localhost:8080/webjars/stomp-websocket/stomp.min.js:8:7229)
    at connect (http://localhost:8080/app.js:18:25)
    at HTMLButtonElement.<anonymous> (http://localhost:8080/app.js:54:9)
    at HTMLButtonElement.dispatch (http://localhost:8080/webjars/jquery/jquery.min.js:3:10315)
    at HTMLButtonElement.q.handle (http://localhost:8080/webjars/jquery/jquery.min.js:3:8342)

现在长话短说，我设法通过删除 withSockJS() 在服务器端禁用了 SockJs。 .那么我的等价物是什么 ws协议(protocol)网址？
此外，除此之外，我面临的另一个挑战是，如何根据客户端的输入设置一个计划进程，该进程可以将消息发送到客户端订阅的 websocket 主题。我知道使用 @Scheduled 设置预定进程很容易。注解。但在我的情况下，我想要来自客户端的一些输入，这些输入在预定流程中是必需的。
另外，请分享您拥有的任何资源或示例，这些资源或示例解释了如何使用 rxjs 实现对主题的 websocket stomp 客户端订阅。

Answer 1

我能够通过进行两个简单的更改来解决这个问题。

我让我的后端支持 ws和 http通过向 WebSocketConfig 添加两个端点来实现协议(protocol)如下图——一个有一个没有sockjs如下图，这使得我的后端在支持两种协议(protocol)建立方面更加灵活websocket联系。我不知道为什么在 spring 文档或其他任何地方都没有提到这一点。或许，人们以为是隐含的!

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer
{

        @Override
        public void configureMessageBroker(MessageBrokerRegistry config)
        {
                config.enableSimpleBroker("/topic");
                config.setApplicationDestinationPrefixes("/ws/");
        }

        @Override
        public void registerStompEndpoints(StompEndpointRegistry registry)
        {
                registry.addEndpoint("/test"); // This will allow you to use ws://localhost:8080/test to establish websocket connection
                registry.addEndpoint("/test").withSockJS(); // This will allow you to use http://localhost:8080/test to establish websocket connection
        }

}

正如 @arturgrzesiak 所指出的在之前的评论中，传递给 Stomp.client(url) 的参数存在错误。我傻了路过ws对象而不是普通 url .

stompClient = Stomp.client('ws://localhost:8080/test');

最后，
如果有人想使用 SockJS客户端连接，他们可以使用连接

var socket = new SockJS('http://localhost:8080/test');
stompClient = Stomp.over(socket);

如果有人只想使用普通的 Websocket要连接的对象，请使用以下内容。

stompClient = Stomp.client('ws://localhost:8080/test');

我发布了这个解决方案，因为这对有类似痛苦经历的人很有用，他们可能会发现它很有用。