使用 Spring Boot 向 JMS 队列发送消息

Question

我是 Spring JMS 的新手。我的应用程序是使用 Spring Boot 开发的，并部署在 JBoss EAP 7.2.0 中。我有一个远程队列，它是一个 Active MQ Artemis 队列，它也嵌入在 JBoss EAP 7.2.0 中。谁能建议我如何使用 Spring Boot 的 JmsTemplate 向远程 JMS 队列发送消息？基本上我不知道我应该如何定义远程连接工厂来连接到远程队列。

Answer 1

1. 将以下内容添加到应用程序属性中，因为您的应用程序部署在应用程序服务器中

  spring.jms.jndi-name=java:/<your connection factory name for artemis>

1. 添加artemis依赖，让spring boot自动配置jmsTemplate

   <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-artemis</artifactId>
   </dependency>

1. 自动装配 jmsTemplate 并发送消息

@Component
public class MyMessageSender {

        @Autowired
        JmsTemplate jmsTemplate;


        public void send(String msg){
                jmsTemplate.convertAndSend("my.queue.name", msg);
        }
}

4. 您可以选择配置消息转换器并将 pojos 作为消息发送，并让 spring 负责将其转换为 json。例如

    @Bean // Serialize message content to json using TextMessage
    public MessageConverter jacksonJmsMessageConverter() {
        MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
        converter.setTargetType(MessageType.TEXT);
        converter.setTypeIdPropertyName("_type");
        return converter;
    }