.Net 简单使用 RabbitMQ_net linux rabbitmq 连接

简介

RabbitMQ的简单使用，官方教程https://www.rabbitmq.com/getstarted.html

AMQP 0-9-1 模型解释

1.Publisher-生产者（发布消息到RabbitMQ中的Exchange）
2.Exchange-交换机（与生产者建立连接并接收生产者的消息,负责将消息路由到具体的队列中）
3.Routes-路由（根据交换机的类型以什么样的策略消息发布到Queue）
4.Queue-队列（Exchange会将消息分发到指定的Queue，Queue和消费者进行交互）
5.Consumer-消费者（监听RabbitMQ中的Queue中的消息）

使用

• 第一步：创建生产者(Publisher)与消费者(Consumer)两个控制台程序，并在Nuget上引用依赖RabbitMQ.Client
  
• 第二步：发布消息

internal class Program
{
   
    static void Main(string[] args)
    {
   
        //建立RabbitMQ连接和通道
        var connectionFactory = new ConnectionFactory
        {
   
            HostName = "127.0.0.1",
            Port = 5672,
            UserName = "admin",
            Password = "admin",
            VirtualHost = "Angel2022",//指定Virtual Host
            AutomaticRecoveryEnabled = true, //自动重连
        };
        try
        {
   
            using (var connection = connectionFactory.CreateConnection())
            {
   
                using (var channel = connection.CreateModel())
                {
   
                    //创建一个新的，持久的交换机，ExchangeType.Direct指定交换机类型：direct，topic，headers，fanout
                    channel
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27