rabbitmq c ++客户端没有连接到5672端口的rabbitmq-server

Question

我在我的Linux机器上安装了rabbitmq-server。我在RABBIRMQ.enter link description here官方网站上安装了AMQP-CPP客户端库

现在我想作为生产者连接到rabbitmq-server，并希望在队列中发布消息。我已经建立了一个连接处理程序，主文件如下：

int main(int argc, char ** argv) {
    const std:: string exchange = "my-exchange";
    const std:: string routingKey = "my-routing-key";
    const char* message = "HELLO WORLD";

    MyTcpHandler myHandler;
    // address of the server
    cout << "TcpHandler object created.." << endl;
    AMQP:: Address address("amqp://guest:guest@localhost:5672");
    //("amqp://guest:guest@localhost/vhost");
    cout << "address object created.." << endl;
    // create a AMQP connection object
    AMQP:: TcpConnection connection(& myHandler, address);
    cout << "connection object created.." << endl;
    // and create a channel
    AMQP:: TcpChannel channel(& connection);
    cout << "channel object created.." << endl;

    // use the channel object to call the AMQP method you like
    channel.declareExchange("my-exchange", AMQP:: fanout);
    channel.declareQueue("my-queue");
    channel.bindQueue("my-exchange", "my-queue", "my-routing-key");

    cout << "before publish.." << endl;

    // start a transaction
    channel.startTransaction();

    int pubVal = channel.publish(exchange, routingKey, message);

我无法连接到队列。也许我没有在MyTcpHandler类中正确实现“monitor”方法：virtual void monitor（AMQP :: TcpConnection * connection，int fd，int flags）有人可以帮忙吗？

Answer 1

答案有点晚了。 AMQP-CPP包装对我来说也总是一场噩梦。好吧，如果你不是在寻找一些非常具体的功能，你可以使用不同的c ++包装器而不是https://github.com/alanxz/SimpleAmqpClient

//SimpleAMQPClient Producer    
Channel::ptr_t connection = Channel::Create("MQ server IP",5672,"username","password");
string producerMessage = "this is a test message";
connection->BasicPublish("exchange","routing key",BasicMessage::Create(producerMessage));

并做了 ！！！

现在如果你坚持使用AMQP-CPP，我想在上面的代码中指出的东西很少。

AMQP::Address address("amqp://guest:guest@localhost:5672");

我不确定这个地址，是你的服务器运行的地方，尝试在端口为15672的浏览器中输入相同的内容，看看它是否为您提供服务器的UI。

AMQP：//来宾：来宾@本地：15672

// use the channel object to call the AMQP method you like
channel.declareExchange("my-exchange", AMQP::fanout);
channel.declareQueue("my-queue");
channel.bindQueue("my-exchange", "my-queue", "my-routing-key");

这段代码将在每次运行时声明一个交换并创建一个队列，大多数它只会在第一次运行，然后每次都会发生名称冲突（如果我的假设是正确的）

更好的方法是从Rabbit-MQ服务器UI创建队列。确保已安装rabbitMQ-server（RabbitMQ-C是客户端）https://www.rabbitmq.com/download.html#server-installation-guides并通过c ++代码发送消息。

现在您只需打开浏览器并输入以下链接即可

运行服务器的IP：15672

对于本地，它应该是127.0.0.1:15672（记住端口号，它的15672）并输入用户名和密码。

//SimpleAMQPClient Consumer    
string consumer_tag=connection->BasicConsume("queue","",true,false);
Envelope::ptr_t envelope = connection->BasicConsumeMessage(consumer_tag);
BasicMessage::ptr_t bodyBasicMessage=envelope->Message();
string messageBody=bodyBasicMessage->Body();

上面的simpleAMQPClient代码是我的应用程序中的工作副本。

希望能帮助到你。