PHPackages                             losingbattle/rocketmq-http - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [HTTP & Networking](/categories/http)
4. /
5. losingbattle/rocketmq-http

ActiveLibrary[HTTP & Networking](/categories/http)

losingbattle/rocketmq-http
==========================

基于阿里云的rocketmq-http客户端及服务端封装

3.1.0(2y ago)82.0k↑90%1PHPPHP >=8.1

Since Sep 8Pushed 2y ago1 watchersCompare

[ Source](https://github.com/cpj555/rocketmq-http)[ Packagist](https://packagist.org/packages/losingbattle/rocketmq-http)[ RSS](/packages/losingbattle-rocketmq-http/feed)WikiDiscussions master Synced today

READMEChangelogDependencies (11)Versions (5)Used By (0)

ROCKETMQ-HTTP 组件
================

[](#rocketmq-http-组件)

\##安装

```
composer require Losingbattle/rocketmq-http

```

- hyperf框架直接引用即可,使用姿势与官方rabbitmq基本一致
- 其余框架生产者依赖guzzlehttp,psr/container,实现即可,消费者使用了协程消费依赖swoole [example](example/RocketMqFactory.php)
- 阿里云的rocketmq-http本身存在一些问题,当gid+topic+instance过长时消费消息将会报错,所以只能自身在创建时把控(Code: NotSupport Message: the length of GID(CID) and TOPIC is too long, total length(include instance) should not longer than 119, please change another topic or another cid RequestId : 605402BE384531236C9E1205 HostId)
- 普通消息相关已在线上稳定运行一年多

默认配置
----

[](#默认配置)

配置类型默认值备注hoststringHostaccess\_key\_idstringaccess\_key\_secretstringinstance\_idstring实例idconcurrent.limitint0同时消费的数量hyperf中使用一下命令初始化即可

```
php bin/hyperf.php vendor:publish losingbattle/rocketmq-http

```

投递消息
----

[](#投递消息)

在 DemoProducer 文件中，我们可以修改 `@Producer` 注解对应的字段来替换对应的 `topic` 和 `tag`。 其中 `MessageBody` 就是最终投递到消息队列中的数据。 示例如下。

> 使用 `@Producer` 注解时需 `use Losingbattle\RocketMqHttp\Annotation\Producer;` 命名空间；

```