模块 org.redkale

程序包 org.redkale.net.sncp

类 SncpClient

java.lang.Object

org.redkale.net.client.Client<SncpClientConnection,SncpClientRequest,SncpClientResult>

org.redkale.net.sncp.SncpClient

所有已实现的接口:

Resourcable

public class SncpClient
extends Client<SncpClientConnection,SncpClientRequest,SncpClientResult>

SNCP版Client, 一个SncpServer只能对应一个SncpClient

详情见: https://redkale.org

从以下版本开始:

2.8.0

作者:

zhangjx

嵌套类概要

从类继承的嵌套类/接口 org.redkale.net.client.Client

Client.AddressConnEntry<C>

字段概要

从类继承的字段 org.redkale.net.client.Client

authenticate, closeRequestSupplier, connectTimeoutSeconds, debug, DEFAULT_MAX_PIPELINES, group, logger, maxPipelines, name, nonBlocking, pingRequestSupplier, random, readTimeoutSeconds, reqWritedCounter, respDoneCounter, tcp, timeoutFuture, timeoutScheduler, writeTimeoutSeconds

构造器概要

构造器

构造器	说明
SncpClient(String name, AsyncGroup group, String nodeid, InetSocketAddress clientSncpAddress, ClientAddress address, String netprotocol, int maxConns, int maxPipelines)

方法概要

修饰符和类型	方法	说明
SncpClientConnection	createClientConnection(AsyncConnection channel)
InetSocketAddress	getClientSncpAddress()
String	getNodeid()
protected long	nextSeqno()
protected CompletableFuture<SncpClientResult>	writeChannel(ClientConnection conn, SncpClientRequest request)

从类继承的方法 org.redkale.net.client.Client

close, connect, connect, connect, connect, createClientFuture, createVirtualRequestAfterConnect, getAddress, getMaxConns, getName, getReadTimeoutSeconds, getWriteTimeoutSeconds, handlePingResult, incrReqWritedCounter, incrRespDoneCounter, newConnection, newConnection, pingIntervalSeconds, resourceName, sendAsync, sendAsync, sendAsync, sendAsync, setReadTimeoutSeconds, setWriteTimeoutSeconds, updateClientAddress, writeChannel, writeChannel, writeChannel

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

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

构造器详细资料

SncpClient

public SncpClient(String name,
                  AsyncGroup group,
                  String nodeid,
                  InetSocketAddress clientSncpAddress,
                  ClientAddress address,
                  String netprotocol,
                  int maxConns,
                  int maxPipelines)

方法详细资料

createClientConnection

public SncpClientConnection createClientConnection(AsyncConnection channel)

指定者:

createClientConnection 在类中 Client<SncpClientConnection,SncpClientRequest,SncpClientResult>

getClientSncpAddress

public InetSocketAddress getClientSncpAddress()

getNodeid

public String getNodeid()

nextSeqno

protected long nextSeqno()

writeChannel

protected CompletableFuture<SncpClientResult> writeChannel(ClientConnection conn,
                                                           SncpClientRequest request)

覆盖:

writeChannel 在类中 Client<SncpClientConnection,SncpClientRequest,SncpClientResult>