该组件集成Redis, 支持Redis所有存储格式
在使用该组件之前, 必须开启Redis

需在pom文件中加入:

<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-spring-redis</artifactId>
  <version>x.x.x</version>
</dependency>

核心语法:

spring-redis://host:port[?options]
可在后面追加相关属性 "?options=value&option2=value&"其中command指定相关命令, 默认为String类型的SET.

具体相关Redis工具类(很详细!):
https://githubcom/apache/camel/tree/main/components/camel-spring-redis/src/test/java/org/apache/camel/component/redis

Hash相关命令

List相关命令

Set相关命令

Zset相关命令

String相关命令

示例1: 自定义Key等相关参数

<route xmlns="http://camel.apache.org/schema/spring" id="demo">
  <from uri="rest:post:demo"/>
  <setHeader name="CamelRedis.Key">
    <simple>ceshi1</simple>
  </setHeader>
  <setHeader name="CamelRedis.Field">
    <simple>ceshi2</simple>
  </setHeader>
  <setHeader name="CamelRedis.Value">
    <constant>${body}</constant>
  </setHeader>
  <to uri="spring-redis:{{spring.redis.host}}:{{spring.redis.port}}?command=HSET"/>
  <log message="${body}"/>
</route>

• {{spring.redis.host/port}}在配置文件中给出.
• command指定本次命令.
• Header中包含的信息应为命令对应参数(即表格中的参数信息).
• body为前端传入参数, 可后续处理.
• 示例为往Redis中添加Hash类型参数.

示例2: 从参数中获取Key等参数

传参:

{
    "key":"1111",
    "field":"2222",
    "body":"这是一次测试"
}

路由:

<route xmlns="http://camel.apache.org/schema/spring" id="setRedisHash">
  <from uri="rest:post:setRedisHash"/>
  <convertBodyTo type="String"/>
  <setHeader name="CamelRedis.Key">
    <jsonpath>$.key</jsonpath>
  </setHeader>
  <setHeader name="CamelRedis.Field">
    <jsonpath>$.field</jsonpath>
  </setHeader>
  <setHeader name="CamelRedis.Value">
    <jsonpath>$.body</jsonpath>
  </setHeader>
  <to uri="spring-redis:{{spring.redis.host}}:{{spring.redis.port}}?command=HSET"/>
  <log message="${body}"/>
</route>

• "$.**"前后端名称应该保持一致.

示例3: 获取redis中相关参数

参数:

{
    "key":"1111",
    "field":"2222"
}

路由:

<route xmlns="http://camel.apache.org/schema/spring" id="getRedisHash">
  <from uri="rest:post:getRedisHash"/>
  <convertBodyTo type="String"/>
  <setHeader name="CamelRedis.Key">
    <jsonpath>$.key</jsonpath>
  </setHeader>
  <setHeader name="CamelRedis.Field">
    <jsonpath>$.field</jsonpath>
  </setHeader>
  <to uri="spring-redis:{{spring.redis.host}}:{{spring.redis.port}}?command=HGET"/>
  <convertBodyTo type="String"/>
  <log message="${body}"/>
</route>

响应:
[图片上传失败...(image-fa8434-1667627842828)]

• 与加入redis写法相似, 与其相关参数保持一致.
• 响应参数可进一步处理(添加自定义键值等).

可以看出通过Camel连接Redis并进行相关操作要比代码编写相对简单, 但也存在逻辑复杂无法实现情况, 总体来说它提供了一个便捷的方式提供开发人员使用.