能兼容阿里云rocketmq吗？

[imlida]

如题。

[lpflpf]

阿里云应该只是添加一些session信息，有接口的，只是没验证过，可以试下。

[imlida]

如何添加session信息，能给个demo吗？

[imlida]

能提供一个连接阿里云rocketmq的demo吗？万分感谢！

[lpflpf]

在定义consumer 之后，

$pullConsumer->setSessionCredentials($accessKey, $secretKey, "ALIYUN")

Producer/ PullConsumer/ PushConsumer 理论上都支持

[imlida]

`<?php namespace RocketMQ; $instanceName = "MQ_INST_xxxx";

$producer = new Producer($instanceName); $producer->setInstanceName($instanceName); $producer->setNamesrvAddr("MQ_INST_xxxx.cn-hangzhou.mq-internal.aliyuncs.com:8080"); $producer->setSessionCredentials('xxxx', 'xxxx', "ALIYUN"); $producer->start();

for ($i = 0; $i < 10; $i ++){ $message = new Message("TEST", "*", "hello world $i"); $sendResult = $producer->send($message); echo $sendResult->getSendStatus() . "\n"; }`

运行如上代码报下面的错误： terminate called after throwing an instance of 'rocketmq::MQException' what(): msg: No route info of this topic: TEST,error:-1,in file line:377 Aborted (core dumped) 但实际上是存在TEST这个topic的

[lpflpf]

尝试本地跑一个mq，试试是否可用？确定是setSessionCredentials 的问题吗？

[imlida]

您那边有环境可以测试一下连接阿里云的rocketmq服务吗？我怀疑是根本没有连接上导致的

[lpflpf]

我这边没有环境，要是有环境，可以帮你试下。