Konsep Pesan

Perpesanan asinkron memungkinkan layanan berkomunikasi tanpa saling memanggil secara langsung. Produsen mengirim sebuah pesan; konsumen mengambilnya kemudian. Hal ini memisahkan layanan, meredam lonjakan beban, dan menjaga ketangguhan sistem ketika konsumen sedang tidak aktif.

MassTransit adalah kerangka kerja .NET yang berjalan di atas perantara pesan seperti RabbitMQ atau Azure Service Bus. MassTransit menangani serialisasi, perutean, percobaan ulang, dan lainnya, sehingga Anda dapat berfokus pada pesan dan penangan, bukan detail perantara pesan.

Ada dua maksud pesan yang penting. Perintah memberi tahu layanan tertentu untuk melakukan sesuatu ("ChargePayment"). Peristiwa mengumumkan bahwa sesuatu telah terjadi ("OrderPlaced") kepada siapa pun yang berkepentingan. Perintah memiliki satu penangan; peristiwa dapat memiliki banyak penangan.

Perintah adalah jenis pesan sederhana yang diberi nama dalam bentuk perintah. Kirimkan perintah tersebut kepada satu konsumen.

Peristiwa diberi nama dalam bentuk lampau dan dipublikasikan kepada semua pelanggan yang berminat.

Antrean menyimpan pesan hingga konsumen memprosesnya. Antrean bersifat titik-ke-titik: setiap pesan dikirimkan tepat kepada satu konsumen, sehingga memungkinkan pembagian beban di antara beberapa instans konsumen (konsumen yang saling bersaing).

Perantara pesan seperti RabbitMQ melakukan perutean melalui pertukaran. Produsen memublikasikan pesan ke pertukaran, yang menyalurkan pesan tersebut ke semua antrean yang terikat. Dengan cara inilah satu peristiwa dapat mencapai banyak pelanggan.

MassTransit secara otomatis memetakan jenis pesan Anda ke pertukaran dan antrean. Kirim menargetkan antrean (perintah); Publikasikan menargetkan pertukaran sehingga antrean setiap konsumen yang berlangganan menerima salinan (peristiwa).

Layanan pesanan memublikasikan OrderPlaced lalu melanjutkan pekerjaannya. Secara terpisah, layanan surel dan layanan analitik masing-masing mengonsumsinya. Menambahkan pelanggan baru tidak memerlukan perubahan pada produsen.

Perantara pesan biasanya menawarkan pengiriman setidaknya sekali: pesan dapat dikirimkan ulang setelah terjadi kegagalan. Oleh karena itu, konsumen harus idempoten, sehingga pemrosesan pesan yang sama dua kali tetap aman.

Gunakan perpesanan ketika pekerjaan dapat berlangsung secara asinkron, ketika Anda perlu memisahkan layanan, atau untuk menyerap lonjakan. Untuk jawaban permintaan-respons yang segera, panggilan API langsung mungkin masih lebih sederhana.

Perpesanan asinkron memisahkan layanan melalui perantara pesan. MassTransit mengabstraksikan perantara pesan seperti RabbitMQ. Perintah (berbentuk perintah, satu penangan) dikirim ke antrean; peristiwa (bentuk lampau, banyak penangan) dipublikasikan ke pertukaran yang menyalurkannya ke pelanggan. Harapkan pengiriman setidaknya sekali, jadi jadikan konsumen idempoten.