php toarray Symfony 5 中实现同步与异步邮件发送的灵活策略

php toarray Symfony 5 中实现同步与异步邮件发送的灵活策略

本文详细介绍了在 5 应用程序中如何灵活地实现同步和异步邮件发送。通过创建自定义消息类和消息，并结合 组件的配置，开发者可以精确控制哪些邮件通过消息队列异步发送，而哪些邮件则立即同步发送，从而优化应用性能和用户体验。

在现代 Web 应用中，邮件发送是常见的需求，但有时我们需要根据业务场景选择不同的发送模式：对于非关键或耗时较长的邮件（如通知、批量邮件），异步发送可以避免阻塞主线程，提升用户体验；而对于关键或需要即时反馈的邮件（如），同步发送则更为合适。 5 结合其 Mler 和 组件，提供了一套强大的机制来实现这种灵活的邮件发送策略。

1. 理解 与

当我们将 \\ 路由到异步传输时，所有通过 ::send() 方法发送的邮件都会被 捕获并推送到队列中。为了实现同步和异步邮件的共存，我们需要更精细的控制。

2. 定义异步邮件消息类

为了让 能够处理我们的异步邮件，我们首先需要创建一个自定义的消息类。这个类将封装所有发送邮件所需的数据，如收件人、主题、邮件模板路径和上下文变量等。

senderEmail = $senderEmail;
        $this->recipient = $recipient;
        $this->subject = $subject;
        $this->bodyHtmlTemplate = $bodyHtmlTemplate;
        $this->bodyTextTemplate = $bodyTextTemplate;
        $this->context = $context;
    }
    // 提供所有属性的公共 getter 方法
    public function getSenderEmail(): string
    {
        return $this->senderEmail;
    }
    public function getRecipient(): string
    {
        return $this->recipient;
    }
    public function getSubject(): string
    {
        return $this->subject;
    }
    public function getBodyHtmlTemplate(): string
    {
        return $this->bodyHtmlTemplate;
    }
    public function getBodyTextTemplate(): ?string
    {
        return $this->bodyTextTemplate;
    }
    public function getContext(): array
    {
        return $this->context;
    }
}

注意：消息类应只包含数据，不应包含业务逻辑。所有属性都应是私有的，并通过 方法暴露。

3. 实现异步邮件消息处理器

消息处理器负责接收并处理特定类型的消息。在这里， 将接收 消息，并使用 实际发送邮件。

mailer = $mailer;
    }
    public function __invoke(EmailAsync $emailAsync): void
    {
        $emailToSend = (new TemplatedEmail())
            ->from(new Address($emailAsync->getSenderEmail())) // 使用消息中的发件人
            ->to(new Address($emailAsync->getRecipient()))
            ->subject($emailAsync->getSubject())
            ->htmlTemplate($emailAsync->getBodyHtmlTemplate())
            ->context($emailAsync->getContext());
        if ($emailAsync->getBodyTextTemplate()) {
            $emailToSend->textTemplate($emailAsync->getBodyTextTemplate());
        }
        $this->mailer->send($emailToSend);
    }
}

注意：

泡泡次元AI-游戏美术AI创作平台，低门槛上手，高度可控php toarray，让你的创意秒速落地

下载

4. 配置 路由

现在我们需要告诉 ，当 类型的消息被分发时，应该将其路由到异步传输。

# config/packages/messenger.yaml 或 config/packages/dev/messenger.yaml
framework:
    messenger:
        # 配置异步传输 DSN
        transports:
            async: '%env(MESSENGER_TRANSPORT_DSN)%' # 例如：MESSENGER_TRANSPORT_DSN=amqp://guest:guest@localhost:5672/%2f/messages
        routing:
            # 将 AppMessageEmailAsync 消息路由到 'async' 传输
            'AppMessageEmailAsync': async
            # 如果不希望 SymfonyComponentMailerMessengerSendEmailMessage 被默认异步处理，
            # 确保这里没有为其配置异步路由，或者明确路由到 'sync' (默认行为)
            # 'SymfonyComponentMailerMessengerSendEmailMessage': sync # 显式同步，或不配置

注意：

5. 分发异步邮件

在你的服务中，当你需要发送异步邮件时，不再直接使用php toarray Symfony 5 中实现同步与异步邮件发送的灵活策略，而是注入php toarray Symfony 5 中实现同步与异步邮件发送的灵活策略，并分发 消息。

bus = $bus;
        $this->defaultSenderEmail = $defaultSenderEmail;
    }
    /**
     * 发送异步邮件
     */
    public function sendAsyncEmail(
        string $recipient,
        string $subject,
        string $htmlTemplate,
        ?string $textTemplate = null,
        array $context = []
    ): void {
        $emailAsync = new EmailAsync(
            $this->defaultSenderEmail, // 可以从配置或服务中获取
            $recipient,
            $subject,
            $htmlTemplate,
            $textTemplate,
            $context
        );
        $this->bus->dispatch($emailAsync);
    }
    // 其他与异步邮件相关的业务逻辑
}

注意：

6. 发送同步邮件

对于需要同步发送的邮件，你仍然可以直接注入 并使用它，而无需经过 。

mailer = $mailer;
        $this->defaultSenderEmail = $defaultSenderEmail;
    }
    /**
     * 发送同步邮件
     */
    public function sendSyncEmail(
        string $recipient,
        string $subject,
        string $htmlTemplate,
        ?string $textTemplate = null,
        array $context = []
    ): void {
        $email = (new TemplatedEmail())
            ->from(new Address($this->defaultSenderEmail))
            ->to(new Address($recipient))
            ->subject($subject)
            ->htmlTemplate($htmlTemplate)
            ->context($context);
        if ($textTemplate) {
            $email->textTemplate($textTemplate);
        }
        $this->mailer->send($email);
    }
    // 其他与同步邮件相关的业务逻辑
}

注意：

总结与注意事项

通过上述步骤php toarray，我们成功地在 5 应用中实现了同步和异步邮件发送的灵活控制：

重要注意事项：

运行：为了处理异步邮件，你必须在生产环境中运行 进程。例如： bin/ : async。建议使用 或 等来管理 进程，确保其持续运行和。错误处理： 提供了强大的错误处理机制，包括重试策略和失败消息存储。请根据你的需求配置这些选项。发件人配置：在实际应用中，发件人通常会从（如 .yaml 或 .yaml）中获取，而不是硬在服务中。模板路径：邮件模板路径应确保正确，并可被 Twig 渲染器访问。DSN 安全：DSN 包含敏感信息，应通过环境变量或 管理。

这种方法提供了一个清晰且可维护的解决方案，允许开发者根据邮件的优先级和发送需求，灵活地选择同步或异步发送模式php toarray，从而优化应用程序的整体性能和响应速度。