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 を構成するための 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
  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 から継承されたメソッド

コンストラクターの詳細

ServerRSocketConnector

ServerRSocketConnector

ServerRSocketConnector

ServerRSocketConnector

メソッドの詳細

setServerConfigurer

setClientRSocketKeyStrategy

setDataMimeType

setMetadataMimeType

setRSocketStrategies

setApplicationContext

setApplicationEventPublisher

afterPropertiesSet

getClientRSocketRequesters

getClientRSocketRequester

getBoundPort

doStart

destroy

afterSingletonsInstantiated