java - Camel 路线执行优先级

Question

我想了解 Camel 是否能够在同一进程中优先执行一条路由而不是另一条路由。

例如，我们有:

from("cxfrs://restendpoint").routeId("HIGH").log("high priority");

和

from("file://filestore").routeId("LOW").log("low priority");

我希望 HIGH 路线不会被 LOW 路线减速。因此，当 LOW 路由正在处理一个巨大的文件并且一个 rest 调用到达 HIGH 路由时，我希望 CPU 给 HIGH 路由更多的时间。

我正在考虑通过将路由拆分为 2 个应用程序并使用 Linux 进程优先级为 HIGH 路由分配更多时间来做到这一点。

有没有办法用 Camel 做到这一点？例如，可以玩线程优先级的东西？

谢谢你的帮助

Answer 1

看看Apache Camel/ActiveMQ priority route (初始情况不同，但解决方案也适用于您的用例):

• 使用 JMS 并确定队列的优先级
• 使用 SEDA 阻塞队列，同样描述 here
• 使用重新排序器

编辑:

作为附加选项，使用带有自定义 ThreadFactory 的 ExecutorService 并设置线程优先级，例如:

ThreadFactory threadFactory = new ThreadFactory() {
    @Override
    public Thread newThread(final Runnable r) {
        Thread thread = new Thread(r);
        thread.setPriority(Thread.MIN_PRIORITY);
        return thread;
    }
};

ExecutorService exe = Executors.newFixedThreadPool(3, threadFactory);

from("direct:slow")
    .threads()
    .executorService(exe)
    ...

可以找到一篇关于 Java 线程优先级的好文章 here .