类的使用
org.redkale.net.AsyncConnection

使用AsyncConnection的程序包

程序包	说明
org.redkale.net	网络TCP/UDP基础服务包
org.redkale.net.client	客户端网络包
org.redkale.net.http	HTTP协议包,提供HTTP协议服务器
org.redkale.net.sncp	SNCP协议包,提供SNCP协议服务器

org.redkale.net中AsyncConnection的使用

声明为AsyncConnection的org.redkale.net中的字段

修饰符和类型	字段	说明
protected AsyncConnection	Request.channel
protected AsyncConnection	Response.channel

类型参数类型为AsyncConnection的org.redkale.net中的字段

修饰符和类型	字段	说明
protected BlockingQueue<AsyncConnection>	Transport.TransportNode.connQueue
protected ArrayBlockingQueue<CompletableFuture<AsyncConnection>>	Transport.TransportNode.pollQueue

返回AsyncConnection的org.redkale.net中的方法

修饰符和类型	方法	说明
AsyncConnection	AsyncConnection.beforeCloseListener(Consumer<AsyncConnection> beforeCloseListener)
AsyncConnection	AsyncIOGroup.newTCPClientConnection()
AsyncConnection	AsyncIOGroup.newUDPClientConnection()
protected AsyncConnection	Response.removeChannel()

返回变量类型为AsyncConnection的类型的org.redkale.net中的方法

修饰符和类型	方法	说明
CompletableFuture<AsyncConnection>	AsyncGroup.createClientConnection(boolean tcp, int ioIndex, SocketAddress address)
CompletableFuture<AsyncConnection>	AsyncGroup.createClientConnection(boolean tcp, int ioIndex, SocketAddress address, int connectTimeoutSeconds)
CompletableFuture<AsyncConnection>	AsyncGroup.createTCPClientConnection(int ioIndex, SocketAddress address)
abstract CompletableFuture<AsyncConnection>	AsyncGroup.createTCPClientConnection(int ioIndex, SocketAddress address, int connectTimeoutSeconds)	创建TCP连接
CompletableFuture<AsyncConnection>	AsyncGroup.createTCPClientConnection(SocketAddress address)
CompletableFuture<AsyncConnection>	AsyncGroup.createTCPClientConnection(SocketAddress address, int connectTimeoutSeconds)
CompletableFuture<AsyncConnection>	AsyncIOGroup.createTCPClientConnection(int ioIndex, SocketAddress address, int connectTimeoutSeconds)
CompletableFuture<AsyncConnection>	AsyncGroup.createUDPClientConnection(int ioIndex, SocketAddress address)
abstract CompletableFuture<AsyncConnection>	AsyncGroup.createUDPClientConnection(int ioIndex, SocketAddress address, int connectTimeoutSeconds)	创建UDP连接
CompletableFuture<AsyncConnection>	AsyncGroup.createUDPClientConnection(SocketAddress address)
CompletableFuture<AsyncConnection>	AsyncGroup.createUDPClientConnection(SocketAddress address, int connectTimeoutSeconds)
CompletableFuture<AsyncConnection>	AsyncIOGroup.createUDPClientConnection(int ioIndex, SocketAddress address, int connectTimeoutSeconds)
BlockingQueue<AsyncConnection>	Transport.TransportNode.getConnQueue()
protected CompletableFuture<AsyncConnection>	Transport.pollAsync(Transport.TransportNode node, SocketAddress addr, Supplier<CompletableFuture<AsyncConnection>> func)	已过时。
CompletableFuture<AsyncConnection>	Transport.pollConnection(SocketAddress addr0)	已过时。
CompletableFuture<AsyncConnection>	TransportStrategy.pollConnection(SocketAddress addr, Transport transport)	已过时。 创建AsyncConnection

参数类型为AsyncConnection的org.redkale.net中的方法

修饰符和类型	方法	说明
protected void	Response.init(AsyncConnection channel)
void	Transport.offerConnection(boolean forceClose, AsyncConnection conn)	已过时。
default boolean	TransportStrategy.offerConnection(boolean forceClose, AsyncConnection conn)	已过时。 回收AsyncConnection，返回false表示使用Transport默认的回收实现， 返回true表示自定义回收实现
protected void	Context.updateReadIOThread(AsyncConnection conn, AsyncIOThread ioReadThread)
protected void	Context.updateWriteIOThread(AsyncConnection conn, AsyncIOThread ioWriteThread)

类型变量类型为AsyncConnection的org.redkale.net中的方法参数

修饰符和类型	方法	说明
AsyncConnection	AsyncConnection.beforeCloseListener(Consumer<AsyncConnection> beforeCloseListener)
protected CompletableFuture<AsyncConnection>	Transport.pollAsync(Transport.TransportNode node, SocketAddress addr, Supplier<CompletableFuture<AsyncConnection>> func)	已过时。

org.redkale.net.client中AsyncConnection的使用

声明为AsyncConnection的org.redkale.net.client中的字段

修饰符和类型	字段	说明
protected AsyncConnection	ClientConnection.channel

返回AsyncConnection的org.redkale.net.client中的方法

修饰符和类型	方法	说明
AsyncConnection	ClientConnection.getChannel()

参数类型为AsyncConnection的org.redkale.net.client中的方法

修饰符和类型	方法	说明
void	ClientConnection.accept(AsyncConnection t)
protected abstract C	Client.createClientConnection(AsyncConnection channel)

参数类型为AsyncConnection的org.redkale.net.client中的构造器

构造器	说明
ClientConnection(Client<? extends ClientConnection<R,P>,R,P> client, AsyncConnection channel)

org.redkale.net.http中AsyncConnection的使用

返回AsyncConnection的org.redkale.net.http中的方法

修饰符和类型	方法	说明
protected AsyncConnection	HttpResponse.getChannel()
protected AsyncConnection	HttpResponse.removeChannel()

参数类型为AsyncConnection的org.redkale.net.http中的方法

修饰符和类型	方法	说明
protected org.redkale.net.http.WebConnection	WebClient.createClientConnection(AsyncConnection channel)
protected void	HttpResponse.init(AsyncConnection channel)
protected void	HttpContext.updateReadIOThread(AsyncConnection conn, AsyncIOThread ioReadThread)
protected void	HttpContext.updateWriteIOThread(AsyncConnection conn, AsyncIOThread ioWriteThread)

org.redkale.net.sncp中AsyncConnection的使用

参数类型为AsyncConnection的org.redkale.net.sncp中的方法

修饰符和类型	方法	说明
SncpClientConnection	SncpClient.createClientConnection(AsyncConnection channel)

参数类型为AsyncConnection的org.redkale.net.sncp中的构造器

构造器	说明
SncpClientConnection(SncpClient client, AsyncConnection channel)