io.netty.handler.codec.http2

接口 Http2Connection

所有已知实现类:

DefaultHttp2Connection

@UnstableApi
public interface Http2Connection

Manager for the state of an HTTP/2 connection with the remote end-point.

嵌套类概要

嵌套类

限定符和类型	接口和说明
static interface	Http2Connection.Endpoint<F extends Http2FlowController> A view of the connection from one endpoint (local or remote).
static interface	Http2Connection.Listener Listener for life-cycle events for streams in this connection.
static interface	Http2Connection.PropertyKey A key to be used for associating application-defined properties with streams within this connection.

方法概要

限定符和类型	方法和说明
void	addListener(Http2Connection.Listener listener) Adds a listener of stream life-cycle events.
Future<java.lang.Void>	close(Promise<java.lang.Void> promise) Close this connection.
Http2Stream	connectionStream() Gets the stream object representing the connection, itself (i.e. stream zero).
Http2Stream	forEachActiveStream(Http2StreamVisitor visitor) Provide a means of iterating over the collection of active streams.
boolean	goAwayReceived() Indicates whether or not a GOAWAY was received from the remote endpoint.
void	goAwayReceived(int lastKnownStream, long errorCode, ByteBuf message) Indicates that a GOAWAY was received from the remote endpoint and sets the last known stream.
boolean	goAwaySent() Indicates whether or not a GOAWAY was sent to the remote endpoint.
boolean	goAwaySent(int lastKnownStream, long errorCode, ByteBuf message) Updates the local state of this Http2Connection as a result of a GOAWAY to send to the remote endpoint.
boolean	isServer() Indicates whether or not the local endpoint for this connection is the server.
Http2Connection.Endpoint<Http2LocalFlowController>	local() Gets a view of this connection from the local Http2Connection.Endpoint.
Http2Connection.PropertyKey	newKey() Creates a new key that is unique within this Http2Connection.
int	numActiveStreams() Gets the number of streams that are actively in use (i.e.
Http2Connection.Endpoint<Http2RemoteFlowController>	remote() Gets a view of this connection from the remote Http2Connection.Endpoint.
void	removeListener(Http2Connection.Listener listener) Removes a listener of stream life-cycle events.
Http2Stream	stream(int streamId) Gets the stream if it exists.
boolean	streamMayHaveExisted(int streamId) Indicates whether or not the given stream may have existed within this connection.

方法详细资料

close

Future<java.lang.Void> close(Promise<java.lang.Void> promise)

Close this connection. No more new streams can be created after this point and all streams that exists (active or otherwise) will be closed and removed.

Note if iterating active streams via forEachActiveStream(Http2StreamVisitor) and an exception is thrown it is necessary to call this method again to ensure the close completes.

参数:

promise - Will be completed when all streams have been removed, and listeners have been notified.

返回:

A future that will be completed when all streams have been removed, and listeners have been notified.

newKey

Http2Connection.PropertyKey newKey()

Creates a new key that is unique within this Http2Connection.

addListener

void addListener(Http2Connection.Listener listener)

Adds a listener of stream life-cycle events.

removeListener

void removeListener(Http2Connection.Listener listener)

Removes a listener of stream life-cycle events. If the same listener was added multiple times then only the first occurrence gets removed.

stream

Http2Stream stream(int streamId)

Gets the stream if it exists. If not, returns null.

streamMayHaveExisted

boolean streamMayHaveExisted(int streamId)

Indicates whether or not the given stream may have existed within this connection. This is a short form for calling Http2Connection.Endpoint.mayHaveCreatedStream(int) on both endpoints.

connectionStream

Http2Stream connectionStream()

Gets the stream object representing the connection, itself (i.e. stream zero). This object always exists.

numActiveStreams

int numActiveStreams()

Gets the number of streams that are actively in use (i.e. OPEN or HALF CLOSED).

forEachActiveStream

Http2Stream forEachActiveStream(Http2StreamVisitor visitor)
                         throws Http2Exception

Provide a means of iterating over the collection of active streams.

参数:

visitor - The visitor which will visit each active stream.

返回:

The stream before iteration stopped or null if iteration went past the end.

抛出:

Http2Exception

isServer

boolean isServer()

Indicates whether or not the local endpoint for this connection is the server.

local

Http2Connection.Endpoint<Http2LocalFlowController> local()

Gets a view of this connection from the local Http2Connection.Endpoint.

remote

Http2Connection.Endpoint<Http2RemoteFlowController> remote()

Gets a view of this connection from the remote Http2Connection.Endpoint.

goAwayReceived

boolean goAwayReceived()

Indicates whether or not a GOAWAY was received from the remote endpoint.

goAwayReceived

void goAwayReceived(int lastKnownStream,
                    long errorCode,
                    ByteBuf message)
             throws Http2Exception

Indicates that a GOAWAY was received from the remote endpoint and sets the last known stream.

参数:

lastKnownStream - The Last-Stream-ID in the GOAWAY frame.

errorCode - the Error Code in the GOAWAY frame.

message - The Additional Debug Data in the GOAWAY frame. Note that reference count ownership belongs to the caller (ownership is not transferred to this method).

抛出:

Http2Exception

goAwaySent

boolean goAwaySent()

Indicates whether or not a GOAWAY was sent to the remote endpoint.

goAwaySent

boolean goAwaySent(int lastKnownStream,
                   long errorCode,
                   ByteBuf message)
            throws Http2Exception

Updates the local state of this Http2Connection as a result of a GOAWAY to send to the remote endpoint.

参数:

lastKnownStream - The Last-Stream-ID in the GOAWAY frame.

errorCode - the Error Code in the GOAWAY frame. GOAWAY frame. Note that reference count ownership belongs to the caller (ownership is not transferred to this method).

返回:

true if the corresponding GOAWAY frame should be sent to the remote endpoint.

抛出:

Http2Exception