我們在 Symfony 5 項目中使用 Symfony Messenger 來與 RabbitMQ 集成。在 Symfony 中發送消息時它工作得很好，但我需要能夠使用 Messenger 組件從一些不是使用 Symfony 框架構建的舊版 PHP 應用程序發送消息。在 Symfony 下，它通過注入 MessageBusInterface 來處理所有的魔法，我需要做的就是這樣： public function processTestMessage(MessageBusInterface $bus) { $bus->dispatch(new TestMessage('Hello World!'); }我需要以某種方式實例化我自己的版本，$bus它將以與 Symfony 相同的方式發送 AMQP 消息。我一直在嘗試重新創建 Symfony 在幕后所做的一切來完成此任務，但無法將所有細節放在一起。問題的關鍵是創建我自己的，SendMessageMiddleware與 Symfony 做同樣的事情。之后，就很簡單了： $sendersLocator = ??? $eventDispatcher = ??? $sendMessageMiddleware = new($sendersLocator, $eventDispatcher); $bus = new MessageBus([$sendMessageMiddleware]);有沒有人有使用 Messenger 組件在 Symfony 之外發送 AMQP 消息的工作代碼示例？
2 回答
人到中年有點甜
TA貢獻1895條經驗 獲得超7個贊
這可以改進，但對我有用：
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpSender;
use Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection;
use Symfony\Component\Messenger\Envelope;
use Symfony\Component\Messenger\MessageBus;
use Symfony\Component\Messenger\Middleware\SendMessageMiddleware;
use Symfony\Component\Messenger\Transport\Sender\SendersLocatorInterface;
$sendersLocator = new class implements SendersLocatorInterface {
public function getSenders(Envelope $envelope): iterable
{
$connection = new Connection(
[
'hosts' => 'localhost',
'port' => 5672,
'vhosts' => '/',
'login' => 'guest',
'password' => 'guest'
],
[
'name' => 'messages'
],
[
'messages' => []
]
);
return [
'async' => new AmqpSender($connection)
];
}
};
$middleware = new SendMessageMiddleware($sendersLocator);
$bus = new MessageBus([$middleware]);
$bus->dispatch(new MyMessage());
精慕HU
TA貢獻1845條經驗 獲得超8個贊
我修改了上面的答案，讓我將 RabbitMQ 憑據作為環境變量傳遞。這就是我的應用程序所需要的。我試圖編寫自己的 DSN 解析器，發現 Symfony 已經做到了，所以我基本上從那里提取了代碼。
如果未設置環境變量，則默認使用上例中所示的相同設置。
use Symfony\Component\Messenger\Bridge\Amqp\Transport\AmqpSender;
use Symfony\Component\Messenger\Bridge\Amqp\Transport\Connection;
use Symfony\Component\Messenger\Envelope;
use Symfony\Component\Messenger\MessageBus;
use Symfony\Component\Messenger\Middleware\SendMessageMiddleware;
use Symfony\Component\Messenger\Transport\Sender\SendersLocatorInterface;
$sendersLocator = new class implements SendersLocatorInterface {
public function getSenders(Envelope $envelope): iterable
{
$dsn = getenv('MESSENGER_TRANSPORT_DSN') ?: $_ENV['MESSENGER_TRANSPORT_DSN'];
$connection = Connection::fromDsn($dsn);
return [
'async' => new AmqpSender($connection)
];
}
};
$middleware = new SendMessageMiddleware($sendersLocator);
$bus = new MessageBus([$middleware]);
$bus->dispatch(new MyMessage());
- 2 回答
- 0 關注
- 173 瀏覽
添加回答
舉報
0/150
提交
取消