簡介
- 一個(gè)消息推送中間件
- 高并發(fā)
- 使用簡單
安裝和運(yùn)行
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#此處為接受到數(shù)據(jù)后的邏輯處理 略。。
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做一次安全認(rèn)證。
