RabbitMQ। भाग 2. आदान-प्रदान की समझ

Exchange- एक्सचेंजर या विनिमय बिंदु। इसके लिए संदेश भेजे जाते हैं। Exchange संदेश को एक या अधिक कतारों में वितरित करता है । यह संदेश को कतार केbindings बीच बने कनेक्शन ( ) और कतार के बीच के मार्गों पर आधारित करता है ।

Exchangeनहीं एक Erlang प्रक्रिया । स्केलेबिलिटी कारणों के लिए exchange, यह एक स्ट्रिंग है (कोड के साथ एक मॉड्यूल के लिए एक लिंक जहां रूटिंग लॉजिक निहित है) mnesia में अंतर्निहित डेटाबेस । 1 हजार एक्सचेंजर्स केवल 1MB मेमोरी की खपत करेंगे।

विषय - सूची

• RabbitMQ। भाग 1. परिचय। एर्लैंग, एएमक्यूपी और आरपीसी
• RabbitMQ। भाग 2. आदान-प्रदान की समझ
• RabbitMQ। भाग 3. कतारों और बिन्दुओं को समझना
• RabbitMQ। भाग 4. कनेक्शन और चैनल के बारे में विवरण
• 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