如何解析spring属性列表

Question

我有这个Spring启动应用程序。属性

list1=valueA,valueB
list2=valueC
list3=valueD,valueE

topics=list1,list2,list3

我想做的是在@KafkaListener的主题元素中使用主题属性值的值注释

使用表达式

@KafkaListener(topics={"#{'${topics}'.split(',')}"})

我得到列表1，列表2，列表3作为分隔字符串

我如何循环到这个列表以获得值A，值B，值C，值D，值E？

编辑：我必须解析主题属性，以便@KafkaListener注册以使用来自主题value eA、value eB、value eC等的消息。

我读到可以通过这种方式调用方法：

@KafkaListener(topics="#parse(${topics})")

所以，我写了这个方法:

public String[] parse(String s) {
   ExpressionParser parser = new SpelExpressionParser();

   return Arrays.stream(s.split(",").map(key -> (String)(parser.parse(key).getValue())).toArray(String[]::new);
}

但未调用parse方法

因此，我尝试用这种方式直接将其添加到注释中：

@KafkaListener(topics="#{Arrays.stream('${topics}'.split(',')).map(key->${key}).toArray(String[]::new)}")

但是这个解决方案也会给我带来错误。

编辑2:

以这种方式修改会调用该方法

@KafkaListener(topics="parse()")

@Bean
    public String[] parse(String s) {
       ...
    }

问题是如何在方法中获得“主题”道具

Answer 1

你不能像那样调用任意的方法；您需要引用bean @someBean.parse(...)；使用< code>#parse需要将静态方法注册为函数。

然而，这对我很有效，而且简单得多:

list1=valueA,valueB
list2=valueC
list3=valueD,valueE

topics=${list1},${list2},${list3}

和

@KafkaListener(id = "so64390079", topics = "#{'${topics}'.split(',')}")

编辑

如果您不能在< code >主题中使用占位符，这也可以...

@SpringBootApplication
public class So64390079Application {

    public static void main(String[] args) {
        SpringApplication.run(So64390079Application.class, args);
    }

    @KafkaListener(id = "so64390079", topics = "#{@parser.parse('${topics}')}")
    public void listen(String in) {
        System.out.println(in);
    }

}

@Component
class Parser implements EnvironmentAware {

    private Environment environmment;

    @Override
    public void setEnvironment(Environment environment) {
        this.environmment = environment;
    }

    public String[] parse(String[] topics) {
        StringBuilder sb = new StringBuilder();
        for (String topic : topics) {
            sb.append(this.environmment.getProperty(topic));
            sb.append(',');
        }
        return StringUtils.commaDelimitedListToStringArray(sb.toString().substring(0, sb.length() - 1));
    }

}