using System;
using System.Text;
using RabbitMQ.Client;namespace _2_Publish
{class Program{static void Main(string[] args){//创建连接工厂var factory = new ConnectionFactory() { HostName = "localhost" };//创建连接using (var connection = factory.CreateConnection()){//创建会话using (var chancel = connection.CreateModel()){//生命交换机chancel.ExchangeDeclare(exchange: "FanoutDemo", type: ExchangeType.Fanout);string readMsg = "helloWorld";while (readMsg.ToLower() != "exit"){var body = Encoding.UTF8.GetBytes(readMsg);//给交换机发送消息chancel.BasicPublish(exchange: "FanoutDemo", routingKey: "", body: body);Console.WriteLine($"成功发送消息{readMsg}");Console.WriteLine("请输入要发送的内容！");readMsg = Console.ReadLine();}}}}}
}

using System;
using System.Text;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;namespace _2_Receiver
{class Program{static void Main(string[] args){//创建连接工厂var factory = new ConnectionFactory() { HostName = "localhost" };//创建连接using (var connection = factory.CreateConnection()){//创建会话using (var channel = connection.CreateModel()){//声明一个Fanout类型的交换机channel.ExchangeDeclare(exchange: "FanoutDemo", type: ExchangeType.Fanout);//声明一个消息队列并获取它的名字var queueName = channel.QueueDeclare().QueueName;//把消息队列和交换机绑定channel.QueueBind(exchange: "FanoutDemo", queue: queueName, routingKey: "");//创建消费者var consume = new EventingBasicConsumer(channel);//把消费者和队列绑定channel.BasicConsume(queue: queueName, autoAck: true,consumer: consume);consume.Received += (model, ea) =>{var body = ea.Body;var message = Encoding.UTF8.GetString(body);Console.WriteLine($"收到消息{message}");};Console.ReadLine();}}}}
}

using System;
using System.Text;
using RabbitMQ.Client;namespace _2_Publish
{class Program{static void Main(string[] args){//创建连接工厂var factory = new ConnectionFactory() { HostName = "localhost" };//创建连接using (var connection = factory.CreateConnection()){//创建会话using (var chancel = connection.CreateModel()){//生命交换机chancel.ExchangeDeclare(exchange: "DirectDemo", type: ExchangeType.Direct);string readMsg = "helloWorld";while (readMsg.ToLower() != "exit"){var body = Encoding.UTF8.GetBytes(readMsg);//给交换机发送消息chancel.BasicPublish(exchange: "DirectDemo", routingKey: "Direct.Key", body: body);Console.WriteLine($"成功发送消息{readMsg}");Console.WriteLine("请输入要发送的内容！");readMsg = Console.ReadLine();}}}}}
}

using System;
using System.Text;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;namespace _2_Receiver
{class Program{static void Main(string[] args){//创建连接工厂var factory = new ConnectionFactory() { HostName = "localhost" };//创建连接using (var connection = factory.CreateConnection()){//创建会话using (var channel = connection.CreateModel()){//声明一个Fanout类型的交换机channel.ExchangeDeclare(exchange: "DirectDemo", type: ExchangeType.Direct);//声明一个消息队列并获取它的名字var queueName = channel.QueueDeclare().QueueName;Console.WriteLine("请输入RoutingKey!");var routingKey = Console.ReadLine();//把消息队列和交换机绑定channel.QueueBind(exchange: "DirectDemo", queue: queueName, routingKey: routingKey);//创建消费者var consume = new EventingBasicConsumer(channel);//把消费者和队列绑定channel.BasicConsume(queue: queueName, autoAck: true,consumer: consume);Console.WriteLine("开始监听消息");consume.Received += (model, ea) =>{var body = ea.Body;var message = Encoding.UTF8.GetString(body);Console.WriteLine($"收到消息{message}");};Console.ReadLine();}}}}
}

using System;
using System.Text;
using RabbitMQ.Client;namespace _2_Publish
{class Program{static void Main(string[] args){//创建连接工厂var factory = new ConnectionFactory() { HostName = "localhost" };//创建连接using (var connection = factory.CreateConnection()){//创建会话using (var chancel = connection.CreateModel()){//生命交换机chancel.ExchangeDeclare(exchange: "TopicDemo", type: ExchangeType.Topic);string readMsg = "helloWorld";while (readMsg.ToLower() != "exit"){var body = Encoding.UTF8.GetBytes(readMsg);//给交换机发送消息chancel.BasicPublish(exchange: "TopicDemo", routingKey: "Topic.Demo.Key", body: body);Console.WriteLine($"成功发送消息{readMsg}");Console.WriteLine("请输入要发送的内容！");readMsg = Console.ReadLine();}}}}}
}

using System;
using System.Text;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;namespace _2_Receiver
{class Program{static void Main(string[] args){//创建连接工厂var factory = new ConnectionFactory() { HostName = "localhost" };//创建连接using (var connection = factory.CreateConnection()){//创建会话using (var channel = connection.CreateModel()){//声明一个Fanout类型的交换机channel.ExchangeDeclare(exchange: "TopicDemo", type: ExchangeType.Topic);//声明一个消息队列并获取它的名字var queueName = channel.QueueDeclare().QueueName;Console.WriteLine("请输入RoutingKey!");var routingKey = Console.ReadLine();//把消息队列和交换机绑定channel.QueueBind(exchange: "TopicDemo", queue: queueName, routingKey: routingKey);//创建消费者var consume = new EventingBasicConsumer(channel);//把消费者和队列绑定channel.BasicConsume(queue: queueName, autoAck: true,consumer: consume);Console.WriteLine("开始监听消息");consume.Received += (model, ea) =>{var body = ea.Body;var message = Encoding.UTF8.GetString(body);Console.WriteLine($"收到消息{message}");};Console.ReadLine();}}}}
}