RabbitMQ中的channel信道、exchange交換機(jī)和queue隊列

環(huán)境：

CentOS 7

RabbitMQ Server 版本3.7.9.RELEASE

connection是指物理的連接，一個client與一個server之間有一個連接；一個連接上可以建立多個channel，可以理解為邏輯上的連接。

一般應(yīng)用的情況下，有一個channel就夠用了，不需要創(chuàng)建更多的channel。

//創(chuàng)建連接和channel
$conn = new AMQPConnection($conn_args);
if (!$conn->connect()) {
die("Cannot connect to the broker!\n");
}
$channel = new AMQPChannel($conn);

exchange 與 routingkey ： 交換機(jī) 與 路由鍵

為了將不同類型的消息進(jìn)行區(qū)分，設(shè)置了交換機(jī)與路由兩個概念。

比如，將A類型的消息發(fā)送到名為‘C1’的交換機(jī)，將類型為B的發(fā)送到'C2'的交換機(jī)。

當(dāng)客戶端連接C1處理隊列消息時，取到的就只是A類型消息。

$e_name = 'e_linvo'; //交換機(jī)名
$k_route = array(0=> 'key_1', 1=> 'key_2'); //路由key
//創(chuàng)建交換機(jī)
$ex = new AMQPExchange($channel);
$ex->setName($e_name);
$ex->setType(AMQP_EX_TYPE_DIRECT); //direct類型
$ex->setFlags(AMQP_DURABLE); //持久化
echo "Exchange Status:".$ex->declare()."\n";
for($i=0; $i<5; ++$i){
echo "Send Message:".$ex->publish($message . date('H:i:s'), $k_route[i%2])."\n";
}

由以上代碼可以看到，發(fā)送消息時，只要有“交換機(jī)”就夠了。

至于交換機(jī)后面有沒有對應(yīng)的處理隊列，發(fā)送方是不用管的。routingkey可以是空的字符串（表示發(fā)送到所有的隊列中）。

在示例中，我使用了兩個key交替發(fā)送消息，是為了下面更便于理解routingkey的作用。

交換機(jī)設(shè)置參數(shù)中有兩個重要的概念：

A，類型。有三種類型： Fanout類型最簡單，這種模型忽略routingkey；Direct類型是使用最多的，使用確定的routingkey。這種模型下，接收消息時綁定'key_1'則只接收key_1的消息；最后一種是Topic，這種模式與Direct類似，但是支持通配符進(jìn)行匹配，比如： 'key_*'，就會接受key_1和key_2。Topic貌似美好，但是有可能導(dǎo)致不嚴(yán)謹(jǐn)，所以還是推薦使用Direct。

B，持久化。指定了持久化的交換機(jī)，在重新啟動時才能重建，否則需要客戶端重新聲明生成才行。

需要特別明確的概念：

• 交換機(jī)的持久化，并不等于消息的持久化。
• 只有在持久化隊列中的消息，才能持久化；
• 如果沒有隊列，消息是沒有地方存儲的；
• 消息本身在投遞時也有一個持久化標(biāo)志的，PHP中默認(rèn)投遞到持久化交換機(jī)就是持久的消息，不用特別指定。

queue： 隊列

隊列僅是針對接收方（consumer）的，由接收方根據(jù)需求創(chuàng)建的。

只有隊列創(chuàng)建了，交換機(jī)才會將新接受到的消息送到隊列中，交換機(jī)是不會在隊列創(chuàng)建之前的消息放進(jìn)來的。

即在建立隊列之前，發(fā)出的所有消息都被丟棄了。

消息的處理，是有兩種方式：

A，一次性。用 $q->get([...])，不管取到取不到消息都會立即返回，一般情況下使用輪詢處理消息隊列就要用這種方式；

B，阻塞。用 $q->consum( callback, [...] ) 程序會進(jìn)入持續(xù)偵聽狀態(tài)，每收到一個消息就會調(diào)用callback指定的函數(shù)一次，直到某個callback函數(shù)返回FALSE才結(jié)束。
使用的$routingkey = ''， 意味著接收全部的消息。我們可以將其改為 $routingkey = 'key_1'，可以看到結(jié)果中僅有設(shè)置routingkey為key_1的內(nèi)容了。

注意： routingkey = 'key_1' 與 routingkey = 'key_2' 是兩個不同的隊列。假設(shè)： client1 與 client2 都連接到 key_1 的隊列上，一個消息被client1處理之后，就不會被client2處理。而 routingkey = '' 是另類，client_all綁定到 '' 上，將消息全都處理后，client1和client2上也就沒有消息了。

到此這篇關(guān)于RabbitMQ中的channel信道、exchange交換機(jī)和queue隊列詳解的文章就介紹到這了,更多相關(guān)RabbitMQ的channel、exchange和queue內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論