php 使用rabbitmq 踩坑記錄

leiyi 發(fā)布于2019-07-01 12:42 / 1473人閱讀

摘要：當(dāng)關(guān)閉的時候，隊列將被刪除。空是自動刪除綁定隊列和交換機(jī)，生成發(fā)送消息到隊列持久化，重啟不會丟失，默認(rèn)為，重啟會丟失

環(huán)境

1.安裝rabbit

php使用

安裝包，直接安裝composer 安裝php-amqplib/php-amqplib 這個包

生產(chǎn)著

連接mq server

require_once __DIR__."/vendor/autoload.php";
use PhpAmqpLibConnectionAMQPStreamConnection;
use PhpAmqpLibExchangeAMQPExchangeType;
use PhpAmqpLibMessageAMQPMessage;

$connection = new AMQPStreamConnection("127.0.0.1", 5672, "guest", "guest", "yedong_test");  //連接server
$channel = $connection->channel(); //創(chuàng)建通道

創(chuàng)建交換機(jī)

$exchange="example_direct_exchange";
/*
name: $exchange
type: fanout  交換機(jī)類型
passive: false // don"t check if an exchange with the same name exists 
durable: false // the exchange won"t survive server restarts  //是否是持久化
auto_delete: true //the exchange will be deleted once the channel is closed. 
*/
$channel->exchange_declare($exchange, AMQPExchangeType::DIRECT, false, true, true);

3.創(chuàng)建隊列

//參數(shù)
        $queue = "",   //隊列名稱
        $passive = false, //檢查是否村子啊
        $durable = false, //是否持久化
        $exclusive = false, //排外，①當(dāng)前定義的隊列是connection的channel是共享的，其他的connection是訪問不到的。②當(dāng)connection關(guān)閉的時候，隊列將被刪除。
        $auto_delete = true, //空是自動刪除
        $nowait = false,     //
        $arguments = array(),
        $ticket = null
        
![clipboard.png](/img/bVbrPP9)

$channel->queue_declare("test_queue_3",true,true,false,false,false,[],null);

4.綁定隊列和交換機(jī)，生成routing_key

$channel->queue_bind("example_direct_queue_2",$exchange,"routeTest1");

5.發(fā)送消息到隊列

![clipboard.png](/img/bVbrPRr)

$msg = new AMQPMessage($i, ["content_type" => "text/plain","delivery_mode"=>2]); //2:持久化，重啟不會丟失，默認(rèn)為1，重啟會丟失
$channel->basic_publish($msg, $exchange,"routeTest1");