spring - 我如何在 spring 应用程序中配置 ssl 工件？

Question

我正在寻求有关使用 kafka 消费者和生产者的 spring 应用程序(其他人的设计)的帮助。该设计允许包含如下条目的 config.properties 文件:

kafkaAddress=10.10.10.12:9093,10.10.10.11:9093,10.10.10.10:9093

这样的配置是由某种 spring bean 代码获取的，如下所示...

Java 代码...

private String kafkaAddress;

public String getKafkaAddress() {
   return kafkaAddress;
}

public void setKafkaAddress(String kafkaAddress) {
   this.kafkaAddress = kafkaAddress;
}

它出现在我使用调试器看到的 Properties 对象中。

"kafkaAddress"-> "10.10.10.12:9093,10.10.10.11:9093,10.10.10.10:9093"

代码将 Properties 对象传递给 Kafka 客户端的构造函数

我认为这一切都是通过 spring 的设计和匹配配置“kafkaAddress”与匹配名称 kafkaAddress 的字符串而发生的

好吧，我想为 ssl 配置诸如...

ssl.truststore.location=C:\some\path\kafka.client.10.10.10.11.truststore.jksssl.truststore.password=mySecretWord

我在配置中放置了这些东西，但是我应该为我的 setter 和 getter 放置什么？

我不能放 String ssl.truststore.location，对吧？

Answer 1

在 config.properties 中我使用 ... ssl_truststore_password=我的 secret 密码

在我使用的 MyConsumerConfig.java 文件中的 setter 和 getter 中......

public void setSsl_truststore_password(String ssl_truststore_password ) {
    this.ssl_truststore_password = ssl_truststore_password;
}
public String getSsl_truststore_password() {
    return this.ssl_truststore_password;
}

在调用构造函数 .java 文件之前我...

if(StringUtils.isNotEmpty(myConsumerConfig.getSsl_truststore_password())) {
        consumerProps.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG,
                onlineConsumerConfig.getSsl_truststore_password());
    }

SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG 定义在包 org.apache.kafka.common.config.SslConfigs ...

public static final String  SSL_TRUSTSTORE_PASSWORD_CONFIG  "ssl.truststore.password"

spring 框架将配置文件中的“ssl_truststore_password”链接到 getter 和 setter，例如 ...

MyConsumerConfig.setSsl_truststore_password(String ssl_truststore_password)