VoldemortにJavaからアクセス

VoldemortにJavaからアクセスする例。

ライブラリー

Voldemortのクライアントプログラムのコンパイル・実行に必要なjarファイルは以下の通り。

Voldemortアクセスのサンプル

import voldemort.client.ClientConfig;
import voldemort.client.SocketStoreClientFactory;
import voldemort.client.StoreClient;
import voldemort.client.StoreClientFactory;
import voldemort.versioning.Versioned;

public class VoldemortSample {

	public static void main(String[] args) {

		// ストア(テーブル)名と接続先
		String storeName    = "test";
		String bootstrapUrl = "tcp://localhost:6666";

		ClientConfig clientConfig = new ClientConfig().setBootstrapUrls(bootstrapUrl);
		StoreClientFactory factory = new SocketStoreClientFactory(clientConfig);
		try {
			StoreClient<String, String> client = factory.getStoreClient(storeName);

			Versioned<String> value = client.get("hello");
			if (value != null) {
				System.out.println(value.getValue());
			}
		} finally {
			factory.close();
		}
	}
}

StoreClientFactoryを生成し、そこからストアアクセス用のclientを取得する。
MockStoreClientFactoryというファクトリークラスもあって、それはDB接続を伴わない一時的なストア用で、テストに使うのに便利らしい。

clientの型は、上記の例ではStoreClient<String, String>にしている。つまりキーの型がStringで値の型もString。
これは、stores.xmlでキーも値もstringとして定義されているから。
なお、Javaの文法的にはジェネリクスのメソッドのみに型引数を適用する機能を使って自分でStringを指定しているだけで、“Java（ソース）上のどこかで定義されていて自動的にStringになっている”という訳では無い。ObjectでもIntegerでもコンパイルは通る。が、当然、一致しないクラスであれば実行時にキャストできなくて例外が発生する。

データアクセスのコーディング

Voldemortのデータを操作する為のメソッド（0.80.2）。

String key = "hello";
Versioned<String> versioned = client.get(key);
if (versioned != null) {
  String value = versioned.getValue();
}

String key = "hello";
Versioned<String> versioned = client.get(key);

if (versioned != null) {
 Version ver = versioned.getVersion();
 System.out.println(ver.toString());

 VectorClock clock = (VectorClock) ver;
 System.out.println(clock.getMaxVersion());
 System.out.println(new Date(clock.getTimestamp()));

 List<ClockEntry> list = clock.getEntries();
 for (ClockEntry ce : list) {
   System.out.println(ce.getNodeId() + " : " + ce.getVersion());
 }
}

List<String> keys = new ArrayList<String>();
keys.add("hello");
keys.add("foo");
keys.add("abc");

Map<String, Versioned<String>> values = client.getAll(keys);
for (Entry<String, Versioned<String>> entry : values.entrySet()) {
  String            key       = entry.getKey();
  Versioned<String> versioned = entry.getValue();
  String value = versioned.getValue();
  System.out.println(key + "=" + value);
}

String key   = "hello";
String value = "world";
client.put(key, value);

String key   = "hello";
String value = "world";

Versioned<String> versioned = client.get(key);
versioned.setObject(value);

client.put(key, versioned);

String key   = "hello";
String value = "world";

Versioned<String> versioned = client.get(key);
versioned.setObject(value);

client.putIfNotObsolete(key, versioned);

String key = "hello";
client.delete(key);

String key = "hello";
Versioned<String> versioned = client.get(key);
if (versioned != null) {
  Version ver = versioned.getVersion();
  client.delete(key, ver);
}

String key = "hello";
List<Node> nodes = client.getResponsibleNodes(key);
FailureDetector fd = factory.getFailureDetector();
for (Node node : nodes) {
  System.out.println("Node "  + node.getId());
  System.out.println("host: " + node.getHost());
  System.out.println("port: " + node.getSocketPort());

  System.out.println("available: " + fd.isAvailable(node));
  System.out.println("last checked: "
                       + new Date(fd.getLastChecked(node)));
}

FailureDetector fd = factory.getFailureDetector();
System.out.println(fd.getNodeCount());
System.out.println(fd.getAvailableNodeCount());

シリアライズ

Voldemortではストアのキーと値の型を定義することが出来るが、そのひとつがJava標準のシリアライズ。[2010-06-05]

ストアの定義（stores.xmlの抜粋）：

  <store>
    <name>test2</name>
    <persistence>bdb</persistence>
    <routing>client</routing>
    <replication-factor>1</replication-factor>
    <required-reads>1</required-reads>
    <required-writes>1</required-writes>
    <key-serializer>
      <type>string</type>
    </key-serializer>
    <value-serializer>
      <type>java-serialization</type>
    </value-serializer>
</store>

put・getする時は、ただ単にシリアライズ可能クラスを指定するだけ。

		// ストア(テーブル)名と接続先
		String storeName    = "test2";
		String bootstrapUrl = "tcp://localhost:6666";

		StoreClientFactory factory = new SocketStoreClientFactory(new ClientConfig().setBootstrapUrls(bootstrapUrl));
		try {
			StoreClient<String, SampleBean> client = factory.getStoreClient(storeName);

			{
				SampleBean bean = new SampleBean();
				bean.setId(123);
				bean.setStr("sample");
				client.put("key", bean);
			}
			{
				Versioned<SampleBean> versioned = client.get("key");
				SampleBean bean = versioned.getValue();
				System.out.println(bean);
			}
		} finally {
			factory.close();
		}

public class SampleBean implements Serializable {
	private static final long serialVersionUID = 1L;

	protected int id;
	protected String str;
〜
}