angular2 не может отправить сообщение весеннему топу через websocket

Question

Я использую пружинный штамп над портом websocket 8080 и angular2 4200 port

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

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

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/query/company/socket")
        .setAllowedOrigins("*")
        .withSockJS();
    }

}

а также:

@MessageMapping("/hello")
    @SendTo("/topic/greetings")
    public Greeting greeting(HelloMessage message) throws Exception {
        System.out.println(" start is : name is : "+message.getName());
        Thread.sleep(1000); // simulated delay
        return new Greeting("Hello, " + message.getName() + "!");
    }

и angular2:

import * as SockJS from 'sockjs-client';
const Stomp = require('stompjs/lib/stomp').Stomp;
import {BehaviorSubject} from "rxjs";


    export class AppComponent implements OnInit{
      private host='http://localhost:8080';
      private url = `${this.host}/query/company/socket`;
      private subUrl=`${this.host}/topic/greetings`;
      private sendUrl=`${this.host}/app/hello`;
      public stompClient: any;

      ngOnInit(): void {
        this.connect();
      }

      connect() {
        var that = this;
        var socket = new SockJS(this.url);
        this.stompClient = Stomp.over(socket);
        this.stompClient.connect({}, function (frame) {
          console.log('Connected: ' + frame);
          that.stompClient.subscribe(this.subUrl, function (greeting) {
            console.log(JSON.parse(greeting.body).content);
          });
        }, function (err) {
          console.log('err', err);
        });
      }

      public send() {

        this.stompClient.send(this.sendUrl , {},      JSON.stringify({ 'name': 'jack' }));

      }
}

при работе: хромированная консоль ---

Web Socket Opened...
stomp.js:134 >>> CONNECT
accept-version:1.1,1.0
heart-beat:10000,10000


stomp.js:134 <<< CONNECTED
version:1.1
heart-beat:0,0


stomp.js:134 connected to server undefined
app.component.ts:41 Connected: CONNECTED
heart-beat:0,0
version:1.1


stomp.js:134 >>> SUBSCRIBE
id:sub-0
destination:undefined

>>> SEND
destination:http://localhost:8080/app/hello
content-length:13

{"name":"ll"}

при отправке сообщения:

пружинная консоль:

WebSocketSession[1 current WS(1)-HttpStream(0)-HttpPoll(0), 1 total, 0 closed abnormally (0 connect failure, 0 send limit, 0 transport error)], stompSubProtocol[processed CONNECT(1)-CONNECTED(1)-DISCONNECT(0)], stompBrokerRelay[null], inboundChannel[pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 9], outboundChannelpool size = 0, active threads = 0, queued tasks = 0, completed tasks = 1], sockJsScheduler[pool size = 4, active threads = 1, queued tasks = 2, completed tasks = 441]

при отправке сообщения спереди пружина должна распечатать:

System.out.println(" start is : name is : "+message.getName());

но это не..

и angular2 не получил никакого ответа..

Answer 1

Я решил это.

хотя у меня angular2 и весна используют разные порты, 4200,8080.

когда я переоденусь

private host='http://localhost:8080';
 private subUrl=`${this.host}/topic/greetings`;
private sendUrl=`${this.host}/app/hello`;

в

private subUrl='/topic/greetings';
private sendUrl='/app/hello';

работает нормально,

но я не знаю причину.

Answer 2

Я запускаю ту же проблему с 2 приложениями, работающими на разных серверах. Независимо от угла я также зарегистрировал клиента таким образом:

...
var socket = new SockJS('http://localhost:8099/websocket');
...
stompClient.subscribe('http://localhost:8099/ws/update', function (msg){
   console.log("received:", msg.body);
});

С этим связыванием я не получил никаких ответов от сервера, даже мой браузер сокет перечислил сообщения. Но по какой-то причине часть подписки должна быть без хоста. Теперь мой код выглядит так:

...
var socket = new SockJS('http://localhost:8099/websocket');
...
stompClient.subscribe('/ws/update', function (msg){
   console.log("received:", msg.body);
});