这类
RabbitMQ
技术博客是打算出三套的,计算如下表格。原理上RabbitMQ
的使用都是一致的,只不过不同平台提供的特性和安装使用方式需要大家注意,本文记录的是在windows
平台下安装和使用RabbitMQ
。
- 案例开发选型如下:后续将更换
RabbitMQ
为RocketMQ
和Kafka
同样开发三套案例,并提供基准测试数据和个人使用心得。
开发平台 | 开发语言 | 应用框架 | 开源地址 |
---|---|---|---|
Windows | PHP | Laravel | https://github.com/erchoc/win-rabbitmq-php |
MacOS | Node | Koa2 | https://github.com/erchoc/mac-rabbitmq-node |
Linux | Python | Django | https://github.com/erchoc/linux-rabbitmq-py3 |
1. RabbitMQ3.7
安装测试和基本CLI
命令操作。
1.1 下载安装 erlang
和 rabbitmq
:
- erlang
下载地址:http://erlang.org/download/otp_win64_21.0.1.exe
- rabbitmq3.7
下载地址:https://github.com/rabbitmq/rabbitmq-server/xxx.exe
1.2 使用命令 erl
和 rabbitmq-server
查看是否安装成功,无效则自行添加环境变量。
- 默认erlang路径
:C:\Program Files\erl10.0.1\bin
- 默认rabbitmq路径
:C:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.7\sbin
1.3 windows
下rabbitmq
的可执行文件均为 .bat
脚本,执行 rabbitmq-server
会默认启动一个名为 rabbit
的服务端结点,你可以使用 `` 中断服务。
1.4 使用插件 rabbitmq_management
,方便在网页上管理和查看消息队列相关信息。请执行命令:rabbitmq-plugins.bat enable rabbitmq_management
添加拓展的三个插件。
1.5 访问 http://server-name:15672
登陆 rabbitmq
管理页面,默认账号密码均为 guest
,默认监听端口 15672
。
1.6 4.配置允许远程访问:队列服务往往不在本机,我们需要远程来控制 RabbitMQ
。但是默认是无法通过 http://server-name:15672
来访问,可以通过修改C:\Program Files\RabbitMQ Server\rabbitmq_server-3.7.7\etc
下的rabbitmq.config.example
来设置允许guest
用户远程登录,具体修改为如下值,然后就到服务管理器中重启 RabbitMQ
服务。
[{
rabbit, [{
loopback_users, [guest]
}]
}].
- 备注:默认
RabbitMQ
会在C:\Users\Administrator\AppData\Roaming\RabbitMQ
中生成一个配置文件,rabbitmq.config.example
里面就是实际用到的配置信息,如果图方便,也可以这里直接改。
1.7 rabbitmq
终端管理命令有:rabbitmqctl
,rabbitmq-server
,rabbitmq-service
,rabbitmq-plugins管理插件
,rabbitmqadmin网页管理
。(windows版均要使用.bat后缀脚本)
1.8
1.9
2. Laravel5.6
安装测试和基本命令操作。
2.1 安装 composer
,创建新的 laravel
项目,代号/目录名为 win-rabbitmq-php
:composer create-project laravel/laravel win-rabbitmq-php
。
-
composer下载地址
https://getcomposer.org/Composer-Setup.exe - 执行命令使用国内
composer
源:composer config -g repo.packagist composer https://packagist.phpcomposer.com
。 - 注意:
windows
版本的composer
安装会有超时错误,请多安装几次或者使用vpn
解决。
2.2 PHP
安装 AMQP
拓展,添加到 ext/
目录下并修改 php.ini
。重启 php
后使用 php -m
查看拓展是否安装。
2.3 引入第三方模块的两种方式:
- 修改
composer.json
文件,然后执行composer update
。 - 命令行输入:
composer require php-amqplib/php-amqplib
。
2.4 配置 config.php
,
3. 创造一个Hello World
试试
3.1 需求:服务提供者和服务消费者均占用一个线程,A提供了一个服务,用于向 test.txt
文件插入一条文本消息,X从消息队列中取出消息,进行消费,插入成功。
3.2 确定配置文件没问题后,在 Laravel
和 php-amqplib
库的基础上进行代码编写。
3.3 发
3.4 发
3.5 发
4. 多进程间RPC
通讯接口实战
4.1 使用到的第三方库:php-amqplib/php-amqplib
4.2 Laravel安装第三方 composer
组件的两种方式:
- 修改
composer.json
文件,然后执行composer update
。 - 命令行输入:
composer require php-amqplib/php-amqplib
。
4.3 实战需求:后端提供多个进程,每个进程中有多个方法操作 Model
层,演示各个进程之间方法的调用和服务消费。
4.4 发
4.5 发
4.6 发