Zeromq 是基于zeromq、gevent和 msgpack开发的分布式RPC框架zerorpc-python。这个框架简单、易用。
1. 安装zeromq
|
1
2
3
4
5
6
|
yum -y install zeromq
yum install gcc gcc-c++ libuuid-devel python-uuid uuid
wget http:
//download.zeromq.org/zeromq-2.1.9.tar.gz
./configure
make
make install
|
2.安装gevent
|
1
|
pip install gevent
|
3. 安装zerorpc
|
1
|
pip install zerorpc
|
server的测试代码：
|
1
2
3
4
5
6
7
8
9
|
import
zerorpc
import
time
class
HelloRPC(object):
def hello(self, name):
print
"this is %s %s"
%(name,time.strftime(
'%Y-%m-%d %H-%m-%S'
,time.localtime(time.time())))
return
"Hello, %s"
%time.strftime(
'%Y-%m-%d %H-%m-%S'
,time.localtime(time.time()))
s = zerorpc.Server(HelloRPC())
s.bind(
"tcp://0.0.0.0:4242"
)
s.run()
|
client的测试代码
|
1
2
3
4
5
|
import
zerorpc
import
os,sys
c
=
zerorpc.Client()
c.connect(
"tcp://127.0.0.1:4242"
)
print
c.hello(
'www.ruifengyun.com'
)
|
也可以传送cmd的命令，然后return结果，这个有点像是 zeromq的req方法
客户端也可以独立的存在
|
1
|
zerorpc --client --connect tcp:
//127.0.0.1:4242 hello lllllllllllllllllllllllllll
|
客户端显示：
服务端显示：
现在看来，如果按照mq的性能对比的话，这个结果还是令人不太满意的，但这个是应用于rpc远程调用的场景内，外部调用的话一秒中可以可以发送并接受10次的调用，内部调用的话，可以每秒钟打到300次左右，但这个结果还是可以接受的，毕竟没有谁每时每刻都在用远端的函数的。。。。。。。
这个一个老外的测试数据：
|
1
2
3
4
|
xmlrpc client & server (single-threaded):
850
calls/sec
zerorpc client & server (single-threaded):
4500
calls/sec
xmlrpc client & server (multi-threaded):
1200
calls/sec
zerorpc client & server (multi-threaded):
11000
calls/sec
|
我很纳闷他是怎么测试出来的~
如果不需要return结果，只是类pub数据过去的话，是可以到600多，但是远达不到他们的数据。。。
很奇怪~
为了测试性能我把gevent引入了，测试的结果不稳定，以我对gevent协程框架的使用，他很少出这样的情况，问题很有可能是server的问题。。。
测试的结果：
完成的测试代码，以供大家学习测试：
server 测试代码：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
class
Cooler:
def add_man(self, sentence):
return
the result.
""
"
return
sentence +
", man!"
def add_42(self, n):
result.
""
"
return
n +
42
def boat(self, sentence):
because it's cooler.
""
"
return
"I'm on a boat!"
import
zerorpc
s = zerorpc.Server(Cooler())
s.bind(
"tcp://0.0.0.0:4242"
)
s.run()
|
client 测试代码：
|
1
2
3
4
5
6
|
$ zerorpc -j tcp:
//:4242 add_42 1
43
$ zerorpc tcp:
//:4242 add_man 'I own a mint-condition Volkswagen Golf'
"I own a mint-condition Volkswagen Golf, man!"
$ zerorpc tcp:
//:4242 boat 'I own a mint-condition Volkswagen Golf, man!'
"I'm on a boat!"
|
zerorpc 官方推荐的高可用的方法是用haproxy实现的
|
1
2
3
4
5
6
7
8
|
haproxy.cfg的配置
$cat haproxy.cfg
listen zerorpc
0.0
.
0.0
:
1111
mode tcp
server backend_a localhost:
2222
check
server backend_b localhost:
3333
check
检测语法
$ haproxy -f haproxy.cfg
|
可以进行语句的超时处理
本文转自 rfyiamcool 51CTO博客，原文链接：http://blog.51cto.com/rfyiamcool/1254000，如需转载请自行联系原作者
