parkjy76

Disque

https://github.com/antirez/disque

disqueはRedisの作者が開発したメモリベースの分散メッセージブローカである。

• ゴールは"Redis as a jobs queue"である。
• redisのようにシングルスレッドで動作する。 これはredis.ioにも言及されたように同じことだと思われる
• 現在のバージョンは1.0 betaでプロダクト環境にはまだ合わないかもしれないと書いてある。

parkjy76

Disque Installation & Configuration

ubuntu, disque 1.0-rc1

インストール

apt-get -y install git tcl build-essential
git clone https://github.com/antirez/disque.git
cd disque
make && make test

parkjy76

Disque Commands

1つのnodeでコマンドを確認してみる キューはredisのように別に生成する必要は無い。

基本コマンド

ADDJOB queue_name job <ms-timeout> [REPLICATE <count>] [DELAY <sec>] [RETRY <sec>] [TTL <sec>] [MAXLEN <count>] [ASYNC]

jobを追加する機能である。成功するとJob IDを返す。

parkjy76

Disque Cluster

disqueをクラスタ化した時の動作を確認してみます。 コマンドに関しては https://iridge.docbase.io/posts/112839 を参考。

基本動作確認

まず二つのnodeを起動する。

src/disque-server disque.1.conf

parkjy76

/*
_PARTITIONTIME  TIMESTAMP NULLABLE
user_id         STRING 	  REQUIRED
received_time   DATETIME  REQUIRED
lat             FLOAT     REQUIRED
lon             FLOAT     REQUIRED
accuracy        FLOAT     REQUIRED
*/
#standardSQL
CREATE TEMPORARY FUNCTION PI() AS (3.141592653589793);