com.xxdb.streaming.client

Class AbstractClient

java.lang.Object

com.xxdb.streaming.client.AbstractClient

Direct Known Subclasses:

EventClient, PollingClient, StreamingSQLClient, ThreadedClient, ThreadPooledClient

public abstract class AbstractClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AbstractClient.HAStreamTableInfo

Field Summary

Fields

Modifier and Type	Field and Description
protected LinkedBlockingQueue<DBConnection>	connList
protected Map<String,Integer>	currentSiteIndexMap
protected static String	DEFAULT_ACTION_NAME
protected static String	DEFAULT_HOST
protected static int	DEFAULT_PORT
protected List<AbstractClient.HAStreamTableInfo>	haStreamTableInfo
protected HashMap<String,String>	HATopicToTrueTopic
protected HashMap<String,Boolean>	hostEndian
protected static boolean	ifUseBackupSite
protected boolean	isClose_
protected String	lastBackupSiteTopic
protected static Map<String,Long>	lastExceptionTopicTimeMap
protected BlockingQueue<List<IMessage>>	lastQueue
protected String	lastSuccessSubscribeTopic
protected String	listeningHost
protected int	listeningPort
protected ConcurrentHashMap<String,List<IMessage>>	messageCache
protected Thread	pThread
protected QueueManager	queueManager
protected ConcurrentHashMap<String,com.xxdb.streaming.client.AbstractClient.ReconnectItem>	reconnectTable
protected static Integer	resubscribeInterval
protected Map<String,StreamDeserializer>	subInfos_
protected static boolean	subOnce
protected HashMap<String,String>	tableNameToTrueTopic
protected ConcurrentHashMap<String,Site[]>	trueTopicToSites
protected HashMap<List<String>,List<String>>	users
protected CopyOnWriteArraySet<String>	waitReconnectTopic

Constructor Summary

Constructors

Constructor and Description
AbstractClient()
AbstractClient(int subscribePort)
AbstractClient(String subscribeHost, int subscribePort)

Method Summary

Modifier and Type	Method and Description
void	activeCloseConnection(Site site)
void	batchDispatch(List<IMessage> messags)
void	close()
void	dispatch(IMessage msg)
protected abstract boolean	doReconnect(Site site)
List<String>	getAllReconnectSites()
Set<String>	getAllReconnectTopic()
List<String>	getAllTopicsBySite(String site)
Site	getCurrentSiteByName(String site)
int	getNeedReconnect(String site)
boolean	getNewLeader(String s, Object[] hostPort)
long	getReconnectTimestamp(String site)
Site	getSiteByName(String site)
Map<String,StreamDeserializer>	getSubInfos()
ConcurrentHashMap<String,Site[]>	getTopicToSites()
boolean	isClose()
boolean	isClosed(String topic)
boolean	isRemoteLittleEndian(String host)
void	setMsgId(String topic, long msgId)
void	setNeedReconnect(String topic, int v)
void	setReconnectTimestamp(String site, long v)
protected BlockingQueue<List<IMessage>>	subscribeInternal(String host, int port, String tableName, long offset)
protected BlockingQueue<List<IMessage>>	subscribeInternal(String host, int port, String tableName, String actionName, long offset)
protected BlockingQueue<List<IMessage>>	subscribeInternal(String host, int port, String tableName, String actionName, long offset, boolean reconnect)
protected BlockingQueue<List<IMessage>>	subscribeInternal(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic)
protected BlockingQueue<List<IMessage>>	subscribeInternal(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean msgAsTable)
protected BlockingQueue<List<IMessage>>	subscribeInternal(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean msgAsTable, boolean createSubInfo)
protected BlockingQueue<List<IMessage>>	subscribeInternal(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean msgAsTable, List<String> backupSites, int resubscribeInterval, boolean subOnce)
protected BlockingQueue<List<IMessage>>	subscribeInternal(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean msgAsTable, List<String> backupSites, int resubscribeInterval, boolean subOnce, boolean createSubInfo)
protected Map<String,Object>	subscribeStreamingSqlLogInfoInternal(String host, int port, String tableName, String actionName, MessageHandler handler, long offset, boolean reconnect, Vector filter, StreamDeserializer deserializer, boolean allowExistTopic, String userName, String passWord, boolean createSubInfo, boolean streamingSQL, boolean msgAsTable)
boolean	tryReconnect(String topic)
protected void	unsubscribeInternal(String host, int port, String tableName)
protected void	unsubscribeInternal(String host, int port, String tableName, String actionName)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_PORT

