com.fr.third.jgroups.protocols

类 TCPGOSSIP

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.Discovery

com.fr.third.jgroups.protocols.TCPGOSSIP

public class TCPGOSSIP
extends Discovery

The TCPGOSSIP protocol layer retrieves the initial membership (used by the GMS when started by sending event FIND_INITIAL_MBRS down the stack). We do this by contacting one or more GossipRouters, which must be running at well-known addresses:ports. The responses should allow us to determine the coordinator whom we have to contact, e.g. in case we want to join the group. When we are a server (after having received the BECOME_SERVER event), we'll respond to TCPGOSSIP requests with a TCPGOSSIP response.

The FIND_INITIAL_MBRS event will eventually be answered with a FIND_INITIAL_MBRS_OK event up the stack.

作者:

Bela Ban

字段概要

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

always_send_physical_addr_with_discovery_request, async_discovery, break_on_coord_rsp, cluster_name, current_coord, discovery_rsp_expiry_time, force_sending_discovery_rsps, is_coord, is_leaving, is_server, local_addr, max_members_in_discovery_request, members, num_discovery_requests, num_initial_members, num_initial_srv_members, ping_responses, return_entire_cache, stagger_timeout, timeout, timer, transport_supports_multicasting, use_disk_cache, view, WHITESPACE

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

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

构造器概要

构造器

构造器和说明
TCPGOSSIP()

方法概要

方法

限定符和类型	方法和说明
void	addInitialHost(java.lang.String hostname, int port)
protected void	connect(RouterStub stub, java.lang.String group, Address logical_addr)
protected void	connectAllStubs(java.lang.String group, Address logical_addr)
void	destroy() This method is called on a Channel.close().
void	findMembers(java.util.List<Address> members, boolean initial_discovery, Responses responses) Fetches information (e.g. physical address, logical name) for the given member addresses.
java.util.List<java.net.InetSocketAddress>	getInitialHosts()
void	handleConnect()
void	handleDisconnect()
void	init() Called after instance has been created (null constructor) and before protocol is started.
boolean	isDynamic()
boolean	removeInitialHost(java.lang.String hostname, int port)
void	setInitialHosts(java.util.List<java.net.InetSocketAddress> hosts)
void	start() This method is called on a Channel.connect(String).
void	stop() This method is called on a Channel.disconnect().

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

addDiscoveryResponseToCaches, addResponse, addressAsString, addToCache, breakOnCoordResponse, breakOnCoordResponse, deserialize, discoveryRequestReceived, down, dumpCache, findInitialMembersAsString, findMembers, forceDiscoveryResponses, forceDiscoveryResponses, getCurrentCoord, getNumberOfDiscoveryRequestsSent, getNumInitialMembers, getTimeout, getView, getViewId, handleDiscoveryResponse, isCoord, isMergeRunning, marshal, numInitialMembers, numInitialMembers, providedUpServices, read, readPingData, resetStats, returnEntireCache, returnEntireCache, sendDiscoveryResponse, serializeWithoutView, setForceSendingDiscoveryRsps, setNumInitialMembers, setTimeout, staggerTimeout, staggerTimeout, timeout, timeout, up, useDiskCache, useDiskCache, write

从类继承的方法 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, requiredDownServices, 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

构造器详细资料

TCPGOSSIP

public TCPGOSSIP()

方法详细资料

setInitialHosts

public void setInitialHosts(java.util.List<java.net.InetSocketAddress> hosts)

getInitialHosts

public java.util.List<java.net.InetSocketAddress> getInitialHosts()

isDynamic

public boolean isDynamic()

指定者:

isDynamic 在类中 Discovery

init

public void init()
          throws java.lang.Exception

从类复制的说明: Protocol

Called after instance has been created (null constructor) and before protocol is started. Properties are already set. Other protocols are not yet connected and events cannot yet be sent.

覆盖:

init 在类中 Discovery

抛出:

java.lang.Exception - Thrown if protocol cannot be initialized successfully. This will cause the ProtocolStack to fail, so the channel constructor will throw an exception

start

public void start()
           throws java.lang.Exception

从类复制的说明: Protocol

This method is called on a Channel.connect(String). Starts work. Protocols are connected and queues are ready to receive events. Will be called from bottom to top. This call will replace the START and START_OK events.

覆盖:

start 在类中 Discovery

抛出:

java.lang.Exception - Thrown if protocol cannot be started successfully. This will cause the ProtocolStack to fail, so Channel.connect(String) will throw an exception

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 在类中 Discovery

destroy

public void destroy()

从类复制的说明: Protocol

This method is called on a Channel.close(). Does some cleanup; after the call the VM will terminate

覆盖:

destroy 在类中 Protocol

handleConnect

public void handleConnect()

覆盖:

handleConnect 在类中 Discovery

handleDisconnect

public void handleDisconnect()

覆盖:

handleDisconnect 在类中 Discovery

findMembers

public void findMembers(java.util.List<Address> members,
               boolean initial_discovery,
               Responses responses)

从类复制的说明: Discovery

Fetches information (e.g. physical address, logical name) for the given member addresses. Needs to add responses to the Responses object. If Discovery.async_discovery is true, this method will be called in a separate thread, otherwise the caller's thread will be used.

指定者:

findMembers 在类中 Discovery

参数:

members - A list of logical addresses (typically UUIDs). If null, then information for all members is fetched

initial_discovery - Set to true if this is for the initial membership discovery. Some protocols (e.g. file based ones) may return only the information for the coordinator(s).

responses - The list to which responses should be added

addInitialHost

public void addInitialHost(java.lang.String hostname,
                  int port)

removeInitialHost

public boolean removeInitialHost(java.lang.String hostname,
                        int port)

connectAllStubs

protected void connectAllStubs(java.lang.String group,
                   Address logical_addr)

connect

protected void connect(RouterStub stub,
           java.lang.String group,
           Address logical_addr)