如何使用Spring Boot收听动态目的地？

如何使用Spring Boot收听动态目的地？

您可以将属性占位符用作目标名称

@SpringBootApplicationpublic class So56226984Application {    public static void main(String[] args) {        SpringApplication.run(So56226984Application.class, args);    }    @JmsListener(destination = "${foo.bar}")    public void listen(String in) {        System.out.println(in);    }    @Bean    public ApplicationRunner runner(JmsTemplate template) {        return args -> template.convertAndSend("baz", "qux");    }}

然后设置属性，例如在Spring Boot应用程序的application.yml中设置，或者在启动JVM时设置命令行属性

-Dfoo.bar=baz

编辑

您可以使侦听器bean成为原型并调整环境属性。

@SpringBootApplicationpublic class So56226984Application {    public static void main(String[] args) {        SpringApplication.run(So56226984Application.class, args).close();    }    @Bean    public ApplicationRunner runner(JmsTemplate template, JmsListenerEndpointRegistry registry, ConfigurableApplicationContext context) {        return args -> { Scanner scanner = new Scanner(System.in); String queue = scanner.nextLine(); Properties props = new Properties(); context.getEnvironment().getPropertySources().addLast(new PropertiesPropertySource("queues", props)); while (!"quit".equals(queue)) {     System.out.println("Adding " + queue);     props.put("queue.name", queue);     context.getBean("listener", Listener.class);     template.convertAndSend(queue, "qux sent to " +  queue);     System.out.println("There are now " + registry.getListenerContainers().size() + " containers");     queue = scanner.nextLine(); } scanner.close();        };    }    @Bean    @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)    public Listener listener() {        return new Listener();    }    public static class Listener {        @JmsListener(destination = "${queue.name}")        public void listen(String in) { System.out.println(in);        }    }}