クラス ReactorResourceFactory

メソッドの詳細

• setUseGlobalResources

  public void setUseGlobalResources(boolean useGlobalResources)

  HttpResources を介してグローバル Reactor Netty リソースを使用するかどうか。

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

  パラメーター:

  useGlobalResources - グローバルリソースを公開および管理するかどうか

  関連事項:

  • addGlobalResourcesConsumer(Consumer)

• isUseGlobalResources

  public boolean isUseGlobalResources()

  このファクトリがグローバル HttpResources ホルダーを公開するかどうか。

• addGlobalResourcesConsumer

  public void addGlobalResourcesConsumer(ConsumerSE<reactor.netty.http.HttpResources> consumer)

  起動時にグローバル Reactor Netty リソースを構成するためのコンシューマーを追加します。このオプションを使用すると、setUseGlobalResources(boolean) も有効になります。

  パラメーター:

  consumer - 適用するコンシューマー

  関連事項:

  • setUseGlobalResources(boolean)

• setConnectionProviderSupplier

  public void setConnectionProviderSupplier(SupplierSE<reactor.netty.resources.ConnectionProvider> supplier)

  グローバルリソースに参加したくない場合や、管理対象の ConnectionProvider の作成をカスタマイズしたい場合に、これを使用します。

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

  isUseGlobalResources() が true の場合、または ConnectionProvider が設定されている場合は、このサプライヤーは無視されることに注意してください。

  パラメーター:

  supplier - 使用するサプライヤー

• setConnectionProvider

  public void setConnectionProvider(reactor.netty.resources.ConnectionProvider connectionProvider)

  これは、外部で管理されている ConnectionProvider インスタンスを提供する場合に使用します。

  パラメーター:

  connectionProvider - そのまま使用する接続プロバイダー

• getConnectionProvider

  public reactor.netty.resources.ConnectionProvider getConnectionProvider()

  設定された ConnectionProvider を返します。

  まだ初期化されていない場合は、オンデマンドでリソースを遅延的に起動しようとします。

  関連事項:

  • start()

• setLoopResourcesSupplier

  public void setLoopResourcesSupplier(SupplierSE<reactor.netty.resources.LoopResources> supplier)

  グローバルリソースに参加したくない場合や、管理対象の LoopResources の作成をカスタマイズしたい場合に、これを使用します。

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

  isUseGlobalResources() が true の場合、または LoopResources が設定されている場合は、このサプライヤーは無視されることに注意してください。

  パラメーター:

  supplier - 使用するサプライヤー

• setLoopResources

  public void setLoopResources(reactor.netty.resources.LoopResources loopResources)

  このオプションは、外部で管理されている LoopResources インスタンスを提供する場合に使用します。

  パラメーター:

  loopResources - そのまま使用するループリソース

• getLoopResources

  public reactor.netty.resources.LoopResources getLoopResources()

  設定された LoopResources を返します。

  まだ初期化されていない場合は、オンデマンドでリソースを遅延的に起動しようとします。

  関連事項:

  • start()

• setShutdownQuietPeriod

  public void setShutdownQuietPeriod(DurationSE shutdownQuietPeriod)

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

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

  関連事項:

  • setShutdownTimeout(Duration)

• setShutdownTimeout

  public void setShutdownTimeout(DurationSE shutdownTimeout)

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

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

  関連事項:

  • setShutdownQuietPeriod(Duration)

• setApplicationContext

  public void setApplicationContext(ApplicationContext applicationContext)

  ApplicationContext の設定はオプションです。設定されている場合、Reactor リソースは lifecycle start フェーズで初期化され、lifecycle stop フェーズで閉じられます。設定されていない場合は、それぞれ afterPropertiesSet() と destroy() で実行されます。

  次で指定:

  インターフェース ApplicationContextAware の setApplicationContext 

  パラメーター:

  applicationContext - このオブジェクトによって使用される ApplicationContext オブジェクト

  関連事項:

  • BeanInitializationException

• afterPropertiesSet

  public void afterPropertiesSet()

  ApplicationContext の外部で初期化された場合、リソースを起動します。これは下位互換性のためです。推奨される方法は、ApplicationContext の lifecycle management に依存することです。

  次で指定:

  インターフェース InitializingBean の afterPropertiesSet 

  関連事項:

  • start()

• destroy

  public void destroy()

  ApplicationContext の外部で初期化された場合、リソースを停止します。これは下位互換性のためです。推奨される方法は、ApplicationContext の lifecycle management に依存することです。

  次で指定:

  インターフェース DisposableBean の destroy 

  関連事項:

  • stop()

• start

  public void start()

  インターフェースからコピーされた説明: Lifecycle

  このコンポーネントを起動します。

  コンポーネントがすでに実行されている場合は、例外をスローしないでください。

  コンテナーの場合、これは適用されるすべてのコンポーネントに開始シグナルを伝播します。

  次で指定:

  インターフェース Lifecycle の start 

  関連事項:

  • SmartLifecycle.isAutoStartup()

• stop

  public void stop()

  インターフェースからコピーされた説明: Lifecycle

  このメソッドを返すとコンポーネントが完全に停止するように、通常は同期的にこのコンポーネントを停止します。非同期停止動作が必要な場合は、SmartLifecycle とその stop(Runnable) バリアントの実装を検討してください。

  この停止通知は破棄前に送信されるとは限らないことに注意してください。通常のシャットダウンでは、一般的な破棄コールバックが伝播される前に、Lifecycle Bean は最初に停止通知を受信します。ただし、コンテキストの存続期間中のホットリフレッシュまたは中断されたリフレッシュ試行では、特定の Bean の destroy メソッドが、停止シグナルを事前に考慮することなく呼び出されます。

  コンポーネントが実行されていない（まだ開始されていない）場合は、例外をスローしないでください。

  コンテナーの場合、これは停止シグナルを適用するすべてのコンポーネントに伝播します。

  次で指定:

  インターフェース Lifecycle の stop 

  関連事項:

  • SmartLifecycle.stop(Runnable)
  • DisposableBean.destroy()

• isRunning

  public boolean isRunning()

  インターフェースからコピーされた説明: Lifecycle

  このコンポーネントが現在実行されているかどうかを確認します。

  コンテナーの場合、これは、適用されるすべてのコンポーネントが現在実行されている場合にのみ、true を返します。

  次で指定:

  インターフェース Lifecycle の isRunning 

  戻り値:

  コンポーネントが現在実行中かどうか

• getPhase

  public int getPhase()

  インターフェースからコピーされた説明: SmartLifecycle

  このライフサイクルオブジェクトが実行されるはずのフェーズを返します。

  デフォルトの実装は、通常の Lifecycle 実装の前に stop() コールバックを実行できるようにするために SmartLifecycle.DEFAULT_PHASE を返します。

  次で指定:

  インターフェース Phased の getPhase 

  次で指定:

  インターフェース SmartLifecycle の getPhase 

  関連事項:

  • SmartLifecycle.isAutoStartup()
  • Lifecycle.start()
  • SmartLifecycle.stop(Runnable)
  • DefaultLifecycleProcessor.getPhase(Lifecycle)