|
|||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | ||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | ||||||||
java.lang.Objectokuyama.imdst.util.DataDispatcher
public class DataDispatcher
MasterNodeが使用するDataNode決定モジュール.
| フィールドの概要 | |
|---|---|
static int[] |
oldRules
|
static java.lang.String |
rule
|
static int |
ruleInt
|
| コンストラクタの概要 | |
|---|---|
DataDispatcher()
|
|
| メソッドの概要 | |
|---|---|
static java.util.HashMap |
addNode4ConsistentHash(java.lang.String keyNodeFullName,
java.lang.String subKeyNodeFullName,
java.lang.String thirdKeyNodeFullName)
ConsitentHashモード時にノードの追加をおこなう. |
static void |
clearConsistentHashOldCircle()
旧サークルが存在する場合は削除する. |
static java.lang.String[] |
dispatchKeyNode(java.lang.String key,
boolean reverse)
Rule値に従って、キー値を渡すことで、KeyNodeの名前とポートの配列を返す. |
static java.lang.String[] |
dispatchKeyNode(java.lang.String key,
boolean reverse,
int useRule)
Rule値に従って、キー値を渡すことで、KeyNodeの名前とポートの配列を返す. |
static java.util.HashMap |
getAllDataNodeInfo()
全てのノードの情報を返す. |
static int |
getDispatchMode()
振り分けモードを返す. |
static boolean |
getInitFlg()
初期化の状態を返す. |
static int[] |
getOldRules()
過去ルールを返す. |
static java.util.ArrayList |
getTransactionManagerInfo()
TransactionManagerの情報を返す. |
static boolean |
hasOldRule()
旧ルールの存在有無を返す |
static void |
init(java.lang.String ruleStr,
int[] oldRules,
java.lang.String keyMapNodes,
java.lang.String subKeyMapNodes,
java.lang.String thirdKeyMapNodes,
java.lang.String transactionManagerStr)
初期化 以下の要素を設定する. |
static void |
initConsistentHashMode(java.lang.String keyMapNodes,
java.lang.String subKeyMapNodes,
java.lang.String thirdKeyMapNodes,
java.lang.String transactionManagerStr)
初期化 ConsistentHash専用. |
static boolean |
isRangeData(java.lang.String key,
int[][] rangs)
引数のKey値が引数のレンジの範囲のデータか確認し結果を返す. |
static boolean |
isRuleMatchKey(java.lang.String key,
int rule,
int matchNo)
引数のKey値が引数のルールのもと引数のmatchNoと合致するかを返す. |
static boolean |
isStandby()
本メソッド呼び出すと本クラスを使用できるまで呼び出し元をロック停止させる. |
static void |
setDispatchMode(java.lang.String mode)
|
static int |
sha1Hash4Int(java.lang.String target)
sha1のアルゴリズムでHashした値をjavaのhashCodeして返す. |
| クラス java.lang.Object から継承されたメソッド |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| フィールドの詳細 |
|---|
public static volatile java.lang.String rule
public static volatile int ruleInt
public static volatile int[] oldRules
| コンストラクタの詳細 |
|---|
public DataDispatcher()
| メソッドの詳細 |
|---|
public static void setDispatchMode(java.lang.String mode)
public static int getDispatchMode()
public static void init(java.lang.String ruleStr,
int[] oldRules,
java.lang.String keyMapNodes,
java.lang.String subKeyMapNodes,
java.lang.String thirdKeyMapNodes,
java.lang.String transactionManagerStr)
ruleStr - ルール設定oldRules - 過去ルール設定keyMapNodes - データノードを指定subKeyMapNodes - スレーブデータノードを指定thirdKeyMapNodes - スレーブデータノードを指定transactionManagerStr - トランザクションマネージャの指定
public static void initConsistentHashMode(java.lang.String keyMapNodes,
java.lang.String subKeyMapNodes,
java.lang.String thirdKeyMapNodes,
java.lang.String transactionManagerStr)
keyMapNodes - データノードを指定subKeyMapNodes - スレーブデータノードを指定thirdKeyMapNodes - スレーブデータノードを指定transactionManagerStr - トランザクションマネージャの指定public static boolean getInitFlg()
public static java.util.HashMap addNode4ConsistentHash(java.lang.String keyNodeFullName,
java.lang.String subKeyNodeFullName,
java.lang.String thirdKeyNodeFullName)
keyNodeFullName - 追加するメインデータノード フォーマット"192.168.1.3:5555"subKeyNodeFullName - 追加するスレーブデータノード フォーマット"192.168.2.3:5555"thirdKeyNodeFullName - 追加するサードデータノード フォーマット"192.168.2.3:5555"
public static void clearConsistentHashOldCircle()
public static int[] getOldRules()
public static java.lang.String[] dispatchKeyNode(java.lang.String key,
boolean reverse)
key - キー値reverse - 逆転指定
public static java.lang.String[] dispatchKeyNode(java.lang.String key,
boolean reverse,
int useRule)
key - キー値reverse - 逆転指定useRule - 旧ルール世代値
public static boolean isRuleMatchKey(java.lang.String key,
int rule,
int matchNo)
key - 対象のキー値rule - 使用ルールmatchNo - 検証No
public static boolean isRangeData(java.lang.String key,
int[][] rangs)
key - 対象のキー値rangs - 範囲
public static java.util.HashMap getAllDataNodeInfo()
public static java.util.ArrayList getTransactionManagerInfo()
public static int sha1Hash4Int(java.lang.String target)
targete - int - public static boolean hasOldRule()
public static boolean isStandby()
|
|||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | ||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | ||||||||