OPQ - 开源持久化消息队列

goldenwolf 发布于11天前 阅读27次
0 条评论

OPQ

  • An Open sourced Persistent message Queue

  • Code is tested under go1.4.2, higher version should be OK (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/OPQ
go build

Run OPQ

cd /path/to/OPQ
nohup ./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);

查看原文: OPQ - 开源持久化消息队列

共收到0条回复

需要 登录 后回复方可回复, 如果你还没有账号你可以 注册 一个帐号。