RabbitMQ在PHP使用,我在這里對RabbitMQ的各項方法和參數進行了一些梳理,有不足的地方還望各位大神指點.想要使用rabbitMQ消息隊列,首先需要安裝 php_amqp.dll 擴展 和 rabbitMQ 服務, 至于怎么安裝大家可以百度一下,這類的資料還是有很多的. ----------------------------------------------------------------------------------------------------------------------------------------------------------------- RabbitMQ的工作原理大概如下: 生產者:生產消息--->創建交換器:對消息進行routekey鑒別,然后分發到相對應的隊列---->隊列:通過routekey,裝載消息,然后運輸給消費者-->消費者:接收隊列傳送的消息,進行處理,然后給予回應. 下面是RabbitMQ生產者實現的簡單代碼:

<?php $exchangeName = 'ceshi1'; $queueName = 'ceshi_queue1'; $str = 'ceshi'.rand(1,9999); $routeKey = 'ceshi_queue1'; $message = $str;$connection = new AMQPConnection(array('host' => '', 'port' => '', 'vhost' => '', 'login' => '', 'password' => '')); $connection->connect() or die("Cannot connect to the broker!\n");# 連接服務 $channel = new AMQPChannel($connection); # 創建交換器 $exchange = new AMQPExchange($channel); # 設置交換器的名稱 $exchange->setName($exchangeName); # 設置多個參數值[setArguments ( array $arguments )]; # 獲取該隊列某個參數的信息 , getArgument ( string $key ) # [如果無法將此交換機的消息路由，則將它們發送到這里指定的備用交換機。（設置“alternate-exchange”參數）。] # 設置交換器類型 # AMQP_EX_TYPE_DIRECT[點對點],AMQP_EX_TYPE_FANOUT[廣播],AMQP_EX_TYPE_TOPIC[模糊匹配],AMQP_EX_TYPE_HEADER[頭匹配] $exchange->setType(AMQP_EX_TYPE_DIRECT); # 交換器持久化 //$exchange->setFlags(AMQP_DURABLE); # 執行創建交換器 $exchange->declareExchange(); # 創建隊列 $queue = new AMQPQueue($channel); $queue->setName($queueName); # 設置單個指定的參數鍵值,setArgument ( string $key , mixed $value ) # 獲取該隊列某個參數的信息 , getArgument ( string $key ) //$queue->setArgument(); # [發布到隊列中的消息可以在被丟棄之前生存多長時間（毫秒（設置x-message-ttl）參數。] # [在自動刪除隊列（毫秒）之前，該隊列不能被使用多長時間。（設置“x-expires”參數）。] # [隊列中有多少（準備好的）消息[個數],可以在它開始,從其頭上刪除之前包含。（設置x-max-length長度）參數] # [準備好的消息的總大小，隊列可以在它開始從頭上刪除之前包含。（設置x-max-length-bytes 縱向字節）參數] # [如果拒絕或過期消息將被重新發布的Exchange的可選名稱。（設置“x-dead-letter-exchange”參數,[交換器名,(string)]）。] # [可選的替換路由密鑰，當消息已被寫入字母時使用。如果未設置此消息，將使用消息的原始路由密鑰。（設置“x-dead-letter-routing-key”參數）。] # [支持隊列的最大優先級數量；如果未設置，隊列將不支持消息優先級。（設置x-max-priority）參數。] # [將隊列設置為懶惰模式，盡可能保留磁盤上的盡可能多的消息以減少RAM的使用；如果沒有設置，隊列將保持內存中的緩存以盡可能快地傳遞消息。（設置“x-queue-mode”參數設置:lazy）。] # [將隊列設置為主定位模式，確定在節點群集上聲明隊列主控器所處的規則。（設置x-queue-master-locator 參數。] # 設置多個參數值[setArguments ( array $arguments )]; # 獲取該隊列所有參數的信息 , getArguments ( void ) //$queue->setArguments(); # 持久化隊列 # AMQP_DURABLE[隊列持久], AMQP_PASSIVE[返回消息計數], AMQP_EXCLUSIVE[只被一個連接（connection）使用，而且當連接關閉后隊列即被刪除], AMQP_AUTODELETE[當最后一個消費者退訂后即被刪除]. $queue->setFlags(AMQP_DURABLE); # 執行創建隊列 $queue->declareQueue();# 開啟事務,確保數據真正不丟失 $channel->startTransaction(); # 將消息和標識綁定到交換器中 # publish(message[消息],route_key,[ flags[ AMQP_MANDATORY,AMQP_IMMEDIATE],attributes[array] ]); # attributes 存有參數 => [content_type(用于描述MIME類型的編碼。例如，對于經常使用的JSON編碼，將此屬性設置為 “application/json” 是一個很好的做法。), #content_encoding,message_id,user_id,app_id,delivery_mode[2 消息持久,1非持久],priority,timestamp,expiration,type,reply_to(主要用于命名一個回調隊列 ) ] $exchange->publish($message,$routeKey); $channel->commitTransaction(); var_dump("[x] Sent $message");# 關閉連接 $connection->disconnect();?>

以上是生產者的簡單代碼,下面我們可以看看消費者的簡單代碼:

<?php $exchangeName = 'ceshi1'; $queueName = 'ceshi_queue1'; $routeKey = 'ceshi_queue1';$connection = new AMQPConnection(array('host' => '', 'port' => '', 'vhost' => '', 'login' => '', 'password' => '')); $connection->connect() or die("Cannot connect to the broker!\n");# 連接服務 $channel = new AMQPChannel($connection); $exchange = new AMQPExchange($channel); $exchange->setName($exchangeName); # 設置交換器類型 $exchange->setType(AMQP_EX_TYPE_DIRECT); # 交換器持久化 //$exchange->setFlags(AMQP_DURABLE); $exchange->declareExchange();$queue = new AMQPQueue($channel); $queue->setName($queueName); $queue->setFlags(AMQP_DURABLE); $queue->declareQueue();# 隊列根據routekey 裝載消息 $queue->bind($exchangeName,$routeKey); var_dump('[*] Waiting for messages. To exit press CTRL+C'); # $queue->consume('callback'); # 設置每次只能處理一條,避免消息堆積,從而導致隊列掛掉 $channel->qos(0,1); #關閉連接 $connection->disconnect();function callback($envelope, $queue) {$msg = $envelope->getBody(); // var_dump(" [x] Received:" . $msg);echo $msg."\n"; // # nack 讓沒有通過的消息可以 再次進入隊列, ack 沒有通過的消息不能再次回到隊列中 // # 通知隊列消息通過,可以執行下一個消息$queue->nack($envelope->getDeliveryTag()); } ?>

?

? 這些代碼都是在網上收集的,我個人在附加了一些方法和參數的使用方法,希望能幫到各位,謝謝!!!!

來源：https://www.cnblogs.com/fqyb/p/9091945.html

總結

以上是生活随笔為你收集整理的PHP中使用RabiitMQ---各项参数的使用方法的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。