activemq js接收消息

ActiveMQ 是一个流行的开源消息中间件，它支持多种消息协议，包括 AMQP、MQTT、STOMP 等。在前端使用 JavaScript 接收 ActiveMQ 消息通常涉及到 WebSocket 或者 Server-Sent Events (SSE) 技术，因为这些技术允许浏览器与服务器进行双向通信。

基础概念

消息中间件：消息中间件是一种软件，它在应用程序之间传递消息，从而实现解耦和异步通信。

ActiveMQ：Apache ActiveMQ 是一个开源的消息代理，它实现了 Java 消息服务 (JMS) API，并提供了高性能、可靠的消息传递。

WebSocket：WebSocket 是一种网络通信协议，它提供了一种在单个 TCP 连接上进行全双工通信的方式。

Server-Sent Events (SSE)：SSE 是一种允许服务器向浏览器推送实时信息的单向通信技术。

优势

实时性：WebSocket 和 SSE 都能提供接近实时的消息传递。
解耦：消息中间件可以减少应用程序之间的依赖，使得系统更加灵活和可维护。
异步处理：消息队列允许应用程序异步处理消息，提高系统的响应能力和吞吐量。

类型

点对点 (Point-to-Point)：每个消息只有一个消费者。
发布/订阅 (Publish/Subscribe)：每个消息可以被多个订阅者接收。

应用场景

实时通知：如聊天应用、股票价格更新等。
日志处理：将日志消息发送到中央日志服务器进行分析。
任务分发：将任务分发给多个工作节点进行处理。

示例代码

以下是一个使用 WebSocket 接收 ActiveMQ 消息的简单示例：

// 创建 WebSocket 连接
const socket = new WebSocket('ws://your-active-mq-server:61614/stomp');

// 连接打开时的事件处理
socket.onopen = function() {
    console.log('WebSocket connection opened');
    // 订阅消息
    socket.send(JSON.stringify({
        command: 'subscribe',
        destination: '/topic/your-topic-name'
    }));
};

// 接收到消息时的事件处理
socket.onmessage = function(event) {
    const message = JSON.parse(event.data);
    console.log('Received message:', message);
    // 处理消息...
};

// 连接关闭时的事件处理
socket.onclose = function() {
    console.log('WebSocket connection closed');
};

// 连接错误时的事件处理
socket.onerror = function(error) {
    console.error('WebSocket error:', error);
};