|
|||||||||
前のクラス 次のクラス | フレームあり フレームなし | ||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
java.lang.Objectokuyama.imdst.client.OkuyamaClient
okuyama.imdst.client.OkuyamaQueueClient
public class OkuyamaQueueClient
MasterNodeと通信を行うプログラムインターフェース
okuyamaを利用してキュー機構を実現するClient
利用手順としては
1.MasterNodeへ接続
2.createQueueSpaceメソッドで任意の名前でQueue領域を作成(既に作成済みのQueue領域を利用する場合は作成不要)
3.putメソッドにてデータを登録、もしくはtakeメソッドにて取り出し
4.利用終了後closeを呼び出す
※.Queue領域を削除する場合はremoveQueueSpaceを呼び出す
実装例)
-----------------------------------------------------------
String[] masterNodeInfos = {"127.0.0.1:8888"};
OkuyamaQueueClient queueClient = new OkuyamaQueueClient();
queueClient.setConnectionInfos(masterNodeInfos);
// 接続
queueClient.autoConnect();
// Queue領域を作成
if(queueClient.createQueueSpace("QueueNameXXX1")) {
System.out.println("Create - Success");
} else {
System.out.println("Create - Error");
}
// Queue領域名"QueueNameXXX1"にデータを登録
if(queueClient.put("QueueNameXXX1", "Data-0001")) {
System.out.println("Put - Success");
} else {
System.out.println("Put - Error");
}
String takeData = null;
// Queue領域名"QueueNameXXX1"からデータを取得
takeData = queueClient.take("QueueNameXXX1", 10000);
if (takeData != null) {
System.out.println("Data NotFound");
} else {
System.out.println("Take Data = " + takeData);
}
// 接続を切断
queueClient.close();
-----------------------------------------------------------
フィールドの概要 | |
---|---|
static java.lang.String |
QUEUE_NAME_PREFIX
|
static java.lang.String |
QUEUE_NAME_PREFIX_NOW_INDEX
|
static java.lang.String |
QUEUE_NAME_PREFIX_NOW_POINT
|
static java.lang.String |
QUEUE_TAKE_END_VALUE
|
コンストラクタの概要 | |
---|---|
OkuyamaQueueClient()
コンストラクタ |
メソッドの概要 | |
---|---|
boolean |
createQueueSpace(java.lang.String queueName)
Queue領域の作成. |
boolean |
put(java.lang.String queueName,
java.lang.String data)
Queueへのデータ登録. |
boolean |
removeQueueSpace(java.lang.String queueName)
Queue領域を削除する. |
java.lang.String |
take(java.lang.String queueName)
Queueからデータ取得. |
java.lang.String |
take(java.lang.String queueName,
long timeOut)
Queueからデータ取得. |
クラス java.lang.Object から継承されたメソッド |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
フィールドの詳細 |
---|
public static java.lang.String QUEUE_NAME_PREFIX
public static java.lang.String QUEUE_NAME_PREFIX_NOW_INDEX
public static java.lang.String QUEUE_NAME_PREFIX_NOW_POINT
public static java.lang.String QUEUE_TAKE_END_VALUE
コンストラクタの詳細 |
---|
public OkuyamaQueueClient()
メソッドの詳細 |
---|
public boolean createQueueSpace(java.lang.String queueName) throws OkuyamaClientException
queueName
- 作成Queue名(上限の長さはOkuyamaClientでのKeyの最大長 - 43byte)
OkuyamaClientException
public boolean removeQueueSpace(java.lang.String queueName) throws OkuyamaClientException
queueName
- 削除Queue領域名
OkuyamaClientException
public boolean put(java.lang.String queueName, java.lang.String data) throws OkuyamaClientException
queueName
- 登録するQueue領域名data
- 登録データ
OkuyamaClientException
public java.lang.String take(java.lang.String queueName) throws OkuyamaClientException
queueName
- 取得対象のQueue領域名
OkuyamaClientException
public java.lang.String take(java.lang.String queueName, long timeOut) throws OkuyamaClientException
queueName
- 取得対象のQueue領域名timeOut
- 待ち受けタイムアウト時間(ミリ秒/単位)
OkuyamaClientException
|
|||||||||
前のクラス 次のクラス | フレームあり フレームなし | ||||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |