インフラエンジニアのためのCassandra情報 ZooKeeperその２：So-net Developer Blog：So-netブログ

	ブログをはじめるログイン

インフラエンジニアのためのCassandra情報 ZooKeeperその２　[Cassandra] [編集]

ZooKeeperのプログラミングについては、以下のURLに簡単なチュートリアルが
あります。
http://hadoop.apache.org/zookeeper/docs/r3.1.1/zookeeperTutorial.html
今回は、ここに載っているサンプルを使って、カウンターを実現してみます。
ZooKeeperはznodeと呼ばれるツリー構造のデータ構造を持っています。znodeのそれぞれに
対応するオブジェクト（または値）を保存することができます。znodeには、登録、更新時に
一意のバージョン番号が付与されるので、これを使うことで、CAS操作が実現できそうです。
そこで、「/app1/counter」というznodeを作成して、これにカウンター用の数値を代入、参照
するようにします。
カウントアップ時には、CAS操作を行っているので、複数プロセスからの同時書込み時でも値
の一意性が保証されます。
チュートリアルを参考にして、まず「/app1]」の作成部分は、

this.root = root_name; ← 「/app1」
counter = counter_name;
// Create ZK node name
if (zk != null) {
        try {
                Stat s = zk.exists(root, false);
                if (s == null) {
                        zk.create(root, new byte[0], Ids.OPEN_ACL_UNSAFE,
                                        CreateMode.PERSISTENT);
                }

となり、「/counter」の部分は、

b.putInt(0);    ←　初期値として0を入れる。
value = b.array();
zk.create(znode, value, Ids.OPEN_ACL_UNSAFE,
                        CreateMode.PERSISTENT); ← znode = /app1/counter

となります。この段階で既に変数として使えるようになっているので、カウンターの
初期値として「0」を入れておきます。
そして、CAS操作を実現するには、バージョン番号を取得し、カウントアップ後に
バージョン番号と一緒にznodeを更新します。このとき他のプロセスが更新していたら
Exceptionが発生するので、はじめからやり直します。
コードは以下のようになります。

int value = 0;
int retry = 0;

do {
        try {
                Stat stat = zk.exists(znode, false); ←バージョン番号を含むメタデータを取得
                byte[] b = zk.getData(znode,false, stat); ←現在の値を取得
                ByteBuffer buffer = ByteBuffer.wrap(b);
                value = buffer.getInt();

                value++;  ←カウントアップ

                ByteBuffer b1 = ByteBuffer.allocate(6);
                b1.putInt(value);
                b = b1.array();
                zk.setData(znode, b, stat.getVersion()); ←バージョン番号と一緒に、更新した値をセット
                retry = 0;
        } catch ( KeeperException e) { ←バージョン番号が変わっている場合は、KeeperExceptionが発生する
                retry = 1; ←一からやり直し
        }
}while(retry > 0);

出来上がったカウンターのソース(CounterPrimitive.java)は
https://github.com/so-net-developer/Cassandra/blob/master/zookeeper/CounterPrimitive.java
にあります。
使用方法は、以下のとおり。
ZookeeperライブラリをCLASSPATHに指定します。

$ export CLASSPATH=./:/usr/lib/zookeeper-3.3.1/zookeeper-3.3.1.jar:/usr/lib/zookeeper-3.3.1/lib/log4j-1.2.15.jarog4j-1.2.15.jar

コンパイル

$ javac CounterPrimitive.java

使い方は、

カウンタの作成:
java CounterPrimitive [Zookeeperノードアドレス] n
カウンタのインクリメント
java CounterPrimitive [Zookeeperノードアドレス] i [増分]
カウンタの削除
java CounterPrimitive [Zookeeperノードアドレス] d

使用例）

$ java CounterPrimitive localhost n
Input: localhost
New Counter

$ java CounterPrimitive localhost i 10
Input: localhost
Item: 10

$ java CounterPrimitive localhost i 10
Input: localhost
Item: 20          <- カウントアップされている。

$ java CounterPrimitive localhost d
Input: localhost
Deleted

参考までに、rubyでのサンプルも
https://github.com/so-net-developer/Cassandra/blob/master/zookeeper/CounterPrimitive.rb
に載せておきます。rubyに馴染みのひとはこちらのほうが見やすいかも。

2011-01-13 10:11 nice!(0) コメント(14) トラックバック(0)
共通テーマ：パソコン・インターネット

nice! 0

威哥王:http://www.威哥王通販.com
巨人倍増:http://www.巨人倍増.net
威哥王:http://www.威哥王通販.net
紅蜘蛛:http://www.紅蜘蛛通販.net

花痴:http://www.花痴.net
紅蜘蛛:http://www.紅蜘蛛通販.com
三便宝:http://www.三便宝.com
三便宝:http://www.三便宝.net

曲美:http://www.曲美通販.com
狼一号:http://www.狼一号.com
狼1号:http://www.狼一号.com
媚薬:http://www.女性用媚薬.com
イカオウ:http://www.威哥王通販.com
ウェイカワン:http://www.威哥王通販.com
イカオウ:http://www.威哥王通販.net
ウェイカワン:http://www.威哥王通販.net

威哥王:http://www.xn--kwrt2jp9z44w3ud.com/
巨人倍増:http://www.xn--gmq15an1qquf.net/
威哥王:http://www.xn--kwrt2jp9z44w3ud.net/
紅蜘蛛:http://www.xn--19zl5rhf54s3ve.net/

花痴:http://www.xn--dtyr5y.net/
紅蜘蛛:http://www.xn--19zl5rhf54s3ve.com/
三便宝:http://www.xn--ehqp5bo3v.com/
三便宝:http://www.xn--ehqp5bo3v.net/

曲美:http://www.xn--lovt16cuijxkd.com/
狼一号:http://www.xn--4gq48lvu4a.com/
狼1号:http://www.xn--4gq48lvu4a.com/
媚薬:http://www.xn--vuss0af3ksozb2s.com/
イカオウ:http://www.xn--kwrt2jp9z44w3ud.com/
ウェイカワン:http://www.xn--kwrt2jp9z44w3ud.com/
イカオウ:http://www.xn--kwrt2jp9z44w3ud.net/
ウェイカワン:http://www.xn--kwrt2jp9z44w3ud.net/
by 花痴 (2013-05-29 12:13)

ヴィヴィアンウエストウッドバッグ http://www.brandstorejapan.com/category-25-b0.html
ポールスミスバッグ http://www.brandstorejapan.com/category-46-b0.html
MCM リュック http://www.brandstorejapan.com/category-59-b0.html
クロムハーツサングラス http://www.brandstorejapan.com/category-65-b0.html
オークリーサングラス http://www.brandstorejapan.com/category-66-b0.html
by ヴィヴィアンウエストウッドバッグ (2013-06-03 16:48)

ヴィヴィアン財布 http://www.viviennewestwood-shop.com/category-12-b0.html
ヴィヴィアンバッグ http://www.viviennewestwood-shop.com/category-1-b0.html
ヴィヴィアンネックレス http://www.viviennewestwood-shop.com/category-9-b0.html
ヴィヴィアン iphoneケース http://www.viviennewestwood-shop.com/category-24-b0.html
ヴィヴィアン靴 http://www.viviennewestwood-shop.com/category-18-b0.html
by ヴィヴィアン財布 (2013-06-03 16:49)

2013年人気最新品バッグ,財布,腕時計,ネクタイ,ベルト全部一流のヴィトン素材を選択してヴィトンコピー品を作っている工場です.
ヴィトン価格で最高品質のヴィトンコピー品をお客様へ提供させていただきます。
ヴィトンコピー
ヴィトンバッグN級N品.
ヴィトン財布激安販売.
100%質量保证！満足保证！
ブランドスカーフ/マフラーコピー
店名：lvutt店
全品送料無料!!
by ヴィトンコピー (2013-11-11 14:46)