没有SockJS的Spring启动Websocket
我已经为此挣扎了至少两个星期。我对 websockets 很陌生。我对休息端点有很好的经验。
我的用例很简单。客户端启动一个 websocket 连接,向服务器发送一些信息,服务器使用该信息,并以固定的时间间隔(例如每 5 秒)向客户端发送一些信息。我按照这里的教程 - https://spring.io/guides/gs/messaging-stomp-websocket/
它按照解释完美运行。根据上面的教程,客户端发起一个 http 请求,该请求被升级为 websocket。
就我而言,前端是一个 angular 10 应用程序,前端开发人员更喜欢使用rxjs/websocket,不想使用SockJS client,因为他确信我们不必支持任何旧版浏览器,这就是我感到震惊的地方. 显然rxjs/websocket在ws://协议中需要 url 。
从下面的片段中,我认为我的等效 ws 协议是
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)
现在长话短说,我设法在服务器端禁用了 SockJs,通过删除withSockJS(). 那么我的等效ws协议 URL 是什么?
此外,除此之外,我面临的另一个挑战是,如何根据客户端的输入设置一个计划进程,该进程可以将消息发送到客户端订阅的 websocket 主题。我知道使用@Scheduled注释设置预定流程很容易。但在我的情况下,我想要来自客户端的一些输入,这些输入在预定流程中是必需的。
另外,请分享您拥有的任何资源或示例,这些资源或示例解释了如何使用 Websocket stomp 客户端订阅主题 rxjs