（1）、引入依賴

RabbitMQ.Client

（2）、編寫發布者代碼

1 var connectionFactory = new ConnectionFactory() { HostName="192.168.205.128",UserName="guest",Password="guest"}; //創建連接工廠 2 var connection = connectionFactory.CreateConnection(); //創建connection 3 var channel = connection.CreateModel(); //創建channel 4 //聲明交換機 5 //String exchange, 交換機名稱 6 //String type, 交換機類型 7 //Boolean durable, 是否持久化 8 //Boolean autoDelete, 是否自動刪除 9 //IDictionary< String, Object > arguments 交換機參數 10 channel.ExchangeDeclare("netExchange", ExchangeType.Direct, true, false, null); 11 //聲明隊列 12 //String queue, 隊列名稱 13 //Boolean durable, 是否持久化 14 //Boolean exclusive, 是否專有的（排外） 15 //Boolean autoDelete, 是否自動刪除 16 //IDictionary<String, Object> arguments 隊列參數 17 channel.QueueDeclare("netQueue", true, false, false, null); 18 //將隊列綁定到交換機上 19 //String queue, 隊列名稱 20 //String exchange, 交換機名稱 21 //String routingKey, routingKey 22 //IDictionary< String, Object > arguments 綁定參數 23 channel.QueueBind("netQueue", "netExchange", "netMessage", null); 24 //發布消息 25 //String exchange, 交換機名稱 26 //String routingKey, routingKey 27 //IBasicProperties basicProperties, 發布屬性 28 //Byte[] body 消息內容 29 channel.BasicPublish("netExchange", "netMessage", null, Encoding.UTF8.GetBytes("來自.net的問候")); 30 Console.ReadKey();

（3）、編寫消費者代碼

1 var connectionFactory = new ConnectionFactory() { HostName = "192.168.205.128", UserName = "guest", Password = "guest" }; //創建連接工廠 2 var connection = connectionFactory.CreateConnection(); //創建connection 3 var channel = connection.CreateModel(); //創建channel 4 //聲明交換機 5 //String exchange, 交換機名稱 6 //String type, 交換機類型 7 //Boolean durable, 是否持久化 8 //Boolean autoDelete, 是否自動刪除 9 //IDictionary< String, Object > arguments 交換機參數 10 channel.ExchangeDeclare("netExchange", ExchangeType.Direct, true, false, null); 11 //聲明隊列 12 //String queue, 隊列名稱 13 //Boolean durable, 是否持久化 14 //Boolean exclusive, 是否專有的（排外） 15 //Boolean autoDelete, 是否自動刪除 16 //IDictionary<String, Object> arguments 隊列參數 17 channel.QueueDeclare("netQueue", true, false, false, null); 18 //將隊列綁定到交換機上 19 //String queue, 隊列名稱 20 //String exchange, 交換機名稱 21 //String routingKey, routingKey 22 //IDictionary< String, Object > arguments 綁定參數 23 channel.QueueBind("netQueue", "netExchange", "netMessage", null); 24 //1.直接獲取消息 25 //var result = channel.BasicGet("netQueue", true); 26 //Console.WriteLine(Encoding.UTF8.GetString(result.Body)); 27 //2.使用事件機制獲取消息 28 EventingBasicConsumer consumer = new EventingBasicConsumer(channel); 29 consumer.Received += (sender, e) => 30 { 31 Console.WriteLine(Encoding.UTF8.GetString(e.Body)); 32 }; 33 channel.BasicConsume("netQueue", true, consumer); 34 Console.ReadKey();

?

轉載于:https://www.cnblogs.com/fanqisoft/p/10388793.html

總結

以上是生活随笔為你收集整理的.Net Core中使用RabbitMQ的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。