firefly技术演讲gevent9miao社团.pdfVIP

Gevent-Firefly 9miao社团 蓝金敏 需要面对的问题 • 网络IO：上千用户同时 交互的网络信息 收发及压缩加密。 • 数据库读写：上万的玩家数据 ， 与装备信息 • 多进程之间调用 （分布式更方便横向扩 展）。 Firefly架构图 Firefly Network 与客户端的通信采用的是请求/ 回应式的，服 务端也能主动的推送消息。 • 怎么定义一个接口，简单的echo实例 from firefly.server.globalobject import \ netserviceHandle @netserviceHandle def echo_1(_conn,data): return data Firefly Data Storage • firefly 的db处理： 将数据库表中的数据缓存到memcache中， 能以对象的形式进行调用相应的对象方法 对数据进行操作，然后将数据同步到数据 库中。（后期将支持redis，leveldb。这些将 以插件的形式，选择性的加入到服务中。） • 来个事例 • 有这样一张表 CREATE TABLE `tb_register` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'id', `username` varchar(255) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT '用户名', `password` varchar(255) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT '用户 ', PRIMARY KEY (`id`) ) ENGINE=MyISAM AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 from firefly.dbentrust.dbpool import dbpool from firefly.dbentrust.madminanager import MAdminManager from firefly.dbentrust import mmode from firefly.dbentrust.mem import m if name ==" main ": dbconfig = {}#这里配置数据库连接地址 dbpool.initPool(**dbconfig) m .connect(['127.0.0.1:11211'], "test") m1 = mmode.MAdmin( 'tb_register', 'id', incrkey='id') m1.insert() new_mode = m1.new({"username":"lan","password":"123"}) new_mode.checkSync() Firefly RPC • Firefly中封装类进程间相互进行接口调用的 过程，是这些变的非常的简洁。采用的是 异步通信，也就是在a进程请求b进程的接 口，在数据没返回是a进程是可以做其他的 逻辑处理的，是无阻塞的。 来个事例： def printResult(result): print result d= remote.callRemote(1001,username,password) d.callback(printResult) Firefly Server • 框架通过抽象使服务器的扩展非常容易。 Firefly config.json • 在firefly 中任意自定义自己的分布