如何与 spring websocket 通信

Question

我正在尝试构建一个应用程序，其中服务器将在某个时间间隔内不断向客户端推送消息。我有一个像这样的简单 html 文件。

    <script src="https://ajax.googleapis.com/ajax/libs/angularjs/1.6.4/angular.min.js"></script>
<script src="sockjs/sockjs.js"></script>
<script src="stomp/stomp.js"></script>
<div ng-app="myApp" ng-controller="myCtrl">
<button ng-click='connect()'>hi</button>
</div>

<script>
var app = angular.module('myApp', []);

app.controller('myCtrl', function($scope) {
    $scope.connect = function() {
        var socket = new SockJS('http://localhost:8099/myws');
        $scope.stompClient = Stomp.over(socket);
        $scope.stompClient.connect({}, function (frame) {
            console.log('Connected:bhabani ' + frame);
            $scope.stompClient.subscribe('http://localhost:8099/topic/jobconfig', function (wsdata) {
                console.log("helloooooooooooooooooooooooooooooooooooooooooooooooooo");
                console.log(wsdata);
            });
        });
    }
});
</script>

我打开了文件系统中的html文件。 file:///export/data1/test-ws.html 在浏览器中。

现在我有一个像这样的 spring 网络套接字。

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

    @Autowired
    private GreetingController gc;

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

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/myws").setAllowedOrigins("*").withSockJS();
        new Thread(gc).start();
    }

}

有一个像这样的问候控制器，它应该在某些内部向主题推送消息

@Component
public class GreetingController implements Runnable{

    @Autowired
    private SimpMessagingTemplate template;

    public void run() {
        try {
            Thread.sleep(10000);
        } catch (InterruptedException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }
        while(true){
        try {
            System.out.println("Sending");
            Thread.sleep(1000);
            template.convertAndSend("/topic/jobconfig", new Greeting("hi"));
        } catch (Exception e) {
            e.printStackTrace();
        }
        }
    }

在我按下连接按钮的地方，我可以看到连接已建立。但在那之后我没有看到任何应该从服务器推送的消息进入浏览器。

我希望 'helloooooooooooo' 消息应在每个时间间隔内打印在我的浏览器控制台中。

Answer 1

将 stomp 客户端订阅代码中的 URL 从这个 http://localhost:8099/topic/jobconfig 更改为这个 /topic/jobconfig。

$scope.stompClient.subscribe('/topic/jobconfig', function(wsdata) {
                    console.log("hello");
                    console.log(wsdata);
                });

如何与 spring websocket 通信

How to communicate with spring websocket

javascript

spring

spring-mvc

websocket

sockjs