如何解决Symfony Messenger和Mailer:如何添加binding_key?
我有一个正在运行的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('from@email.tld')
->replyTo($request->request->get('mail'))
->to('$request->request->get('mail')')
->subject('test')
->html($body);
$mailer->send($email);
return new JsonResponse('OK',200);
}
}
如何将binding_key添加到mailer
以便让RabbitMQ知道如何处理电子邮件?
解决方法
可以指定via stamps路由键。不幸的是,邮件程序集成没有提供添加它们的方法,它只是将邮件分派到默认队列。但是您仍然可以手动发送消息:
t1 = datetime(2002,02,01);
t2 = datetime(2019,11,01);
t = t1:calmonths:t2;
t= datenum(char(t),'dd-mm-yyyy');
figure;
hold on
% 1st shaded area
d1=datenum(datetime(2003,01,01));
d2=datenum(datetime(2015,10,01));
x=[[d1,d2],[d2,d1],d1];
y=[-[3,3],[3,[-3]];
fill(x,y,'r');
% 2nd shaded area
d1=datenum(datetime(2009,04,01));
d2=datenum(datetime(2010,'g');
% Time-series
plot(t,randn(214,1),'LineWidth',1,'Color',[0 0 0]);
ax.XTick = t(1:end);
datetick('x','yyyy','keepticks');
yline(0,'-')
ylabel('%')
这种方法有一些局限性:由于未使用$this->dispatchMessage(new SendEmailMessage($email),[new AmqpStamp('email')]);
代码,因此不会分派mailer
,并且探查器中的“电子邮件”窗格为空。
另一种选择是使用中间件添加印章:
- 创建中间件
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'
,
好吧,我在搜索完整的Messenger配置参考时找到了答案。
为了处理不带绑定键的消息,必须添加一个default_publish_routing_key
条目。
现在的配置如下:
transports:
# https://symfony.com/doc/current/messenger.html#transport-configuration
async:
dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
options:
exchange:
name: myexchange
type: direct
default_publish_routing_key: email
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
如果没有指定任何队列,这将允许Messenger组件处理消息事件。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。