com.fr.third.jgroups.protocols.pbcast

类 STATE_SOCK

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.pbcast.StreamingStateTransfer

com.fr.third.jgroups.protocols.pbcast.STATE_SOCK

所有已实现的接口:

ProcessingQueue.Handler<Address>

public class STATE_SOCK
extends StreamingStateTransfer

STATE_SOCK has the state provider create a server socket to which the state requester connects and from which the latter reads the state.

When implementing MessageListener.getState(java.io.OutputStream), the state should be written in sizeable chunks, because the underlying output stream sends 1 message / write over the socket. So if there are 1000 writes of 1 byte each, this would generate 1000 messages ! We suggest using a BufferedOutputStream over the output stream handed to the application as argument of the callback.

When implementing the MessageListener.setState(java.io.InputStream) callback, there is no need to use a BufferedOutputStream, as the input stream handed to the application already buffers incoming data internally.

从以下版本开始:

3.0

作者:

Vladimir Blagojevic, Bela Ban

另请参阅:

STATE_TRANSFER

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	STATE_SOCK.StateProviderAcceptor

从类继承的嵌套类/接口 com.fr.third.jgroups.protocols.pbcast.StreamingStateTransfer

StreamingStateTransfer.StateGetter, StreamingStateTransfer.StateHeader

字段概要

字段

限定符和类型	字段和说明
protected java.net.InetAddress	bind_addr
protected java.lang.String	bind_interface_str
protected int	bind_port
protected java.net.InetAddress	external_addr
protected int	external_port
protected STATE_SOCK.StateProviderAcceptor	spawner Runnable that listens for state requests and spawns threads to serve those requests if socket transport is used

从类继承的字段 com.fr.third.jgroups.protocols.pbcast.StreamingStateTransfer

avg_state_size, buffer_size, flushProtocolInStack, local_addr, max_pool, members, num_bytes_sent, num_state_reqs, pool_thread_keep_alive, state_provider, state_requesters, thread_pool

从类继承的字段 com.fr.third.jgroups.stack.Protocol

down_prot, ergonomics, id, log, name, stack, stats, up_prot

构造器概要

构造器

构造器和说明
STATE_SOCK()

方法概要

方法

限定符和类型	方法和说明
protected void	close(java.lang.Object resource)
protected STATE_SOCK.StateProviderAcceptor	createAcceptor()
protected Tuple<java.io.InputStream,java.lang.Object>	createStreamToProvider(Address provider, StreamingStateTransfer.StateHeader hdr) Creates an InputStream to the state provider to read the state.
protected void	handleConfig(java.util.Map<java.lang.String,java.lang.Object> config)
protected void	handleStateReq(Address requester)
protected void	handleViewChange(View v)
protected void	modifyStateResponseHeader(StreamingStateTransfer.StateHeader hdr)
void	stop() This method is called on a Channel.disconnect().

从类继承的方法 com.fr.third.jgroups.protocols.pbcast.StreamingStateTransfer

closeBarrierAndSuspendStable, closeHoleFor, createStreamToRequester, createThreadPool, destroy, determineCoordinator, down, getAverageStateSize, getNumberOfStateBytesSent, getNumberOfStateRequests, getStateFromApplication, getThreadPoolCompletedTasks, getThreadPoolSize, handle, handleEOF, handleException, handleStateChunk, handleStateRsp, init, isDigestNeeded, openBarrier, openBarrierAndResumeStable, punchHoleFor, requiredDownServices, resetStats, resumeStable, sendEof, sendException, setStateInApplication, start, up, useAsyncStateDelivery

从类继承的方法 com.fr.third.jgroups.stack.Protocol

accept, dumpStats, enableStats, getConfigurableObjects, getDownProtocol, getDownServices, getId, getIdsAbove, getLevel, getName, getProtocolStack, getSocketFactory, getThreadFactory, getTransport, getUpProtocol, getUpServices, getValue, isErgonomics, level, parse, printStats, providedDownServices, providedUpServices, requiredUpServices, resetStatistics, setDownProtocol, setErgonomics, setId, setLevel, setProtocolStack, setSocketFactory, setUpProtocol, setValue, setValues, statsEnabled, up

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

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

字段详细资料

bind_addr

protected java.net.InetAddress bind_addr

external_addr

protected java.net.InetAddress external_addr

external_port

protected int external_port

bind_interface_str

protected java.lang.String bind_interface_str

bind_port

protected int bind_port

spawner

protected volatile STATE_SOCK.StateProviderAcceptor spawner

Runnable that listens for state requests and spawns threads to serve those requests if socket transport is used

构造器详细资料

STATE_SOCK

public STATE_SOCK()

方法详细资料

stop

public void stop()

从类复制的说明: Protocol

This method is called on a Channel.disconnect(). Stops work (e.g. by closing multicast socket). Will be called from top to bottom. This means that at the time of the method invocation the neighbor protocol below is still working. This method will replace the STOP, STOP_OK, CLEANUP and CLEANUP_OK events. The ProtocolStack guarantees that when this method is called all messages in the down queue will have been flushed

覆盖:

stop 在类中 StreamingStateTransfer

createAcceptor

protected STATE_SOCK.StateProviderAcceptor createAcceptor()

modifyStateResponseHeader

protected void modifyStateResponseHeader(StreamingStateTransfer.StateHeader hdr)

覆盖:

modifyStateResponseHeader 在类中 StreamingStateTransfer

createStreamToProvider

protected Tuple<java.io.InputStream,java.lang.Object> createStreamToProvider(Address provider,
                                                                 StreamingStateTransfer.StateHeader hdr)
                                                                      throws java.lang.Exception

从类复制的说明: StreamingStateTransfer

Creates an InputStream to the state provider to read the state. Return the input stream and a handback object as a tuple. The handback object is handed back to the subclass when done, or in case of an error (e.g. to clean up resources)

指定者:

createStreamToProvider 在类中 StreamingStateTransfer

抛出:

java.lang.Exception

close

protected void close(java.lang.Object resource)

覆盖:

close 在类中 StreamingStateTransfer

handleStateReq

protected void handleStateReq(Address requester)

覆盖:

handleStateReq 在类中 StreamingStateTransfer

handleViewChange

protected void handleViewChange(View v)

覆盖:

handleViewChange 在类中 StreamingStateTransfer

handleConfig

protected void handleConfig(java.util.Map<java.lang.String,java.lang.Object> config)

覆盖:

handleConfig 在类中 StreamingStateTransfer