用于 RabbitMQ 的一致哈希交换的 Akka echangetype答案

【问题标题】：Akka echangetype for consistent hash exchange of RabbitMQ用于 RabbitMQ 的一致哈希交换的 Akka echangetype
【发布时间】：2011-12-05 18:44:15
【问题描述】：

有没有办法将 RabbitMQ 的一致性哈希交换 (http://hg.rabbitmq.com/rabbitmq-consistent-hash-exchange/file/default/README.md) 与 Akka amqp 一起使用？它很容易使用主题、直接等。我想知道是否可以以某种方式将 Akka 的交换类型指定为 x-consistent-hash。新的 ExchangeParameters (exchangeName: String, exchangeType: ExchangeType)

目前支持的 ExchangeTypes 是 Direct、Fanout、Match、Topic

【问题讨论】：

标签： rabbitmq akka

【解决方案1】：

我已经有一段时间没有编写任何 Scala 了，但看起来好像没有，因为 ExchangeType 是一个密封的特征。

如果任何 Akka 开发人员正在阅读本文，那么让开发人员将交换类型指定为任意字符串是一个非常的好主意。为内置的交换类型提供快捷方式很好，但是会出现许多有趣的新交换类型。

【讨论】：

是的，这就是关键。一致的散列是我们可以很好地使用在我们想要轮询多个队列上的传入消息的场景中的东西。这个想法不是在所有队列上发送相同的......
感谢您确认我决定不使用 Akka 的 AMQP，而是在我的 Akka 应用程序中使用 Java AMQP 客户端。

【解决方案2】：

Vikas，这是我目前能做的最好的：

https://www.assembla.com/spaces/akka/tickets/1413-support-custom-exchange-types-in-akka-amqp

这意味着我将尝试在 1.3-RC2 中包含它，该版本将在本周末被删除。

我添加了 CustomExchange("")，它将成为 1.3-RC2 的一部分

【讨论】：

当然，维克多，听起来不错。我们现在已经实施了本土循环赛。一旦上述票证关闭，将重构。