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, initParamConnectionTimeout, initParamEncoding, initParamMasterNodes, initParamOpenTimeout, initParamPort, initParamServer, masterNodesList, maxKeySize, maxValueSize, nowConnectServerInfo, okuyamaVersionNo, pw, saveSize, SEARCH_VALUE_TYPE_AND, SEARCH_VALUE_TYPE_OR, sepStr, setValueServerReqBuf, socket, tagKeySep, transactionCode, useAutoConnect |
クラス okuyama.imdst.client.OkuyamaClient から継承されたメソッド |
autoConnect, clearDictionaryCharacters, close, connect, connect, dataDecoding, dataEncoding, decrValue, endTransaction, execCompress, execDecompres, getByteData, getByteValue, getByteValueVer2, getMultiTagKeys, getMultiTagKeys, getMultiTagKeys, getMultiTagKeysResult, getMultiTagKeysResult, getMultiTagValues, getMultiTagValues, getMultiTagValues, getMultiValue, getMultiValue, getObjectValue, getObjectValueAndUpdateExpireTime, getOkuyamaVersion, getTagKeys, getTagKeys, getTagKeys, getTagKeysResult, getTagKeysResult, getTagKeysResult, getTagKeysResult, getTagKeysResult, getTagKeysResult, getTagKeysResult, getTagKeysResult, getTagValues, getTagValues, getTargetIndexTagKeys, getValue, getValue, getValueAndUpdateExpireTime, getValueAndUpdateExpireTime, 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, setByteValue, setByteValue, setCompressMode, setConnectionInfos, setDictionaryCharacters, setNewValue, setNewValue, setNewValue, setNewValue, setNewValue, setNewValue, setObjectValue, setObjectValue, setObjectValue, setObjectValue, setSendDataDebug, setValue, setValue, setValue, setValue, setValue, setValue, setValue, setValue, setValueAndCreateIndex, setValueAndCreateIndex, setValueAndCreateIndex, setValueAndCreateIndex, setValueAndCreateIndex, setValueAndCreateIndex, setValueAndCreateIndex, setValueVersionCheck, 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