Spring Boot 多个 JMS 连接

使用Spring Boot可以轻松地构建和管理JMS（Java Message Service）连接。JMS是一种用于在分布式系统中进行消息传递的标准。在Spring Boot中，我们可以通过配置多个JMS连接来实现更灵活的消息传递。

java
@Configuration
public class JmsConfig {
    @Value("${jms1.broker-url}")
    private String jms1BrokerUrl;
    @Value("${jms2.broker-url}")
    private String jms2BrokerUrl;
    @Value("${jms1.username}")
    private String jms1Username;
    @Value("${jms1.password}")
    private String jms1Password;
    @Value("${jms2.username}")
    private String jms2Username;
    @Value("${jms2.password}")
    private String jms2Password;
    @Bean
    public ConnectionFactory jms1ConnectionFactory() {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        connectionFactory.setBrokerURL(jms1BrokerUrl);
        connectionFactory.setUserName(jms1Username);
        connectionFactory.setPassword(jms1Password);
        return connectionFactory;
    }
    @Bean
    public JmsTemplate jms1Template() {
        JmsTemplate jmsTemplate = new JmsTemplate();
        jmsTemplate.setConnectionFactory(jms1ConnectionFactory());
        return jmsTemplate;
    }
    @Bean
    public ConnectionFactory jms2ConnectionFactory() {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        connectionFactory.setBrokerURL(jms2BrokerUrl);
        connectionFactory.setUserName(jms2Username);
        connectionFactory.setPassword(jms2Password);
        return connectionFactory;
    }
    @Bean
    public JmsTemplate jms2Template() {
        JmsTemplate jmsTemplate = new JmsTemplate();
        jmsTemplate.setConnectionFactory(jms2ConnectionFactory());
        return jmsTemplate;
    }
}

java
@Service
public class MessageService {
    @Autowired
    private JmsTemplate jms1Template;
    @Autowired
    private JmsTemplate jms2Template;
    public void sendMessageToJms1(String message) {
        jms1Template.convertAndSend("queue1", message);
    }
    public void sendMessageToJms2(String message) {
        jms2Template.convertAndSend("queue2", message);
    }
    @JmsListener(destination = "queue1")
    public void receiveMessageFromJms1(String message) {
        System.out.println("Received message from jms1: " + message);
    }
    @JmsListener(destination = "queue2")
    public void receiveMessageFromJms2(String message) {
        System.out.println("Received message from jms2: " + message);
    }
}