stompjs使用文档总结

简介

StompJS 是一个用于浏览器和 Node.js 的简单、有效且易于使用的 STOMP 客户端。 STOMP 是一种流行的文本协议，用于通过消息队列传输协议（例如 Apache ActiveMQ，RabbitMQ 等）进行异步消息传递。 此客户端基于 Websockets（在现代浏览器中）或 AJAX 长轮询（在较旧浏览器中）。

安装

可以使用 npm 或 yarn 安装 StompJS：

npm install stompjs

连接到 STOMP 服务器

首先，需要创建 STOMP 客户端。 创建 STOMP 客户端需要一个 WebSocket 或 HTTP 长轮询连接。 下面是创建 WebSocket 连接的示例代码：

import Stomp from 'stompjs';

let stompClient = Stomp.client('ws://localhost:15674/ws');
stompClient.connect({}, frame => {
    console.log('Connected: ' + frame);
});

要使用HTTP长轮询连接，则可以使用以下代码：

import Stomp from 'stompjs';

let socket = new SockJS('http://localhost:15674/stomp');
let stompClient = Stomp.over(socket);
stompClient.connect({}, frame => {
    console.log('Connected: ' + frame);
});

订阅主题

要订阅主题，需要使用 subscribe() 方法。 下面是订阅一个名为 '/topic/greetings' 的主题的示例代码：

let stompClient = Stomp.client('ws://localhost:15674/ws');
stompClient.connect({}, frame => {
    stompClient.subscribe('/topic/greetings', message => {
        console.log(`Received: ${message.body}`);
    });
});

发布消息

要向主题发布消息，需要使用 send() 方法。 下面是发布一个名为 '/app/hello' 的主题的示例代码：

let stompClient = Stomp.client('ws://localhost:15674/ws');
stompClient.connect({}, frame => {
    stompClient.send('/app/hello', {}, 'Hello, World!');
});

断开连接

要断开连接，需要使用 disconnect() 方法。 下面是断开连接的示例代码：

let stompClient = Stomp.client('ws://localhost:15674/ws');
stompClient.connect({}, frame => {
    console.log('Connected: ' + frame);

    stompClient.disconnect(() => {
        console.log('Disconnected');
    });
});

总结

StompJS 是一个方便易用的 STOMP 客户端，可以用于浏览器和 Node.js 等环境中。 可以使用 connect() 方法连接到 STOMP 服务器，使用 subscribe() 方法订阅主题，并使用 send() 方法发布消息。 此外，StompJS 还提供了其他一些有用的功能，例如错误处理和断开连接的处理。