本文共 751 字，大约阅读时间需要 2 分钟。
转自：
txmysql -- 异步mysql库
txredisapi -- 异步redis库
txmongo -- 异步mongodb库
txzmq -- 异步zmq库
txsockjs -- sockjs库--
其中txmysql说明:
和twisted自带的不同,这个不是通过MySQLdb+deferToThread实现的,是真正的异步,通过twisted的tcp连接到mysql服务器,使用mysql相关协议进行操作的.自带的通过线程.这个是通过异步io
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 | from txmysql import client from twisted.internet import reactor from twisted.internet.defer import inlineCallbacks from twisted.python import log import sys log.startLogging(sys.stdout) @inlineCallbacks def test(): conn = client.MySQLConnection( "192.168.6.234" , "root" , "123456" , "test" ) result = yield conn.runQuery( "select * from book" ) log.msg(result) reactor.callLater( 1 , reactor.stop) if __name__ = = "__main__" : reactor.callWhenRunning(test) reactor.run() |
转载地址：http://pifvb.baihongyu.com/