org.zodiac.server.proxy.impl

类 ConnectionFlow

java.lang.Object

org.zodiac.server.proxy.impl.ConnectionFlow

class ConnectionFlow
extends Object

Coordinates the various steps involved in establishing a connection, such as establishing a socket connection, SSL handshaking, HTTP CONNECT request processing, and so on.

字段概要

字段

限定符和类型	字段和说明
private ClientToProxyConnection	clientConnection
private Object	connectLock
private ConnectionFlowStep	currentStep
private ProxyToServerConnection	serverConnection
private Queue<ConnectionFlowStep>	steps
private boolean	suppressInitialRequest

构造器概要

构造器

构造器和说明
ConnectionFlow(ClientToProxyConnection clientConnection, ProxyToServerConnection serverConnection, Object connectLock) Construct a new ConnectionFlow for the given client and server connections.

方法概要

限定符和类型	方法和说明
(专用程序包) void	advance() Advances the flow.
private void	doProcessCurrentStep(ProxyConnectionLogger logger) Does the work of processing the current step, checking the result and handling success/failure.
(专用程序包) void	fail() Like fail(Throwable) but with no cause.
(专用程序包) void	fail(Throwable cause) Called when the flow fails at some ConnectionFlowStep.
private void	notifyThreadsWaitingForConnection() Once we've finished recording our connection and written our initial request, we can notify anyone who is waiting on the connection that it's okay to proceed.
private void	processCurrentStep() Process the current ConnectionFlowStep.
(专用程序包) void	read(Object msg) While we're in the process of connecting, any messages read by the ProxyToServerConnection are passed to this method, which passes it on to ConnectionFlowStep.read(ConnectionFlow, Object) for the current ConnectionFlowStep.
(专用程序包) void	start() Starts the connection flow, notifying the ClientToProxyConnection that we've started.
(专用程序包) void	succeed() Called when the flow is complete and successful.
(专用程序包) ConnectionFlow	then(ConnectionFlowStep step) Add a ConnectionFlowStep to this flow.

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

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

字段详细资料

steps

private Queue<ConnectionFlowStep> steps

clientConnection

private final ClientToProxyConnection clientConnection

serverConnection

private final ProxyToServerConnection serverConnection

currentStep

private volatile ConnectionFlowStep currentStep

suppressInitialRequest

private volatile boolean suppressInitialRequest

connectLock

private final Object connectLock

构造器详细资料

ConnectionFlow

ConnectionFlow(ClientToProxyConnection clientConnection,
               ProxyToServerConnection serverConnection,
               Object connectLock)

Construct a new ConnectionFlow for the given client and server connections.

参数:

clientConnection - client connection

serverConnection - server connection

connectLock - an object that's shared by ConnectionFlow and ProxyToServerConnection and that is used for synchronizing the reader and writer threads that are both involved during the establishing of a connection.

方法详细资料

then

ConnectionFlow then(ConnectionFlowStep step)

Add a ConnectionFlowStep to this flow.

参数:

step - step

返回:

self

read

void read(Object msg)

While we're in the process of connecting, any messages read by the ProxyToServerConnection are passed to this method, which passes it on to ConnectionFlowStep.read(ConnectionFlow, Object) for the current ConnectionFlowStep.

参数:

msg - message

start

void start()

Starts the connection flow, notifying the ClientToProxyConnection that we've started.

advance

void advance()

Advances the flow. advance() will be called until we're either out of steps, or a step has failed.

processCurrentStep

private void processCurrentStep()

Process the current ConnectionFlowStep. With each step, we:

1. Change the state of the associated ProxyConnection to the value of ConnectionFlowStep.getState()
2. Call ConnectionFlowStep.execute()
3. On completion of the Future returned by ConnectionFlowStep.execute(), check the success.
4. If successful, we call back into ConnectionFlowStep.onSuccess(ConnectionFlow).
5. If unsuccessful, we call fail(), stopping the connection flow

doProcessCurrentStep

private void doProcessCurrentStep(ProxyConnectionLogger logger)

Does the work of processing the current step, checking the result and handling success/failure.

参数:

logger - 日志对象

succeed

void succeed()

Called when the flow is complete and successful. Notifies the ProxyToServerConnection that we succeeded.

fail

void fail(Throwable cause)

Called when the flow fails at some ConnectionFlowStep. Disconnects the ProxyToServerConnection and informs the ClientToProxyConnection that our connection failed.

参数:

cause - error

fail

void fail()

Like fail(Throwable) but with no cause.

notifyThreadsWaitingForConnection

private void notifyThreadsWaitingForConnection()

Once we've finished recording our connection and written our initial request, we can notify anyone who is waiting on the connection that it's okay to proceed.