使用c++ 連接 rabbit mq

因為需要，不得不用c++搞這個，還是比較惡心的，不像java成熟，資料也多，沒辦法也得整。

步驟：

一、安裝rabbit mq，之前裝了個centos的，這次搞了個windows的，網上資料多，安裝也沒有什么坑，順利

二、基於rabbitmq-c去弄吧，要不真的是閑得蛋騰。https://www.rabbitmq.com/devtools.html

       這個rabbitmq-c要自己編譯，網上資料也算可以，因為坑比較少，自己選擇編譯成32位或64位都可以。

       在這里吐槽一下某個SB，技術界越來越向着開源方向，它下載個JB資料還要積分，去TMD

       我把生成的項目和編譯好的32/64位都傳上來(vs2015)

       鏈接: https://pan.baidu.com/s/1mkNmgJVLA9CBdZvJPTNzMA 提取碼: nhgb  

三、關於對rabbitmq-c進行再次封裝，我沒有用官網上的那個SimpleAmqpClient，太難了。編譯成功了最后也連不上rabbit mq server，不知道是什么原因。

      自己在網上找了個封裝的，感覺還不錯，

      https://plain.blog.csdn.net/article/details/88875446

四、三天時間，終於可以了 

    

// ConsoleApplication2.cpp : 定義控制台應用程序的入口點。
//

#include "stdafx.h"
#include <windows.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <iostream>

#include "RabbitmqClient.h"
int Rec()
{
    CRabbitMqClient objRabbitmq;
    std::string ErrorReturn;
    int iRet = objRabbitmq.Connect(ErrorReturn);
    printf("Rabbitmq Connect Ret: %d\n", iRet);

    CExchange my_exchange(exchange_name);
    iRet = objRabbitmq.DeclareExchange(my_exchange, ErrorReturn);
    printf("Rabbitmq ExchangeDeclare Ret: %d\n", iRet);

    CQueue my_Queue(queue_name);
    iRet = objRabbitmq.DeclareQueue(my_Queue, ErrorReturn);
    printf("Rabbitmq QueueDeclare Ret: %d\n", iRet);

 
    iRet = objRabbitmq.BindQueueToExchange(my_Queue, my_exchange, routing_keys_name, ErrorReturn);
    printf("Rabbitmq QueueBind Ret: %d\n", iRet);

    
    while (true)
    {
        std::string msg;
        iRet = objRabbitmq.ConsumerMessage(msg, "my_Queue", { 1, 0 }, ErrorReturn);
        printf("Rabbitmq QueueBind Ret: %d\n", iRet);
        printf("Consumer: %s\n", msg.c_str());
        Sleep(0.5);
    }
    return 0;
}
int Send()
{
    CRabbitMqClient objRabbitmq;
    std::string ErrorReturn;
    int iRet = objRabbitmq.Connect(ErrorReturn);
    printf("Rabbitmq Connect Ret: %d\n"  , iRet);

    CExchange my_exchange(exchange_name);
    iRet = objRabbitmq.DeclareExchange(my_exchange,ErrorReturn);
    printf("Rabbitmq ExchangeDeclare Ret: %d\n", iRet);

    CQueue my_Queue(queue_name);
    iRet = objRabbitmq.DeclareQueue(my_Queue, ErrorReturn);
    printf("Rabbitmq QueueDeclare Ret: %d\n", iRet);

    iRet = objRabbitmq.BindQueueToExchange(my_Queue, my_exchange, routing_keys_name, ErrorReturn);
    printf("Rabbitmq QueueBind Ret: %d\n", iRet);


    std::string strSendMsg1 = "rabbitmq send test msg1";
    amqp_basic_properties_t properties = {};
    CMessage cmsg(strSendMsg1, properties, routing_keys_name);
    iRet = objRabbitmq.PublishMessage(cmsg, ErrorReturn);
    printf("Rabbitmq Publish 1 Ret: %d\n", iRet);
    iRet = objRabbitmq.PublishMessage(cmsg, ErrorReturn);
    printf("Rabbitmq Publish 1 Ret: %d\n", iRet);    
    iRet = objRabbitmq.PublishMessage(cmsg, ErrorReturn);
    printf("Rabbitmq Publish 1 Ret: %d\n", iRet);    
    iRet = objRabbitmq.PublishMessage(cmsg, ErrorReturn);
    printf("Rabbitmq Publish 1 Ret: %d\n", iRet);


    //objRabbitmq.DisConnect(ErrorReturn);

    return 0;
}

int test()
{
    CRabbitMqClient objRabbitmq;
    std::string ErrorReturn;
    int iRet = objRabbitmq.Connect(ErrorReturn);
    printf("Rabbitmq Connect Ret: %d\n", iRet);


    while (true)
    {
        CQueue my_Queue(queue_name, true, true);
        amqp_queue_declare_ok_t r = objRabbitmq.DeclareQueue_Query(my_Queue, ErrorReturn);
        printf("Rabbitmq QueueDeclare Ret: %d\n", r.message_count);
        Sleep(2);
    }
    return 0;
}

int main()
{
    /*Send();
    std::cin.get();
    Rec();
    std::cin.get();*/
    test();
    system("pause");
    return 0;
}

test方法是用來檢測隊列里有多少消息，有多少消費者