rabbitmq AmqpClient 使用Topic 交換機同一個channel 同時多個隊列 ，多個交換機，C++代碼示例

// 消息發送
bool PublishExchangeTopicMulti(const std::string &strUri)
{
    AmqpClient::Channel::ptr_t channel = 
        AmqpClient::Channel::CreateFromUri(strUri);

    if (channel == nullptr)
    {
        return false;
    }

    // 聲明交換機，若不存在則創建 
    std::string strTopicExchange1 = "topic_exchange_1";
    std::string strTopicExchange2 = "topic_exchange_2";
    channel->DeclareExchange(strTopicExchange1, AmqpClient::Channel::EXCHANGE_TYPE_TOPIC);
    channel->DeclareExchange(strTopicExchange2, AmqpClient::Channel::EXCHANGE_TYPE_TOPIC);

    while (true)
    {
        // 可輸入例如 "topic_exchange_1 disk.info 666"
        // "topic_exchange_2 any.warning 123"
        std::cout << "請輸入[exchange] [routing_key1.routing_key2] [message]: " << std::endl;
    
        std::string strExchange;
        std::string severity;
        std::string message;
        std::cin >> strExchange;
        std::cin >> severity;
        std::cin >> message;

        channel->BasicPublish(strExchange, severity,
            AmqpClient::BasicMessage::Create(message));

        std::cout << "[X] to " << strExchange << ", send " 
            << severity << ": " << message << std::endl;
    }

}


void ReceiveTopicExchangeMulti(const std::string &strUri)
{
    AmqpClient::Channel::ptr_t channel = 
        AmqpClient::Channel::CreateFromUri(strUri);

    if (channel == nullptr)
    {
        return ;
    }

    // 這里我們聲明兩個交換機，類型均為topic , 我們將通過不同的隊列從兩個交換機中取消息。
    // 這里交換機的名稱需要與發送端的保持一致。
    std::string strTopicExchange1 = "topic_exchange_1";
    std::string strTopicExchange2 = "topic_exchange_2";
    channel->DeclareExchange(strTopicExchange1, AmqpClient::Channel::EXCHANGE_TYPE_TOPIC);
    channel->DeclareExchange(strTopicExchange2, AmqpClient::Channel::EXCHANGE_TYPE_TOPIC);

    // 這里我們聲明了三個隊列，第一個隊列從交換機1 取數據第二三個隊列從交換機2 取數據；
    // 但是第二三個隊列所綁定的routing_key 有所不同。
    // 當然了，routing_key 也可以相同，這樣的話相同routing_key 的消息就會在兩個隊列中都出現。
    std::string strTopicQueue_1 = "topic_queue_1";
    std::string strTopicQueue_2 = "topic_queue_2";
    std::string strTopicQueue_3 = "topic_queue_3";
    // 第一個參數若為空，則系統默認生成隨機隊列名稱
    // 第三個參數 表明隊列是否持久的。true: 服務器重啟將會保留該Exchange,
    // 警告，若只設置此項，不代表消息的持久化。即不保證重啟后消息還在。
    channel->DeclareQueue(strTopicQueue_1, false, true, false, false);
    channel->DeclareQueue(strTopicQueue_2, false, true, false, false);
    channel->DeclareQueue(strTopicQueue_3, false, true, false, false);

    // 隊列綁定我們感興趣的routing_key, 表示我們只接收這些routing_key 相關的消息。
    channel->BindQueue(strTopicQueue_1, strTopicExchange1, "*.info");
    channel->BindQueue(strTopicQueue_1, strTopicExchange1, "disk.*");
    channel->BindQueue(strTopicQueue_1, strTopicExchange1, "info.error");

    // 在交換機2 上面我們綁定了隊列2 和隊列3 。但是它們所關心的routing_key 不同。
    channel->BindQueue(strTopicQueue_3, strTopicExchange2, "*.info");
    channel->BindQueue(strTopicQueue_3, strTopicExchange2, "disk.*");
    channel->BindQueue(strTopicQueue_2, strTopicExchange2, "info.error");

    // 創建消費者標志，這個在后面會告訴 channel 我們需要哪些隊列中的相關routing_key 的消息。
    // BasicConsume() 第五個參數是指該消息是否以獨占的方式處理，若是則不允許第二個消費者綁定到該隊列 上，
    // 若否，則多個消費者同時綁定到該隊列，那么 在該隊列上的消息將隨機分配到某一個消費者。
    // 即，同一個消息將不會同時出現 在兩個消費者身上。
    std::string strFlagConsume_1 = "tab_consume_1";
    std::string strFlagConsume_2 = "tab_consume_2";
    std::string strFlagConsume_3 = "tab_consume_3";
    channel->BasicConsume(strTopicQueue_1, strFlagConsume_1, true, false, true);
    channel->BasicConsume(strTopicQueue_2, strFlagConsume_2, true, false, true);
    channel->BasicConsume(strTopicQueue_3, strFlagConsume_3, true, false, true);
    // BasicConsume() 的第4 個參數為false 表示，我們需要主動ack 服務器才將該消息清除。

    std::vector<std::string> vecFlagConsume;
    vecFlagConsume.push_back(strFlagConsume_1);
    vecFlagConsume.push_back(strFlagConsume_2);
    vecFlagConsume.push_back(strFlagConsume_3);

    while (true)
    {
        AmqpClient::Envelope::ptr_t envelope = channel->BasicConsumeMessage(vecFlagConsume);

        std::string strExchange = envelope->Exchange();
        std::string strFlagConsume = envelope->ConsumerTag();
        std::string severity = envelope->RoutingKey();
        std::string buffer = envelope->Message()->body();

        std::cout << "[Y] exchange: " << strExchange << ", flagconsume: " << strflagConsume 
            << ", receive " << severity << ": " << buffer << std::endl;

        channel->BasicAck(envelope);
    }

    for (size_t i = 0; i < vecFlagConsume.size(); ++i)
        channel->BasicCancel(vecFlagConsume[i]);
}