rabbitmq安裝和使用簡介

2021-08-21 21:39:37 字數 1682 閱讀 7744

apt install rabbitmq-server 

開啟rabbitmq-server

service rabbitmq-server restart

rabbitmq自帶了很多外掛程式, 都放在

/usr/lib/rabbitmq/lib/rabbitmq_server-3.5.7/plugins

目錄下, 可通過rabbitmq-plugins 指令開啟

rabbitmq-plugins enable rabbitmq_management

開啟後需要重啟rabbitmq-server服務才會生效。

開啟介面後發現需要賬號密碼才能進去, 在老版本是可以用guest賬號進去, 但是在新版本中禁用掉了。

所以需要先建立賬號:

rabbitmqctl add_user admin admin

然後給賬號分配角色:

rabbitmqctl add_user admin admin

最後還需要給賬號分配許可權

rabbitmqctl set_permissions  -p / admin ".*" ".*" ".*"

關於rabbitmq的角色參考:

生產者:

producer.php

require_once __dir__ . '/vendor/autoload.php';

//建立連線

$connection = new \phpamqplib\connection\amqpstreamconnection('172.17.0.2', 5672, 'admin', 'admin');

//建立channel

$channel = $connection->channel();

//宣告佇列

$channel->queue_declare('test');

//定義訊息物件

$msg = new \phpamqplib\message\amqpmessage('hello world');

//發布訊息

$channel->basic_publish($msg, '', 'test');

echo 'send message';

//關閉channel

$channel->close();

//關閉連線

$connection->close();

消費者:

consumer.php

require_once __dir__ . '/vendor/autoload.php';

$connection = new \phpamqplib\connection\amqpstreamconnection('172.17.0.2', 5672, 'admin', 'admin');

$chanel = $connection->channel();

$chanel->queue_declare('test');

$callback = function ($msg) ;

$chanel->basic_consume('test', '', false, true, false, false, $callback);

while (count($chanel->callbacks))

RabbitMQ簡介和安裝

微服務架構中,應用系統與應用系統之間的邏輯關係,根據產生請求與消化請求的立場區別,可以分為生產者 請求方 與消費者 服務方 就像是辦理銀行業務的過程中客戶 產生請求 和銀行的服務視窗 用來消化請求 之間的對等關係,而mq message queue 訊息佇列就相當於叫號器,客戶取票後它來對請求進行分...

RabbitMQ簡介及其安裝

rabbitmq是實現了高階訊息佇列協議 amqp 的開源訊息 軟體 亦稱面向訊息的中介軟體 rabbitmq伺服器是用erlang語言編寫的。發布者 publisher 發布訊息 message 經由交換機 exchange 交換機根據路由規則將收到的訊息分發給與該交換機繫結的佇列 queue 最...

rabbitMq安裝和簡單使用

首先要在 etc yum.repos.d 建立乙個檔案檔案的結尾必須以.repo結尾。eg rabbitmq.repo centos7中新增下面的內容 bintray rabbitmq server name bintray rabbitmq rpm baseurl gpgcheck 0 repo ...