NettyServerBuilder (grpc-netty 1.44.0 API)

java.lang.Object
- io.grpc.ServerBuilder<T>
- - io.grpc.internal.AbstractServerImplBuilder<NettyServerBuilder>
  - - io.grpc.netty.NettyServerBuilder

@ExperimentalApi(value="https://github.com/grpc/grpc-java/issues/1784")
 @CanIgnoreReturnValue
public final class NettyServerBuilder
extends io.grpc.internal.AbstractServerImplBuilder<NettyServerBuilder>

A builder to help simplify the construction of a Netty-based GRPC server.

Field Summary

Fields
Modifier and Type Field and Description

static int DEFAULT_FLOW_CONTROL_WINDOW

Fields
Modifier and Type	Field and Description
`static int`	`DEFAULT_FLOW_CONTROL_WINDOW`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method and Description
`NettyServerBuilder`	`addListenAddress(SocketAddress listenAddress)` Adds an additional address for this server to listen on.
`NettyServerBuilder`	`bossEventLoopGroup(io.netty.channel.EventLoopGroup group)` Provides the boss EventGroupLoop to the server.
`NettyServerBuilder`	`channelFactory(io.netty.channel.ChannelFactory<? extends io.netty.channel.ServerChannel> channelFactory)` Specifies the `ChannelFactory` to create `ServerChannel` instances.
`NettyServerBuilder`	`channelType(Class<? extends io.netty.channel.ServerChannel> channelType)` Specifies the channel type to use, by default we use `EpollServerSocketChannel` if available, otherwise using `NioServerSocketChannel`.
`protected io.grpc.ServerBuilder<?>`	`delegate()`
`NettyServerBuilder`	`flowControlWindow(int flowControlWindow)` Sets the flow control window in bytes.
`static NettyServerBuilder`	`forAddress(SocketAddress address)` Creates a server builder configured with the given `SocketAddress`.
`static NettyServerBuilder`	`forAddress(SocketAddress address, io.grpc.ServerCredentials creds)` Creates a server builder configured with the given `SocketAddress`.
`static NettyServerBuilder`	`forPort(int port)` Creates a server builder that will bind to the given port.
`static NettyServerBuilder`	`forPort(int port, io.grpc.ServerCredentials creds)` Creates a server builder that will bind to the given port.
`NettyServerBuilder`	`initialFlowControlWindow(int initialFlowControlWindow)` Sets the initial flow control window in bytes.
`NettyServerBuilder`	`keepAliveTime(long keepAliveTime, TimeUnit timeUnit)` Sets a custom keepalive time, the delay time for sending next keepalive ping.
`NettyServerBuilder`	`keepAliveTimeout(long keepAliveTimeout, TimeUnit timeUnit)` Sets a custom keepalive timeout, the timeout for keepalive ping requests.
`NettyServerBuilder`	`maxConcurrentCallsPerConnection(int maxCalls)` The maximum number of concurrent calls permitted for each incoming connection.
`NettyServerBuilder`	`maxConnectionAge(long maxConnectionAge, TimeUnit timeUnit)` Sets a custom max connection age, connection lasting longer than which will be gracefully terminated.
`NettyServerBuilder`	`maxConnectionAgeGrace(long maxConnectionAgeGrace, TimeUnit timeUnit)` Sets a custom grace time for the graceful connection termination.
`NettyServerBuilder`	`maxConnectionIdle(long maxConnectionIdle, TimeUnit timeUnit)` Sets a custom max connection idle time, connection being idle for longer than which will be gracefully terminated.
`NettyServerBuilder`	`maxHeaderListSize(int maxHeaderListSize)` Deprecated. Use `maxInboundMetadataSize(int)` instead
`NettyServerBuilder`	`maxInboundMessageSize(int bytes)`
`NettyServerBuilder`	`maxInboundMetadataSize(int bytes)` Sets the maximum size of metadata allowed to be received.
`NettyServerBuilder`	`maxMessageSize(int maxMessageSize)` Deprecated. Call `maxInboundMessageSize(int)` instead. This method will be removed in a future release.
`NettyServerBuilder`	`permitKeepAliveTime(long keepAliveTime, TimeUnit timeUnit)` Specify the most aggressive keep-alive time clients are permitted to configure.
`NettyServerBuilder`	`permitKeepAliveWithoutCalls(boolean permit)` Sets whether to allow clients to send keep-alive HTTP/2 PINGs even if there are no outstanding RPCs on the connection.
`NettyServerBuilder`	`protocolNegotiator(io.grpc.netty.ProtocolNegotiator protocolNegotiator)` Sets the `ProtocolNegotiator` to be used.
`NettyServerBuilder`	`sslContext(io.netty.handler.ssl.SslContext sslContext)` Sets the TLS context to use for encryption.
`NettyServerBuilder`	`useTransportSecurity(File certChain, File privateKey)`
`NettyServerBuilder`	`useTransportSecurity(InputStream certChain, InputStream privateKey)`
`<T> NettyServerBuilder`	`withChildOption(io.netty.channel.ChannelOption<T> option, T value)` Specifies a child channel option.
`<T> NettyServerBuilder`	`withOption(io.netty.channel.ChannelOption<T> option, T value)` Specifies a channel option.
`NettyServerBuilder`	`workerEventLoopGroup(io.netty.channel.EventLoopGroup group)` Provides the worker EventGroupLoop to the server.

