java - 在 RabbitMQ Java 客户端中每次发布时打开和关闭 Channel

Question

场景

我正在编写一个 Java 应用程序，该应用程序将产品从多个不同来源导入到数据库，然后将更新的产品导出到其他系统，例如搜索引擎和 RSS 提要。多次进口，多次导出。由于某些导出器尽快获得更新至关重要，因此我让它们保持运行并通过 RabbitMQ 实例中的队列监听更新。一些导入器将批量处理文件(这意味着附近会有许多更新)，一些导入器会偶尔获取更新(每小时更新几次，例如来自管理员)。每个导入器都会有一个 UpdateNotifier 实例。

示例

这是(稍微简化的)类，用于将更新产品的 ID 添加到 RabbitMQ 交换:

public class UpdateNotifier
{
    private Connection conn;

    public UpdateNotifier(Connection alreadyOpenConnection)
    {
        conn = alreadyOpenConnection;
    }

    public void productIsUpdated(String id)
    {
        Channel chan = conn.createChannel();

        publishTheMessageToExchange(chan, id);

        chan.close();
    }
}

问题

是否建议为每次发布打开一个新 channel 然后关闭它，或者在 UpdateNotifier 的每个实例中缓存该 channel 会更好吗？

也许有两种不同的通知程序，一种用于在实例中保留 channel 的批量更新，一种用于每次更新时打开和关闭 channel 的零星更新？

所以归结为:打开和关闭 channel 的成本有多大？

Answer 1

创建和销毁 channel 对于 RabbitMQ 来说是非常简单且快速的操作。

但是，如果您需要高吞吐量，则为每个发布创建/销毁 channel 可能会影响性能。

就我的观点而言，您不需要缓存 channel 等，只需为线程使用一个 channel 即可安全。

我建议阅读这篇文章 https://www.rabbitmq.com/production-checklist.html和 https://www.rabbitmq.com/networking.html .

这些链接可以帮助您调整 RabbitMQ