この例では、クエリが生成され、まったく使用されていないため、クライアントはすぐに応答を受け取る必要があります。「print msg」行はサーバー側にすぐに表示されますが、クライアントはクエリの実行が完了するまで応答を受け取りません。どうしたの?
#!/usr/bin/python
import sys
import gevent
from gevent_zeromq import zmq
import umysql
context = zmq.Context()
def serve():
socket = context.socket(zmq.REP)
socket.connect('inproc://backend')
msg = socket.recv()
gevent.spawn(serve)
db = umysql.Connection()
db.connect('localhost',3306,'user','password','database')
gevent.spawn(db.query,"SELECT SLEEP(10)")
socket.send(msg)
socket.close()
print msg
gevent.spawn(serve)
frontend = context.socket(zmq.ROUTER)
frontend.bind('tcp://*:5571')
backend = context.socket(zmq.DEALER)
backend.bind('inproc://backend')
def zeromq_relay(a, b):
while True:
msg = a.recv()
more = a.getsockopt(zmq.RCVMORE)
if more:
b.send(msg, zmq.SNDMORE)
else:
b.send(msg)
a = gevent.spawn(zeromq_relay, frontend, backend)
b = gevent.spawn(zeromq_relay, backend, frontend)
gevent.joinall([a,b])