简介

• 一个消息推送中间件
• 高并发
• 使用简单

安装和运行

wget --no-check-certificate https://github.com/ideawu/icomet/archive/master.zip
unzip master.zip
cd icomet-master/
make
./icomet-server icomet.conf
./icomet-server icomet.conf -s stop

配置

location ~ ^/icomet/.* {
    rewrite ^/icomet/(.*) /$1 break;

    proxy_read_timeout 60;
    proxy_connect_timeout 60;
    proxy_buffering off;
    proxy_pass   http://127.0.0.1:8100;
}

使用

• curl demo

//订阅
curl -v "http://127.0.0.1:8100/stream?cname=12"
//推送
curl -v "http://127.0.0.1:8000/push?cname=12&content=hi"

• python demo test.py

#coding=utf-8
import pycurl

class Test: 
  def body_callback(self, buf):
    if  buf!="" :
      print buf#此处为接受到数据后的逻辑处理 略。。 

if __name__ == "__main__":   
  url = 'http://127.0.0.1:8100/stream?cname=12'  
  t = Test()
  c = pycurl.Curl()
  c.setopt(c.URL, url) 
  c.setopt(c.WRITEFUNCTION, t.body_callback)
  c.perform()
  c.close() 

其他

如考虑安全等因素，可在nginx做一次安全认证。