Spring Boot が JMS をどのようにサポートするかを簡単に説明します

コード例

サンプルコードはここからのもので、いくつかの変更が加えられています。執筆時点では、Spring Boot 3.3.0 (Spring Framework 6.1.8) が使用されています。

complete/pom.xml

ActiveMQ 組み込みブローカーに切り替える

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

<dependency>
    <groupId>org.apache.activemq</groupId>
    <!--<artifactId>artemis-jakarta-server</artifactId>-->
    <artifactId>activemq-broker</artifactId>
    <scope>runtime</scope>
</dependency>

<!-- ... -->

complete/src/main/resources/application.properties

デバッグログをオンにし、組み込みブローカー URL をセットアップします

#spring.artemis.mode=embedded
debug=true
spring.activemq.broker-url=vm://localhost?broker.persistent=false

complete/src/main/java/hello/Application.java

独自に構築するのではなく、Spring Boot によって作成された JmsListenerContainerFactory Bean を使用します

@SpringBootApplication
@EnableJms
public class Application {

    /*@Bean
    public JmsListenerContainerFactory<?> myFactory(ConnectionFactory connectionFactory,
                                                    DefaultJmsListenerContainerFactoryConfigurer configurer) {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        // This provides all auto-configured defaults to this factory, including the message converter
        configurer.configure(factory, connectionFactory);
        // You could still override some settings if necessary.
        return factory;
    }*/

    //...

}

complete/src/main/java/hello/Receiver.java

デフォルトを指定しますJmsListenerContainerFactory

@Component
public class Receiver {

    //@JmsListener(destination = "mailbox", containerFactory = "myFactory")
    @JmsListener(destination = "mailbox")
    public void receiveMessage(Email email) {
        System.out.println("Received <" + email + ">");
    }

}

Spring Boot 自動構成ログ

JMS 関連の構成のみが表示されます。

   ActiveMQAutoConfiguration matched:
      - @ConditionalOnClass found required classes 'jakarta.jms.ConnectionFactory', 'org.apache.activemq.ActiveMQConnectionFactory' (OnClassCondition)
      - @ConditionalOnMissingBean (types: jakarta.jms.ConnectionFactory; SearchStrategy: all) did not find any beans (OnBeanCondition)

   ActiveMQAutoConfiguration#activemqConnectionDetails matched:
      - @ConditionalOnMissingBean (types: org.springframework.boot.autoconfigure.jms.activemq.ActiveMQConnectionDetails; SearchStrategy: all) did not find any beans (OnBeanCondition)

   ActiveMQConnectionFactoryConfiguration matched:
      - @ConditionalOnMissingBean (types: jakarta.jms.ConnectionFactory; SearchStrategy: all) did not find any beans (OnBeanCondition)

   ActiveMQConnectionFactoryConfiguration.SimpleConnectionFactoryConfiguration matched:
      - @ConditionalOnProperty (spring.activemq.pool.enabled=false) matched (OnPropertyCondition)

   ActiveMQConnectionFactoryConfiguration.SimpleConnectionFactoryConfiguration.CachingConnectionFactoryConfiguration matched:
      - @ConditionalOnClass found required class 'org.springframework.jms.connection.CachingConnectionFactory' (OnClassCondition)
      - @ConditionalOnProperty (spring.jms.cache.enabled=true) matched (OnPropertyCondition)

   JmsAnnotationDrivenConfiguration matched:
      - @ConditionalOnClass found required class 'org.springframework.jms.annotation.EnableJms' (OnClassCondition)

   JmsAnnotationDrivenConfiguration#jmsListenerContainerFactory matched:
      - @ConditionalOnSingleCandidate (types: jakarta.jms.ConnectionFactory; SearchStrategy: all) found a single bean 'jmsConnectionFactory'; @ConditionalOnMissingBean (names: jmsListenerContainerFactory; SearchStrategy: all) did not find any beans (OnBeanCondition)

   JmsAnnotationDrivenConfiguration#jmsListenerContainerFactoryConfigurer matched:
      - @ConditionalOnMissingBean (types: org.springframework.boot.autoconfigure.jms.DefaultJmsListenerContainerFactoryConfigurer; SearchStrategy: all) did not find any beans (OnBeanCondition)

   JmsAutoConfiguration matched:
      - @ConditionalOnClass found required classes 'jakarta.jms.Message', 'org.springframework.jms.core.JmsTemplate' (OnClassCondition)
      - @ConditionalOnBean (types: jakarta.jms.ConnectionFactory; SearchStrategy: all) found bean 'jmsConnectionFactory' (OnBeanCondition)

   JmsAutoConfiguration.JmsTemplateConfiguration#jmsTemplate matched:
      - @ConditionalOnSingleCandidate (types: jakarta.jms.ConnectionFactory; SearchStrategy: all) found a single bean 'jmsConnectionFactory'; @ConditionalOnMissingBean (types: org.springframework.jms.core.JmsOperations; SearchStrategy: all) did not find any beans (OnBeanCondition)

   JmsAutoConfiguration.MessagingTemplateConfiguration matched:
      - @ConditionalOnClass found required class 'org.springframework.jms.core.JmsMessagingTemplate' (OnClassCondition)

   JmsAutoConfiguration.MessagingTemplateConfiguration#jmsMessagingTemplate matched:
      - @ConditionalOnSingleCandidate (types: org.springframework.jms.core.JmsTemplate; SearchStrategy: all) found a single bean 'jmsTemplate'; @ConditionalOnMissingBean (types: org.springframework.jms.core.JmsMessageOperations; SearchStrategy: all) did not find any beans (OnBeanCondition)

