刘勇虎的官方网站

使用相关技术

• vuejs
• stompjs

初始化客户端

console.log("VUE_APP_STOMP_URL  ", process.env.VUE_APP_STOMP_URL);

    if (this.stompClient === null) {
      this.stompClient = Stomp.client(process.env.VUE_APP_STOMP_URL);
      //   console.log("this.stompClient  ", JSON.stringify(this.stompClient));
      const client = this.stompClient;
      client.connect({ username: "1" }, function(frame) {
        console.log("连接服务端成功");
        console.log("Connected: " + frame);
        console.log("this.stompClient  ", JSON.stringify(client));
        client.subscribe("/queue/trafficQueue", function(m) {
          // reply by sending the reversed text to the temp queue defined in the "reply-to" header
          var reversedText = m.body
            .split("")
            .reverse()
            .join("");

          // client.send('/topic/test', {"content-type":"text/喷脸ain"}, reversedText);
          console.log("收到消息：" + m.body);
        });
      });
    }

连接前客户端信息

{
  "ws": {},
  "counter": 0,
  "connected": false,
  "heartbeat": { "outgoing": 10000, "incoming": 10000 },
  "maxWebSocketFrameSize": 16384,
  "subscriptions": {}
}

连接后客户端信息

{
  "ws": {},
  "counter": 0,
  "connected": true,
  "heartbeat": { "outgoing": 10000, "incoming": 10000 },
  "maxWebSocketFrameSize": 16384,
  "subscriptions": {},
  "serverActivity": 1615433916730,
  "pinger": 32,
  "ponger": 33
}

参考

rabbitmq-stomp

rabbitmq-web-stomp

github-stomp-websocket

stomp-websocket