# 模块二 基础巩固 RabbitMQ HelloWorld
## 2.6.3 RabbitMQ -- HelloWorld
* 发送端
* 接收端
* rabbitmq container
* 发送信息
新建控制台项目 Sender，Receiver
添加 nuget 包：RabbitMQ.Client
### 发送端
```
namespace Sender
{
class Sender
{
public static void Main()
{
var factory = new ConnectionFactory() { HostName = "localhost" };
using (var connection = factory.CreateConnection())
{
using (var channel = connection.CreateModel())
{
channel.QueueDeclare(queue: "hello",
durable: false, // 持久化
exclusive: false, // 排它
autoDelete: false, // 自动删除
arguments: null);
string message = "Hello World!";
var body = Encoding.UTF8.GetBytes(message);
channel.BasicPublish(exchange: "",
routingKey: "hello",
basicProperties: null,
body: body);
Console.WriteLine(" [x] Sent {0}", message);
}
Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();
}
}
}
}
```
### 接收端
```
namespace Receiver
{
class Receiver
{
public static void Main()
{
var factory = new ConnectionFactory() { HostName = "localhost" };
using (var connection = factory.CreateConnection())
using (var channel = connection.CreateModel())
{
channel.QueueDeclare(queue: "hello",
durable: false,
exclusive: false,
autoDelete: false,
arguments: null);
var consumer = new EventingBasicConsumer(channel);
consumer.Received += (model, ea) =>
{
var body = ea.Body.ToArray();
var message = Encoding.UTF8.GetString(body);
Console.WriteLine(" [x] Received {0}", message);
};
channel.BasicConsume(queue: "hello",
autoAck: true,
consumer: consumer);
Console.WriteLine(" Press [enter] to exit.");
Console.ReadLine();
}
}
}
}
```
### rabbitmq container
```
docker run -d -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management
```
运行成功后可以访问（localhost 替换为服务器地址）
```
http://localhost:15672/#/
```
用户名密码默认为 guest
替换发送端，接收端的 localhost 为服务器地址
### 发送信息
先启动接收端，再启动发送端
发送多条信息
Sender
```
channel.QueueDeclare(queue: "hello",
durable: false, // 持久化
exclusive: false, // 排它
autoDelete: false, // 自动删除
arguments: null);
Console.WriteLine("Please input your message with enter:");
string message = Console.ReadLine();
while (message != "EXIT")
{
var body = Encoding.UTF8.GetBytes(message);
channel.BasicPublish(exchange: "",
routingKey: "hello",
basicProperties: null,
body: body);
Console.WriteLine(" [x] Sent {0}", message);
Console.WriteLine("Please input your message with enter:");
message = Console.ReadLine();
}
```
先启动接收端，再启动发送端
### GitHub源码链接：