Symfony Messenger处理程序“参数过少”错误排查与最佳实践

class UserRegistrationEmailHandler implements MessageHandlerInterface
{
    public function __invoke(UserRegistrationEmail $message)
    {
        // 处理消息逻辑
    }
}

// src/Message/UserRegistrationEmail.php
namespace App\Message;

class UserRegistrationEmail
{
    private string $userEmail;

    public function __construct(string $userEmail)
    {
        $this->userEmail = $userEmail;
    }

    public function getUserEmail(): string
    {
        return $this->userEmail;
    }
}

// src/Message/MessageHandler/UserRegistrationEmailHandler.php
namespace App\Message\MessageHandler;

use App\Message\UserRegistrationEmail;
use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
use Symfony\Component\Mailer\MailerInterface;
use Symfony\Component\Mime\Email;
use Psr\Log\LoggerInterface; // 引入日志服务，便于调试

class UserRegistrationEmailHandler implements MessageHandlerInterface
{
    private MailerInterface $mailer;
    private LoggerInterface $logger; // 注入日志服务

    public function __construct(MailerInterface $mailer, LoggerInterface $logger)
    {
        $this->mailer = $mailer;
        $this->logger = $logger;
    }

    public function __invoke(UserRegistrationEmail $message): void
    {
        $recipientEmail = $message->getUserEmail();
        $this->logger->info(sprintf('开始发送注册邮件至: %s', $recipientEmail));

        try {
            // 模拟耗时操作或实际邮件发送逻辑
            sleep(2); // 模拟网络延迟或邮件服务器响应时间

            $email = (new Email())
                ->from('no-reply@yourdomain.com')
                ->to($recipientEmail)
                ->subject('欢迎注册我们的服务！')
                ->text('感谢您的注册。我们很高兴有您加入！');

            $this->mailer->send($email);

            $this->logger->info(sprintf('注册邮件成功发送至: %s', $recipientEmail));
        } catch (\Exception $e) {
            $this->logger->error(sprintf('发送注册邮件至 %s 失败: %s', $recipientEmail, $e->getMessage()), ['exception' => $e]);
            // 根据业务需求，可以重新抛出异常，让Messenger进行重试
            throw $e;
        }
    }
}

// src/Controller/RegistrationController.php
namespace App\Controller;

use App\Form\UserType;
use App\Entity\User;
use App\Message\UserRegistrationEmail;
use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpFoundation\Response;
use Symfony\Component\Routing\Annotation\Route;
use Symfony\Component\Security\Core\Encoder\UserPasswordEncoderInterface;
use Symfony\Component\Messenger\MessageBusInterface;

class RegistrationController extends AbstractController
{
    /**
     * @Route(path="/register", name="user_registration")
     */
    public function register(
        Request $request,
        UserPasswordEncoderInterface $passwordEncoder,
        MessageBusInterface $bus
    ): Response {
        $user = new User();
        $form = $this->createForm(UserType::class, $user);

        $form->handleRequest($request);
        if ($form->isSubmitted() && $form->isValid()) {
            $password = $passwordEncoder->encodePassword($user, $user->getPlainPassword());
            $user->setPassword($password);

            $entityManager = $this->getDoctrine()->getManager();
            $entityManager->persist($user);
            $entityManager->flush();

            // 调度消息，将用户的实际邮箱传递给消息对象
            $bus->dispatch(new UserRegistrationEmail($user->getEmail()));

            $this->addFlash('success', '用户已注册，注册邮件正在发送中。');

            return $this->redirectToRoute('user_registration'); // 重定向以避免重复提交
        }

        return $this->render(
            'registration/register.html.twig',
            ['form' => $form->createView()]
        );
    }
}