RabbitMQ。第2部分。了解交流

Exchange-交换器或交换点。消息发送给它。Exchange 将邮件分发到一个或多个队列中。它基于在队列和队列之间创建的连接（）将消息路由到bindings队列。

Exchange不是一个Erlang进程。出于可伸缩性原因exchange，这是mnesia内置数据库中的字符串（指向路由代码所在的代码的模块的链接）。一千个交换器将仅消耗1MB的内存。

目录

• RabbitMQ。第1部分。简介。Erlang，AMQP和RPC
• RabbitMQ。第2部分。了解交流
• RabbitMQ。第3部分。了解队列和绑定
• RabbitMQ。第4部分。有关Connection和Chanel的详细信息
• RabbitMQ。第5部分。了解什么消息和框架
• RabbitMQ。第6部分。消息发布和使用性能
• RabbitMQ。第7部分。联合和铲铲模块概述
• RabbitMQ。第8部分。NET中的RabbitMQ
• RabbitMQ。第9部分。监视

直接交换

Direct exchange — , . , . — . .

:

rabbitmq . direct exchange . , .

Topic Exchange

Topic exchange – direct exchange . , , . 0 ( AZ az 0-9), , * #.

• * — 1
• # — 0

:

RabbitMQ 2.4.0 topic exchange 145 . trie implementation, . a.b.c, a.*.b.c, a.#.c b.b.c :

, .

:

• , .. , direct exchange fanout exchange
• , * , , #.
• topic exchange direct exchange

Fanout Exchange

Fanout exchange – .

:

• RabbitMQ . exchange;
• ;

:

Headers Exchange

Headers exchange — (, ) headers . headers Dictionary<, >.

x-match any, (, ). or.

var bindingArguments = new Dictinary<String, Object>();
bindingArguments.add("x-match", "any");

x-match all. , (, ). and.

:

:

• . (, ) headers . , exchange.

Consistent-Hashing Exchange

RabbitMQ.

Consistent-hashing exchange (exchange ) – , , , . ( 0 - n).

– , ( ). .

:

Hash headers . headers, . headers.

, , .

(E2E)

Exchange-to-Exchange ( AMQP. RabbitMQ).

:

E2E , , .

Exchange

RPC . Exchange.Declare, :

exchange RabbitMQ.Client:

//...
channel.ExchangeDeclare(
    exchange: "my_exchange",
    type: "direct",
    durable: "false",
    autoDelete: "false",
    arguments: null
);
//...

• exchange — , .
• type —
• durable — true, exchange . /. false, exchange , /
• autoDelete — . Exchange ,
• arguments — . , alternative exchange ( ). , .

exchange , RPC Exchange.DeclareOk. ( Exchange.Declare), Channel.Close OperationInterruptedException, .

. - — RabbitMQ .

Exchange

RabbitMQ guest (username: guest password: guest). , guest . Exchanges Add a new exchange. :

. , Internal, E2E. Producer .

. , .. (). . .

, , fanout exchange, 1:1 . , fanout exchange .

, topic exchange , , direct exchnge, .. topic exchange.

exchange , , .

exchange .

Queues Bindings.

Code

C#, . .

public interface IExchange
{
    /// <summary>
    ///      ,    . 
    ///        .
    /// </summary>
    string Name { get; }

    /// <summary>
    ///      
    /// </summary>
    string Type { get; }

    /// <summary>
    ///       true,  exchange  
    ///      . 
    ///            
    ///       /. 
    ///       false,  exchange  
    ///        , 
    ///      /  
    /// </summary>
    bool IsDurable { get; }

    /// <summary>
    ///      . Exchange  , 
    ///            
    /// </summary>
    bool IsAutoDelete { get; }

    /// <summary>
    ///      
    /// </summary>
    IDictionary<string, object> Arguments { get; }
}

/// <summary>
///      
/// </summary>
public static class ExchangeType
{
    public const string Direct = "direct";
    public const string Topic = "topic";
    public const string Fanout = "fanout";
    public const string Header = "headers";
}

/// <summary>
///     
/// </summary>
public class Exchange : IExchange
{
    public Exchange(
           string name, 
           string type = ExchangeType.Direct, 
           bool durable = true, 
           bool autoDelete = false, 
           IDictionary<string, object> arguments = null)
    {
        Name = name ??
            throw new ArgumentNullException(name, $"{name} must not be null");

        Type = type;
        IsDurable = durable;
        IsAutoDelete = autoDelete;
        Arguments = arguments ?? new Dictionary<string, object>();
    }

    public string Name { get; }
    public string Type { get; }
    public bool IsDurable { get; }
    public bool IsAutoDelete { get; }
    public IDictionary<string, object> Arguments { get; }

    /// <summary>
    ///      Exchange  . 
    ///     Exchange   - direct exchnge  .
    ///         ,   
    ///         
    ///          .
    /// </summary>        
    public static IExchange GetDefault()
    {
        return new Exchange("");
    }
}

• RabbitMQ