public class OkuyamaClientFactoryImpl extends Object implements OkuyamaClientFactory
| コンストラクタと説明 |
|---|
OkuyamaClientFactoryImpl(String[] masternodes,
int minPoolSize)
マスターノード、最小のソケットプールサイズを指定してファクトリクラスを生成する。
|
OkuyamaClientFactoryImpl(String[] masternodes,
int minPoolSize,
boolean compatibilityMode)
マスターノード、最小のソケットプールサイズ、互換モードを指定してファクトリクラスを生成する。
|
OkuyamaClientFactoryImpl(String[] masternodes,
int minPoolSize,
boolean compatibilityMode,
boolean dumpStream)
マスターノード、最小のソケットプールサイズ、互換モード、ストリームのダンプモードを指定してファクトリクラスを生成する。
|
OkuyamaClientFactoryImpl(String[] masternodes,
int minPoolSize,
boolean compatibilityMode,
boolean dumpStream,
CompressionStrategy compressionStrategy)
マスターノード、最小のソケットプールサイズ、互換モード、ストリームのダンプモードを指定してファクトリクラスを生成する。
|
| 修飾子とタイプ | メソッドと説明 |
|---|---|
OkuyamaClient |
createClient()
OkuyamaClientを生成する。 |
void |
destroy()
確保しているリソースを解放してファクトリクラスを破棄する。
|
CompressionStrategy |
getCompressionStrategy()
圧縮戦略を取得する。
|
int |
getDelayToMarkOnlineInMillis()
オフライン状態からTCP接続が確立後にオンラインにするまでに待つ時間(ミリ秒)を取得
|
int |
getMaxCoucurrentSockets()
同時に開いたソケットの最大値を取得する。
|
int |
getMaxPoolSize()
保持するソケットの最大数を取得する。
|
SocketManager |
getSocketManager() |
int |
getTimeoutToConnectInMillis()
TCP接続が確立するかどうか確認するときのコネクションタイムアウト時間(ミリ秒)を取得する。
|
int |
getTimeoutToReadInMillis()
ソケットの読み取りタイムアウト時間(ミリ秒)を取得する。
|
boolean |
isBase64key()
キーをBase64でエンコードするかを返す。
|
boolean |
isCompatibilityMode()
互換モードが設定されているかを確認する。
|
boolean |
isCompressionMode()
圧縮モードを取得する。
|
boolean |
isSerializeString()
文字列を格納する際にJavaのシリアライズをするかを返す。
|
void |
setBase64key(boolean base64key)
キーをBase64でエンコードする設定をする。
|
void |
setCompatibilityMode(boolean compatibilityMode)
互換モードを設定する。
|
void |
setCompressionMode(boolean doCompress)
圧縮モードを設定する。
|
void |
setCompressionStrategy(CompressionStrategy compressionStrategy)
圧縮戦略を設定する。
|
void |
setDelayToMarkOnlineInMillis(int delayToMarkOnlineInMillis)
オフライン状態からTCP接続が確立後にオンラインにするまでに待つ時間(ミリ秒)を設定する(デフォルト:3000ミリ秒)。
|
void |
setSerializeString(boolean serializeString)
文字列を格納する際にJavaのシリアライズをするかを設定する。
|
void |
setSocketManager(SocketManager socketManager) |
void |
setSocketTimeToLiveInMilli(long socketTimeToLiveInMilli)
新規に作成されてから設定値の期間経過したソケットは、そのソケットがプールから選択されるタイミングで削除され、利用されなくなります。
|
void |
setTimeoutToConnectInMillis(int timeoutToConnectInMillis)
TCP接続が確立するかどうか確認するときのコネクションタイムアウト時間(ミリ秒)を設定する(デフォルト:1000ミリ秒)。
|
void |
setTimeoutToReadInMillis(int timeoutToReadInMillis)
ソケットの読み取りタイムアウト時間(ミリ秒)を設定する(デフォルト:1000ミリ秒)
|
public OkuyamaClientFactoryImpl(String[] masternodes, int minPoolSize) throws UnknownHostException
互換モードを設定すると下のような状態で稼働する。
masternodes - マスターノード接続先の配列minPoolSize - 最小のソケットプールサイズUnknownHostException - 指定したホスト名のIPアドレスが取得できない場合IllegalArgumentException - 指定したホストの形式が不正の場合public OkuyamaClientFactoryImpl(String[] masternodes, int minPoolSize, boolean compatibilityMode) throws UnknownHostException
masternodes - マスターノード接続先の配列minPoolSize - 最小のソケットプールサイズcompatibilityMode - オリジナルOkuyamaClient互換モードUnknownHostException - 指定したホスト名のIPアドレスが取得できない場合IllegalArgumentException - 指定したホストの形式が不正の場合public OkuyamaClientFactoryImpl(String[] masternodes, int minPoolSize, boolean compatibilityMode, boolean dumpStream) throws UnknownHostException
masternodes - マスターノード接続先の配列minPoolSize - 最小のソケットプールサイズcompatibilityMode - オリジナルOkuyamaClient互換モードdumpStream - 入出力のストリームをダンプする(主にデバッグ用)UnknownHostException - 指定したホスト名のIPアドレスが取得できない場合IllegalArgumentException - 指定したホストの形式が不正の場合public OkuyamaClientFactoryImpl(String[] masternodes, int minPoolSize, boolean compatibilityMode, boolean dumpStream, CompressionStrategy compressionStrategy) throws UnknownHostException
CompressionStrategy)
互換モードを指定すると、オリジナルのOkuyamaClientからでも読み出し可能な形式で格納するように下の設定でクライアントを生成する。
masternodes - マスターノード接続先の配列minPoolSize - 最小のソケットプールサイズcompatibilityMode - オリジナルOkuyamaClient互換モードdumpStream - 入出力のストリームをダンプする(主にデバッグ用)compressionStrategy - 圧縮戦略UnknownHostException - 指定したホスト名のIPアドレスが取得できない場合IllegalArgumentException - 指定したホストの形式が不正の場合、互換モードを指定しているにもかかわらず圧縮戦略を指定した場合public OkuyamaClient createClient()
OkuyamaClientFactoryOkuyamaClientを生成する。接続先や各種パラメータは OkuyamaClientFactoryの実装クラスで設定されたものを用いる。createClient インタフェース内 OkuyamaClientFactorypublic void destroy()
OkuyamaClientFactorydestroy インタフェース内 OkuyamaClientFactorypublic boolean isCompatibilityMode()
public void setCompatibilityMode(boolean compatibilityMode)
compatibilityMode - 互換モードに設定するなら truepublic CompressionStrategy getCompressionStrategy()
public void setCompressionStrategy(CompressionStrategy compressionStrategy)
DefaultCompressionStrategyで提供される。設定を解除する場合はnullを設定する。compressionStrategy - 圧縮戦略。解除する場合はnullpublic boolean isCompressionMode()
public void setCompressionMode(boolean doCompress)
DefaultCompressionStrategyが利用される。doCompress - 圧縮する場合はtruepublic boolean isBase64key()
public void setBase64key(boolean base64key)
base64key - キーをBase64でエンコードするならtruepublic boolean isSerializeString()
public void setSerializeString(boolean serializeString)
serializeString - 文字列を格納する際にJavaのシリアライズをするならtruepublic int getMaxPoolSize()
public int getMaxCoucurrentSockets()
public int getTimeoutToReadInMillis()
public void setTimeoutToReadInMillis(int timeoutToReadInMillis)
timeoutToReadInMillis - ソケットの読み取りタイムアウト時間(ミリ秒)public int getTimeoutToConnectInMillis()
public void setTimeoutToConnectInMillis(int timeoutToConnectInMillis)
timeoutToConnectInMillis - TCP接続が確立するかどうか確認するときのコネクションタイムアウト時間(ミリ秒)public int getDelayToMarkOnlineInMillis()
public void setDelayToMarkOnlineInMillis(int delayToMarkOnlineInMillis)
delayToMarkOnlineInMillis - オフライン状態からTCP接続が確立後にオンラインにするまでに待つ時間(ミリ秒)public SocketManager getSocketManager()
public void setSocketManager(SocketManager socketManager)
public void setSocketTimeToLiveInMilli(long socketTimeToLiveInMilli)
socketTimeToLiveInMilli - ソケットの生存期間[ミリ秒](デフォルトは5分)Copyright © 2013–2016. All rights reserved.