クラス ReactorNetty2ResourceFactory

java.lang.ObjectSE
org.springframework.http.client.reactive.ReactorNetty2ResourceFactory
実装されたすべてのインターフェース:
DisposableBeanInitializingBean

public class ReactorNetty2ResourceFactory extends ObjectSE implements InitializingBean, DisposableBean
Spring ApplicationContext のライフサイクル内で Reactor Netty リソース(イベントループスレッドの LoopResources、接続プールの ConnectionProvider など)を管理するファクトリ。

このファクトリは InitializingBean および DisposableBean を実装し、通常、Spring 管理の Bean として宣言されることが期待されています。

このクラスは ReactorResourceFactory に基づいています。

導入:
6.0
作成者:
Violeta Georgieva
  • コンストラクターのサマリー

    コンストラクター
    コンストラクター
    説明
  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    addGlobalResourcesConsumer(ConsumerSE<reactor.netty5.http.HttpResources> consumer)
    起動時にグローバル Reactor Netty リソースを構成するためのコンシューマーを追加します。
    void
    すべての Bean プロパティを設定し、BeanFactoryAwareApplicationContextAware などを満たした後、包含 BeanFactory によって呼び出されます。
    void
    Bean の破棄時に、包含 BeanFactory によって呼び出されます。
    reactor.netty5.resources.ConnectionProvider
    設定された ConnectionProvider を返します。
    reactor.netty5.resources.LoopResources
    設定された LoopResources を返します。
    boolean
    このファクトリがグローバル HttpResources ホルダーを公開するかどうか。
    void
    setConnectionProvider(reactor.netty5.resources.ConnectionProvider connectionProvider)
    これは、外部で管理されている ConnectionProvider インスタンスを提供する場合に使用します。
    void
    setConnectionProviderSupplier(SupplierSE<reactor.netty5.resources.ConnectionProvider> supplier)
    グローバルリソースに参加したくない場合や、管理対象の ConnectionProvider の作成をカスタマイズしたい場合に、これを使用します。
    void
    setLoopResources(reactor.netty5.resources.LoopResources loopResources)
    このオプションは、外部で管理されている LoopResources インスタンスを提供する場合に使用します。
    void
    setLoopResourcesSupplier(SupplierSE<reactor.netty5.resources.LoopResources> supplier)
    グローバルリソースに参加したくない場合や、管理対象の LoopResources の作成をカスタマイズしたい場合に、これを使用します。
    void
    setShutdownQuietPeriod(DurationSE shutdownQuietPeriod)
    リソースをシャットダウンする前に待機する時間を設定します。
    void
    shutdownQuietPeriod 中にタスクが送信されたかどうかに関係なく、基になるリソースが破棄されるまで待機する最大時間を構成します。
    void
    setUseGlobalResources(boolean useGlobalResources)
    HttpResources を介してグローバル Reactor Netty リソースを使用するかどうか。

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE
  • コンストラクターの詳細

    • ReactorNetty2ResourceFactory

      public ReactorNetty2ResourceFactory()
  • メソッドの詳細

    • setUseGlobalResources

      public void setUseGlobalResources(boolean useGlobalResources)
      HttpResources を介してグローバル Reactor Netty リソースを使用するかどうか。

      デフォルトは "true" です。この場合、このファクトリは Spring の ApplicationContext ライフサイクル内のグローバル Reactor Netty リソースを初期化および停止します。"false" に設定すると、ファクトリはグローバルリソースから独立してリソースを管理します。

      パラメーター:
      useGlobalResources - グローバルリソースを公開および管理するかどうか
      関連事項:
    • isUseGlobalResources

      public boolean isUseGlobalResources()
      このファクトリがグローバル HttpResources ホルダーを公開するかどうか。
    • addGlobalResourcesConsumer

      public void addGlobalResourcesConsumer(ConsumerSE<reactor.netty5.http.HttpResources> consumer)
      起動時にグローバル Reactor Netty リソースを構成するためのコンシューマーを追加します。このオプションを使用すると、setUseGlobalResources(boolean) も有効になります。
      パラメーター:
      consumer - 適用するコンシューマー
      関連事項:
    • setConnectionProviderSupplier

      public void setConnectionProviderSupplier(SupplierSE<reactor.netty5.resources.ConnectionProvider> supplier)
      グローバルリソースに参加したくない場合や、管理対象の ConnectionProvider の作成をカスタマイズしたい場合に、これを使用します。

      デフォルトでは、ConnectionProvider.elastic("http") が使用されます。

      userGlobalResources=false または setConnectionProvider(ConnectionProvider) が設定されている場合、このオプションは無視されることに注意してください。

      パラメーター:
      supplier - 使用するサプライヤー
    • setConnectionProvider

      public void setConnectionProvider(reactor.netty5.resources.ConnectionProvider connectionProvider)
      これは、外部で管理されている ConnectionProvider インスタンスを提供する場合に使用します。
      パラメーター:
      connectionProvider - そのまま使用する接続プロバイダー
    • getConnectionProvider

      public reactor.netty5.resources.ConnectionProvider getConnectionProvider()
      設定された ConnectionProvider を返します。
    • setLoopResourcesSupplier

      public void setLoopResourcesSupplier(SupplierSE<reactor.netty5.resources.LoopResources> supplier)
      グローバルリソースに参加したくない場合や、管理対象の LoopResources の作成をカスタマイズしたい場合に、これを使用します。

      デフォルトでは、LoopResources.create("webflux-http") が使用されます。

      userGlobalResources=false または setLoopResources(LoopResources) が設定されている場合、このオプションは無視されることに注意してください。

      パラメーター:
      supplier - 使用するサプライヤー
    • setLoopResources

      public void setLoopResources(reactor.netty5.resources.LoopResources loopResources)
      このオプションは、外部で管理されている LoopResources インスタンスを提供する場合に使用します。
      パラメーター:
      loopResources - そのまま使用するループリソース
    • getLoopResources

      public reactor.netty5.resources.LoopResources getLoopResources()
      設定された LoopResources を返します。
    • setShutdownQuietPeriod

      public void setShutdownQuietPeriod(DurationSE shutdownQuietPeriod)
      リソースをシャットダウンする前に待機する時間を設定します。shutdownQuietPeriod 中にタスクが送信された場合、そのタスクは受け入れられることが保証され、shutdownQuietPeriod が最初からやり直します。

      デフォルトでは、これは 2 秒の LoopResources.DEFAULT_SHUTDOWN_QUIET_PERIOD に設定されていますが、システムプロパティ ReactorNetty.SHUTDOWN_QUIET_PERIOD でオーバーライドすることもできます。

      関連事項:
    • setShutdownTimeout

      public void setShutdownTimeout(DurationSE shutdownTimeout)
      shutdownQuietPeriod 中にタスクが送信されたかどうかに関係なく、基になるリソースが破棄されるまで待機する最大時間を構成します。

      デフォルトでは、これは 15 秒の LoopResources.DEFAULT_SHUTDOWN_TIMEOUT に設定されていますが、システムプロパティ ReactorNetty.SHUTDOWN_TIMEOUT でオーバーライドすることもできます。

      関連事項:
    • afterPropertiesSet

      public void afterPropertiesSet()
      インターフェースからコピーされた説明: InitializingBean
      すべての Bean プロパティを設定し、BeanFactoryAwareApplicationContextAware などを満たした後、包含 BeanFactory によって呼び出されます。

      このメソッドにより、Bean インスタンスは、すべての Bean プロパティが設定されたときに、その全体的な構成の検証と最終的な初期化を実行できます。

      次で指定:
      インターフェース InitializingBeanafterPropertiesSet 
    • destroy

      public void destroy()
      インターフェースからコピーされた説明: DisposableBean
      Bean の破棄時に、包含 BeanFactory によって呼び出されます。
      次で指定:
      インターフェース DisposableBeandestroy