zoukankan      html  css  js  c++  java
  • 二、Rabbit使用-初次测试

    RabbitMQ提供了后台管理的页面,如果想使用该页面,需要进入安装rabbitmq的安装目录,运行以下cmd命令

    rabbitmq-plugins enable rabbitmq_management  

    然后我们直接在浏览器中输入http://localhost:15672/

    发现出来了一个登陆页面,默认账号和密码是guest,在登陆进入以后我们可以自行创建新的账户和密码。

    现在我们创建一个队列

     然后现在我们创建一个控制台项目,在项目中我们使用nuget安装RabbitMQ.Client,这里我选用的版本是5.0.0.0,项目框架是4.5.2

    接着我们在控制台编写我们的代码

            static void Main(string[] args)
            {
                var factory = new ConnectionFactory() { HostName = "localhost" };
                using (var connection = factory.CreateConnection())
                {
                    using (var channel = connection.CreateModel())
                    {
                        channel.QueueDeclare("test", true, false, false, null);
    
                        var consumer = new EventingBasicConsumer(channel);
                        consumer.Received += Consumer_Received;
                        channel.BasicConsume("test", true, consumer);
    
                        Console.ReadLine();
                    }
                }
            }
            private static void Consumer_Received(object sender, BasicDeliverEventArgs e)
            {
                var body = e.Body;
                var content = Encoding.UTF8.GetString(body);
                Console.WriteLine(content);
           }                                                           

    接着我们在浏览器的管理页面中发布一个消息

     这边一点击发布,结果我们运行的控制台项目中就已经收到了消息

  • 相关阅读:
    连通块问题
    线性数据结构
    NOIP2018总结
    原码反码补码详解
    一些常用的算法技巧总结
    骗分导论
    模板
    模板
    AcWing
    AcWing
  • 原文地址:https://www.cnblogs.com/ITzhangyunpeng/p/11431333.html
Copyright © 2011-2022 走看看