RabbitMQ. Bagian 3. Memahami Antrian dan Ikatan

Queue(antrian) - struktur data pada disk atau dalam RAM yang menyimpan tautan ke pesan dan memberikan salinannya consumers(kepada konsumen). QueueIni adalah proses Erlang dengan status (tempat pesan itu sendiri bisa di-cache). 1 ribu antrian dapat menempati sekitar 80MB.

Binding (mengikat) - aturan yang memberi tahu penukar yang mana dari antrian yang harus menerima pesan.

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

Antrian sementara

Jika antrian dibuat dengan set parameter autoDelete, maka antrian tersebut memperoleh kemampuan untuk menghapus dirinya sendiri secara otomatis . Antrian seperti itu biasanya dibuat ketika klien pertama terhubung dan dihapus ketika semua klien memutuskan sambungan.

exclusive, . , /, . exclusive , autoDelete .

:

• ,
• binding churn. , / . .

durable, /. Queue.Delete.

Highly Available

HA RabbitMQ. , , .

- HA , , HA . - , .

HA .

:

• HA . HA HA RabbitMQ (2-3 )

RPC . Queue.Declare, :

RabbitMQ.Client:

// ...
channel.QueueDeclare(
    queue: "my_queue",
    durable: false,
    exclusive: false,
    autoDelete: false,
    arguments: null
);
// ...

• queue — , .
• durable — true, /
• exclusive — true,
• autoDelete — true,
• arguments — . .

arguments

• x-message-ttl(x-message-time-to-live) — . x-message-ttl, , . x-message-ttl . . . x-message-ttl, .
• x-expires — . . , , Basic.Cancel . , Basic.Get. , . , .
• x-max-length — . ,

• x-max-lenght-bytes — . ( )
• x-overflow — . : drop-head ( ) reject-publish. drop-head, . reject-publish,
• x-dead-letter-exchange — exchange, ,
• x-dead-letter-routing-key —
• x-max-priority — 255 (RabbitMQ 3.5.0 ). , . ,
• x-queue-mode — . . . , , ,
• x-queue-master-locator — ,
• x-ha-policy — HA . all, . nodes,
• x-ha-nodes — , HA

, RPC Queue.DeclareOk. ( Queue.Declare), Channel.Close OperationInterruptedException, .

Queue.Declare . , , , .

Queue.Declare , Channel.Close OperationInterruptedException, 403 .

, >= 10 , , GC , , .

Queue

RabbitMQ guest (username: guest password: guest). , guest . Queues Add a new queue. :

Add queues, .

. , consumers, / , .

Binding

RPC . Queue.Bind, :

RabbitMQ.Client:

//...
channel.QueueBind(
    queue: queueName,
    exchange: "my_exchange",
    routingKey: "my_key",
    arguments: null
);
//...

• queue —
• exchange —
• routingKey —
• arguments —

, RPC Queue.BindOk.

Binding

RabbitMQ guest (username: guest password: guest). , guest . Queues my_queue. bindings:

Bind, :

Code

Di bagian ini, kami menjelaskan antrian dan pengikatan menggunakan kode C #, jadi jika kami perlu mengembangkan perpustakaan. Mungkin itu akan berguna untuk persepsi.

public interface IQueue
    {        
        string Name { get; }

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

        /// <summary>
        ///        true,  
        ///          
        ///       consumer-
        /// </summary>
        bool IsExclusive { get; }

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

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

public class Queue : IQueue
    {
        public Queue(
             string name, 
             bool isDurable = true, 
             bool isExclusive = false, 
             bool isAutoDelete = false, 
             IDictionary<string, object> arguments = null)
        {
            Name = name ??
                throw new ArgumentNullException(name, $"{name} must not be null");

            IsDurable = isDurable;
            IsExclusive = isExclusive;
            IsAutoDelete = isAutoDelete;
            Arguments = arguments ?? new Dictionary<string, object>();
        }

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

public static class QueueMode
    {       
        public const string Default = "default";
        /// <summary>
        ///      .     
        ///          ,   
        ///       
        /// </summary>
        public const string Lazy = "lazy";
    }

public interface IBinding
    {
        /// <summary>
        ///     ,    
        /// </summary>
        IExchange Exchange { get; }

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

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

public class Binding : IBinding
    {
        public Binding(
             IExchange exchange, 
             string routingKey, 
             IDictionary<string, object> arguments)
        {
            Exchange = exchange;
            RoutingKey = routingKey;
            Arguments = arguments;
        }

        public IExchange Exchange { get; }
        public string RoutingKey { get; }
        public IDictionary<string, object> Arguments { get; }
    }