java - 调用http组件时 Camel 线程ID发生变化

Question

我的路线是这样的:

from(rabbitmq).
to(redisLockerProcessor).
to(processor1).
to(ahc://http:).to(processor2)
.to(redisLockReleaseProcessor)

我正在使用 redisson 库，它存储在 redis 中获取锁的线程 id。但是在 redisLockReleaseProcessor 中它抛出异常 thread id 与获取锁的线程 id 不同。 http组件线程如何在 Camel 中工作？我虽然整个路线在同一个线程中运行。如果整个路由不在同一个线程中，我们如何解决这里的 redis 问题？

Answer 1

camel-ahc 组件正在使用非阻塞调用，因此线程可能会在您的 camel 路由中发生变化。您可以考虑将线程 ID 存储为交换属性(您可以使用它来释放 redisLockReleaseProcessor 中的 redisLock)或使用其他 camel http 组件，例如使用 block API 发送请求的 camel-http。