Quarkus Mailer动态多租户/多配置实现方案咨询

针对SaaS场景下需要从数据库读取租户邮件配置、动态发送品牌化邮件的需求，官方静态多配置方案无法满足，可通过动态构建Mailer实例的方式实现，具体步骤如下：

1. 定义租户邮件配置模型与存储 #

先在数据库中创建租户邮件配置表，对应Java实体类：

@Entity
@Table(name = "tenant_mail_configs")
public class TenantMailConfig {
    @Id
    private String tenantId; // 租户唯一标识
    private String smtpHost;
    private int smtpPort;
    private String username;
    private String encryptedPassword; // 建议加密存储密码
    private String fromAddress; // 租户专属发件人地址，如sales@companyx.com
    // 省略getter/setter
}

2. 实现租户配置获取服务 #

编写服务类从数据库查询指定租户的邮件配置：

@ApplicationScoped
public class TenantMailConfigService {
    @Inject
    EntityManager em;

    public TenantMailConfig getByTenantId(String tenantId) {
        return em.find(TenantMailConfig.class, tenantId);
    }
}

3. 动态构建Mailer实例 #

利用Quarkus提供的MailerBuilder，根据租户配置动态创建Mailer，同时加入缓存避免重复实例化：

@ApplicationScoped
public class TenantMailerFactory {
    @Inject
    TenantMailConfigService configService;
    @Inject
    Cache cache; // 可使用Quarkus的缓存扩展，如quarkus-cache-caffeine

    public Mailer getMailerForTenant(String tenantId) {
        // 尝试从缓存获取
        return cache.get(tenantId, () -> {
            TenantMailConfig config = configService.getByTenantId(tenantId);
            if (config == null) {
                throw new IllegalArgumentException("No mail config found for tenant: " + tenantId);
            }
            // 解密密码（如果存储时加密）
            String decryptedPassword = decrypt(config.getEncryptedPassword());
            
            // 构建Mailer实例
            return MailerBuilder.newBuilder()
                    .host(config.getSmtpHost())
                    .port(config.getSmtpPort())
                    .username(config.getUsername())
                    .password(decryptedPassword)
                    .build();
        });
    }

    // 密码解密逻辑示例（需替换为实际加密算法）
    private String decrypt(String encrypted) {
        // 实现AES或其他加密算法的解密逻辑
        return encrypted;
    }
}

4. 封装租户感知的邮件发送服务 #

提供上层服务，接收租户ID和邮件内容，完成发送：

@ApplicationScoped
public class TenantAwareMailService {
    @Inject
    TenantMailerFactory mailerFactory;

    public void sendTenantMail(String tenantId, String to, String subject, String content) {
        Mailer mailer = mailerFactory.getMailerForTenant(tenantId);
        TenantMailConfig config = mailerFactory.configService.getByTenantId(tenantId);
        
        mailer.send(Mail.withText(to, subject, content)
                .setFrom(config.getFromAddress()));
    }
}

关键注意事项 #

• 密码安全：数据库中务必加密存储SMTP密码，避免明文泄露。
• 缓存策略：根据租户数量和配置更新频率，设置合理的缓存过期时间，确保配置变更能及时生效。
• 异常处理：需处理租户配置不存在、SMTP连接失败等异常，返回友好的错误提示。
• 性能优化：如果租户数量极大，可考虑连接池复用或异步发送，避免资源耗尽。

内容的提问来源于stack exchange，提问作者wiradikusuma