ITPub博客

首页 > > > RabbitMQ无法接收消息的问题

RabbitMQ无法接收消息的问题

作者:deeply 时间:2019-09-17 15:11:54 0 删除 编辑

目前遇到一个RabbitMQ无法接收消息的问题,问题如下:

发送端代码:

factory.HostName = "localhost";
        factory.UserName = "station";
        factory.Password = "123456-a";

        using (var connection = factory.CreateConnection())
        {
            using (var channel = connection.CreateModel())
            {
                var properties = channel.CreateBasicProperties();
                properties.Persistent = true;

                channel.QueueDeclare("20-x:device-message", true, false, false, null);
                var body = Encoding.UTF8.GetBytes(message);
                channel.BasicPublish("", "20-x:device-message", properties, body);
            }
        }

消息发送成功。

接收端代码:

var factory = new ConnectionFactory();
        factory.HostName = "localhost";
        factory.UserName = "station";
        factory.Password = "123456-a";

        using (var connection = factory.CreateConnection())
        {
            using (var channel = connection.CreateModel())
            {
                var consumer = new EventingBasicConsumer(channel);

                consumer.Received += (model, ea) =>
                {
                    var body = ea.Body;
                    var messageText = Encoding.UTF8.GetString(body);

                    //var message = JsonConvert.DeserializeObject<ICreateMessageDto>(messageText);

                    //channel.BasicAck(ea.DeliveryTag, true);
                };
                channel.BasicConsume("20-x:device-message", false, consumer);
            }
        }

var messageText = Encoding.UTF8.GetString(body);

这行代码一直无法触发。

来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/1978/viewspace-3137288/ ,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2008-05-30

  • 博文量
    215
  • 访问量
    24533