我們在 Symfony 5 項(xiàng)目中使用 Symfony Messenger 來與 RabbitMQ 集成。在 Symfony 中發(fā)送消息時(shí)它工作得很好，但我需要能夠使用 Messenger 組件從一些不是使用 Symfony 框架構(gòu)建的舊版 PHP 應(yīng)用程序發(fā)送消息。在 Symfony 下，它通過注入 MessageBusInterface 來處理所有的魔法，我需要做的就是這樣： public function processTestMessage(MessageBusInterface $bus) { $bus->dispatch(new TestMessage('Hello World!'); }我需要以某種方式實(shí)例化我自己的版本，$bus它將以與 Symfony 相同的方式發(fā)送 AMQP 消息。我一直在嘗試重新創(chuàng)建 Symfony 在幕后所做的一切來完成此任務(wù)，但無法將所有細(xì)節(jié)放在一起。問題的關(guān)鍵是創(chuàng)建我自己的，SendMessageMiddleware與 Symfony 做同樣的事情。之后，就很簡單了： $sendersLocator = ??? $eventDispatcher = ??? $sendMessageMiddleware = new($sendersLocator, $eventDispatcher); $bus = new MessageBus([$sendMessageMiddleware]);有沒有人有使用 Messenger 組件在 Symfony 之外發(fā)送 AMQP 消息的工作代碼示例？
2 回答
人到中年有點(diǎn)甜
TA貢獻(xiàn)1895條經(jīng)驗(yàn) 獲得超7個贊
這可以改進(jìn)，但對我有用：
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貢獻(xiàn)1845條經(jīng)驗(yàn) 獲得超8個贊
我修改了上面的答案，讓我將 RabbitMQ 憑據(jù)作為環(huán)境變量傳遞。這就是我的應(yīng)用程序所需要的。我試圖編寫自己的 DSN 解析器，發(fā)現(xiàn) Symfony 已經(jīng)做到了，所以我基本上從那里提取了代碼。
如果未設(shè)置環(huán)境變量，則默認(rèn)使用上例中所示的相同設(shè)置。
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 關(guān)注
- 199 瀏覽
添加回答
舉報(bào)
0/150
提交
取消