修正 ./config/sys.php 系统配置文件,修正对应的RabbitMQ连接配置:

/ RabbitMQ配置 / 'rabbitmq' => array( 'host' => 'localhost', 'port' => '5672', 'user' => 'root', 'password' => '', 'phalapi_pro_open_push_key' => 'phalapi_pro_open_push_key', // 修正后须要重启脚本! ),

温馨提示:sys.rabbitmq.phalapi_pro_open_push_key 配置值可自定义,修正后须要重启脚本!

启动平台推送数据做事

在根目录,手动实行:

php实现订单消息推送技巧架构产物设计若何搭建API接口异步新闻订阅治理平台 SQL

$ ./bin/push/phalapi_pro_open_push_server.sh

推举在crontab定时任务配置守护进程:

$ crontab -e# phalapi_pro_open_push_server 推送数据守护进程/1 /path/to/phalapi-pro/bin/push/phalapi_pro_open_push_server.sh做事端开拓本地开拓测试

当须要进行二次开拓时,可以在本地命令终端,手动运行。

例如,手动提交数据:

[phalapi-pro]$ php ./bin/push/phalapi_pro_open_push_example.php Usage: ./bin/push/phalapi_pro_open_push_example.php <push_topic> <push_data|JSON>[phalapi-pro]$ php ./bin/push/phalapi_pro_open_push_example.php order '{"order_id":888}' [x] Sent order {"order_id":888}

例如,消费数据(可以开启多个命令终端):

【phalapi-pro]$ php ./bin/push/phalapi_pro_open_push_server.php Starting push ... [] Waiting for push... To exit press CTRL+C [x] {"push_topic":"order","push_data":{"order_id":888}}

温馨提示:如果提示 平台主题不存在,则先请前往Admin管理后台发布一个新主题,例如订单推送:order。

在PHP源代码中提交数据

当推送数据运行成功和稳定后,在后续开拓过程中,如果须要在接口大师中进行数据的提交,可参考以下示例代码:

// 平台主题和待提交的数据$publishTopic = 'order';$emitData = ['order_id' => 123];// 提交到异步队列$engine = new \Base\Domain\PushData\Engine();$engine->emit($publishTopic, $emitData);通过API接口在做事端内部进行提交数据

如果须要跨系统进行数据提交,可以利用 Task.PushData.Emit 接口,进行调用。

下贱回调下贱回调地址格式哀求

推送格式:// TODO:请根据业务情形填写推送Header头部信息:Content-Type: application/x-www-form-urlencodedAPPKEY: 开拓者运用APPKEY回调地址返回哀求:返回HTTP 200状态码,表示吸收成功。
产品利用管理后台

利用管理员账号,可以在Admin管理后台 - 平台管理 - 行列步队管理,发布新的主题并进行管理。
同时对新申请的运用订阅进行审核、查看、推送成功次数和总次数的统计,以及详细的推送结果记录。

开放平台

对付开拓者,可以进入 开放平台 - 运用管理 - 我的订阅,申请订阅平台的主题。
申请通过后,可以查看推送成功次数和总次数的统计。

请把稳:如果须要编辑订阅,则须要等待管理后台重新审核。
单独 开启/关闭 订阅,不须要等待重新审核。

技能架构设计

目前,利用RabbitMQ作为异步队列。

更多开拓文档

开拓文档:http://www.yesx2.com/wiki/#/2x-push-data

免费体验账号:http://www.yesx2.com/ 超管体验账号:admin / 123456