public class ServerRSocketConnector extends AbstractRSocketConnector implements ApplicationEventPublisherAware
AbstractRSocketConnector
拡張。RSocketConnector
rSocketMessageHandler
DEFAULT_PHASE
コンストラクターと説明 |
---|
ServerRSocketConnector(reactor.netty.http.server.HttpServer server) WebsocketServerTransport に基づいてサーバーコネクターをインスタンス化します。 |
ServerRSocketConnector(ServerRSocketMessageHandler serverRSocketMessageHandler) RSocket サーバーも外部で作成されることを前提として、提供された ServerRSocketMessageHandler に基づいてサーバーコネクターをインスタンス化します。 |
ServerRSocketConnector(io.rsocket.transport.ServerTransport<io.rsocket.transport.netty.server.CloseableChannel> serverTransport) 提供されている ServerTransport に基づいてサーバーコネクターをインスタンス化します。 |
ServerRSocketConnector(StringSE bindAddress, int port) TcpServerTransport に基づいてサーバーコネクターをインスタンス化します。 |
addEndpoint, getDataMimeType, getMetadataMimeType, getRSocketStrategies, isAutoStartup, isRunning, setAutoStartup, setEndpoints, start, stop
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
getPhase, stop
public ServerRSocketConnector(ServerRSocketMessageHandler serverRSocketMessageHandler)
ServerRSocketMessageHandler
に基づいてサーバーコネクターをインスタンス化します。他のすべてのオプションは無視され、提供された ServerRSocketMessageHandler
とその外部 RSocket サーバー構成が優先されます。serverRSocketMessageHandler
- 依存する ServerRSocketMessageHandler
。public ServerRSocketConnector(StringSE bindAddress, int port)
TcpServerTransport
に基づいてサーバーコネクターをインスタンス化します。bindAddress
- TCP サーバーをバインドするローカルアドレス。port
- バインドするローカル TCP ポート。ServerRSocketConnector(ServerTransport)
public ServerRSocketConnector(reactor.netty.http.server.HttpServer server)
WebsocketServerTransport
に基づいてサーバーコネクターをインスタンス化します。server
- 使用する HttpServer
。ServerRSocketConnector(ServerTransport)
public ServerRSocketConnector(io.rsocket.transport.ServerTransport<io.rsocket.transport.netty.server.CloseableChannel> serverTransport)
ServerTransport
に基づいてサーバーコネクターをインスタンス化します。serverTransport
- サーバーを作成するための ServerTransport
。public void setServerConfigurer(java.util.function.ConsumerSE<io.rsocket.core.RSocketServer> serverConfigurer)
RSocketServer
を構成するための Consumer
SE を提供します。serverConfigurer
- RSocketServer
を構成する Consumer
SE。public void setClientRSocketKeyStrategy(java.util.function.BiFunctionSE<MapSE<StringSE,ObjectSE>,DataBuffer,ObjectSE> clientRSocketKeyStrategy)
RSocketRequester
のキーを決定するための戦略を構成します。デフォルトは、クライアントが接続されている destination
です。clientRSocketKeyStrategy
- クライアント RSocketRequester
のキーを決定するための BiFunction
SE。public void setDataMimeType(@Nullable MimeType dataMimeType)
AbstractRSocketConnector
MimeType
を構成します。AbstractRSocketConnector
の setDataMimeType
dataMimeType
- 使用する MimeType
。public void setMetadataMimeType(MimeType metadataMimeType)
AbstractRSocketConnector
MimeType
を構成します。デフォルトは "message/x.rsocket.composite-metadata.v0"
です。AbstractRSocketConnector
の setMetadataMimeType
metadataMimeType
- 使用する MimeType
。public void setRSocketStrategies(RSocketStrategies rsocketStrategies)
AbstractRSocketConnector
RSocketStrategies
を構成します。AbstractRSocketConnector
の setRSocketStrategies
rsocketStrategies
- 使用する RSocketStrategies
。public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
ApplicationContextAware
の setApplicationContext
AbstractRSocketConnector
の setApplicationContext
BeansException
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
ApplicationEventPublisherAware
の setApplicationEventPublisher
public void afterPropertiesSet()
InitializingBean
の afterPropertiesSet
AbstractRSocketConnector
の afterPropertiesSet
public MapSE<ObjectSE,RSocketRequester> getClientRSocketRequesters()
RSocketRequester
を返します。RSocketRequester
はキーによってマップされます。ServerRSocketMessageHandler.getClientRSocketRequesters()
@Nullable public RSocketRequester getClientRSocketRequester(ObjectSE key)
RSocketRequester
を返します。key
- マッピングキー。RSocketRequester
または null。ServerRSocketMessageHandler.getClientRSocketRequester(Object)
public reactor.core.publisher.Mono<IntegerSE> getBoundPort()
Mono
を返します。Mono
。protected void doStart()
AbstractRSocketConnector
の doStart
public void destroy()
DisposableBean
の destroy
public void afterSingletonsInstantiated()
SmartInitializingSingleton
の afterSingletonsInstantiated
AbstractRSocketConnector
の afterSingletonsInstantiated