Methods inherited from class io.grpc.internal.AbstractServerImplBuilder
addService, addService, addStreamTracerFactory, addTransportFilter, build, callExecutor, compressorRegistry, decompressorRegistry, directExecutor, executor, fallbackHandlerRegistry, handshakeTimeout, intercept, setBinaryLog, thisT, toString

Methods inherited from class io.grpc.ServerBuilder
addServices

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - DEFAULT_FLOW_CONTROL_WINDOW
```
public static final int DEFAULT_FLOW_CONTROL_WINDOW
```
    See Also:
    
    Constant Field Values
- Method Detail
  - forPort
```
@CheckReturnValue
public static NettyServerBuilder forPort(int port)
```
    Creates a server builder that will bind to the given port.
    
    Parameters:
    
    port - the port on which the server is to be bound.
    
    Returns:
    
    the server builder.
  - forPort
```
@CheckReturnValue
public static NettyServerBuilder forPort(int port,
                                                           io.grpc.ServerCredentials creds)
```
    Creates a server builder that will bind to the given port.
    
    Parameters:
    
    port - the port on which the server is to be bound.
    
    Returns:
    
    the server builder.
  - forAddress
```
@CheckReturnValue
public static NettyServerBuilder forAddress(SocketAddress address)
```
    Creates a server builder configured with the given SocketAddress.
    
    Parameters:
    
    address - the socket address on which the server is to be bound.
    
    Returns:
    
    the server builder
  - forAddress
```
@CheckReturnValue
public static NettyServerBuilder forAddress(SocketAddress address,
                                                              io.grpc.ServerCredentials creds)
```
    Creates a server builder configured with the given SocketAddress.
    
    Parameters:
    
    address - the socket address on which the server is to be bound.
    
    Returns:
    
    the server builder
  - delegate
```
@Internal
protected io.grpc.ServerBuilder<?> delegate()
```
    Specified by:
    
    delegate in class io.grpc.internal.AbstractServerImplBuilder<NettyServerBuilder>
  - addListenAddress
```
public NettyServerBuilder addListenAddress(SocketAddress listenAddress)
```
    Adds an additional address for this server to listen on. Callers must ensure that all socket addresses are compatible with the Netty channel type, and that they don't conflict with each other.
  - channelType
