如何为 RabbitMQ 上的传入消息触发某些功能

Question

每当 rabbitMq 收到任何消息时，它应该触发一些功能。我怎样才能做到这一点？

Answer 1

我们可以使用接收事件来实现功能。下面的代码示例显示了如何执行相同的操作。

     ConnectionFactory oFactory = new ConnectionFactory();
     oFactory.UserName = oRabbitMQData.userName;
     oFactory.Password = oRabbitMQData.password;
     oFactory.VirtualHost = oRabbitMQData.virtualHost;
     oFactory.HostName = oRabbitMQData.hostName;
     oFactory.Port = oRabbitMQData.port;

     var connection = oFactory.CreateConnection();

     var channel = connection.CreateModel();
     // setup signal
     var signal = new ManualResetEvent(true);

     oRabbitMQConnections.Add(connection);
     oRabbitMQChannels.Add(channel);

     var consumer = new EventingBasicConsumer(channel);
     byte[] messageBody = null;

     consumer.Received += (sender, args) =>
     {

        messageBody = args.Body;
        string sMsg = UTF8Encoding.UTF8.GetString(messageBody);

        // process your message or store for later
        // set signal

        channel.BasicAck(args.DeliveryTag, false);

       // Do something

        signal.Set();
     };

     // start consuming
     channel.BasicConsume(oRabbitMQData.queueName, false, consumer);

如何为 RabbitMQ 上的传入消息触发某些功能

How to trigger some functionality for incoming messages on RabbitMQ

c#

asp.net

monitoring

rabbitmq