石頭的coding之路

前文

在處理高併發系統架構時，非同步是一個很好的手段和提升效率的方式.

我今天跟大家分享，如何利用 MQ 搭配 Worker Pool 來提高系統吞吐量且又不失彈性

本篇會包含兩個部分解說

1. 如何使用 k3d (k8s) 和 docker-compose 來 Run 起我們 MQ 服務
2. 主要核心程式解說

前文

現今越來越多系統使用MQ來達成非同步並來提升系統吞吐量，我今天想要介紹的是EasyNetQ一個封裝RabbitMq Client .net框架

• 小型DI容器
• 對於RabbitMq封裝
• 對於連接使用lazy connection連接RabbitMq

If the server disconnects for any reason (maybe a network fault, maybe the RabbitMQ server itself has been bounced), EasyNetQ will revert to polling the endpoint until it can reconnect.

RabbitMQ是個訊息仲介（broker），主要是利用消息把生產者跟消費者解耦合

在RabbitMQ主要有以下角色

1. 產生者（producer）
2. 接收者（consumer）
3. 佇列（Queue）
4. 交換器(Exchange)
5. 訊息(Message)

上面太抽象?  讓我來舉一個簡單點的例子

RabbitMQ是什麼?

RabbitMQ是一個訊息中介軟體 (broker), 他實作​AMQP標準, 特點是消息轉發是非同步並且可靠.

主要用來處理應用程序之間消息的儲存與轉發可讓消費者和生產者解耦合, 消息是基於二進制