Package org.apache.hadoop.hbase.ipc

Class NettyRpcClient

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractRpcClient<NettyRpcConnection>

org.apache.hadoop.hbase.ipc.NettyRpcClient

All Implemented Interfaces:

Closeable, AutoCloseable, RpcClient

@LimitedPrivate("Configuration")
public class NettyRpcClient
extends AbstractRpcClient<NettyRpcConnection>

Netty client for the requests and responses.

Since:

2.0.0

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.ipc.AbstractRpcClient

AbstractRpcClient.BlockingRpcChannelImplementation, AbstractRpcClient.RpcChannelImplementation

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>	channelClass
(package private) final org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup	group
private final AtomicReference<FileChangeWatcher>	keyStoreWatcher
private final boolean	shutdownGroupWhenClose
private final AtomicReference<org.apache.hbase.thirdparty.io.netty.handler.ssl.SslContext>	sslContextForClient
private final AtomicReference<FileChangeWatcher>	trustStoreWatcher

Fields inherited from class org.apache.hadoop.hbase.ipc.AbstractRpcClient

cellBlockBuilder, clusterId, codec, compressor, conf, connectionAttributes, connectTO, failedServers, failureSleep, fallbackAllowed, localAddr, LOG, maxRetries, metrics, minIdleTimeBeforeClose, readTO, tcpKeepAlive, tcpNoDelay, userProvider, WHEEL_TIMER, writeTO

Fields inherited from interface org.apache.hadoop.hbase.ipc.RpcClient

DEFAULT_CODEC_CLASS, DEFAULT_SOCKET_TIMEOUT_CONNECT, DEFAULT_SOCKET_TIMEOUT_READ, DEFAULT_SOCKET_TIMEOUT_WRITE, FAILED_SERVER_EXPIRY_DEFAULT, FAILED_SERVER_EXPIRY_KEY, IDLE_TIME, IPC_CLIENT_FALLBACK_TO_SIMPLE_AUTH_ALLOWED_DEFAULT, IPC_CLIENT_FALLBACK_TO_SIMPLE_AUTH_ALLOWED_KEY, PING_CALL_ID, REGISTRY_PREAMBLE_HEADER, SECURITY_PREAMBLE_HEADER, SOCKET_TIMEOUT_CONNECT, SOCKET_TIMEOUT_READ, SOCKET_TIMEOUT_WRITE, SPECIFIC_WRITE_THREAD

Constructor Summary

Constructors

Constructor	Description
NettyRpcClient(org.apache.hadoop.conf.Configuration configuration)	Used in test only.
NettyRpcClient(org.apache.hadoop.conf.Configuration configuration, String clusterId, SocketAddress localAddress, MetricsConnection metrics)
NettyRpcClient(org.apache.hadoop.conf.Configuration configuration, String clusterId, SocketAddress localAddress, MetricsConnection metrics, Map<String,byte[]> connectionAttributes)

Method Summary

Modifier and Type	Method	Description
protected void	closeInternal()
protected NettyRpcConnection	createConnection(ConnectionId remoteId)	Not connected.
(package private) org.apache.hbase.thirdparty.io.netty.handler.ssl.SslContext	getSslContext()

Methods inherited from class org.apache.hadoop.hbase.ipc.AbstractRpcClient

cancelConnections, close, configureHBaseRpcController, createAddr, createBlockingRpcChannel, createRpcChannel, getCodec, getConnections, getDefaultCodec, hasCellBlockSupport, isTcpNoDelay

Methods inherited from class java.lang.Object

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

Field Details

group

final org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup group

channelClass

final Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> channelClass

shutdownGroupWhenClose

private final boolean shutdownGroupWhenClose

sslContextForClient

private final AtomicReference<org.apache.hbase.thirdparty.io.netty.handler.ssl.SslContext> sslContextForClient

keyStoreWatcher

private final AtomicReference<FileChangeWatcher> keyStoreWatcher

trustStoreWatcher

private final AtomicReference<FileChangeWatcher> trustStoreWatcher

Constructor Details

NettyRpcClient

public NettyRpcClient(org.apache.hadoop.conf.Configuration configuration,
 String clusterId,
 SocketAddress localAddress,
 MetricsConnection metrics)

NettyRpcClient

public NettyRpcClient(org.apache.hadoop.conf.Configuration configuration,
 String clusterId,
 SocketAddress localAddress,
 MetricsConnection metrics,
 Map<String,byte[]> connectionAttributes)

NettyRpcClient

public NettyRpcClient(org.apache.hadoop.conf.Configuration configuration)

Used in test only.

Method Details

createConnection

protected NettyRpcConnection createConnection(ConnectionId remoteId)
                                       throws IOException

Description copied from class: AbstractRpcClient

Not connected.

Specified by:

createConnection in class AbstractRpcClient<NettyRpcConnection>

Throws:

IOException

closeInternal

protected void closeInternal()

Specified by:

closeInternal in class AbstractRpcClient<NettyRpcConnection>

getSslContext

org.apache.hbase.thirdparty.io.netty.handler.ssl.SslContext getSslContext()
                                                                   throws X509Exception,
IOException

Throws:

X509Exception

IOException