备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

【AMQP】macOS下的AMQP服务器以及PHP扩展搭建

2017-02-23 2132
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 环境说明macOS版本, macOS Sierra 10.12.3 (16D32)PHP集成环境, XAMPP 7.0.15-0 Apache 2.4.25,MariaDB 10.

环境说明

  • macOS版本, macOS Sierra 10.12.3 (16D32)
  • PHP集成环境, XAMPP 7.0.15-0
  • Apache 2.4.25,
  • MariaDB 10.1.21
  • PHP 7.0.15

前期准备

修改本地path文件

sudo vi /etc/paths

在文件的最上面添加/Applications/XAMPP/xamppfiles/bin

重启中端

bogon:~ xiaoyu$ php -v
PHP 7.0.15 (cli) (built: Jan 20 2017 07:22:25) ( NTS )
Copyright (c) 1997-2017 The PHP Group
Zend Engine v3.0.0, Copyright (c) 1998-2017 Zend Technologies

安装RabbitMQ扩展

wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.6/rabbitmq-server-mac-standalone-3.6.6.tar.xz

tar -xf rabbitmq-server-mac-standalone-3.6.6.tar.xz 

cd rabbitmq_server-3.6.6/

sbin/rabbitmq-server

报错 ERROR: epmd error for host bogon: timeout (timed out)

修改hosts , 增加 127.0.0.1 bogon

继续

bogon:rabbitmq_server-3.6.6 xiaoyu$ sbin/rabbitmq-server

              RabbitMQ 3.6.6. Copyright (C) 2007-2016 Pivotal Software, Inc.
  ##  ##      Licensed under the MPL.  See http://www.rabbitmq.com/
  ##  ##
  ##########  Logs: /Applications/XAMPP/rabbitmq_server-3.6.6/var/log/rabbitmq/rabbit@bogon.log
  ######  ##        /Applications/XAMPP/rabbitmq_server-3.6.6/var/log/rabbitmq/rabbit@bogon-sasl.log
  ##########
              Starting broker...
 completed with 0 plugins.

添加到本地PATH

sudo vi /etc/paths

添加所在sbin路径/Applications/XAMPP/rabbitmq_server-3.6.6/sbin

重启终端

再次启动服务

rabbitmq-server

安装 RabbitMQ management UI

这个图形化界面是一个插件

bogon:~ xiaoyu$ rabbitmq-plugins enable rabbitmq_management
The following plugins have been enabled:
  mochiweb
  webmachine
  rabbitmq_web_dispatch
  amqp_client
  rabbitmq_management_agent
  rabbitmq_management

Applying plugin configuration to rabbit@bogon... failed.
 * Could not contact node rabbit@bogon.
   Changes will take effect at broker restart.
 * Options: --online  - fail if broker cannot be contacted.
            --offline - do not try to contact broker.

重启服务后，就会变成completed with 6 plugins.

访问图形化登录界面的地址为http://localhost:15672/

用户管理

# 创建用户
rabbitmqctl add_user demo pwd

# 赋予超级管理员权限
rabbimqctl set_user_tags  demo administrator

之后就可以登录图形化管理界面了

用户标签

在创建用户的之后，需要通过标签的形式给用户赋予对应的权限

administrator | monitoring | policymaker | management |

Comma-separated list of tags to apply to the user. Currently supported by the management plugin:
- management
User can access the management plugin
- policymaker
User can access the management plugin and manage policies and parameters for the vhosts they have access to.
- monitoring
User can access the management plugin and see all connections and channels as well as node-related information.
- administrator
User can do everything monitoring can do, manage users, vhosts and permissions, close other user’s connections, and manage policies and parameters for all vhosts.
Note that you can set any tag here; the links for the above four tags are just for convenience.

安装AMQP扩展

sudo pecl install amqp

#失败

configure: error: Please reinstall the librabbitmq distribution itself or (re)install librabbitmq development package if it available in your system

安装 rabbitmq-c


git clone git://github.com/alanxz/rabbitmq-c.git

cd rabbitmq-c

git submodule init

git submodule update



#报错
bogon:rabbitmq-c xiaoyu$  autoreconf -i && ./configure && make && sudo make install
Can't exec "aclocal": No such file or directory at /usr/local/Cellar/autoconf/2.69/share/autoconf/Autom4te/FileUtils.pm line 326.
autoreconf: failed to run aclocal: No such file or directory

安装 aclocal

