摘要：需要對外提供配置接口，通過配置接口，動態配置，可接收的消息。遇到問題正式這種注解的方式，使得只能在代碼中寫死，沒法動態修改。而我想實現的效果是能夠動態的修改，動態的創建。因此能不能動態修改配置文件對應的變量，然后消費者動態注入。
背景
最近在寫一個Mqtt消息轉發的中間件,可通過ActvieMq接收消息。需要對外提供配置接口，通過配置接口，動態配置Queue，可接收Queue的消息。
整個項目依賴于SpringBoot ，通過SpringBoot實現隊列消費，只需要通過@JmsListener(destination = "queueName") 注解，就可以實現對特定隊列的消費。
遇到問題
正式這種注解的方式，使得destination只能在代碼中寫死，沒法動態修改。 而我想實現的效果是能夠動態的修改destination，動態的創建Consumer。
解決方案
繼續使用@JmsListener，找到某種方式，能夠動態修改destination
不使用@JmsListener，通過ActiveMq提供的Jar，手動實現連接、消費等。之前通過這種方式實現過RabbitMq的處理，因此該方案不會有難度，只是工作量多一些。
由于SpringBoot的過分簡單，因此開始嘗試通過第一種方式。
解決過程
一開始想著通過反射修改注解destination但是嘗試失敗。后來想到@JmsListener(destination = "${xxx}")這種方式，根據配置文件，可以修改消費的隊列，但是需要從新啟動。 因此能不能動態修改配置文件對應的變量，然后消費者動態注入Spring。
自定義實現一個MapPropertySource，然后加入到Environment中
@Configuration
public class DynamicTestSetting {
public static final String DYNAMIC_CONFIG = "dynamic_settting";
@Autowired
AbstractEnvironment environment;
@PostConstruct
public void init() {
environment.getPropertySources().addFirst(new DynamicLoadPropertySource(DYNAMIC_CONFIG, null));
}
}
@Slf4j
public class DynamicLoadPropertySource extends MapPropertySource {
private static Map map = new ConcurrentHashMap(64);
private static ScheduledExecutorService scheduled = Executors.newScheduledThreadPool(1);
static {
scheduled.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
//測試：定時修改value
//真正使用可能需要傳遞一個參數或者定時讀取配置文件
map.put("test", String.valueOf(System.currentTimeMillis()));
}
}, 1, 1, TimeUnit.SECONDS);
}
public DynamicLoadPropertySource(String name, Map source) {
super(name, map);
}
@Override
public Object getProperty(String name) {
return map.get(name);
}
}
2.消費者需要動態加入
@Slf4j
public class TestConsumer {
@JmsListener(destination = "${test}")
public void receiveQueue(BytesMessage msg) {
//接收消息后的處理邏輯
}
}
/*動態注入bean到spring，需要用到ApplicationContext/
DefaultListableBeanFactory defaultListableBeanFactory = (DefaultListableBeanFactory) context.getAutowireCapableBeanFactory();
BeanDefinitionBuilder definitionBuilder = BeanDefinitionBuilder.genericBeanDefinition(TestConsumer.class);
defaultListableBeanFactory.registerBeanDefinition("testConsumer",definitionBuilder.getBeanDefinition());
//調用getBeaan時Spring會創建一個TestConsumer實例，這個時候ActiveMq中會創建一個destination = "${test}"隊列，TestConsummer和其綁定消費
TestConsumer consumer = context.getBean("testConsumer", TestConsumer.class);
System.out.println(consumer);
動態關閉Queue的消費者
參見另一篇：https://segmentfault.com/n/13...
參考文章：https://blog.csdn.net/qq_3491...
文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。
轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/71482.html
