首页 > 解决方案 > 可变 Spring Bean 中的线程安全

问题描述

  1. 我有一个服务,它是一个集群Spring Boot的监听器Kafka@KafkaListner
  2. Kafka提供json数据来指导我的服务需要做什么。
  3. 我收到后将此配置转换json为。pojo
  4. 我想在我的&中分享这个。pojoclassesmethods
  5. 我不想通过不需要知道的中间课程

所以,我这样做了。

  1. 首先创建空pojo并保存到弹簧容器中。
  2. 然后,在接收 from 之后,从Kafka获取空的 pojospring container及其set
  3. 这样我就可以从我服务的任何地方获取它。

但是,我发现这个可变的 pojo 不是线程安全的。我探索了 bean-scope,似乎没有什么适合我。

  1. 我怎样才能使它成为线程安全的?请提供使用自定义的示例SimpleThreadScope
  2. 你能建议任何不需要使用的设计模式spring bean吗?

标签: javaspring-bootdesign-patternsapache-kafkathread-safety

解决方案


推荐阅读