這篇文章比較全面詳細的介紹了rabbitmq中涉及的相關概念及元件,推薦閱讀 超詳細的rabbitmq入門,看這篇就夠了!-阿里雲開發者社群 (aliyun.com).
文章是j**a實現的,因為工作使用的是c#, 所以使用c#進行實踐。
1. 生產者:
1//1、建立連線工廠
2var factory = new
connectionfactory()3;
10using (var connection =factory.createconnection())
1131 _logger.loginformation("
成功傳送訊息
");
2. 消費者:
1//1、建立連線
2var factory = new
connectionfactory()3;
10var connection =factory.createconnection();
11var channel =connection.createmodel();
12 channel.queuedeclare(queue: "
test
", durable: false, exclusive: false, autodelete: false, arguments: null
);13
var consumer = new
eventingbasicconsumer(channel);
14 consumer.received += (model, ea) =>15"
);17
var body =ea.body;
18//
業務邏輯
19var message =encoding.utf8.getstring(body.toarray());
20console.writeline(message);
21};
22 channel.basicconsume(queue: "
test",
23 autoack: true
,24 consumer: consumer);
實踐為 最簡單的單生產者,單消費者模式。
初識RabbitMQ系列之一 簡單介紹
一 rabbitmq是什麼?眾所周知,mq是message queue 訊息佇列 的意思,rabbitmq就是眾多mq框架其中的一款,開源實現了amqp協議 官網 也就是說rabbitmq是乙個開源的訊息佇列框架。他用於在分布式系統中儲存 訊息,在易用性 擴充套件性 高可用性等方面都非常的優秀。是當...
初識RabbitMQ系列之一 簡單介紹
一 rabbitmq是什麼?眾所周知,mq是message queue 訊息佇列 的意思,rabbitmq就是眾多mq框架其中的一款,開源實現了amqp協議 官網 也就是說rabbitmq是乙個開源的訊息佇列框架。他用於在分布式系統中儲存 訊息,在易用性 擴充套件性 高可用性等方面都非常的優秀。是當...
RabbitMQ的安裝及簡單實用(二)
一 安裝erlang rabbitmq是由erlang語言編寫的,所以在安裝rabbitmq之前需要安裝erlang。可以到erlang官網根據自己的系統選擇安裝。wget tar zxvf otp src 23.0.tar.gz cd otp src 23.0 configure prefix o...