RabbitMQ入門 使用

2021-08-19 11:03:11 字數 659 閱讀 2589

測試環境:thinkphp5.0

use

phpamqplib\connection\amqpstreamconnection;

usephpamqplib\message\amqpmessage;

3、在控制器或者配置檔案中定義相關引數

public

static

$amqp = array(

'name' => 'admin',

'password' => 'admin',//填寫加密用的encodingaeskey,

'exchange' => 'publish-topic',

'command'=>'admin',//主題口令

'mode' => 'topic'

//方式

);

4、定義qmqp方法

/**

* [amqp 訊息佇列]

*@param [arr] $data [傳送資料]**/

public

function

amqp

($data="aaa",$topic="hello")

這裡只簡單演示訊息傳送;訊息的消費可參考rabbit官網

RabbitMQ入門案例

二.編寫 1.建立佇列 建立訊息佇列 configuration public class queueconfig 2.建立訊息提供者 component public class sender 3.訊息接收者 component public class receiver 3.rabbitmq原理...

RabbitMQ入門 總結

1rabbitmq入門 認識並安裝rabbitmq 以windows系統為例 我們初步認識並安裝了rabbitmq 2rabbitmq入門 hello rabbitmq 例項 通過小例子了解了 的實現方式 3rabbitmq入門 工作佇列 work queue 認識了工作佇列 迴圈分發 公平分發 訊...

RabbitMQ入門 Topic模式

上篇 rabbitmq入門 routing直連模式 我們介紹了可以定向傳送訊息,並可以根據自定義規則派發訊息。看起來,這個routing模式已經算靈活的了,但是,這還不夠,我們還有更加多樣靈活的topic模式。這時候我們給program argument賦值如下,並啟動傳送端程式 程式執行完,可以在...