如何创建Haraka插件实现从RabbitMQ消费并接入邮件处理流程？

Haraka本身没有提供直接对接RabbitMQ的官方集成方案，但你可以通过模拟SMTP连接的核心对象（Connection + Transaction），把RabbitMQ消费到的消息接入Haraka的后续处理流程。以下是具体实现步骤：

1. 构建模拟的Connection与Transaction对象 #

Haraka的所有消息处理逻辑都依赖connection和transaction这两个核心对象，你需要为RabbitMQ消费的消息构建这两个对象的最小实现，包含后续插件依赖的关键属性：

// 模拟Connection对象
const mockConnection = {
  remote_ip: '127.0.0.1', // 自定义来源IP，用于插件校验
  helo: 'rabbitmq-consumer', // 自定义HELO标识
  log: require('haraka-logger')({ debug: true }), // 复用Haraka的日志工具
  run_hooks: require('haraka').Connection.prototype.run_hooks.bind(this), // 绑定钩子执行方法
  // 其他可能需要的属性：比如tls_enabled、auth等，按需添加
};

// 模拟Transaction对象，填充RabbitMQ消费到的邮件数据
const buildTransaction = (rabbitmqMsg) => {
  const transaction = require('haraka').Transaction(mockConnection);
  
  // 填充邮件核心信息
  transaction.mail_from = { address: rabbitmqMsg.from }; // 发件人
  transaction.rcpt_to = rabbitmqMsg.to.map(addr => ({ address: addr })); // 收件人列表
  transaction.headers = rabbitmqMsg.headers; // 邮件头（格式要符合Haraka要求：{ 'Subject': ['xxx'], 'From': ['xxx'] }）
  transaction.body = rabbitmqMsg.body; // 邮件正文
  
  // 标记消息来源为RabbitMQ，方便后续插件识别
  transaction.notes.rabbitmq_source = true;
  
  return transaction;
};

2. 触发Haraka的消息处理钩子 #

构建好对象后，将transaction挂载到connection上，然后触发Haraka的核心处理钩子（比如queue_outbound或process_message，根据你的需求选择）：

// 假设你已经有RabbitMQ的消费回调函数
const handleRabbitMQMessage = async (msg) => {
  try {
    const transaction = buildTransaction(JSON.parse(msg.content.toString()));
    mockConnection.transaction = transaction;
    
    // 触发process_message钩子，这是Haraka处理邮件的核心流程
    await new Promise((resolve, reject) => {
      mockConnection.run_hooks('process_message', transaction, (err) => {
        if (err) reject(err);
        else resolve();
      });
    });
    
    // 处理完成后触发transaction_done钩子，清理资源
    await new Promise((resolve) => {
      mockConnection.run_hooks('transaction_done', transaction, resolve);
    });
    
    console.log('RabbitMQ消息已通过Haraka处理完成');
  } catch (err) {
    console.error('处理RabbitMQ消息失败:', err);
  }
};

3. 关键注意事项 #

• 按需补充对象属性：不同Haraka插件可能依赖connection或transaction上的特定属性（比如反垃圾插件需要connection.hostname），如果运行时出现属性缺失错误，直接在mock对象上补充即可。
• 日志与调试：确保mock的connection.log正常工作，方便排查插件执行过程中的问题。
• 消息格式兼容：RabbitMQ中存储的邮件数据要符合Haraka的预期格式（比如headers是键值对数组，body是字符串或Buffer），如果格式不匹配，需要先做转换。

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