如何在Camel Context中使用base64字符串前对其进行解码

有两种常用的实现方式，可根据你的业务场景选择：

方案1：扩展DatabaseConfiguration实现全局自动解码 #

该方案会在属性读取阶段自动完成解码，后续路由使用时无需额外处理，适配性最高。

1. 继承org.apache.commons.configuration.DatabaseConfiguration重写属性读取方法：

import org.apache.commons.configuration.DatabaseConfiguration;
import org.apache.commons.codec.binary.Base64;
import javax.sql.DataSource;

public class Base64DecodeDatabaseConfig extends DatabaseConfiguration {
    // 构造方法和父类保持一致
    public Base64DecodeDatabaseConfig(DataSource dataSource, String tableName, String keyColumn, String valueColumn) {
        super(dataSource, tableName, keyColumn, valueColumn);
    }

    @Override
    public Object getProperty(String key) {
        Object rawValue = super.getProperty(key);
        if (rawValue == null) {
            return null;
        }
        // 仅对字符串类型的配置值做Base64解码，可根据需要调整类型判断逻辑
        if (rawValue instanceof String encodedStr) {
            return new String(Base64.decodeBase64(encodedStr));
        }
        return rawValue;
    }
}

2. 替换Camel Context中原来的DatabaseConfiguration Bean，以Spring XML配置为例：

<!-- 数据源 Bean 沿用你原有配置即可 -->
<bean id="dbConfig" class="com.your.package.Base64DecodeDatabaseConfig">
    <constructor-arg ref="yourDataSource" />
    <constructor-arg value="你的配置表名" />
    <constructor-arg value="配置键对应的字段名" />
    <constructor-arg value="配置值对应的字段名" />
</bean>

<!-- 注册到Camel属性组件，沿用你原有配置即可 -->
<bean id="properties" class="org.apache.camel.component.properties.PropertiesComponent">
    <property name="properties" ref="dbConfig" />
</bean>

配置完成后，路由中直接通过{{配置键名}}占位符即可获取解码后的明文值。

方案2：路由中局部解码 #

如果不想修改原有配置类，仅需要在部分路由中使用解码后的属性，可直接在路由中处理：

• Java DSL 示例：

import org.apache.commons.codec.binary.Base64;

// 路由逻辑
from("xxx:xxx")
    .process(exchange -> {
        // 读取编码后的配置值
        String encodedValue = exchange.getContext().resolvePropertyPlaceholders("{{你的配置键}}");
        // 解码
        String decodedValue = new String(Base64.decodeBase64(encodedValue));
        // 存入交换属性供后续节点使用
        exchange.setProperty("decodedConfig", decodedValue);
    })
    // 后续节点直接通过${exchangeProperty.decodedConfig}获取明文
    .to("xxx:xxx");

• XML DSL 示例（需要引入Camel Groovy 依赖）：

<setProperty propertyName="decodedConfig">
    <groovy>new String(org.apache.commons.codec.binary.Base64.decodeBase64(context.resolvePropertyPlaceholders("{{你的配置键}}")))</groovy>
</setProperty>

注意事项 #

• 需要确保项目中已引入commons-codec依赖，避免类不存在异常
• 如果存在不需要解码的配置，可在解码逻辑中增加Key白名单校验，只对指定配置做解码处理

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