apt install rabbitmq-server

# 查看当前所有用户

$ rabbitmqctl list_users
 
# 查看默认guest用户的权限
$ rabbitmqctl list_user_permissions guest
 
# 由于RabbitMQ默认的账号用户名和密码都是guest。为了安全起见, 先删掉默认用户
$ rabbitmqctl delete_user guest
 
# 添加新用户
$ rabbitmqctl add_user username password
 
# 新增管理员用户
$ rabbitmqctl set_user_tags username administrator
 
# 赋予用户默认vhost的全部操作权限
$ rabbitmqctl set_permissions -p / username ".*" ".*" ".*"
 
# 查看用户的权限
$ rabbitmqctl list_user_permissions username

# 列出所有队列
$ rabbitmqctl list_queues

# 查看未确认队列
$ rabbitmqctl list_queues name messages_ready messages_unacknowledged

# 列出服务器上所有的交换器  直连交换机（direct）, 主题交换机（topic）, （头交换机）headers和 扇型交换机（fanout）
$ rabbitmqctl list_exchanges

# 列出所有现存的绑定
$ rabbitmqctl list_bindings

# 查看运行信息，版本等信息
$ rabbitmqctl status

[
{rabbit, [{tcp_listeners, [5670]}]}
].

listeners.tcp.default = 21130
management.listener.port = 21131
mqtt.listeners.tcp.default = 21132
web_mqtt.tcp.port = 21133
# MQTT开启匿名远程访问
mqtt.allow_anonymous  = true
loopback_users = none

rabbitmq-plugins enable rabbitmq_management

rabbitmq-plugins enable rabbitmq_mqtt

rabbitmq-plugins enable rabbitmq_web_mqtt

apt remove rabbitmq-server

wget -O- https://packages.erlang-solutions.com/ubuntu/erlang_solutions.asc | apt-key add -
echo "deb https://packages.erlang-solutions.com/ubuntu bionic contrib" | tee /etc/apt/sources.list.d/rabbitmq.list
apt update
apt -y install erlang

wget -O- https://dl.bintray.com/rabbitmq/Keys/rabbitmq-release-signing-key.asc | apt-key add -
wget -O- https://www.rabbitmq.com/rabbitmq-release-signing-key.asc | apt-key add -
echo "deb https://dl.bintray.com/rabbitmq/debian $(lsb_release -sc) main" | tee /etc/apt/sources.list.d/rabbitmq.list
apt update
apt -y install rabbitmq-server

[{rabbitmq_management, [{listener, [{port, 12345}]}]}].

[{rabbit, [{loopback_users, []}]}].

[
	{rabbitmq_management, [{listener, [{port, 11131}]}]},
	{rabbit, [{tcp_listeners, [11130]},{loopback_users, []}]}
].

apt install php7.2-bcmath

composer require php-amqplib/php-amqplib

<?php
require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

$connection = new AMQPStreamConnection('192.168.1.45', 11111, 'u1', 'u1');
$channel = $connection->channel();

$body = 'hi bric';

$queue_name = 'Hello_ERP';

$channel->queue_declare($queue_name, false, true, false, false);
$msg = new AMQPMessage($body,
	array('delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT)
);
$channel->basic_publish($msg, '', $queue_name);
echo " [x] Sent '${body}'\n";
$channel->close();
$connection->close();
die;

<?php
require_once __DIR__ . '/vendor/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;

$queue_name = 'Hello_16988';

$connection = new AMQPStreamConnection('192.168.1.45', 11111, 'u1', 'u1');
$channel = $connection->channel();

$channel->queue_declare($queue_name, false, true, false, false);

echo " [*] Waiting for messages. To exit press CTRL+C\n";


$callback = function ($msg) {
	echo " [x] Received ", $msg->body, "\n";
	$msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
};

$channel->basic_consume($queue_name, '', false, false, false, false, $callback);

while (count($channel->callbacks)) {
	$channel->wait();
}