CentOS7下安装RabbitMQ3.7.9
1.首先安装Erlang
[1] 安装依赖组件
yum install epel-release yum install unixODBC unixODBC-devel wxBase wxGTK SDL wxGTK-gl
[2] 可能会出现如下错误erlang >= 19.3 被 rabbitmq-server-3.7.9-1.el7.noarch,通过下面步骤解决
[3] 设置RabbitMQ的依赖源, 编辑/etc/yum.repos.d/rabbitmq-erlang.repo输入以下内容:
[rabbitmq-erlang] name=rabbitmq-erlang baseurl=https://dl.bintray.com/rabbitmq/rpm/erlang/20/el/7 gpgcheck=1 gpgkey=https://dl.bintray.com/rabbitmq/Keys/rabbitmq-release-signing-key.asc repo_gpgcheck=0 enabled=1
2. 下载RabbitMQ的安装包
# yum clean all # yum makecache # wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.7.9/rabbitmq-server-3.7.9-1.el7.noarch.rpm
3. yum install rabbitmq-server-3.7.9-1.el7.noarch.rpm
4. 出现的问题
[1] 问题1
Transaction check error: file /usr/bin/epmd from install of erlang-20.3.8.10-1.el7.centos.x86_64 conflicts with file from package esl-erlang-21.1.1-1.x86_64 file /usr/bin/erl from install of erlang-20.3.8.10-1.el7.centos.x86_64 conflicts with file from package esl-erlang-21.1.1-1.x86_64 file /usr/bin/erlc from install of erlang-20.3.8.10-1.el7.centos.x86_64 conflicts with file from package esl-erlang-21.1.1-1.x86_64 file /usr/bin/escript from install of erlang-20.3.8.10-1.el7.centos.x86_64 conflicts with file from package esl-erlang-21.1.1-1.x86_64 file /usr/bin/run_erl from install of erlang-20.3.8.10-1.el7.centos.x86_64 conflicts with file from package esl-erlang-21.1.1-1.x86_64 file /usr/bin/to_erl from install of erlang-20.3.8.10-1.el7.centos.x86_64 conflicts with file from package esl-erlang-21.1.1-1.x86_64:
解决:卸载冲突的组件
yum remove esl-erlang-21.1.1-1.x86_64 esl-erlang-21.1.1-1.x86_64 esl-erlang-21.1.1-1.x86_64 esl-erlang-21.1.1-1.x86_64 esl-erlang-21.1.1-1.x86_64 esl-erlang-21.1.1-1.x86_64 esl-erlang-21.1.1-1.x86_64 esl-erlang-21.1.1-1.x86_64
解决参考网址:https://blog.csdn.net/huijiangu4621/article/details/83619707
5. RabbitMQ 管理
[1] 启动RabbitMQ # rabbitmq-server start # rabbitmqctl stop [2] 用户管理 # rabbitmqctl add_user admin admim # rabbitmqctl delete_user admin # rabbitmqctl list_users # rabbitmqctrl change_password admin admin123 [3] 权限管理 # rabbitmqctl set_permissions -p / admin ".*" ".*" ".*" # rabbitmqctl list_permissions -p / # rabbitmqctl clear_permissions -p / admin 说明: -p /:代表 set_permissions 控制条目应该用到哪个 vhosts 上; admin:代表被授权的用户名字; ".*" ".*" ".*":分别代表配置、读和写权限,而其中的 ".*" 为正则表达式,代表匹配所有权限; [4] 角色管理 # rabbitmqctl set_user_tags admin administrator # rabbitmqctl list_users 说明: 为用户添加权限,已经基本可以满足我们的需求了,但有时,我们可以使用系统预置的角色,为用户赋予角色,那么该用户也就拥有了该角色所赋予的所有权限了,在 RabbitMQ 中,角色大致分为超级管理员、监控者、策略制定者、普通管理者以及其他,它们的区别是什么? (1) 超级管理员(administrator) 可登陆管理控制台(启用managementplugin的情况下),可查看所有的信息,并且可以对用户,策略(policy)进行操作。 (2) 监控者(monitoring) 可登陆管理控制台(启用managementplugin的情况下),同时可以查看rabbitmq节点的相关信息(进程数,内存使用情况,磁盘使用情况等) (3) 策略制定者(policymaker) 可登陆管理控制台(启用managementplugin的情况下),同时可以对policy进行管理。但无法查看节点的相关信息(上图红框标识的部分)。 (4) 普通管理者(management) 仅可登陆管理控制台(启用managementplugin的情况下),无法看到节点信息,也无法对策略进行管理。 [5] 启用/禁用Web控制台 # rabbitmq-plugins enable/disabled rabbitmq_management
[6] PHP 与 RabbitMQ 基础操作
(1) 在项目根目录创建 composer.json 文件。内容如下: { "require": { "php-amqplib/php-amqplib": ">=2.6.1" } } (2) $ composer install (3) 然后新建send.php发送消息内容如下: <?php require_once __DIR__ . '/vendor/autoload.php'; use PhpAmqpLib\Connection\AMQPStreamConnection; use PhpAmqpLib\Message\AMQPMessage; // [1] 创建 RabbitMQ 连接 $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); // [2] 打开一个通道。 $channel = $connection->channel(); // [3] 定义一个队列。 $channel->queue_declare('hello', false, false, false, false); // [4] 创建一条字符串消息对象。 $msg = new AMQPMessage('Hello World!'); // [5] 向队列当中推送一条消息。 $channel->basic_publish($msg, '', 'hello'); echo " [x] Sent 'Hello World!'\n"; // [6] 关闭通道。 $channel->close(); // [7] 关闭连接。 $connection->close(); (4) 接收队列消息并消费 require_once __DIR__ . '/vendor/autoload.php'; use PhpAmqpLib\Connection\AMQPStreamConnection; // [1] 创建 RabbitMQ 连接。 $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest'); // [2] 打开一个通道。 $channel = $connection->channel(); // [3] 定义一个队列。 $channel->queue_declare('hello', false, false, false, false); echo ' [*] Waiting for messages. To exit press CTRL+C', "\n"; // [4] 定义一个匿名方法处理接收到的消息。 $callback = function($msg) { echo " [x] Received ", $msg->body, "\n"; }; // [5] 设置接收到的消息由谁来消息。 $channel->basic_consume('hello', '', false, true, false, false, $callback); // [6] 循环等待接收队列的消息。 while(count($channel->callbacks)) { $channel->wait(); } (5) 启动脚本 #php receive.php #php php send.php
参考网址: https://www.jianshu.com/p/3528eb0481c8
相关推荐
NVEFLY 2020-07-04
OnMyHeart 2020-06-06
87447007 2020-05-16
zhuxue 2020-10-14
shenzhenzsw 2020-10-09
shyoldboy 2020-09-27
leihui00 2020-09-16
lishijian 2020-08-17
程序员伊成 2020-08-06
ljcsdn 2020-07-27
waitzkj 2020-07-25
powrexly 2020-07-20
liym 2020-07-20
zhoucheng0 2020-07-19
shenzhenzsw 2020-07-18
woaishanguosha 2020-07-18
waitzkj 2020-07-18
zhoucheng0 2020-07-08