我正在寻找一种方法来获取大量入站 SMTP 消息并将它们放到 AMQP 代理上以进行进一步的路由和处理。消息实际上不会最终进入邮箱,而是使用 SMTP 作为消息网关。
我用 Python 编写了一个 Postfix 队列后内容过滤器,它将入站 SMTP 消息放到 RabbitMQ 代理上。效果很好 - 我通过队列获取原始消息,并且它被消费者很好地拾取。问题是每条消息都会创建和拆除 AMQP 连接......内容过滤器脚本每次都会从头开始重新执行。我想这最终会成为一个性能问题。
如果我可以利用可重入的东西,我可以重用连接。或者也许我只是错误地接近整个事情......