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` に基づいてサーバーコネクターをインスタンス化します。

メソッドのサマリー

修飾子と型	メソッド	説明
`void`	`afterPropertiesSet()`
`void`	`afterSingletonsInstantiated()`
`void`	`destroy()`
`protected void`	`doStart()`
`reactor.core.publisher.Mono<IntegerSE>`	`getBoundPort()`	この内部サーバーがバインドされているポートまたは空の `Mono` を返します。
`RSocketRequester`	`getClientRSocketRequester(ObjectSE key)`	キーまたは null によってマップされた接続済み `RSocketRequester` を返します。
`MapSE<ObjectSE,RSocketRequester>`	`getClientRSocketRequesters()`	キーによってマップされた接続済み `RSocketRequester` を返します。
`void`	`setApplicationContext(ApplicationContext applicationContext)`
`void`	`setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)`
`void`	`setClientRSocketKeyStrategy(BiFunctionSE<MapSE<StringSE,ObjectSE>,DataBuffer,ObjectSE> clientRSocketKeyStrategy)`	接続されているクライアント `RSocketRequester` のキーを決定するための戦略を構成します。
`void`	`setDataMimeType(MimeType dataMimeType)`	データ交換用に `MimeType` を構成します。
`void`	`setMetadataMimeType(MimeType metadataMimeType)`	メタデータ交換用に `MimeType` を構成します。
`void`	`setRSocketStrategies(RSocketStrategies rsocketStrategies)`	データのエンコード / デコード用に `RSocketStrategies` を構成します。
`void`	`setServerConfigurer(ConsumerSE<io.rsocket.core.RSocketServer> serverConfigurer)`	`RSocketServer` を構成するための `Consumer`SE を提供します。

クラス 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
  public ServerRSocketConnector(ServerRSocketMessageHandler serverRSocketMessageHandler)
  RSocket サーバーも外部で作成されることを前提として、提供された ServerRSocketMessageHandler に基づいてサーバーコネクターをインスタンス化します。他のすべてのオプションは無視され、提供された ServerRSocketMessageHandler とその外部 RSocket サーバー構成が優先されます。
  パラメーター:
  serverRSocketMessageHandler - 依存する ServerRSocketMessageHandler。
  導入:
  5.2.1
- ServerRSocketConnector
  public ServerRSocketConnector(StringSE bindAddress, int port)
  TcpServerTransport に基づいてサーバーコネクターをインスタンス化します。
  パラメーター:
  bindAddress - TCP サーバーをバインドするローカルアドレス。
  port - バインドするローカル TCP ポート。
  関連事項:
  ServerRSocketConnector(ServerTransport)
- ServerRSocketConnector
  public ServerRSocketConnector(reactor.netty.http.server.HttpServer server)
  WebsocketServerTransport に基づいてサーバーコネクターをインスタンス化します。
  パラメーター:
  server - 使用する HttpServer。
  関連事項:
  ServerRSocketConnector(ServerTransport)
- ServerRSocketConnector
  public ServerRSocketConnector(io.rsocket.transport.ServerTransport<io.rsocket.transport.netty.server.CloseableChannel> serverTransport)
  提供されている ServerTransport に基づいてサーバーコネクターをインスタンス化します。
  パラメーター:
  serverTransport - サーバーを作成するための ServerTransport。
メソッドの詳細
- setServerConfigurer
  public void setServerConfigurer(ConsumerSE<io.rsocket.core.RSocketServer> serverConfigurer)
  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
  public void setDataMimeType(@Nullable MimeType dataMimeType)
  クラスからコピーされた説明: AbstractRSocketConnector
  データ交換用に MimeType を構成します。
  オーバーライド:
  クラス AbstractRSocketConnector の setDataMimeType
  パラメーター:
  dataMimeType - 使用する MimeType。
- setMetadataMimeType
  public void setMetadataMimeType(MimeType metadataMimeType)
  クラスからコピーされた説明: AbstractRSocketConnector
  メタデータ交換用に MimeType を構成します。デフォルトは "message/x.rsocket.composite-metadata.v0" です。
  オーバーライド:
  クラス AbstractRSocketConnector の setMetadataMimeType
  パラメーター:
  metadataMimeType - 使用する MimeType。
- setRSocketStrategies
  public void setRSocketStrategies(RSocketStrategies rsocketStrategies)
  クラスからコピーされた説明: AbstractRSocketConnector
  データのエンコード / デコード用に RSocketStrategies を構成します。
  オーバーライド:
  クラス AbstractRSocketConnector の setRSocketStrategies
  パラメーター:
  rsocketStrategies - 使用する RSocketStrategies。
- setApplicationContext
  public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
  次で指定:
  インターフェース ApplicationContextAware の setApplicationContext
  オーバーライド:
  クラス AbstractRSocketConnector の setApplicationContext
  例外:
  BeansException
- setApplicationEventPublisher
  public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
  次で指定:
  インターフェース ApplicationEventPublisherAware の setApplicationEventPublisher
- afterPropertiesSet
  public void afterPropertiesSet()
  次で指定:
  インターフェース InitializingBean の afterPropertiesSet
  オーバーライド:
  クラス AbstractRSocketConnector の afterPropertiesSet
- getClientRSocketRequesters
  public MapSE<ObjectSE,RSocketRequester> getClientRSocketRequesters()
  キーによってマップされた接続済み RSocketRequester を返します。
  戻り値:
  接続された RSocketRequester はキーによってマップされます。
  関連事項:
  ServerRSocketMessageHandler.getClientRSocketRequesters()
- getClientRSocketRequester
  @Nullable public RSocketRequester getClientRSocketRequester(ObjectSE key)
  キーまたは null によってマップされた接続済み RSocketRequester を返します。
  パラメーター:
  key - マッピングキー。
  戻り値:
  RSocketRequester または null。
  関連事項:
  ServerRSocketMessageHandler.getClientRSocketRequester(Object)
- getBoundPort
  public reactor.core.publisher.Mono<IntegerSE> getBoundPort()
  この内部サーバーがバインドされているポートまたは空の Mono を返します。
  戻り値:
  この内部サーバーがバインドされているポート、または外部サーバーが使用されている場合は空の Mono。
- doStart
  protected void doStart()
  次で指定:
  クラス AbstractRSocketConnector の doStart
- destroy
  public void destroy()
  次で指定:
  インターフェース DisposableBean の destroy
- afterSingletonsInstantiated
  public void afterSingletonsInstantiated()
  次で指定:
  インターフェース SmartInitializingSingleton の afterSingletonsInstantiated
  オーバーライド:
  クラス AbstractRSocketConnector の afterSingletonsInstantiated

クラス ServerRSocketConnector

フィールドのサマリー

クラス org.springframework.integration.rsocket.AbstractRSocketConnector から継承されたフィールド

インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.integration.rsocket.AbstractRSocketConnector から継承されたメソッド

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

インターフェース org.springframework.context.SmartLifecycle から継承されたメソッド

コンストラクターの詳細

メソッドの詳細