使用现有组件阻止 apache Camel 中的消费者

Question

我想使用 Apache Camel JDBC 组件来读取 Oracle 表。我希望 Camel 在分布式环境中运行，以满足可用性问题。但是，我正在读取的表类似于队列，因此我只想在任何给定时间有一个读取器，这样我就可以避免锁定问题（在 Oracle 中很混乱）。

如果读者宕机了，我希望另一个读者能够接替。

您将如何使用开箱即用的 Camel 组件来完成此任务？是否可以？

Answer 1

这取决于您的部署架构。例如，如果您以主/从配置（用于 HA）在 Servicemix（或 ActiveMQ）上部署 Camel 应用程序，那么在给定时间只有一个消费者处于活动状态……

但是，如果您需要多个运行（集群化）可扩展性），那么（默认情况下）它们将竞争/重复从表中读取，除非您编写自己的锁定逻辑。

使用 Hazelcast 分布式锁定 可以轻松实现这一点。有一个camel-hazelcast组件，但它不支持lock API。一旦您配置您的应用以参与 Hazelcast 集群，那么只需使用锁定 API您需要为给定对象同步的任何代码...

import com.hazelcast.core.Hazelcast;
import java.util.concurrent.locks.Lock;

Lock lock = Hazelcast.getLock(myLockedObject);
lock.lock();
try {
    // do something here
} finally {
    lock.unlock();
}