xianghua_we/stomp-queue

本包最新版本（0.1.5）没有提供许可证信息。

为 webman 编写的 PHP Stomp 客户端。

维护者

详细信息

github.com/xianghuawe/stomp-queue

源代码

安装: 17

依赖: 0

建议者: 0

安全: 0

星标: 0

关注者: 0

分支: 1

0.1.5 2022-04-20 06:54 UTC

Requires

Unknown License 0a3f2cc437e40e294a7f6eab76e4e920a45a6fa5

This package is auto-updated.

Last update: 2024-09-13 08:11:31 UTC

README

为 webman 提供的异步 STOMP 客户端。

特性

  1. 使用 php-amqplib/php-amqplib 组件创建交换和队列。
  2. 使用 /amq/queue/[queuename] 模式进行订阅。
  3. 使用 /exchange/[exchangename]/[routing_key] 模式发送消息。
  4. 通过 rabbitmq_delayed_message_exchange 插件支持延迟消息。

文档

https://www.workerman.net/doc/webman#/queue/stomp

安装

composer require teamones/stomp-queue

配置

return [
    'default' => [
        'host' => 'stomp://' . env("rabbitmq_host", '127.0.0.1') . ':' . env("rabbitmq_stomp_port", 61613),
        'options' => [
            'vhost' => env("rabbitmq_vhost", '/'),
            'login' => env("rabbitmq_user", 'guest'),
            'passcode' => env("rabbitmq_password", 'guest'),
            'debug' => (bool)env("app_debug", false),
        ],
        'amqp' => [
            'host' => env("rabbitmq_host", '127.0.0.1'),
            'port' => env("rabbitmq_amqp_port", 5672),
            'namespace' => env("belong_system", ''),
            'exchange_name' => env("rabbitmq_exchange_name", 'exchange'),
            'exchange_delay' => (bool)env("rabbitmq_exchange_delay", true)
        ]
    ]
]