Search by 
pangku / php-mq-publish
rocketmq Publish Order Message
dev-master
2021-02-24 09:33 UTC
Requires
- aliyunmq/mq-http-sdk: >=1.0.3
This package is not auto-updated.
Last update: 2025-04-04 00:30:14 UTC
README
预发配置和正式配置待定
2.发布顺序消息
文档:https://help.aliyun.com/document_detail/141783.html?spm=a2c4g.11186623.6.639.1dbf7b5bpCsgbd
3.封装sdk要求
参考lixiaohong/tyrex
发布结构: $pkOrderProducer = new PkPublish($config);
$rocketmqPublishMessage = new RqPublishMessage(xx,xxx,....);
rocketmqPublishMessage->setLogHandler(xxxx);
$topicMessage = $pkOrderProducer->publishMessage($rocketmqPublishMessage);
支持业务系统设置日志处理
了解一下monolog/monolog
sdk库的name pangku/php-mq-publish
composer require monolog/monolog
use PangKu\RocketMQ\PkPublish;
use PangKu\RocketMQ\Message\RqPublishOrderMessage;
use Monolog\Logger;
use Monolog\Handler\StreamHandler;
$config = [
"account_endpoint" => "http://xxxxx.aliyuncs.com",
"access_id" => "xxXXWw",
"access_key" => "xx9DQy",
"instance_id" => "xxxBXgBYndb",
"topic" => "local-partition-test",
"tag" => "business-test",
];
// create a log channel
$log = new Logger('name');
$log->pushHandler(new StreamHandler('D:/tmp/RocketMQ.log', Logger::WARNING));
$pkOrderProducer = new PkPublish($config);
$pkOrderProducer->setLogHandler($log, true);
$rocketmqPublishMessage = new RqPublishOrderMessage("xxxxxxxyyyyyyyyy", "xxxxxx", $config["tag"], ["a" => 12]);
$topicMessage = $pkOrderProducer->publishMessage($rocketmqPublishMessage);