クラス ServerRSocketConnector
java.lang.ObjectSE
org.springframework.integration.rsocket.AbstractRSocketConnector
org.springframework.integration.rsocket.ServerRSocketConnector
- 実装済みのインターフェース一覧:
Aware、DisposableBean、InitializingBean、SmartInitializingSingleton、ApplicationContextAware、ApplicationEventPublisherAware、Lifecycle、Phased、SmartLifecycle
public class ServerRSocketConnector
extends AbstractRSocketConnector
implements ApplicationEventPublisherAware
クライアント RSocket 接続を受け入れて管理するためのサーバー
AbstractRSocketConnector 拡張。- 導入:
- 5.2
- 作成者:
- Artem Bilan
- 関連事項:
RSocketConnector
フィールド概要
クラス org.springframework.integration.rsocket.AbstractRSocketConnector から継承されたフィールド
rSocketMessageHandlerインターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASEコンストラクター概要
コンストラクターコンストラクター説明ServerRSocketConnector(io.rsocket.transport.ServerTransport<io.rsocket.transport.netty.server.CloseableChannel> serverTransport) 提供されているServerTransportに基づいてサーバーコネクターをインスタンス化します。ServerRSocketConnector(StringSE bindAddress, int port) TcpServerTransportに基づいてサーバーコネクターをインスタンス化します。ServerRSocketConnector(ServerRSocketMessageHandler serverRSocketMessageHandler) RSocket サーバーも外部で作成されることを前提として、提供されたServerRSocketMessageHandlerに基づいてサーバーコネクターをインスタンス化します。ServerRSocketConnector(reactor.netty.http.server.HttpServer server) WebsocketServerTransportに基づいてサーバーコネクターをインスタンス化します。方法の概要
修飾子と型メソッド説明voidvoidvoiddestroy()protected voiddoStart()reactor.core.publisher.Mono<IntegerSE>この内部サーバーがバインドされているポートまたは空のMonoを返します。キーまたは null によってマップされた接続済みRSocketRequesterを返します。キーによってマップされた接続済みRSocketRequesterを返します。voidsetApplicationContext(ApplicationContext applicationContext) voidsetApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) voidsetClientRSocketKeyStrategy(BiFunctionSE<MapSE<StringSE, ObjectSE>, DataBuffer, ObjectSE> clientRSocketKeyStrategy) 接続されているクライアントRSocketRequesterのキーを決定するための戦略を構成します。voidsetDataMimeType(MimeType dataMimeType) データ交換用にMimeTypeを構成します。voidsetMetadataMimeType(MimeType metadataMimeType) メタデータ交換用にMimeTypeを構成します。voidsetRSocketStrategies(RSocketStrategies rsocketStrategies) データのエンコード / デコード用にRSocketStrategiesを構成します。voidsetServerConfigurer(ConsumerSE<io.rsocket.core.RSocketServer> serverConfigurer) RSocketServerを構成するためのConsumerSE を提供します。クラス org.springframework.integration.rsocket.AbstractRSocketConnector から継承されたメソッド
addEndpoint, getDataMimeType, getMetadataMimeType, getRSocketStrategies, isAutoStartup, isRunning, setAutoStartup, setEndpoints, start, stopクラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース org.springframework.context.SmartLifecycle から継承されたメソッド
getPhase, stop
コンストラクターの詳細
ServerRSocketConnector
RSocket サーバーも外部で作成されることを前提として、提供されたServerRSocketMessageHandlerに基づいてサーバーコネクターをインスタンス化します。他のすべてのオプションは無視され、提供されたServerRSocketMessageHandlerとその外部 RSocket サーバー構成が優先されます。- パラメーター:
serverRSocketMessageHandler- 依存するServerRSocketMessageHandler。- 導入:
- 5.2.1
ServerRSocketConnector
TcpServerTransportに基づいてサーバーコネクターをインスタンス化します。- パラメーター:
bindAddress- TCP サーバーをバインドするローカルアドレス。port- バインドするローカル TCP ポート。- 関連事項:
ServerRSocketConnector
public ServerRSocketConnector(reactor.netty.http.server.HttpServer server) WebsocketServerTransportに基づいてサーバーコネクターをインスタンス化します。- パラメーター:
server- 使用するHttpServer。- 関連事項:
ServerRSocketConnector
public ServerRSocketConnector(io.rsocket.transport.ServerTransport<io.rsocket.transport.netty.server.CloseableChannel> serverTransport) 提供されているServerTransportに基づいてサーバーコネクターをインスタンス化します。- パラメーター:
serverTransport- サーバーを作成するためのServerTransport。
方法の詳細
setServerConfigurer
RSocketServerを構成するためのConsumerSE を提供します。- パラメーター:
serverConfigurer-RSocketServerを構成するConsumerSE。- 導入:
- 5.2.6
setClientRSocketKeyStrategy
public void setClientRSocketKeyStrategy(BiFunctionSE<MapSE<StringSE, ObjectSE>, DataBuffer, ObjectSE> clientRSocketKeyStrategy) 接続されているクライアントRSocketRequesterのキーを決定するための戦略を構成します。デフォルトは、クライアントが接続されているdestinationです。- パラメーター:
clientRSocketKeyStrategy- クライアントRSocketRequesterのキーを決定するためのBiFunctionSE。
setDataMimeType
クラスからコピーされた説明:AbstractRSocketConnectorデータ交換用にMimeTypeを構成します。- オーバーライド:
- クラス
AbstractRSocketConnectorのsetDataMimeType - パラメーター:
dataMimeType- 使用するMimeType。
setMetadataMimeType
クラスからコピーされた説明:AbstractRSocketConnectorメタデータ交換用にMimeTypeを構成します。デフォルトは"message/x.rsocket.composite-metadata.v0"です。- オーバーライド:
- クラス
AbstractRSocketConnectorのsetMetadataMimeType - パラメーター:
metadataMimeType- 使用するMimeType。
setRSocketStrategies
クラスからコピーされた説明:AbstractRSocketConnectorデータのエンコード / デコード用にRSocketStrategiesを構成します。- オーバーライド:
- クラス
AbstractRSocketConnectorのsetRSocketStrategies - パラメーター:
rsocketStrategies- 使用するRSocketStrategies。
setApplicationContext
- 次で指定:
- インターフェース
ApplicationContextAware内のsetApplicationContext - オーバーライド:
- クラス
AbstractRSocketConnectorのsetApplicationContext - 例外:
BeansException
setApplicationEventPublisher
- 次で指定:
- インターフェース
ApplicationEventPublisherAware内のsetApplicationEventPublisher
afterPropertiesSet
public void afterPropertiesSet()- 次で指定:
- インターフェース
InitializingBean内のafterPropertiesSet - オーバーライド:
- クラス
AbstractRSocketConnectorのafterPropertiesSet
getClientRSocketRequesters
キーによってマップされた接続済みRSocketRequesterを返します。- 戻り値:
- 接続された
RSocketRequesterはキーによってマップされます。 - 関連事項:
getClientRSocketRequester
キーまたは null によってマップされた接続済みRSocketRequesterを返します。- パラメーター:
key- マッピングキー。- 戻り値:
RSocketRequesterまたは null。- 関連事項:
getBoundPort
この内部サーバーがバインドされているポートまたは空のMonoを返します。- 戻り値:
- この内部サーバーがバインドされているポート、または外部サーバーが使用されている場合は空の
Mono。
doStart
protected void doStart()- 次で指定:
- クラス
AbstractRSocketConnectorのdoStart
destroy
public void destroy()- 次で指定:
- インターフェース
DisposableBean内のdestroy
afterSingletonsInstantiated
public void afterSingletonsInstantiated()- 次で指定:
- インターフェース
SmartInitializingSingleton内のafterSingletonsInstantiated - オーバーライド:
- クラス
AbstractRSocketConnectorのafterSingletonsInstantiated