protected static final int DEFAULT_PORT

See Also:

Constant Field Values

DEFAULT_HOST

protected static final String DEFAULT_HOST

See Also:

Constant Field Values

DEFAULT_ACTION_NAME

protected static final String DEFAULT_ACTION_NAME

See Also:

Constant Field Values

reconnectTable

protected ConcurrentHashMap<String,com.xxdb.streaming.client.AbstractClient.ReconnectItem> reconnectTable

listeningPort

protected int listeningPort

listeningHost

protected String listeningHost

queueManager

protected QueueManager queueManager

messageCache

protected ConcurrentHashMap<String,List<IMessage>> messageCache

tableNameToTrueTopic

protected HashMap<String,String> tableNameToTrueTopic

HATopicToTrueTopic

protected HashMap<String,String> HATopicToTrueTopic

hostEndian

protected HashMap<String,Boolean> hostEndian

pThread

protected Thread pThread

trueTopicToSites

protected ConcurrentHashMap<String,Site[]> trueTopicToSites

waitReconnectTopic

protected CopyOnWriteArraySet<String> waitReconnectTopic

subInfos_

protected Map<String,StreamDeserializer> subInfos_

users

protected HashMap<List<String>,List<String>> users

isClose_

protected boolean isClose_

connList

protected LinkedBlockingQueue<DBConnection> connList

ifUseBackupSite

protected static boolean ifUseBackupSite

lastBackupSiteTopic

protected String lastBackupSiteTopic

currentSiteIndexMap

protected Map<String,Integer> currentSiteIndexMap

lastExceptionTopicTimeMap

protected static Map<String,Long> lastExceptionTopicTimeMap

resubscribeInterval

protected static Integer resubscribeInterval

subOnce

protected static boolean subOnce

lastQueue

protected BlockingQueue<List<IMessage>> lastQueue

lastSuccessSubscribeTopic

protected String lastSuccessSubscribeTopic

haStreamTableInfo

protected List<AbstractClient.HAStreamTableInfo> haStreamTableInfo

Constructor Detail

AbstractClient

public AbstractClient()
               throws SocketException

Throws:

SocketException

AbstractClient

public AbstractClient(int subscribePort)
               throws SocketException

Throws:

SocketException

AbstractClient

public AbstractClient(String subscribeHost,
                      int subscribePort)
               throws SocketException

Throws:

SocketException

Method Detail

setNeedReconnect

public void setNeedReconnect(String topic,
                             int v)

getNeedReconnect

public int getNeedReconnect(String site)

getReconnectTimestamp

public long getReconnectTimestamp(String site)

setReconnectTimestamp

public void setReconnectTimestamp(String site,
                                  long v)

getAllTopicsBySite

public List<String> getAllTopicsBySite(String site)

getAllReconnectTopic

public Set<String> getAllReconnectTopic()

getAllReconnectSites

public List<String> getAllReconnectSites()

getSiteByName

public Site getSiteByName(String site)

getCurrentSiteByName

public Site getCurrentSiteByName(String site)

getSubInfos

public Map<String,StreamDeserializer> getSubInfos()

doReconnect

protected abstract boolean doReconnect(Site site)

setMsgId

public void setMsgId(String topic,
                     long msgId)

tryReconnect

public boolean tryReconnect(String topic)

activeCloseConnection

public void activeCloseConnection(Site site)

dispatch

public void dispatch(IMessage msg)

batchDispatch

public void batchDispatch(List<IMessage> messags)

isRemoteLittleEndian

public boolean isRemoteLittleEndian(String host)

isClosed

public boolean isClosed(String topic)

subscribeInternal

protected BlockingQueue<List<IMessage>> subscribeInternal(String host,
                                                          int port,
                                                          String tableName,
                                                          String actionName,
                                                          MessageHandler handler,
                                                          long offset,
                                                          boolean reconnect,
                                                          Vector filter,
                                                          StreamDeserializer deserializer,
                                                          boolean allowExistTopic)
                                                   throws IOException,
                                                          RuntimeException

Throws:

IOException

RuntimeException

subscribeInternal

