MQTT开发笔记：windows下C++ ActiveMQ客户端介绍、编译和使用

2023-09-30 04:06:20

写在前面

在项目的需求下，我们遇到了使用MQTT协议的任务。之前我们曾编译过QtMqtt库，但它不支持队列模式（点对点），只支持订阅/发布者模式。因此，我们决定使用C++ ActiveMQ来实现MQTT协议。

MQTT协议简介

MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息协议，专为物联网（IoT）设备而设计。它支持低带宽和高延迟的网络，并可以有效地处理大量设备。MQTT协议使用发布/订阅模式，其中发布者将消息发布到主题，而订阅者订阅这些主题以接收消息。

编译和使用C++ ActiveMQ客户端

步骤1：下载和安装ActiveMQ

首先，我们需要下载并安装ActiveMQ。前往Apache ActiveMQ网站，下载适用于您操作系统的ActiveMQ版本。然后，按照安装说明进行安装。

步骤2：下载和安装CMake

CMake是一个跨平台的构建系统，用于生成各种平台的本地构建文件。前往CMake网站，下载适用于您操作系统的CMake版本。然后，按照安装说明进行安装。

步骤3：配置CMake

接下来，我们需要配置CMake以构建C++ ActiveMQ客户端。打开CMake GUI，并指定以下内容：

源代码目录：ActiveMQ源代码目录
构建目录：CMake将生成构建文件的目录
生成器：选择与您的编译器兼容的生成器，例如"Visual Studio 16 2019"。

步骤4：生成和构建客户端

点击CMake GUI中的"生成"按钮，生成构建文件。然后，点击"打开项目"按钮，打开生成的项目文件。最后，点击"生成"按钮，构建C++ ActiveMQ客户端。

步骤5：使用客户端

客户端构建完成后，就可以使用了。以下是一个简单的示例，展示如何使用客户端连接到ActiveMQ服务器并发送消息：

#include <activemq/library/ActiveMQCPP.h>

using namespace activemq::core;
using namespace activemq::library;
using namespace activemq::util;

int main() {
  // 创建连接工厂
  auto factory = ConnectionFactory("tcp://localhost:61616");

  // 创建连接
  auto connection = factory->createConnection();
  connection->start();

  // 创建会话
  auto session = connection->createSession(nullptr);

  // 创建主题
  auto topic = session->createTopic("my-topic");

  // 创建消息生产者
  auto producer = session->createProducer(topic);

  // 创建消息
  auto message = session->createTextMessage("Hello, world!");

  // 发送消息
  producer->send(message);

  // 关闭连接
  connection->close();

  return 0;
}