OPQ
AnOpen sourcedPersistent messageQueue
Code is tested under go1.4.2(CAUTION: OPQ hasn't been tested in production environment so far)
Features
? ? 1.persistent message storage
? ? 2.push model - push message to target service and block when failure
? ? 3.easy to use - simple API whith HTTP POST method, no addtional client integration is required
? ? 4.message replay
? ? 5.high performance aimed
? ? 6.operations-friendly - graceful stop/restart, HA (TODO)
Performance
? ? 1.over 20,000(Message/Second) with 2K(Byte) message payload
? ? 2.over 30,000(Message/Second) with 1K(Byte) message payload
Install
Download source code
? ? go get -u github.com/LevinLin/OPQ
Build OPQ
? ? cd /path/to/OPQgo build
Run OPQ
? ? cd /path/to/OPQnohup ./OPQ &>/dev/null &
? ??-debug
? ? System runs in debug model when given debug=yes, which will enable log/output in debug level, default to no
? ??-port
? ? Listening port, default to 8999
? ??-syslog
? ? System log name, default to system.log
? ? -admin
? ? Enable admin portal when given admin=yes, default to no(TODO, not available yet)
Gracefully restart OPQ
? ? kill -1 %{PID}
Usage
Push Message
? ? url: http://%{SERVER_NAME}[:%{SERVER_PORT}]/opq/push
? ? post fields:
? ? ? ? 1.url: target url
? ? ? ? 2.topic: each message should belong to a topic
? ? ? ? 3.message: message content
? ? header: specify the header if you need
? ? example:(PHP)
? ? <?php
? ? ? ? $url="http://localhost:8999/opq/push";
? ? ? ? $ch=curl_init();
? ? ? ? curl_setopt($ch, CURLOPT_URL,$url);
? ? ? ? curl_setopt($ch, CURLOPT_RETURNTRANSFER,1);
? ? ? ? curl_setopt($ch, CURLOPT_POST,1);
? ? ? ? $data=array(
? ? ? ? ? ? 'url'=>'http://127.0.0.1/Comment/addComment?comment=nny&user=q18',
? ? ? ? ? ? 'topic'=>'comment',?
? ? ? ? ? ? 'message'=>'this is message body',
? ? ? ? );
? ? ? ? curl_setopt($ch, CURLOPT_POSTFIELDS,$data);
? ? ? ? $response=curl_exec($ch);
? ? ? ? var_dump($response);
? ? ? ? curl_close($ch);
Replay Message
? ? url: http://%{SERVER_NAME}[:%{SERVER_PORT}]/opq/replay
? ? post fields:
? ? ? ? 1.topic: topic name
? ? ? ? 2.cmd: commond number (message index, start from 0)
? ? example:(PHP)
? ? <?php
? ? ? ? $url="http://localhost:8999/opq/replay";
? ? ? ? $ch=curl_init();
? ? ? ? curl_setopt($ch, CURLOPT_URL,$url);
? ? ? ? curl_setopt($ch, CURLOPT_RETURNTRANSFER,1);
? ? ? ? curl_setopt($ch, CURLOPT_POST,1);
? ? ? ? $data=array(
? ? ? ? ? ? 'topic'=>'comment',
? ? ? ? ? ? 'cmd'=>'30',
? ? ? ? );
? ? ? ? curl_setopt($ch, CURLOPT_POSTFIELDS,$data);
? ? ? ? $response=curl_exec($ch);
? ? ? ? var_dump($response);
? ? ? ? curl_close($ch);
