第 155 章 Ignite Cache 组件
作为 Camel 2.17 版提供
Ignite Cache 端点是 camel-ignite 端点之一，可让您与 Ignite 缓存 交互。这既提供了 Producer （用于在 Ignite 缓存上调用缓存操作）和消费者（消耗来自持续查询的更改）。
缓存值始终是消息的正文，而 cache 键总是存储在 IgniteConstants.IGNITE_CACHE_KEY 消息标头中。
即使在端点 URI 中配置固定操作，您可以通过设置 IgniteConstants.IGNITE_CACHE_OPERATION 消息标头来为每个交换不同。
155.1. 选项
Ignite Cache 组件支持 4 个选项，它们如下所列。
| 名称 | 描述 | 默认 | 类型 |
|---|---|---|---|
| ignite (common) | 设置 Ignite 实例。 | Ignite | |
| configurationResource (common) | 设置从中加载配置的资源。它可以是： URI、String (URI)或 InputStream。 | 对象 | |
| igniteConfiguration (common) | 允许用户设置程序化 IgniteConfiguration。 | IgniteConfiguration | |
| resolveProperty Placeholders (advanced) | 启动时，组件是否应自行解析属性占位符。只有 String 类型的属性才能使用属性占位符。 | true | 布尔值 |
Ignite Cache 端点使用 URI 语法配置：
ignite-cache:cacheName
使用以下路径和查询参数：
155.1.1. 路径名(1 参数)：
| 名称 | 描述 | 默认 | 类型 |
|---|---|---|---|
| cacheName | 所需的 缓存名称。 | 字符串 |
155.1.2. 查询参数(16 参数)：
| 名称 | 描述 | 默认 | 类型 |
|---|---|---|---|
| propagateIncomingBodyIfNo ReturnValue (common) | 如果底层 Ignite 操作的返回类型为 void，则设置是否传播传入的正文。 | true | 布尔值 |
| treatCollectionsAsCache Objects (common) | 设置是否将集合视为缓存对象，还是作为项目集合来插入/更新/计算等。 | false | 布尔值 |
| autoUnsubscribe (consumer) | 是否在持续查询消费者中启用自动取消订阅。 | true | 布尔值 |
| bridgeErrorHandler (consumer) | 允许将消费者桥接到 Camel 路由 Error Handler，这意味着使用者试图获取传入消息或类似信息时出现任何异常，现在将作为一个消息进行处理，并由路由 Error Handler 处理。默认情况下，使用者将使用 org.apache.camel.spi.Exception 处理程序处理异常，该处理程序将记录在 WARN 或 ERROR 级别，并忽略。 | false | 布尔值 |
| fireExistingQueryResults (consumer) | 是否处理与查询匹配的现有结果。用于初始化持续查询使用者。 | false | 布尔值 |
| oneExchangePerUpdate (consumer) | 是否要在单独交换中打包每个更新，即使在一个批内收到多个更新。仅限持续查询使用者使用。 | true | 布尔值 |
| pageSize (consumer) | 页面大小。仅限持续查询使用者使用。 | 1 | int |
| query (consumer) | 要执行的查询，仅需要它的操作，以及持续查询消费者的操作。 | 查询 | |
| remoteFilter (consumer) | 远程过滤器，仅由 Continuous Query Consumer 使用。 | CacheEntryEvent SerializableFilter | |
| timeInterval (consumer) | 持续查询使用者的时间间隔。 | 0 | long |
| exceptionHandler (consumer) | 要让使用者使用自定义 ExceptionHandler。请注意，如果启用了选项 bridgeErrorHandler，则不使用这个选项。默认情况下，消费者处理异常，这将在 WARN 或 ERROR 级别记录，并忽略。 | ExceptionHandler | |
| exchangePattern (consumer) | 在使用者创建交换时设置交换模式。 | ExchangePattern | |
| cachePeekMode (producer) | CachePeekMode，只适用于需要它的操作(IgniteCacheOperation#SIZE)。 | ALL | CachePeekMode |
| failIfInexistentCache (producer) | 如果缓存不存在，是否会导致初始化失败。 | false | 布尔值 |
| operation (producer) | 要调用的缓存操作。可能的值有：GET、PUT、REMOVE、SIZE、REBALANCE、QUERY、CLEAR. | IgniteCacheOperation | |
| 同步 （高级） | 设置同步处理是否应当严格使用，还是允许 Camel 使用异步处理（如果受支持）。 | false | 布尔值 |
