RabbitMQ. Bagian 2. Memahami Pertukaran

Exchange- Penukar atau titik pertukaran. Pesan dikirim ke sana. Exchange Sebarkan pesan ke dalam satu atau beberapa antrian. Ini merutekan pesan ke antrian berdasarkan koneksi yang dibuat ( bindings) antara itu dan antrian.

Exchangebukan proses Erlang . Untuk alasan skalabilitas exchange, ini adalah string (tautan ke modul dengan kode tempat logika perutean terletak) di basis data mnesia bawaan . 1.000 penukar hanya akan menggunakan memori 1MB.

Daftar Isi

• RabbitMQ. Bagian 1. Pendahuluan. Erlang, AMQP dan RPC
• RabbitMQ. Bagian 2. Memahami Pertukaran
• RabbitMQ. Bagian 3. Memahami Antrian dan Ikatan
• RabbitMQ. Bagian 4. Detail tentang Koneksi dan Saluran
• RabbitMQ. Bagian 5. Memahami pesan dan bingkai apa
• RabbitMQ. Bagian 6. Kinerja penerbitan pesan dan konsumsi
• RabbitMQ. Bagian 7. Ikhtisar modul Federation dan Shovel
• RabbitMQ. Bagian 8. RabbitMQ di .NET
• RabbitMQ. Bagian 9. Pemantauan

Pertukaran langsung

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