0

我无法连接到 RabbitMQ 实例，并且找不到很好的教程或指南。我可以通过以下方式连接到 RabbitMQ websocket

var ws = new WebSocket('ws://localhost:15674/ws')

但是现在我不知道如何使用我的凭据连接到我的集群。我还需要从这样的队列中使用消息/exchange/myExchange/routingKey。RxStompService通过使用以下代码，我可以轻松地在角度应用程序中做到这一点


  rxStompService.configure({
          brokerURL: `ws://localhost:15674/ws`,
          connectHeaders: {
            login: 'guest',
            passcode: 'guest'
          },
          heartbeatIncoming: 0, // Typical value 0 - disabled
          heartbeatOutgoing: 20000, // Typical value 20000 - every 20 seconds
          reconnectDelay: 200,
          debug: (msg: string): void => {
            console.log(new Date(), msg);
          }
        })

  this.exchange = 'myExchange'
  this.routingKey = 'routingKey'
  this.headers ={
    'x-queue-name': 'myQueue',
    'durable': 'true',
    'auto-delete': 'false'
  }

  ngOnInit() {
    this.rxStompService.watch(`/exchange/${this.exchange}/${this.routingKey}`, this.headers ).subscribe((message: Message) => {
     this.user = new User(JSON.parse(message.body))
    });
  }

我怎么能从我的反应应用程序中做同样的事情？

4

1 回答 1

0

我能够使用stompjs.

import Stomp from 'stompjs'


export function connectRabbit(){

let stompClient

    var ws = new WebSocket('ws://localhost:15674/ws')

    const headers = {
        'login': 'guest',
        'passcode': 'guest',
        'durable': 'true',
        'auto-delete': 'false'
    }
    stompClient = Stomp.over(ws)

    stompClient.connect(headers , function(frame){
                console.log('Connected')
               const subscription = stompClient.subscribe('/queue/myQueue', function(message){
                   console.log(message)
               })
    })

}
于 2019-11-05T20:42:24.293 回答