@UnstableApi public class DefaultHttp2Connection extends java.lang.Object implements Http2Connection
Http2Connection
。
Http2Connection.Endpoint<F extends Http2FlowController>, Http2Connection.Listener, Http2Connection.PropertyKey
Constructor and Description |
---|
DefaultHttp2Connection(boolean server)
用给定的设置创建一个新的连接。
|
DefaultHttp2Connection(boolean server, int maxReservedStreams)
用给定的设置创建一个新的连接。
|
Modifier and Type | Method and Description |
---|---|
void |
addListener(Http2Connection.Listener listener)
添加流生命周期事件的侦听器。
|
Future<java.lang.Void> |
close(Promise<java.lang.Void> promise)
关闭此连接。
|
Http2Stream |
connectionStream()
获取表示连接本身的流对象(即流零)。
|
Http2Stream |
forEachActiveStream(Http2StreamVisitor visitor)
提供一种迭代活动流集合的方法。
|
boolean |
goAwayReceived()
指示是否从远程端点接收到
GOAWAY 。
|
void |
goAwayReceived(int lastKnownStream, long errorCode, ByteBuf debugData)
表示从远程端点接收到
GOAWAY 并设置最后一个已知流。
|
boolean |
goAwaySent()
指示是否将
GOAWAY 发送到远程端点。
|
void |
goAwaySent(int lastKnownStream, long errorCode, ByteBuf debugData)
表示
GOAWAY 已发送到远程端点并设置最后一个已知流。
|
boolean |
isServer()
指示此连接的本地端点是否为服务器。
|
Http2Connection.Endpoint<Http2LocalFlowController> |
local()
从当地 Http2Connection.Endpoint 获取此连接的视图。
|
Http2Connection.PropertyKey |
newKey()
创建一个在此 Http2Connection 内唯一的新密钥。
|
int |
numActiveStreams()
获取正在使用的流的数量(即
|
Http2Connection.Endpoint<Http2RemoteFlowController> |
remote()
从远程 Http2Connection.Endpoint 获取此连接的视图。
|
void |
removeListener(Http2Connection.Listener listener)
删除流生命周期事件的监听器。
|
Http2Stream |
stream(int streamId)
获取流如果存在。
|
boolean |
streamMayHaveExisted(int streamId)
指示给定流是否可能存在于此连接中。
|
public DefaultHttp2Connection(boolean server)
server
- 该端点是否是HTTP / 2连接的服务器端。
public DefaultHttp2Connection(boolean server, int maxReservedStreams)
server
- 此端点是否是HTTP / 2连接的服务器端。
maxReservedStreams
- 每个端点在保留状态下可以存在的最大流量。
public Future<java.lang.Void> close(Promise<java.lang.Void> promise)
Http2Connection
请注意,如果通过Http2Connection.forEachActiveStream(Http2StreamVisitor)
迭代活动流并抛出异常,则需要再次调用此方法以确保关闭完成。
close
,界面
Http2Connection
promise
- 将在所有流都被删除并且收到通知时完成。
public void addListener(Http2Connection.Listener listener)
Http2Connection
addListener
接口
Http2Connection
public void removeListener(Http2Connection.Listener listener)
Http2Connection
removeListener
,界面
Http2Connection
public boolean isServer()
Http2Connection
isServer
在界面
Http2Connection
public Http2Stream connectionStream()
Http2Connection
connectionStream
在界面
Http2Connection
public Http2Stream stream(int streamId)
Http2Connection
null
。
stream
,界面
Http2Connection
public boolean streamMayHaveExisted(int streamId)
Http2Connection
Http2Connection.Endpoint.mayHaveCreatedStream(int)
的简短形式。
streamMayHaveExisted
在界面
Http2Connection
public int numActiveStreams()
Http2Connection
OPEN
或
HALF CLOSED
)。
numActiveStreams
接口
Http2Connection
public Http2Stream forEachActiveStream(Http2StreamVisitor visitor) throws Http2Exception
Http2Connection
forEachActiveStream
,界面
Http2Connection
visitor
- 将访问每个活动流的访问者。
null
。
Http2Exception
public Http2Connection.Endpoint<Http2LocalFlowController> local()
Http2Connection
Http2Connection.Endpoint
获取此连接的视图。
local
在界面
Http2Connection
public Http2Connection.Endpoint<Http2RemoteFlowController> remote()
Http2Connection
Http2Connection.Endpoint
获取此连接的视图。
remote
在界面
Http2Connection
public boolean goAwayReceived()
Http2Connection
GOAWAY
。
goAwayReceived
接口
Http2Connection
public void goAwayReceived(int lastKnownStream, long errorCode, ByteBuf debugData)
Http2Connection
GOAWAY
并设置最后一个已知流。
goAwayReceived
在界面
Http2Connection
public boolean goAwaySent()
Http2Connection
GOAWAY
发送到远程端点。
goAwaySent
,界面
Http2Connection
public void goAwaySent(int lastKnownStream, long errorCode, ByteBuf debugData)
Http2Connection
GOAWAY
发送到远程端点并设置最后一个已知流。
goAwaySent
在界面
Http2Connection
public Http2Connection.PropertyKey newKey()
Http2Connection
Http2Connection
内唯一的新密钥。
newKey
在界面
Http2Connection
Copyright © 2008–2018 The Netty Project. All rights reserved.