程序包 org.springframework.boot.rsocket.netty

类 NettyRSocketServerFactory

java.lang.Object

org.springframework.boot.rsocket.netty.NettyRSocketServerFactory

所有已实现的接口:

ConfigurableRSocketServerFactory, RSocketServerFactory

public class NettyRSocketServerFactory
extends Object
implements RSocketServerFactory, ConfigurableRSocketServerFactory

RSocketServerFactory that can be used to create RSocketServers backed by Netty.

从以下版本开始:

2.2.0

作者:

Brian Clozel, Chris Bono, Scott Frederick

构造器概要

构造器

构造器	说明
NettyRSocketServerFactory()

方法概要

修饰符和类型	方法	说明
void	addRSocketServerCustomizers(RSocketServerCustomizer... rSocketServerCustomizers)	Add RSocketServerCustomizers that should be called to configure the RSocketServer.
NettyRSocketServer	create(io.rsocket.SocketAcceptor socketAcceptor)	Gets a new fully configured but paused RSocketServer instance.
protected final Map<String,SslBundle>	getServerNameSslBundles()
void	setAddress(InetAddress address)	Set the specific network address that the server should bind to.
void	setFragmentSize(DataSize fragmentSize)	Specify the maximum transmission unit.
void	setLifecycleTimeout(Duration lifecycleTimeout)	Set the maximum amount of time that should be waited when starting or stopping the server.
void	setPort(int port)	Set the port that the server should listen on.
void	setResourceFactory(ReactorResourceFactory resourceFactory)	Set the ReactorResourceFactory to get the shared resources from.
void	setRSocketServerCustomizers(Collection<? extends RSocketServerCustomizer> rSocketServerCustomizers)	Set RSocketServerCustomizers that should be called to configure the RSocketServer while building the server.
void	setSsl(Ssl ssl)	Sets the SSL configuration that will be applied to the server's default connector.
void	setSslBundles(SslBundles sslBundles)	Sets an SSL bundle that can be used to get SSL configuration.
void	setTransport(RSocketServer.Transport transport)	Set the transport that the RSocket server should use.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

NettyRSocketServerFactory

public NettyRSocketServerFactory()

方法详细资料

setPort

public void setPort(int port)

从接口复制的说明: ConfigurableRSocketServerFactory

Set the port that the server should listen on. If not specified port '9898' will be used.

指定者:

setPort 在接口中 ConfigurableRSocketServerFactory

参数:

port - the port to set

setFragmentSize

public void setFragmentSize(DataSize fragmentSize)

从接口复制的说明: ConfigurableRSocketServerFactory

Specify the maximum transmission unit. Frames larger than the specified fragmentSize are fragmented.

指定者:

setFragmentSize 在接口中 ConfigurableRSocketServerFactory

参数:

fragmentSize - the fragment size

setAddress

public void setAddress(InetAddress address)

从接口复制的说明: ConfigurableRSocketServerFactory

Set the specific network address that the server should bind to.

指定者:

setAddress 在接口中 ConfigurableRSocketServerFactory

参数:

address - the address to set (defaults to null)

setTransport

public void setTransport(RSocketServer.Transport transport)

从接口复制的说明: ConfigurableRSocketServerFactory

Set the transport that the RSocket server should use.

指定者:

setTransport 在接口中 ConfigurableRSocketServerFactory

参数:

transport - the transport protocol to use

setSsl

public void setSsl(Ssl ssl)

从接口复制的说明: ConfigurableRSocketServerFactory

Sets the SSL configuration that will be applied to the server's default connector.

指定者:

setSsl 在接口中 ConfigurableRSocketServerFactory

参数:

ssl - the SSL configuration

setSslBundles

public void setSslBundles(SslBundles sslBundles)

从接口复制的说明: ConfigurableRSocketServerFactory

Sets an SSL bundle that can be used to get SSL configuration.

指定者:

setSslBundles 在接口中 ConfigurableRSocketServerFactory

参数:

sslBundles - the SSL bundles

setResourceFactory

public void setResourceFactory(ReactorResourceFactory resourceFactory)

Set the ReactorResourceFactory to get the shared resources from.

参数:

resourceFactory - the server resources

setRSocketServerCustomizers

public void setRSocketServerCustomizers(Collection<? extends RSocketServerCustomizer> rSocketServerCustomizers)

Set RSocketServerCustomizers that should be called to configure the RSocketServer while building the server. Calling this method will replace any existing customizers.

参数:

rSocketServerCustomizers - customizers to apply before the server starts

从以下版本开始:

2.2.7

addRSocketServerCustomizers

public void addRSocketServerCustomizers(RSocketServerCustomizer... rSocketServerCustomizers)

Add RSocketServerCustomizers that should be called to configure the RSocketServer.

参数:

rSocketServerCustomizers - customizers to apply before the server starts

从以下版本开始:

2.2.7

setLifecycleTimeout

public void setLifecycleTimeout(Duration lifecycleTimeout)

Set the maximum amount of time that should be waited when starting or stopping the server.

参数:

lifecycleTimeout - the lifecycle timeout

create

public NettyRSocketServer create(io.rsocket.SocketAcceptor socketAcceptor)

从接口复制的说明: RSocketServerFactory

Gets a new fully configured but paused RSocketServer instance. Clients should not be able to connect to the returned server until RSocketServer.start() is called (which happens when the ApplicationContext has been fully refreshed).

指定者:

create 在接口中 RSocketServerFactory

参数:

socketAcceptor - the socket acceptor

返回:

a fully configured and started RSocketServer

另请参阅:

• RSocketServer.stop()

getServerNameSslBundles

protected final Map<String,SslBundle> getServerNameSslBundles()