pangku/php-mq-publish

rocketmq Publish Order Message

Maintainers

Details

github.com/liucaihs/php-mq-publish

Source

Issues

Installs: 3

Dependents: 0

Suggesters: 0

Security: 0

Stars: 0

Watchers: 1

Forks: 0

Open Issues: 0

dev-master 2021-02-24 09:33 UTC

Requires

MIT 94093f385992569c7986fa1b617baf7f8e5f4487

  • liucai <1207204940.woop@qq.com>

This package is not auto-updated.

Last update: 2025-04-18 00:37:11 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);