protected BlockingQueue<List<IMessage>> subscribeInternal(String host,
                                                          int port,
                                                          String tableName,
                                                          String actionName,
                                                          MessageHandler handler,
                                                          long offset,
                                                          boolean reconnect,
                                                          Vector filter,
                                                          StreamDeserializer deserializer,
                                                          boolean allowExistTopic,
                                                          String userName,
                                                          String passWord,
                                                          boolean msgAsTable)
                                                   throws IOException,
                                                          RuntimeException

Throws:

IOException

RuntimeException

subscribeInternal

protected BlockingQueue<List<IMessage>> subscribeInternal(String host,
                                                          int port,
                                                          String tableName,
                                                          String actionName,
                                                          MessageHandler handler,
                                                          long offset,
                                                          boolean reconnect,
                                                          Vector filter,
                                                          StreamDeserializer deserializer,
                                                          boolean allowExistTopic,
                                                          String userName,
                                                          String passWord,
                                                          boolean msgAsTable,
                                                          boolean createSubInfo)
                                                   throws IOException,
                                                          RuntimeException

Throws:

IOException

RuntimeException

subscribeInternal

protected BlockingQueue<List<IMessage>> subscribeInternal(String host,
                                                          int port,
                                                          String tableName,
                                                          String actionName,
                                                          MessageHandler handler,
                                                          long offset,
                                                          boolean reconnect,
                                                          Vector filter,
                                                          StreamDeserializer deserializer,
                                                          boolean allowExistTopic,
                                                          String userName,
                                                          String passWord,
                                                          boolean msgAsTable,
                                                          List<String> backupSites,
                                                          int resubscribeInterval,
                                                          boolean subOnce,
                                                          boolean createSubInfo)
                                                   throws IOException,
                                                          RuntimeException

Throws:

IOException

RuntimeException

subscribeStreamingSqlLogInfoInternal

protected Map<String,Object> subscribeStreamingSqlLogInfoInternal(String host,
                                                                  int port,
                                                                  String tableName,
                                                                  String actionName,
                                                                  MessageHandler handler,
                                                                  long offset,
                                                                  boolean reconnect,
                                                                  Vector filter,
                                                                  StreamDeserializer deserializer,
                                                                  boolean allowExistTopic,
                                                                  String userName,
                                                                  String passWord,
                                                                  boolean createSubInfo,
                                                                  boolean streamingSQL,
                                                                  boolean msgAsTable)
                                                           throws IOException,
                                                                  RuntimeException

Throws:

IOException

RuntimeException

subscribeInternal

protected BlockingQueue<List<IMessage>> subscribeInternal(String host,
                                                          int port,
                                                          String tableName,
                                                          String actionName,
                                                          MessageHandler handler,
                                                          long offset,
                                                          boolean reconnect,
                                                          Vector filter,
                                                          StreamDeserializer deserializer,
                                                          boolean allowExistTopic,
                                                          String userName,
                                                          String passWord,
                                                          boolean msgAsTable,
                                                          List<String> backupSites,
                                                          int resubscribeInterval,
                                                          boolean subOnce)
                                                   throws IOException,
                                                          RuntimeException

Throws:

IOException

RuntimeException

subscribeInternal

protected BlockingQueue<List<IMessage>> subscribeInternal(String host,
                                                          int port,
                                                          String tableName,
                                                          String actionName,
                                                          long offset,
                                                          boolean reconnect)
                                                   throws IOException,
                                                          RuntimeException

Throws:

IOException

RuntimeException

subscribeInternal

protected BlockingQueue<List<IMessage>> subscribeInternal(String host,
                                                          int port,
                                                          String tableName,
                                                          long offset)
                                                   throws IOException,
                                                          RuntimeException

Throws:

IOException

RuntimeException

subscribeInternal

protected BlockingQueue<List<IMessage>> subscribeInternal(String host,
                                                          int port,
                                                          String tableName,
                                                          String actionName,
                                                          long offset)
                                                   throws IOException,
                                                          RuntimeException

Throws:

IOException

RuntimeException

unsubscribeInternal

protected void unsubscribeInternal(String host,
                                   int port,
                                   String tableName,
                                   String actionName)
                            throws IOException

Throws:

IOException

close

public void close()

isClose

public boolean isClose()

unsubscribeInternal

protected void unsubscribeInternal(String host,
                                   int port,
                                   String tableName)
                            throws IOException

Throws:

IOException

getTopicToSites

public ConcurrentHashMap<String,Site[]> getTopicToSites()

getNewLeader

public boolean getNewLeader(String s,
                            Object[] hostPort)