|
|||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | ||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | ||||||||
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
|
|||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | ||||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | ||||||||