第 85 章 Disruptor 组件
从 Camel 版本 2.12 开始提供
disruptor: 组件提供异步 SEDA 行为，但使用 Disruptor 而不是标准 SEDA 使用的 BlockingQueue。或者，a
disruptor-vm： 此组件支持端点，提供标准 虚拟机 的替代选择。与 SEDA 组件一样，破坏者的缓冲区 ： 端点仅在 单个 CamelContext 中可见，不提供对持久性或恢复的支持。disruptor-vm: 端点的缓冲区也支持 CamelContexts 实例之间的通信，因此您可以使用此机制在 Web 应用之间进行通信（提供 camel-disruptor.jar 在系统/启动 类路径上）。
选择在生成者和/或多播或并发消费者之间有高竞争时，使用 SEDA 或 VM 组件相比，使用 Disruptor 组件或虚拟机组件的主要优点是性能。在这些情况下，可以看到大量吞吐量并缩短延迟。在没有竞争的情况下的性能与 SEDA 和虚拟机组件相当。
Disruptor 实施，目的是尽可能模拟 SEDA 和 VM 组件的行为和选项。与它们的主要区别如下：
- 使用的缓冲区的大小始终绑定（默认的 1024 个交换）。
- 因为缓冲区总是被滥用，因此 Disruptor 的默认行为是在缓冲区已满而不是抛出异常时阻止。此默认行为可以在组件上配置（请参阅选项）。
- Disruptor enpoints 不实施 BrowsableEndpoint 接口。因此，目前无法在 Disruptor 中检索的交换，只有交换量。
- Disruptor 要求其消费者（多播或其他）需要静态配置。即时添加或删除用户，需要完全刷新 Disruptor 中的所有待处理交换。
- 重新配置结果：通过 Disruptor 发送的数据将直接处理，如果至少有一个消费者，则后接接者仅获得新的交换程序在加入后发布新的交换。
- Disruptor 组件不支持 pollTimeout 选项。
- 当完全 Disruptor 上的生成者块时，它不会响应线程中断。
Maven 用户需要将以下依赖项添加到这个组件的 pom.xml 中：
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-disruptor</artifactId>
<version>x.x.x</version>
<!-- use the same version as your Camel core version -->
</dependency>85.1. URI 格式
disruptor:someName[?options]
or
disruptor-vm:someName[?options]
其中 someName 可以是在当前 CamelContext 中唯一标识端点的任何字符串（如果
disruptor-vm:），则跨上下文。
您可以使用以下格式将查询选项附加到 URI 中：
?option=value&option=value&…
