首页 > 其他 > 详细

简单的使用RabbitMQ

时间:2020-09-16 14:37:15      阅读:47      评论:0      收藏:0      [点我收藏+]

1、需要引用相关组件

Nuget查找RabbitMQ.Client,并引用

2、基础代码

1)生产者

			//基础配置
            ConnectionFactory factory = new ConnectionFactory() {
                HostName = "10.123.44.12",
                UserName = "datamip",
                Password = "datamip"
            };

            //第一步:创建connection
            using (var connection = factory.CreateConnection())
            {
                //第二步:创建channel
                using (var channel = connection.CreateModel())
                {
                    //第三步:创建exchange  当前使用默认

                    //第四步:创建一个队列(queue)
                    channel.QueueDeclare("mytest", true, false, false, null);

                    var msg = Encoding.UTF8.GetBytes("你好");
                    //第五步:发布消息
                    channel.BasicPublish(string.Empty, "mytest", basicProperties: null, body: msg);
                }
            }

2)消费者

			//创建连接工厂
            ConnectionFactory factory = new ConnectionFactory
			{
				UserName = "datamip",//用户名
				Password = "datamip",//密码
				HostName = "10.123.44.12"//rabbitmq ip
			};  
			
            //第一步:创建connection
            using (var connection = factory.CreateConnection())
            {
                //第二步:创建channel
                using (var channel = connection.CreateModel())
                {
                    //第三步:获取信息
                    var result= channel.BasicGet("mytest",true);
                    //第四步:处理消息
                    Console.WriteLine(Encoding.UTF8.GetString(result.Body.ToArray()));
                }
            }

  

简单的使用RabbitMQ

原文:https://www.cnblogs.com/sailing92/p/13678658.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!