`aclocal’ is part of automake package, try to install it first.

所以需要重新安装automake

brew install automake

继续安装rabbitmq-c

autoreconf -i


#报错 

Makefile.am:6: error: Libtool library used but 'LIBTOOL' is undefined

brew install libtool
autoreconf -i

#报错

Can't exec "libtoolize": No such file or directory at /usr/local/share/autoconf/Autom4te/FileUtils.pm line 344, <GEN3> line 4.
autoreconf: failed to run libtoolize: No such file or directory
autoreconf: libtoolize is needed because this package uses Libtool


#添加PATH /usr/local/Cellar/libtool/2.4.6_1/bin

brew install boost double-conversion gflags glog libevent
sudo ln -s /usr/local/bin/glibtoolize /usr/local/bin/libtoolize

继续

autoreconf -i

./configure && make && sudo make install

#报错

./librabbitmq/amqp_openssl_bio.h:26:10: fatal error: 'openssl/bio.h' file not found
#include <openssl/bio.h>
         ^
1 error generated.
make[1]: *** [librabbitmq/librabbitmq_librabbitmq_la-amqp_openssl.lo] Error 1
make: *** [all] Error 2


#xcode安装openssl

xcode-select --install

xcode-select -p #找到xcode的路径

找不到 对应文件夹，失败

#编译安装openssl

git clone  https://github.com/openssl/openssl.git

cd openssl

./config

make

make test

make install 

## 编译安装报错
Cannot find "ERR_get_error(3)" in podpath: cannot find suitable replacement path, cannot resolve link

经过下面验证可以用

继续

./configure && make && sudo make install

继续安装AMQP

sudo pecl install amqp

#成功
Build process completed successfully
Installing '/Applications/XAMPP/xamppfiles/lib/php/extensions/no-debug-non-zts-20151012/amqp.so'
install ok: channel://pecl.php.net/amqp-1.8.0
configuration option "php_ini" is not set to php.ini location
You should add "extension=amqp.so" to php.ini

修改配置文件

重启服务器

php -m

# 扩展安装成功

[PHP Modules]
**amqp**
bcmath
bz2
calendar
Core
.....

编写测试代码

创建项目

创建 composer.json文件

{
  "require": {
      "php-amqplib/php-amqplib": "2.6.*"
  }
}

在项目所在目录执行composer install

测试demo

配置文件config.php

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

define('HOST', 'bogon');
define('PORT', 5672);
define('USER', 'guest');
define('PASS', 'guest');
define('VHOST', '/');
//If this is enabled you can see AMQP output on the CLI
define('AMQP_DEBUG', true);

demo文件test.php

<?php
include(__DIR__ . '/config.php');
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

$exchange = 'basic_get_test';
$queue = 'basic_get_queue';

$connection = new AMQPStreamConnection(HOST, PORT, USER, PASS, VHOST);
$channel = $connection->channel();
/*
    The following code is the same both in the consumer and the producer.
    In this way we are sure we always have a queue to consume from and an
        exchange where to publish messages.
*/
/*
    name: $queue
    passive: false
    durable: true // the queue will survive server restarts
    exclusive: false // the queue can be accessed in other channels
    auto_delete: false //the queue won't be deleted once the channel is closed.
*/
$channel->queue_declare($queue, false, true, false, false);
/*
    name: $exchange
    type: direct
    passive: false
    durable: true // the exchange will survive server restarts
    auto_delete: false //the exchange won't be deleted once the channel is closed.
*/
$channel->exchange_declare($exchange, 'direct', false, true, false);
$channel->queue_bind($queue, $exchange);
$toSend = new AMQPMessage('test message', array('content_type' => 'text/plain', 'delivery_mode' => 2));
$channel->basic_publish($toSend, $exchange);
$message = $channel->basic_get($queue);
$channel->basic_ack($message->delivery_info['delivery_tag']);
var_dump($message->body);
$channel->close();
$connection->close();

命令行运行代码php test.php,得到debug信息，和正确的返回

< [hex]: 
0000  41 4D 51 50 00 00 09 01                            AMQP.... 

waiting for 10,10
waiting for a new frame
> 10,10: Connection.start
Start from server, version: 0.9, properties: capabilities=(publisher_confirms=1, exchange_exchange_bindings=1, basic.nack=1, consumer_cancel_notify=1, connection.blocked=1, consumer_priorities=1, authentication_failure_close=1, per_consumer_qos=1, direct_reply_to=1), cluster_name=rabbit@bogon, copyright=Copyright (C) 2007-2016 Pivotal Software, Inc., information=Licensed under the MPL.  See http://www.rabbitmq.com/, platform=Erlang/OTP, product=RabbitMQ, version=3.6.6, mechanisms: AMQPLAIN, PLAIN, locales: en_US
< 10,11:: Connection.start_ok
< [hex]: 
0000  01 00 00 00 00 01 31 00  0A 00 0B 00 00 00 F3 07   ......1. ......?.
0010  70 72 6F 64 75 63 74 53  00 00 00 07 41 4D 51 50   productS ....AMQP
0020  4C 69 62 08 70 6C 61 74  66 6F 72 6D 53 00 00 00   Lib.plat formS...
0030  03 50 48 50 07 76 65 72  73 69 6F 6E 53 00 00 00   .PHP.ver sionS...
0040  03 32 2E 36 0B 69 6E 66  6F 72 6D 61 74 69 6F 6E   .2.6.inf ormation
0050  53 00 00 00 00 09 63 6F  70 79 72 69 67 68 74 53   S.....co pyrightS
0060  00 00 00 00 0C 63 61 70  61 62 69 6C 69 74 69 65   .....cap abilitie
0070  73 46 00 00 00 8C 1C 61  75 74 68 65 6E 74 69 63   sF...?.a uthentic
0080  61 74 69 6F 6E 5F 66 61  69 6C 75 72 65 5F 63 6C   ation_fa ilure_cl
0090  6F 73 65 74 01 12 70 75  62 6C 69 73 68 65 72 5F   oset..pu blisher_
00A0  63 6F 6E 66 69 72 6D 73  74 01 16 63 6F 6E 73 75   confirms t..consu
00B0  6D 65 72 5F 63 61 6E 63  65 6C 5F 6E 6F 74 69 66   mer_canc el_notif
00C0  79 74 01 1A 65 78 63 68  61 6E 67 65 5F 65 78 63   yt..exch ange_exc
00D0  68 61 6E 67 65 5F 62 69  6E 64 69 6E 67 73 74 01   hange_bi ndingst.
00E0  0A 62 61 73 69 63 2E 6E  61 63 6B 74 01 12 63 6F   .basic.n ackt..co
00F0  6E 6E 65 63 74 69 6F 6E  2E 62 6C 6F 63 6B 65 64   nnection .blocked
0100  74 01 08 41 4D 51 50 4C  41 49 4E 00 00 00 23 05   t..AMQPL AIN...#.
0110  4C 4F 47 49 4E 53 00 00  00 05 67 75 65 73 74 08   LOGINS.. ..guest.
0120  50 41 53 53 57 4F 52 44  53 00 00 00 05 67 75 65   PASSWORD S....gue
0130  73 74 05 65 6E 5F 55 53  CE                        st.en_US ?

< 10,11:: Connection.start_ok
waiting for 10,20, 10,30
waiting for a new frame
> 10,30: Connection.tune
< 10,31:: Connection.tune_ok
< [hex]: 
0000  01 00 00 00 00 00 0C 00  0A 00 1F FF FF 00 02 00   ........ ...??...
0010  00 00 00 CE                                        ...?

< 10,31:: Connection.tune_ok
< 10,40:: Connection.open
< [hex]: 
0000  01 00 00 00 00 00 08 00  0A 00 28 01 2F 00 00 CE   ........ ..(./..?

< 10,40:: Connection.open
waiting for 10,41
waiting for a new frame
> 10,41: Connection.open_ok
Open OK! known_hosts: 
using channel_id: 1
< 20,10:: Channel.open
< [hex]: 
0000  01 00 01 00 00 00 05 00  14 00 0A 00 CE            ........ ....?

< 20,10:: Channel.open
waiting for 20,11
waiting for a new frame
> 20,11: Channel.open_ok
Channel open
< 50,10:: Queue.declare
< [hex]: 
0000  01 00 01 00 00 00 1B 00  32 00 0A 00 00 0F 62 61   ........ 2.....ba
0010  73 69 63 5F 67 65 74 5F  71 75 65 75 65 02 00 00   sic_get_ queue...
0020  00 00 CE                                           ..?

< 50,10:: Queue.declare
waiting for 50,11
waiting for a new frame
> 50,11: Queue.declare_ok
< 40,10:: Exchange.declare
< [hex]: 
0000  01 00 01 00 00 00 21 00  28 00 0A 00 00 0E 62 61   ......!. (.....ba
0010  73 69 63 5F 67 65 74 5F  74 65 73 74 06 64 69 72   sic_get_ test.dir
0020  65 63 74 02 00 00 00 00  CE                        ect..... ?

< 40,10:: Exchange.declare
waiting for 40,11
waiting for a new frame
> 40,11: Exchange.declare_ok
< 50,20:: Queue.bind
< [hex]: 
0000  01 00 01 00 00 00 2B 00  32 00 14 00 00 0F 62 61   ......+. 2.....ba
0010  73 69 63 5F 67 65 74 5F  71 75 65 75 65 0E 62 61   sic_get_ queue.ba
0020  73 69 63 5F 67 65 74 5F  74 65 73 74 00 00 00 00   sic_get_ test....
0030  00 00 CE                                           ..?

< 50,20:: Queue.bind
waiting for 50,21
waiting for a new frame
> 50,21: Queue.bind_ok
< 60,40:: Basic.publish
< [hex]: 
0000  01 00 01 00 00 00 17 00  3C 00 28 00 00 0E 62 61   ........ <.(...ba
0010  73 69 63 5F 67 65 74 5F  74 65 73 74 00 00 CE 02   sic_get_ test..?.
0020  00 01 00 00 00 1A 00 3C  00 00 00 00 00 00 00 00   .......< ........
0030  00 0C 90 00 0A 74 65 78  74 2F 70 6C 61 69 6E 02   ..?..tex t/plain.
0040  CE 03 00 01 00 00 00 0C  74 65 73 74 20 6D 65 73   ?....... test mes
0050  73 61 67 65 CE                                     sage?

< 60,70:: Basic.get
< [hex]: 
0000  01 00 01 00 00 00 17 00  3C 00 46 00 00 0F 62 61   ........ <.F...ba
0010  73 69 63 5F 67 65 74 5F  71 75 65 75 65 00 CE      sic_get_ queue.?

< 60,70:: Basic.get
waiting for 60,71, 60,72
waiting for a new frame
> 60,71: Basic.get_ok
waiting for a new frame
waiting for a new frame
< 60,80:: Basic.ack
< [hex]: 
0000  01 00 01 00 00 00 0D 00  3C 00 50 00 00 00 00 00   ........ <.P.....
0010  00 00 01 00 CE                                     ....?

< 60,80:: Basic.ack
string(12) "test message"
< 20,40:: Channel.close
< [hex]: 
0000  01 00 01 00 00 00 0B 00  14 00 28 00 00 00 00 00   ........ ..(.....
0010  00 00 CE                                           ..?

< 20,40:: Channel.close
waiting for 20,41
waiting for a new frame
> 20,41: Channel.close_ok
< 10,50:: Connection.close
< [hex]: 
0000  01 00 00 00 00 00 0B 00  0A 00 32 00 00 00 00 00   ........ ..2.....
0010  00 00 CE                                           ..?

< 10,50:: Connection.close
waiting for 10,51
waiting for a new frame
> 10,51: Connection.close_ok
closing input
closing socket

到此，环境配置完成

总结

本次配置环境涉及到了

  • 不同bash下的环境变量的修改
  • 软件环境的相互依赖关系
  • 编译的报错以及排查
  • 出现问题之后的问题搜索技巧
  • 只要可能出问题就一定出问题的墨菲定律

参考资料

文章标签：
云消息队列 MQ
PHP
消息中间件
iOS开发
MacOS
开发工具
关键词：
PHP扩展
PHP服务器
amqp PHP
PHP AMQP
云服务器 ECS扩展
相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv，使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列：消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验：基于MNS，0基础轻松构建 Web Client 本节课带您一起基于MNS，0基础轻松构建 Web Client
小雨雨hi
目录
相关文章
GG2020gg
|
2月前
|
运维 Unix Linux
Linux系统 PHP安装expect扩展详解
Linux系统 PHP安装expect扩展详解
GG2020gg
39 5
Damon小智
|
3月前
|
网络安全 PHP 开发者
IIS服务器发布PHP网站
IIS服务器，相信开发者都不会陌生，它的英文全称是Internet Information Services，是由微软公司提供的基于运行Microsoft Windows的互联网基本服务，常用于Windows系统的Web项目部署，本篇以PHP项目为例，讲解如何使用IIS完成PHP项目的发布。
Damon小智
56 0
极客小俊
|
5月前
|
安全 PHP Apache
php7.4.32如何快速正确的开启OpenSSL扩展 最简单的办法在这里!
快速开启OpenSSL扩展库
极客小俊
92 0
php7.4.32如何快速正确的开启OpenSSL扩展 最简单的办法在这里!
阿甘兄
|
6月前
|
PHP Apache
PHP环境搭建（配置php模块到apache服务器）
PHP环境搭建（配置php模块到apache服务器）
阿甘兄
65 0
码银wu
|
6月前
|
网络协议 Shell 网络安全
在外SSH远程连接macOS服务器【cpolar内网穿透】
macOS系统自带有Secure Shell 客户端，它可让您登录到侦听传入SSH连接的远程服务器和台式机。我们可以用ssh username@ip来ssh到服务器，但通常局限于局域网内的远程。
码银wu
62 0
卡尔特斯
|
8月前
|
缓存 前端开发 JavaScript
PHP - Laravel 创建项目到服务器(nginx、apache)运行（附带目录结构）
PHP - Laravel 创建项目到服务器(nginx、apache)运行（附带目录结构）
卡尔特斯
216 0
jianz123
|
15天前
|
NoSQL Linux PHP
php添加redis扩展 linux和windos图文详解 l
php添加redis扩展 linux和windos图文详解 l
jianz123
3 0
aly109u0
|
30天前
|
监控 安全 容灾
PHP服务器稳定性保障
确保PHP服务器稳定性，需关注以下几点：配置合适硬件及优化操作系统；使用最新稳定版PHP，及时更新安全补丁；编写高质量代码并优化性能；处理异常，记录日志以便监控；管理资源，使用性能监控工具；加强安全防护，如权限设置、防注入攻击；采用自动化部署和持续集成工具；定期备份数据，建立容灾机制。
aly109u0
19 0
贵哥的编程之路(热爱分享)
|
3月前
|
存储 PHP
php扩展之exif
php扩展之exif
贵哥的编程之路(热爱分享)
31 1
php扩展之exif
贵哥的编程之路(热爱分享)
|
3月前
|
PHP Windows
php扩展com_dndnet（PHP与.NET框架进行交互）
php扩展com_dndnet（PHP与.NET框架进行交互）
贵哥的编程之路(热爱分享)
41 1
php扩展com_dndnet（PHP与.NET框架进行交互）

热门文章

最新文章

  • 1
    Linux基础与服务器架构综合小实践
  • 2
    服务器中常用的几个资源监控工具整理
  • 3
    ECS独立站问题之建立独立站如何解决
  • 4
    2024年阿里云服务器不同实例规格与配置实时优惠价格整理与分享
  • 5
    ECS迁移问题之跨账号迁移ECS如何解决
  • 6
    ECS网页问题之认证实验考不了如何解决
  • 7
    使用阿里云 mqtt serverless 版本超低成本快速实现 webscoket 长链接服务器
  • 8
    阿里云服务器实例、CPU内存、带宽、操作系统选择参考
  • 9
    ecs服务器shell常用脚本练习（十）
  • 10
    ecs服务器shell常用脚本练习（九）
  • 1
    MacOS平台翻译OCR软件，双管齐下，还可自定义插件，为其添砖加瓦！
    25
  • 2
    如何测试 Linux、Windows 和 macOS 中的本地网络速度？
    80
  • 3
    Rust 交叉编译 macOS 为 Linux 和 Windows
    213
  • 4
    python学习第一课——macOS环境下Python的安装
    34
  • 5
    使用mac自带VNC公网远程控制macOS
    123
  • 6
    macos查看本机所有java路径
    27
  • 7
    【macOS 系列】如何在mac下安装nvm实现多版本nodejs
    56
  • 8
    使用Swift编写电脑监控录屏软件：在macOS平台上实现
    238
  • 9
    在外SSH远程连接macOS服务器【cpolar内网穿透】
    62
  • 10
    解决第三方邮箱APP登陆QQ、163邮箱无法验证账户名或密码的问题（IOS、MacOS、Windows、Android）
    111

    • 相关课程

    更多
  • PHP进阶教程 - 由浅入深掌握面向对象开发 - 第二阶段
  • Linux Web服务器Nginx搭建与配置
  • PHP完全自学手册文档教程
  • 7天玩转云服务器
  • 云服务器选型、迁云最佳实践
  • 云服务器ECS基本操作

    • 相关电子书

    更多
  • 阿里云栖开发者沙龙PHP技术专场-深入浅出网络编程与swoole内核-吴镇宇
  • PHP安全开发:从白帽角度做安全
  • PHP 2017.北京 全球开发者大会——高可用的PHP

    • 相关实验场景

    更多
  • 使用阿里云ECS监控您的特斯拉
  • 使用阿里云ECS安装家用内网穿透服务
  • ECS实例选型最佳实践
  • ECS服务保活和宕机启动
  • 云原生场景自动化响应ECS系统事件
  • 幻兽帕鲁联机服务快速部署【有ECS用户】
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）