```
public NettyServerBuilder channelType(Class<? extends io.netty.channel.ServerChannel> channelType)
```
    Specifies the channel type to use, by default we use EpollServerSocketChannel if available, otherwise using NioServerSocketChannel.
    You either use this or channelFactory(io.netty.channel.ChannelFactory) if your ServerChannel implementation has no no-args constructor.
    It's an optional parameter. If the user has not provided an Channel type or ChannelFactory when the channel is built, the builder will use the default one which is static.
    You must also provide corresponding EventLoopGroup using workerEventLoopGroup(EventLoopGroup) and bossEventLoopGroup(EventLoopGroup). For example, NioServerSocketChannel must use NioEventLoopGroup, otherwise your server won't start.
  - channelFactory
```
public NettyServerBuilder channelFactory(io.netty.channel.ChannelFactory<? extends io.netty.channel.ServerChannel> channelFactory)
```
    Specifies the ChannelFactory to create ServerChannel instances. This method is usually only used if the specific ServerChannel requires complex logic which requires additional information to create the ServerChannel. Otherwise, recommend to use channelType(Class).
    It's an optional parameter. If the user has not provided an Channel type or ChannelFactory when the channel is built, the builder will use the default one which is static.
    You must also provide corresponding EventLoopGroup using workerEventLoopGroup(EventLoopGroup) and bossEventLoopGroup(EventLoopGroup). For example, if the factory creates NioServerSocketChannel you must use NioEventLoopGroup, otherwise your server won't start.
  - withOption
```
public <T> NettyServerBuilder withOption(io.netty.channel.ChannelOption<T> option,
                                         T value)
```
    Specifies a channel option. As the underlying channel as well as network implementation may ignore this value applications should consider it a hint.
    
    Since:
    
    1.30.0
  - withChildOption
```
public <T> NettyServerBuilder withChildOption(io.netty.channel.ChannelOption<T> option,
                                              T value)
```
    Specifies a child channel option. As the underlying channel as well as network implementation may ignore this value applications should consider it a hint.
    
    Since:
    
    1.9.0
  - bossEventLoopGroup
```
public NettyServerBuilder bossEventLoopGroup(io.netty.channel.EventLoopGroup group)
```
    Provides the boss EventGroupLoop to the server.
    It's an optional parameter. If the user has not provided one when the server is built, the builder will use the default one which is static.
    You must also provide corresponding Channel type using channelType(Class) and workerEventLoopGroup(EventLoopGroup). For example, NioServerSocketChannel must use NioEventLoopGroup for both boss and worker EventLoopGroup, otherwise your server won't start.
    The server won't take ownership of the given EventLoopGroup. It's caller's responsibility to shut it down when it's desired.
    Grpc uses non-daemon Threads by default and thus a Server will continue to run even after the main thread has terminated. However, users have to be cautious when providing their own EventLoopGroups. For example, Netty's EventLoopGroups use daemon threads by default and thus an application with only daemon threads running besides the main thread will exit as soon as the main thread completes. A simple solution to this problem is to call Server.awaitTermination() to keep the main thread alive until the server has terminated.
  - workerEventLoopGroup
```
public NettyServerBuilder workerEventLoopGroup(io.netty.channel.EventLoopGroup group)
```
    Provides the worker EventGroupLoop to the server.
    It's an optional parameter. If the user has not provided one when the server is built, the builder will create one.
    You must also provide corresponding Channel type using channelType(Class) and bossEventLoopGroup(EventLoopGroup). For example, NioServerSocketChannel must use NioEventLoopGroup for both boss and worker EventLoopGroup, otherwise your server won't start.
    The server won't take ownership of the given EventLoopGroup. It's caller's responsibility to shut it down when it's desired.
    Grpc uses non-daemon Threads by default and thus a Server will continue to run even after the main thread has terminated. However, users have to be cautious when providing their own EventLoopGroups. For example, Netty's EventLoopGroups use daemon threads by default and thus an application with only daemon threads running besides the main thread will exit as soon as the main thread completes. A simple solution to this problem is to call Server.awaitTermination() to keep the main thread alive until the server has terminated.
  - sslContext
```
public NettyServerBuilder sslContext(io.netty.handler.ssl.SslContext sslContext)
```
    Sets the TLS context to use for encryption. Providing a context enables encryption. It must have been configured with GrpcSslContexts, but options could have been overridden.
  - protocolNegotiator
