如何在带有Scala的批注中使用Spring Expression Language

Question

我有一个看起来像这样的简单Scala项目...

@Configuration
public class CommonConfiguration{
    ...
    @Value("${spring.kafka.topic}")
    public String topic;
    ...
}
@Service
class KafkaService @Autowired()(producer: KafkaTemplate[String, Array[Byte]], config: CommonConfiguration){

  def sendMessage(msg: String): Unit = {
    println(s"Writing the message $msg ${config.topic}")
    producer.send(config.topic, msg.getBytes());
  }

  @KafkaListener(id="test", topics="#{'${spring.kafka.topic}'.split(',')}")
  def consume(record: ConsumerRecord[String, String]): Unit = {
    System.out.println(s"Consumed Strinsg Message : ${record.value()}")
  }

}

这给了我错误...

KafkaService.scala:26: error: type mismatch;
[ERROR]  found   : String("#{\'${spring.kafka.topic}\'.split(\',\')}")
[ERROR]  required: Array[String]
[ERROR]   @KafkaListener(id="test", topics= "#{'${spring.kafka.topic}'.split(',')}")

我尝试根据#{'${spring.kafka.topic}'.split(',')}建议使用this，但无法正常工作。制片人得到的话题很好。如何在Scala中使用Spring Expression Language？

这里是有效的Java版本...

@Service
public class KafkaJavaService {
    @KafkaListener(id="test", topics="#{'${spring.kafka.topic}'.split(',')}")
    public void consume(ConsumerRecord<String, String> record){
        System.out.println("Consumed String Message : "+record.value())
    }
}

Answer 1

根据this question，看起来topics = Array("...")应该可以工作。

阅读@RequestMapping文档：http://static.springsource.org/spring/docs/2.5.x/api/org/springframework/web/bind/annotation/RequestMapping.html

它接受String数组参数作为其路径映射。

所以这可以使用java：

@RequestMapping("MYVIEW")

但是在scala中，我需要使用：

@RequestMapping(Array("MYVIEW"))

scala版本很有意义，因为注释需要一个String数组。但是，为什么上面的代码在Java中有效，它不应该给出编译时错误吗？

编辑

这在技术上也不是同一件事，因为我可以使用CSV的另一种方式。即使工作正常，它也将是一个1字符串数组，除非Array构造函数花哨一些。

不应该有所作为；如我所说，如果String[]元素中的表达式解析为String[]，我们将以递归方式将其分开（展平）。参见here和here。

尝试在这些方法中设置断点；我没有安装Scala，否则我来看看。