public class NettyRSocketServerFactory extends ObjectSE implements RSocketServerFactory, ConfigurableRSocketServerFactory
RSocketServer の作成に使用できる RSocketServerFactory。| コンストラクターと説明 |
|---|
NettyRSocketServerFactory() |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | addSocketFactoryProcessors(ServerRSocketFactoryProcessor... socketFactoryProcessors) サーバーの構築中に RSocketFactory.ServerRSocketFactory を処理するために呼び出す ServerRSocketFactoryProcessor を追加します。 |
NettyRSocketServer | create(io.rsocket.SocketAcceptor socketAcceptor) 完全に構成済みで一時停止された新しい RSocketServer インスタンスを取得します。 |
void | setAddress(InetAddressSE address) サーバーがバインドする特定のネットワークアドレスを設定します。 |
void | setLifecycleTimeout(DurationSE lifecycleTimeout) サーバーの起動または停止時に待機する最大時間を設定します。 |
void | setPort(int port) サーバーが待機するポートを設定します。 |
void | setResourceFactory(org.springframework.http.client.reactive.ReactorResourceFactory resourceFactory) 共有リソースを取得するように ReactorResourceFactory を設定します。 |
void | setSocketFactoryProcessors(CollectionSE<? extends ServerRSocketFactoryProcessor> socketFactoryProcessors) サーバーの構築中に RSocketFactory.ServerRSocketFactory を処理するために呼び出す必要のある ServerRSocketFactoryProcessor を設定します。 |
void | setTransport(RSocketServer.Transport transport)RSocket サーバーが使用するトランスポートを設定します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic void setPort(int port)
ConfigurableRSocketServerFactoryConfigurableRSocketServerFactory 内の setPort port - 設定するポート public void setAddress(InetAddressSE address)
ConfigurableRSocketServerFactoryConfigurableRSocketServerFactory 内の setAddress address - 設定するアドレス (デフォルトは null)public void setTransport(RSocketServer.Transport transport)
ConfigurableRSocketServerFactoryConfigurableRSocketServerFactory 内の setTransport transport - 使用するトランスポートプロトコル public void setResourceFactory(org.springframework.http.client.reactive.ReactorResourceFactory resourceFactory)
ReactorResourceFactory を設定します。resourceFactory - サーバーリソース public void setSocketFactoryProcessors(CollectionSE<? extends ServerRSocketFactoryProcessor> socketFactoryProcessors)
RSocketFactory.ServerRSocketFactory を処理するために呼び出す ServerRSocketFactoryProcessor を設定します。このメソッドを呼び出すと、既存のプロセッサーがすべて置き換えられます。socketFactoryProcessors - サーバーが起動する前に適用するプロセッサー public void addSocketFactoryProcessors(ServerRSocketFactoryProcessor... socketFactoryProcessors)
RSocketFactory.ServerRSocketFactory を処理するために呼び出す ServerRSocketFactoryProcessor を追加します。socketFactoryProcessors - サーバーが起動する前に適用するプロセッサー public void setLifecycleTimeout(DurationSE lifecycleTimeout)
lifecycleTimeout - ライフサイクルのタイムアウト public NettyRSocketServer create(io.rsocket.SocketAcceptor socketAcceptor)
RSocketServerFactoryRSocketServer インスタンスを取得します。クライアントは、RSocketServer.start() が呼び出されるまで(ApplicationContext が完全にリフレッシュされると発生します)、返されたサーバーに接続できません。RSocketServerFactory 内の create socketAcceptor - ソケットアクセプター RSocketServerRSocketServer.stop()Copyright © 2019 Pivotal Software, Inc.. All rights reserved.