AMQP-CPP > 处理程序中的错误文件描述符

Question

我正在尝试使用 AMQP-CPP 库进行消息传递，但我无法使其正常工作。我想使用库中已经构建的类作为通道、连接、处理程序。我从他们的示例开始，但每次运行代码都会出现 Bad file descriptor 错误并且进程结束。我的代码看起来像这样

#include <amqpcpp.h>
#include <amqpcpp/libboostasio.h>
#include <boost/asio/io_service.hpp>
#include <boost/asio/strand.hpp>
#include <boost/asio/deadline_timer.hpp>

class MyHandler : public AMQP::LibBoostAsioHandler
{
public:
    MyHandler(boost::asio::io_service& service)
        : AMQP::LibBoostAsioHandler(service)
    {
    }

    virtual void onError(AMQP::TcpConnection *connection, const char *message) override
    {
        std::cout << "MyHandler::onError " << message << std::endl;
    }
};

int main()
{
    // access to the event loop
    boost::asio::io_service service(2);

    // handler for libevent
    MyHandler handler(service);

    // make a connection
    AMQP::TcpConnection connection(&handler, AMQP::Address("amqp://localhost/"));

    // we need a channel too
    AMQP::TcpChannel channel(&connection);

    channel.onError([](const char *message) {
        // report error
        std::cout << "channel error: " << message << std::endl;
    });
    channel.onReady([]() {
        // send the first instructions (like publishing messages)
        std::cout << "channel onReady: " << std::endl;
    });

    // create a temporary queue
    channel.declareQueue("aaa").onSuccess([&connection](const std::string& name, uint32_t messagecount, uint32_t consumercount) {

        // report the name of the temporary queue
        std::cout << "declared queue " << name << std::endl;

        // now we can close the connection
        connection.close();
    });  

    auto startCb = [](const std::string &consumertag) {
        std::cout << "consume operation started" << std::endl;
    };

    // callback function that is called when the consume operation failed
    auto errorCb = [](const char *message) {
        std::cout << "consume operation failed" << std::endl;
    };

    // callback operation when a message was received
    auto messageCb = [&channel](const AMQP::Message &message, uint64_t deliveryTag, bool redelivered) {
        std::cout << "message received" << std::endl;
        // acknowledge the message
        channel.ack(deliveryTag);
    };

    channel.consume("aaa").onReceived(messageCb)
    .onSuccess(startCb)
    .onError(errorCb);

    // run the loop
    service.run();

    return 0;
}

输出：

MyHandler::onError Bad file descriptor

另外，service.run();

行出现错误

我也用 libevent 尝试过类似的事情。

这里有什么问题以及如何解决？有什么想法吗？

Answer 1

原来是两个问题

首先，应该使用libev，因为这是官方支持的。其次，确保你的 RabbitMQ 服务器是运行。更详细的信息你可以找到here.

AMQP-CPP > 处理程序中的错误文件描述符

AMQP-CPP > Bad file descriptor in handler

c++

boost

amqp

boost-asio

rabbitmq