0

この例では、クエリが生成され、まったく使用されていないため、クライアントはすぐに応答を受け取る必要があります。「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])
4

1 に答える 1

4

ultramysql は素晴らしいパッケージですが、ドキュメントが完全に欠如しているのは悪臭を放ちます。

ultramysql は gevent と自動的に互換性がありません。先頭に追加:

geventからのインポートモンキーmonkey.patch_socket（）

問題が解決しました。

于 2012-09-17T17:58:28.397 に答える