首页 > 解决方案 > 如何在Spring中创建一个服务来监听请求

问题描述

我是 Spring 框架的新手。我已经有一个 Spring 服务,它向/topic/liveFeed. 这是我现有服务的代码

public class DataPublisher {

  @Autowired private SimpMessagingTemplate webSocket;

  @Scheduled(fixedRate = 1000)
  public void publish() throws Exception {

    ...

  webSocket.convertAndSend("/topic/liveFeed", currentTick);
  }
}

在我的app.js我有

function connect() {
  var socket = new SockJS('/stocks');
  stompClient = Stomp.over(socket);
  stompClient.connect({}, function (frame) {
  setConnected(true);
  console.log('Connected: ' + frame);
  stompClient.subscribe('/topic/liveFeed', function (tick) {
  console.log(tick)
});
});
}

所以,看起来这个服务正在向 发送请求/topic/liveFeed,所以我需要创建另一个服务来监听/topic/liveFeed和处理请求。有人可以帮助我应该从哪里开始以及我需要哪些其他组件?

标签: javaspringjava-websocket

解决方案


推荐阅读