上述代码 connection没有isStarted()方法

非常抱歉，我之前提供的代码中的 `connection->isStarted()` 是一个错误。在 ActiveMQ C++ 库中，我们可以使用 `connection->getTransport()->isConnected()` 来检查连接是否已建立。

以下是修正后的代码：

#include <activemq/core/ActiveMQConnectionFactory.h>
#include <activemq/library/ActiveMQCPP.h>
#include <cms/Connection.h>
#include <cms/Session.h>
#include <cms/TextMessage.h>

using namespace activemq::core;
using namespace cms;

int main() {
    // 设置 ActiveMQ broker 地址
    std::string brokerURI = "tcp://localhost:61616";
    // 设置 Topic 名称
    std::string topicName = "topicName";
    // 设置最大重连尝试次数
    int maxReconnectAttempts = 3;
    // 设置重连延迟时间（毫秒）
    int reconnectDelay = 5000;

    try {
        // 初始化 ActiveMQ C++ 库
        activemq::library::ActiveMQCPP::initializeLibrary();

        // 创建连接工厂
        ActiveMQConnectionFactory* connectionFactory = new ActiveMQConnectionFactory(brokerURI);

        // 创建连接
        Connection* connection = connectionFactory->createConnection();

        // 设置异常监听器
        connection->setExceptionListener([](CMSException const* ex) {
            std::cout << "Connection exception: " << ex->getMessage() << std::endl;
            // 在这里可以添加重连逻辑
        });

        // 启动连接
        connection->start();

        // 创建会话
        Session* session = connection->createSession(Session::AUTO_ACKNOWLEDGE);

        // 创建目标（Topic）
        Destination* destination = session->createTopic(topicName);

        // 创建消息生产者
        MessageProducer* producer = session->createProducer(destination);

        // 创建消息
        TextMessage* message = session->createTextMessage("Hello, ActiveMQ!");

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

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

        // 清理资源
        delete message;
        delete producer;
        delete destination;
        delete session;
        delete connectionFactory;

        // 终止 ActiveMQ C++ 库
        activemq::library::ActiveMQCPP::shutdownLibrary();
    } catch (CMSException& ex) {
        std::cout << "Exception occurred: " << ex.getMessage() << std::endl;
    }

    return 0;
}

在异常监听器中，可以添加重连逻辑来尝试重新建立连接。例如，可以使用一个 while 循环来不断尝试连接，直到连接成功或达到最大重连尝试次数。在循环中，可以使用 `connection->getTransport()->isConnected()` 来检查连接是否已建立。

需要注意的是，在重连过程中，需要适当地添加延迟等待时间，以免频繁地尝试连接对 ActiveMQ 服务器造成过大的压力。

通过添加重连机制，可以增强 C++ 生产者与 ActiveMQ 之间的连接稳定性，并确保消息的可靠发送。根据具体需求，还可以根据实际情况进行适当的错误处理和日志记录。