Camel Route集成Redis时端点解析失败问题求助

嘿，我刚看完你的问题，这是个新手很容易踩的典型坑——Spring Redis组件的命令参数传递方式和你想的不一样！

问题根源 #

你把CamelRedis.Key和CamelRedis.Value直接放到了Redis端点的URL参数里，但实际上Spring Redis组件中，除了command本身，具体命令的参数（比如SET的键和值）需要通过消息头（Message Header）来传递，而不是作为URL的查询参数。这就是为什么报错说这两个是“未知参数”的核心原因。

解决方案：用消息头传递命令参数 #

我们需要调整你的Route代码，把键值对放到消息头里，而不是硬编码在URL中，两种方式供你选择：

方式1：用setHeader快速实现硬编码测试

修改代码如下，这种方式简洁直接，适合快速验证：

private static final String SOURCE = "file:C:/Users/sahmad4/workspace/EmailResponseAutomation/response/";
// 只保留基础连接和命令，去掉URL里的键值参数
private static final String DESTINATION = "spring-redis://127.0.0.1:6379?command=SET";

@Override
public void configure() throws Exception {
    from(SOURCE)
        // 设置Redis SET命令需要的键和值到消息头
        .setHeader("CamelRedis.Key", constant("testkey"))
        .setHeader("CamelRedis.Value", constant("100"))
        .to(DESTINATION);
}

方式2：用Processor（适配后续数据映射需求）

如果你之后要从源文件提取数据映射到Redis，用Processor会更灵活，现在先做硬编码测试的话：

private static final String SOURCE = "file:C:/Users/sahmad4/workspace/EmailResponseAutomation/response/";
private static final String DESTINATION = "spring-redis://127.0.0.1:6379?command=SET";

@Override
public void configure() throws Exception {
    from(SOURCE)
        .process(exchange -> {
            // 硬编码设置Redis键值
            exchange.getIn().setHeader("CamelRedis.Key", "testkey");
            exchange.getIn().setHeader("CamelRedis.Value", "100");
            // 后续可以在这里添加从源文件读取数据、映射到Redis的逻辑
        })
        .to(DESTINATION);
}

额外提示 #

• 确保你的项目已经正确引入camel-spring-redis和对应Redis依赖（比如Spring Boot项目的spring-boot-starter-data-redis），避免依赖缺失引发其他问题。
• 其他Redis命令（如GET、HSET等）的参数，也都是通过对应的CamelRedis.*消息头传递，你可以参考Camel官方文档里的Spring Redis组件章节了解所有可用头信息。

内容的提问来源于stack exchange，提问作者Shamim Ahmad