com.fr.third.jgroups.protocols

类 JDBC_PING

java.lang.Object

com.fr.third.jgroups.stack.Protocol

com.fr.third.jgroups.protocols.Discovery

com.fr.third.jgroups.protocols.JDBC_PING

public class JDBC_PING
extends Discovery

Discovery protocol using a JDBC connection to a shared database. Connection options can be defined as configuration properties, or the JNDI name of a DataSource can be provided (avoid providing both).

Both the schema and the used SQL statements can be customized; make sure the order of parameters of such customized SQL statements is maintained and that compatible types are used for the columns. The recommended schema uses a single table, with two String columns being used primary key (local address, cluster name) and a third column to store the serialized form of the objects needed by JGroups.

A default table will be created at first connection, errors during this operation are not considered critical. Set the initialize_sql to an empty value to prevent this initial table creation, or change it to create a customized table.

从以下版本开始:

2.12

作者:

Sanne Grinovero

字段概要

字段

限定符和类型	字段和说明
protected java.lang.String	connection_driver
protected java.lang.String	connection_password
protected java.lang.String	connection_url
protected java.lang.String	connection_username
protected java.lang.String	datasource_jndi_name
protected java.lang.String	delete_single_sql
protected java.lang.String	initialize_sql
protected java.lang.String	insert_single_sql
protected java.lang.String	select_all_pingdata_sql

从类继承的字段 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

构造器概要

构造器

构造器和说明
JDBC_PING()

方法概要

方法

限定符和类型	方法和说明
protected void	attemptSchemaInitialization()
protected void	closeConnection(java.sql.Connection connection)
protected void	delete(java.sql.Connection connection, java.lang.String clustername, java.lang.String addressToDelete)
protected void	delete(java.lang.String clustername, java.lang.String addressToDelete)
protected void	deleteSelf()
java.lang.Object	down(Event evt) An event is to be sent down the stack.
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.
protected java.sql.Connection	getConnection()
protected javax.sql.DataSource	getDataSourceFromJNDI(java.lang.String name)
protected void	handleView(View new_view, View old_view, boolean coord_changed)
void	init() Called after instance has been created (null constructor) and before protocol is started.
protected void	insert(java.sql.Connection connection, PingData data, java.lang.String clustername, java.lang.String address)
boolean	isDynamic()
protected void	loadDriver()
protected void	readAll(java.sql.Connection connection, java.util.List<Address> members, java.lang.String clustername, Responses rsps)
protected void	readAll(java.util.List<Address> members, java.lang.String clustername, Responses responses)
protected void	remove(java.lang.String clustername, Address addr)
void	stop() This method is called on a Channel.disconnect().
protected void	verifyconfigurationParameters()
protected void	writeOwnInformation() Write my own UUID,logical name and physical address to a file
protected void	writeToDB(PingData data, java.lang.String clustername)

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

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

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

accept, destroy, 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

字段详细资料

connection_url

protected java.lang.String connection_url

connection_username

protected java.lang.String connection_username

connection_password

protected java.lang.String connection_password

connection_driver

protected java.lang.String connection_driver

initialize_sql

protected java.lang.String initialize_sql

insert_single_sql

protected java.lang.String insert_single_sql

delete_single_sql

protected java.lang.String delete_single_sql

select_all_pingdata_sql

protected java.lang.String select_all_pingdata_sql

datasource_jndi_name

protected java.lang.String datasource_jndi_name

构造器详细资料

JDBC_PING

public JDBC_PING()

方法详细资料

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

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

down

public java.lang.Object down(Event evt)

从类复制的说明: Protocol

An event is to be sent down the stack. The layer may want to examine its type and perform some action on it, depending on the event's type. If the event is a message MSG, then the layer may need to add a header to it (or do nothing at all) before sending it down the stack using down_prot.down(). In case of a GET_ADDRESS event (which tries to retrieve the stack's address from one of the bottom layers), the layer may need to send a new response event back up the stack using up_prot.up().

覆盖:

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

handleView

protected void handleView(View new_view,
              View old_view,
              boolean coord_changed)

writeOwnInformation

protected void writeOwnInformation()

Write my own UUID,logical name and physical address to a file

writeToDB

protected void writeToDB(PingData data,
             java.lang.String clustername)

remove

protected void remove(java.lang.String clustername,
          Address addr)

readAll

protected void readAll(java.util.List<Address> members,
           java.lang.String clustername,
           Responses responses)

readAll

protected void readAll(java.sql.Connection connection,
           java.util.List<Address> members,
           java.lang.String clustername,
           Responses rsps)
                throws java.sql.SQLException

抛出:

java.sql.SQLException

attemptSchemaInitialization

protected void attemptSchemaInitialization()

loadDriver

protected void loadDriver()

getConnection

protected java.sql.Connection getConnection()

insert

protected void insert(java.sql.Connection connection,
          PingData data,
          java.lang.String clustername,
          java.lang.String address)
               throws java.sql.SQLException

抛出:

java.sql.SQLException

delete

protected void delete(java.sql.Connection connection,
          java.lang.String clustername,
          java.lang.String addressToDelete)
               throws java.sql.SQLException

抛出:

java.sql.SQLException

delete

protected void delete(java.lang.String clustername,
          java.lang.String addressToDelete)
               throws java.sql.SQLException

抛出:

java.sql.SQLException

deleteSelf

protected void deleteSelf()
                   throws java.sql.SQLException

抛出:

java.sql.SQLException

closeConnection

protected void closeConnection(java.sql.Connection connection)

getDataSourceFromJNDI

protected javax.sql.DataSource getDataSourceFromJNDI(java.lang.String name)

verifyconfigurationParameters

protected void verifyconfigurationParameters()