我有一个正在运行的 Symfony 4.4 项目,其中包含Messenger和rabbitMQ。
我有一个带有 2 个队列的异步传输。
transports:
# https://symfony.com/doc/current/messenger.html#transport-configuration
async:
dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
options:
exchange:
name: myexchange
type: direct
queues:
email:
binding_keys:
- email
extranet:
binding_keys:
- extranet
# failed: 'doctrine://default?queue_name=failed'
# sync: 'sync://'
routing:
# Route your messages to the transports
'App\Message\ExtranetMessage': async
'Symfony\Component\Mailer\Messenger\SendEmailMessage': async
我需要发送电子邮件symfony/mailer
电子邮件队列的组件。
public function contact(Request $request, MailerInterface $mailer)
{
if($request->isXmlHttpRequest())
{
//dd($request->request->all());
$body =
'Nouveau message depuis le front<br />
Nom = '.$request->request->get('nom').'<br />
Prénom = '.$request->request->get('prenom').'<br />
Société = '.$request->request->get('societe').'<br />
Email = '.$request->request->get('mail').'<br />';
$email = (new Email())
->from('[email protected] /cdn-cgi/l/email-protection')
->replyTo($request->request->get('mail'))
->to('$request->request->get('mail')')
->subject('test')
->html($body);
$mailer->send($email);
return new JsonResponse('OK', 200);
}
}
如何将绑定密钥添加到mailer
为了让rabbitMQ知道如何处理电子邮件?
可以指定路由键通过邮票 https://symfony.com/doc/current/messenger.html#amqp-transport。不幸的是,邮件程序集成没有公开添加它们的方法,它只是将消息分派到默认队列。但您仍然可以手动发送消息:
$this->dispatchMessage(new SendEmailMessage($email), [new AmqpStamp('email')]);
这种方法有一些局限性:因为这没有使用mailer
code, MessageEvent
不会发送,并且分析器中的“电子邮件”窗格将为空。
另一种选择是使用中间件添加标记:
- 创建中间件
// src/Messenger/StampEmailMessageMiddleware.php
class StampEmailMessageMiddleware implements MiddlewareInterface
{
const bindingKey = 'email';
public function handle(Envelope $envelope, StackInterface $stack): Envelope
{
// Add the stamp. Since the middleware gets called both when dispatching and
// consuming the message, we make sure there's no stamp already added.
if (
$envelope->getMessage() instanceof SendEmailMessage &&
null === $envelope->last(AmqpStamp::class)
) {
$envelope = $envelope->with(new AmqpStamp(self::bindingKey));
}
return $stack->next()->handle($envelope, $stack);
}
}
- 将中间件添加到总线配置中:
# config/packages/messenger.yaml
messenger:
buses:
messenger.bus.default:
middleware:
- 'App\Messenger\StampEmailMessageMiddleware'
- 正常发送消息:
$mailer->send($email);
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)