```
@Internal
public final NettyServerBuilder protocolNegotiator(io.grpc.netty.ProtocolNegotiator protocolNegotiator)
```
    Sets the ProtocolNegotiator to be used. Overrides the value specified in sslContext(SslContext).
  - maxConcurrentCallsPerConnection
```
public NettyServerBuilder maxConcurrentCallsPerConnection(int maxCalls)
```
    The maximum number of concurrent calls permitted for each incoming connection. Defaults to no limit.
  - initialFlowControlWindow
```
public NettyServerBuilder initialFlowControlWindow(int initialFlowControlWindow)
```
    Sets the initial flow control window in bytes. Setting initial flow control window enables auto flow control tuning using bandwidth-delay product algorithm. To disable auto flow control tuning, use flowControlWindow(int). By default, auto flow control is enabled with initial flow control window size of DEFAULT_FLOW_CONTROL_WINDOW.
  - flowControlWindow
```
public NettyServerBuilder flowControlWindow(int flowControlWindow)
```
    Sets the flow control window in bytes. Setting flowControlWindow disables auto flow control tuning; use initialFlowControlWindow(int) to enable auto flow control tuning. If not called, the default value is DEFAULT_FLOW_CONTROL_WINDOW) with auto flow control tuning.
  - maxMessageSize
```
@Deprecated
public NettyServerBuilder maxMessageSize(int maxMessageSize)
```
    Deprecated. Call maxInboundMessageSize(int) instead. This method will be removed in a future release.
    
    Sets the maximum message size allowed to be received on the server. If not called, defaults to 4 MiB. The default provides protection to services who haven't considered the possibility of receiving large messages while trying to be large enough to not be hit in normal usage.
  - maxInboundMessageSize
```
public NettyServerBuilder maxInboundMessageSize(int bytes)
```
    Overrides:
    
    maxInboundMessageSize in class io.grpc.internal.AbstractServerImplBuilder<NettyServerBuilder>
  - maxHeaderListSize
```
@Deprecated
public NettyServerBuilder maxHeaderListSize(int maxHeaderListSize)
```
    Deprecated. Use maxInboundMetadataSize(int) instead
    
    Sets the maximum size of header list allowed to be received. This is cumulative size of the headers with some overhead, as defined for HTTP/2's SETTINGS_MAX_HEADER_LIST_SIZE. The default is 8 KiB.
  - maxInboundMetadataSize
```
public NettyServerBuilder maxInboundMetadataSize(int bytes)
```
    Sets the maximum size of metadata allowed to be received. This is cumulative size of the entries with some overhead, as defined for HTTP/2's SETTINGS_MAX_HEADER_LIST_SIZE. The default is 8 KiB.
    
    Overrides:
    
    maxInboundMetadataSize in class io.grpc.internal.AbstractServerImplBuilder<NettyServerBuilder>
    
    Parameters:
    
    bytes - the maximum size of received metadata
    
    Returns:
    
    this
    
    Throws:
    
    IllegalArgumentException - if bytes is non-positive
    
    Since:
    
    1.17.0
  - keepAliveTime
```
public NettyServerBuilder keepAliveTime(long keepAliveTime,
                                        TimeUnit timeUnit)
```
    Sets a custom keepalive time, the delay time for sending next keepalive ping. An unreasonably small value might be increased, and Long.MAX_VALUE nano seconds or an unreasonably large value will disable keepalive.
    
    Since:
    
    1.3.0
  - keepAliveTimeout
```
public NettyServerBuilder keepAliveTimeout(long keepAliveTimeout,
                                           TimeUnit timeUnit)
```
    Sets a custom keepalive timeout, the timeout for keepalive ping requests. An unreasonably small value might be increased.
    
    Since:
    
    1.3.0
  - maxConnectionIdle
