首页 > 其他分享> 文章详细

NetCore+RabbitMQ

2022-08-02 18:03:14 阅读：170 来源： 互联网

标签：false NetCore factory RabbitMQ var message channel

1.首先要清楚什么是RabbitMQ，是干啥用的？

　　RabbitMQ就是一个消息中间件，那什么又是中间件呐？我的理解是，消息中转站，生产者生产完消息，放入中转站，就接着干别的事情去了。

至于你什么时候消费，就看你自己了，一旦消费成功，中间件将不再存储你的消息。类似我们生活中的菜鸟驿站。

厂家就是生产者，我们就是消费者，快递员把快递放到菜鸟驿站，就走了，

至于你什么时候去拿就是你自己的事情了。当你拿到的时候，你的手机会收到短信 “出库成功”，那么就说明你消费成功了

2.RabbitMQ解决了什么问题？

3.简单的demo

static void Main(string[] args)
        {
            var factory = new ConnectionFactory();
            factory.HostName = "127.0.0.1";//主机名，Rabbit会拿这个IP生成一个endpoint，这个很熟悉吧，就是socket绑定的那个终结点。
            factory.UserName = "guest";//默认用户名,用户可以在服务端自定义创建，有相关命令行
            factory.Password = "guest";//默认密码

            using (var connection = factory.CreateConnection())//连接服务器，即正在创建终结点。
            {
                //创建一个通道，这个就是Rabbit自己定义的规则了，如果自己写消息队列，这个就可以开脑洞设计了
                //这里Rabbit的玩法就是一个通道channel下包含多个队列Queue
                using (var channel = connection.CreateModel())
                {
                    for (int i = 0; i < 20; i++)
                    {
                        channel.QueueDeclare("chnQueue", false, false, false, null);//创建一个名称为chnqueue的消息队列
                        var properties = channel.CreateBasicProperties();
                        properties.DeliveryMode = 1;  //非持久性
                        string message = $"I am a King {i}"; //传递的消息内容
                        channel.BasicPublish("", "chnQueue", properties, Encoding.UTF8.GetBytes(message)); //生产消息
                        Console.WriteLine($"Send:{message}");
                        Thread.Sleep(2000);
                    }
                    
                }
            }


            Console.ReadKey();
        }

 static void Main(string[] args)
        {
            var factory = new ConnectionFactory();
            factory.HostName = "127.0.0.1";
            factory.UserName = "guest";
            factory.Password = "guest"; 

            using (var connection = factory.CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    channel.QueueDeclare("chnQueue", false, false, false, null);

                    /* 这里定义了一个消费者，用于消费服务器接受的消息
                     * C#开发需要注意下这里，在一些非面向对象和面向对象比较差的语言中，是非常重视这种设计模式的。
                     * 比如RabbitMQ使用了生产者与消费者模式，然后很多相关的使用文章都在拿这个生产者和消费者来表述。
                     * 但是，在C#里，生产者与消费者对我们而言，根本算不上一种设计模式，他就是一种最基础的代码编写规则。
                     * 所以，大家不要被复杂的名词吓到，其实，并没那么复杂。
                     * 这里，其实就是定义一个EventingBasicConsumer类型的对象，然后该对象有个Received事件，
                     * 该事件会在服务接收到数据时触发。
　　　　　　　　　　　　　　只不过被某些自认为起名字很牛逼的人唬住了，别怕，很简单，比我们面向对象的低级多了
                     */
                    var consumer = new EventingBasicConsumer(channel);//消费者
                    channel.BasicConsume("chnQueue", true, consumer);//消费消息
                    consumer.Received += (model, ea) =>
                    {
                        var body = ea.Body.ToArray();//原来写法：var body = ea.Body();
                        var message = Encoding.UTF8.GetString(body);
                        Console.WriteLine($"消费：{message}");
                    };
                }
            }
            Console.ReadKey();
        }

这样，先启动生产者，打开rabbitmq的页面，就可以看到消息了。然后启动消费者，刷新rabbitmq页面，就看到消息消失了，被消费掉了！！！

标签：false,NetCore,factory,RabbitMQ,var,message,channel
来源： https://www.cnblogs.com/messi-10/p/16544619.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

NetCore+RabbitMQ