如何解决没有 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)
长话短说,我设法通过删除 withSockJS()
在服务器端禁用了 SockJs。那么我的等效 ws
协议网址是什么?
此外,除此之外,我面临的另一个挑战是,如何根据客户端的输入设置一个计划进程,该进程可以将消息发送到客户端订阅的 websocket 主题。我知道使用 @Scheduled
注释设置预定进程很容易。但就我而言,我希望客户提供一些在预定流程中所需的输入。
此外,请分享您拥有的任何资源或示例,这些资源或示例解释了如何使用 rxjs
解决方法
我通过两个简单的更改就解决了这个问题。
- 我通过向
ws
添加两个端点,使我的后端支持http
和WebSocketConfig
协议,如下所示 - 一个带有sockjs
作为如下所示,这使我的后端在支持两种协议以建立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');
我发布了这个解决方案,因为这对有类似痛苦经历的人很有用,他们可能会发现它很有用。
,如评论中所述:
来自 stomp 文档:var url = "ws://localhost:15674/ws"; var client = Stomp.client(url); - 你应该只传递 url 字符串而不是已经创建的 websocket 对象。
,您可以尝试使用
var client = Stomp.overWS('ws://localhost:61614');
参考:https://github.com/jmesnil/stomp-websocket
,我不是专家,但我虽然所有 WebSocket URI 都使用方案 ws: 或 wss: 来实现安全的 WebSocket。要更熟悉 WebSockets,您应该查看 How Do Websockets Work?。
当我开始使用 Websockets 时,我从 Androidhive; Building Group Chat App using Sockets
中学到了很多东西我不太习惯 spring Websockets,但在过去,当我使用 Java EE 时,它相对简单。您所要做的就是使用带注释的@ServerEndpoint 配置服务器端点。在那里你会使用带有注释的函数
@OnMessage
public String onMessage(String message,Session session) {
...
}
@OnOpen
public void onOpen(Session session) {
...
// Here you can start a session handler
// which will send message every 5 sec or so.
s = new SessionHandler(session,id);
s.start();
}
@OnClose
public void onClose(Session session) {
...
}
这是您发送消息的方式
public void send(String msg) throws IOException {
session.getBasicRemote().sendText(msg);
// session.getBasicRemote().flushBatch();
}
这里是 javascript 方面,
var wsUri = "ws://" + (document.location.hostname === "" ? "localhost" : document.location.hostname) + ":" +
(document.location.port === "" ? "80" : document.location.port);
var websocket;
function connect() {
websocket = new WebSocket(wsUri);
websocket.onopen = function (evt) {
onOpen(evt);
};
websocket.onmessage = function (evt) {
onMessage(evt);
};
websocket.onerror = function (evt) {
onError(evt);
};
websocket.onclose = function (evt) {
onClose(evt);
};
}
connect();
我知道这专注于 Java EE,但也许您可以考虑使用 Java EE,它不再那么糟糕了。如果您有兴趣,请查看此更深入的示例How to build applications with the WebSocket API for Java EE and Jakarta EE
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。