```
public NettyServerBuilder maxConnectionIdle(long maxConnectionIdle,
                                            TimeUnit timeUnit)
```
    Sets a custom max connection idle time, connection being idle for longer than which will be gracefully terminated. Idleness duration is defined since the most recent time the number of outstanding RPCs became zero or the connection establishment. An unreasonably small value might be increased. Long.MAX_VALUE nano seconds or an unreasonably large value will disable max connection idle.
    
    Since:
    
    1.4.0
  - maxConnectionAge
```
public NettyServerBuilder maxConnectionAge(long maxConnectionAge,
                                           TimeUnit timeUnit)
```
    Sets a custom max connection age, connection lasting longer than which will be gracefully terminated. An unreasonably small value might be increased. A random jitter of +/-10% will be added to it. Long.MAX_VALUE nano seconds or an unreasonably large value will disable max connection age.
    
    Since:
    
    1.3.0
  - maxConnectionAgeGrace
```
public NettyServerBuilder maxConnectionAgeGrace(long maxConnectionAgeGrace,
                                                TimeUnit timeUnit)
```
    Sets a custom grace time for the graceful connection termination. Once the max connection age is reached, RPCs have the grace time to complete. RPCs that do not complete in time will be cancelled, allowing the connection to terminate. Long.MAX_VALUE nano seconds or an unreasonably large value are considered infinite.
    
    Since:
    
    1.3.0
    
    See Also:
    
    maxConnectionAge(long, TimeUnit)
  - permitKeepAliveTime
```
public NettyServerBuilder permitKeepAliveTime(long keepAliveTime,
                                              TimeUnit timeUnit)
```
    Specify the most aggressive keep-alive time clients are permitted to configure. The server will try to detect clients exceeding this rate and when detected will forcefully close the connection. The default is 5 minutes.
    Even though a default is defined that allows some keep-alives, clients must not use keep-alive without approval from the service owner. Otherwise, they may experience failures in the future if the service becomes more restrictive. When unthrottled, keep-alives can cause a significant amount of traffic and CPU usage, so clients and servers should be conservative in what they use and accept.
    
    Since:
    
    1.3.0
    
    See Also:
    
    permitKeepAliveWithoutCalls(boolean)
  - permitKeepAliveWithoutCalls
```
public NettyServerBuilder permitKeepAliveWithoutCalls(boolean permit)
```
    Sets whether to allow clients to send keep-alive HTTP/2 PINGs even if there are no outstanding RPCs on the connection. Defaults to false.
    
    Since:
    
    1.3.0
    
    See Also:
    
    permitKeepAliveTime(long, TimeUnit)
  - useTransportSecurity
```
public NettyServerBuilder useTransportSecurity(File certChain,
                                               File privateKey)
```
    Overrides:
    
    useTransportSecurity in class io.grpc.internal.AbstractServerImplBuilder<NettyServerBuilder>
  - useTransportSecurity
```
public NettyServerBuilder useTransportSecurity(InputStream certChain,
                                               InputStream privateKey)
```
    Overrides:
    
    useTransportSecurity in class io.grpc.internal.AbstractServerImplBuilder<NettyServerBuilder>

Class NettyServerBuilder

Field Summary

Method Summary

Methods inherited from class io.grpc.internal.AbstractServerImplBuilder

Methods inherited from class io.grpc.ServerBuilder

Methods inherited from class java.lang.Object

Field Detail

DEFAULT_FLOW_CONTROL_WINDOW

Method Detail

forPort

forPort

forAddress

forAddress

delegate

addListenAddress

channelType

channelFactory

withOption

withChildOption

bossEventLoopGroup

workerEventLoopGroup

sslContext

protocolNegotiator

maxConcurrentCallsPerConnection

initialFlowControlWindow

flowControlWindow

maxMessageSize

maxInboundMessageSize

maxHeaderListSize

maxInboundMetadataSize

keepAliveTime

keepAliveTimeout

maxConnectionIdle

maxConnectionAge

maxConnectionAgeGrace

permitKeepAliveTime

permitKeepAliveWithoutCalls

useTransportSecurity

useTransportSecurity