我已经为此挣扎了至少两个星期。我对 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");
}
}
Run Code Online (Sandbox Code Playgroud)
从教程中,我更改了app.js,如下以测试这一点。
function connect() {
// var socket = new SockJS('http://localhost:8080/test'); This works perfectly
// stompClient = Stomp.over(socket);
ws …Run Code Online (Sandbox Code Playgroud) 我们计划淘汰现有的旧Java批处理应用程序,并使用最新的可用批处理框架重新创建它.鉴于我们有大量的批处理作业需要现代化,我们正在寻找一个允许我们的框架或架构
spring spring-batch spring-boot spring-cloud spring-cloud-task