okuyama.imdst.client
クラス ImdstKeyValueClient

java.lang.Object
  上位を拡張 okuyama.imdst.client.OkuyamaClient
      上位を拡張 okuyama.imdst.client.ImdstKeyValueClient

public class ImdstKeyValueClient
extends OkuyamaClient

MasterNodeと通信を行うプログラムインターフェース
okuyamaが内部で使用するClient
一般的なクライアントアプリケーションが使用する想定ではない
okuyama.imdst.client.OkuyamaClientを使用してください.

作成者:
T.Okuyama

フィールドの概要
 
クラス okuyama.imdst.client.OkuyamaClient から継承されたフィールド
blankStr, br, byteDataKeysSep, compressMode, connectDefaultEncoding, connectExitStr, getValueServerReqBuf, masterNodesList, maxKeySize, maxValueSize, nowConnectServerInfo, pw, saveSize, SEARCH_VALUE_TYPE_AND, SEARCH_VALUE_TYPE_OR, sepStr, setValueServerReqBuf, socket, tagKeySep, transactionCode
 
コンストラクタの概要
ImdstKeyValueClient()
          コンストラクタ
 
メソッドの概要
 boolean arrivalMasterNode()
          MasterNodeの生死を確認する.
 void changeByteSaveSize(int size)
          バイナリデータ分割保存サイズを変更
 void connect(java.lang.String server, int port)
          接続処理.
 java.lang.String getDataNodeStatus(java.lang.String nodeInfo)
          DataNodeのステータスを取得する.
 java.lang.String getNowTransactionCode()
          トランザクションを開始している場合、自身のトランザクションを一意に表す コードを返す.
 void nextConnect()
          設定されたMasterNodeの接続情報を元に自動的に接続を行う.
 void setNowTransactionCode(java.lang.String transactionCode)
          他のクライアントが実施しているトランザクションコードを設定することで、 トランザクション処理を引き継ぐことが出来る。
 void setSaveMaxDataSize(int size)
          保存するデータの最大長を変更する.
 
クラス okuyama.imdst.client.OkuyamaClient から継承されたメソッド
autoConnect, close, connect, connect, dataDecoding, dataEncoding, decrValue, endTransaction, execCompress, execDecompres, getByteData, getByteValue, getByteValueVer2, getMultiValue, getMultiValue, getTagKeys, getTagKeys, getTagValues, getTagValues, getValue, getValue, getValueScript, getValueScript, getValueScriptForUpdate, getValueScriptForUpdate, getValueVersionCheck, getValueVersionCheck, incrValue, initClient, lockData, readByteValue, readSearchValueResponse, readSearchValueResponse, releaseLockData, removeSearchIndex, removeSearchIndex, removeSearchIndex, removeSearchIndex, removeTagFromKey, removeValue, removeValue, searchValue, searchValue, searchValue, searchValue, sendByteValue, sendSearchValueRequest, sendSearchValueRequest, sendSearchValueRequest, setByteValue, setByteValue, setCompressMode, setConnectionInfos, setNewValue, setNewValue, setValue, setValue, setValueAndCreateIndex, setValueAndCreateIndex, setValueAndCreateIndex, setValueAndCreateIndex, setValueVersionCheck, setValueVersionCheck, startTransaction
 
クラス java.lang.Object から継承されたメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

コンストラクタの詳細

ImdstKeyValueClient

public ImdstKeyValueClient()
コンストラクタ

メソッドの詳細

connect

public void connect(java.lang.String server,
                    int port)
             throws OkuyamaClientException
接続処理.
エンコーディング指定なし.

オーバーライド:
クラス OkuyamaClient 内の connect
パラメータ:
server - サーバ名
port - ポート番号
例外:
OkuyamaClientException

setSaveMaxDataSize

public void setSaveMaxDataSize(int size)
保存するデータの最大長を変更する.
接続時に

パラメータ:
size - 保存サイズ(バイト長)

changeByteSaveSize

public void changeByteSaveSize(int size)
バイナリデータ分割保存サイズを変更

パラメータ:
size - サイズ

nextConnect

public void nextConnect()
                 throws OkuyamaClientException
設定されたMasterNodeの接続情報を元に自動的に接続を行う.
接続出来ない場合自動的に別ノードへ再接続を行う.

パラメータ:
masterNodes - 接続情報の配列 "IP:PORT"の形式
例外:
OkuyamaClientException

getNowTransactionCode

public java.lang.String getNowTransactionCode()
トランザクションを開始している場合、自身のトランザクションを一意に表す コードを返す. このコードをsetNowTransactionCodeに渡すと、別クライアントのTransactionを引き継げる !! 他クライアントの処理を横取ることが出来るため、使用を推奨しない !!

オーバーライド:
クラス OkuyamaClient 内の getNowTransactionCode
戻り値:
String

setNowTransactionCode

public void setNowTransactionCode(java.lang.String transactionCode)
他のクライアントが実施しているトランザクションコードを設定することで、 トランザクション処理を引き継ぐことが出来る。 !!! 他クライアントの処理を横取ることが出来るため、使用を推奨しない !!!

オーバーライド:
クラス OkuyamaClient 内の setNowTransactionCode

arrivalMasterNode

public boolean arrivalMasterNode()
                          throws OkuyamaClientException
MasterNodeの生死を確認する.

戻り値:
boolean true:開始成功 false:開始失敗
例外:
OkuyamaClientException

getDataNodeStatus

public java.lang.String getDataNodeStatus(java.lang.String nodeInfo)
                                   throws OkuyamaClientException
DataNodeのステータスを取得する.
DataNodのステータスは常にメインマスターノードが管理しているので、メインマスターノードに
接続している場合のみ取得可能.

パラメータ:
nodeInfo - DataNodeとPortの組み合わせ文字列 "NodeName:PortNo"
戻り値:
String 結果文字列
例外:
OkuyamaClientException