関連インターフェース

Interface	Function
org.springframework.jms.support.destination.DestinationResolver	lookup jakarta.jms.Destination instance by String name
org.springframework.transaction.jta.JtaTransactionManager	control transaction by JTA
org.springframework.jms.support.converter.MessageConverter	serialize/deserialize DTO instance
jakarta.jms.ExceptionListener	processor when jakarta.jms.JMSException throws. One implementation is SingleConnectionFactory, connection managed by that class will be restarted once exception is catched
io.micrometer.observation.ObservationRegistry	for statistics

コネクションファクトリーについて

ActiveMQ の実装は org.apache.activemq.ActiveMQConnectionFactory ですが、Spring Framework はこれを直接使用しません。このクラスは、 の後続のために org.springframework.jms.connection.CachingConnectionFactory

によってラップされます。

• 接続 が 1 つだけ作成され、これが再利用されます
• MessageProducer と MessageConsumer をキャッシュします (この例では、MessageProducer のみがキャッシュされます)

出版社

org.springframework.jms.core.JmsTemplate
を介してメッセージを送信する

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

<dependency>
    <groupId>org.apache.activemq</groupId>
    <!--<artifactId>artemis-jakarta-server</artifactId>-->
    <artifactId>activemq-broker</artifactId>
    <scope>runtime</scope>
</dependency>

<!-- ... -->

JmsTemplate Bean は org.springframework.boot.autoconfigure.jms.JmsAutoConfiguration.JmsTemplateConfiguration#jmsTemplate によってビルドされます。 DTO を逆シリアル化するには、MessageConverter Bean が必要です。

使用される

DestinationResolver は org.springframework.jms.support.destination.DynamicDestinationResolver です。クラスは、jakarta.jms.Destination インスタンスを取得するだけです。 🎜>jakarta.jms.Session#createTopic または jakarta.jms.Session#createQueue.

購読者

org.springframework.jms.annotation.JmsListener アノテーション

org.springframework.jms.listener.DefaultMessageListenerContainer クラス

JMS 仕様では、非同期メッセージ処理がサポートされており、リスナーは JMS プロバイダーのスレッドで実行されます。

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

<dependency>
    <groupId>org.apache.activemq</groupId>
    <!--<artifactId>artemis-jakarta-server</artifactId>-->
    <artifactId>activemq-broker</artifactId>
    <scope>runtime</scope>
</dependency>

<!-- ... -->

ただし、Spring Framework では非同期アプローチは使用されず、同期 API (ポーリング) が使用されます。実際のコードは org.springframework.jms.support.destination.JmsDestinationAccessor#receiveFromConsumer.
にあります。

#spring.artemis.mode=embedded
debug=true
spring.activemq.broker-url=vm://localhost?broker.persistent=false

org.springframework.jms.listener.DefaultMessageListenerContainer.AsyncMessageListenerInvoker クラスは、定期的にポーリング ジョブを実行するためのものです。これは org.springframework.core.task.SimpleAsyncTaskExecutor.

でスケジュールされます。

1 つの @JmsListener アノテーション付き関数に対して 1 つの DefaultMessageListenerContainer インスタンスが作成されます。これは org.springframework.jms.config.DefaultJmsListenerContainerFactory.

によって生成されます。

もちろん、MessageConverter と ExceptionListener インスタンスは必要です。

以上がSpring Boot が JMS をどのようにサポートするかを簡単に説明しますの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。