keruald/broker

消息代理抽象层

0.5.0 2023-03-15 23:49 UTC

This package is auto-updated.

Last update: 2024-09-16 03:46:36 UTC


README

用于使用消息代理的抽象库。

当前重点是准备一个参考的AMQP实现。

示例代码

您可以使用类实例初始化,然后使用流畅模式依次连接到服务器,设置参数,然后发送消息。

例如,向RabbitMQ的'haiku'交换点发送消息,使用特定的路由键允许消费者查看他们是否对消息感兴趣

$broker = new AMQPBroker();
$broker
    ->connect()
    ->setExchangeTarget('haiku')
    ->routeTo('basho.oldpond')
    ->sendMessage('古池や蛙飛び込む水の音');

为另一个代理添加实现

我们感兴趣解决的目标问题。我们最初想提供交换和队列类,但代理对它们有不同的处理方式。