浏览模式: 标准 | 列表 | 订阅

用python来开发webgame服务端(2)

作者:ciniao 时间:2011-08-30 分类:python 6 Comments

    刺鸟原创文章,转载请注明出处
    就在刚才,我们用基于python下的Twisted库写了一个简单的socket服务器,不知道它的性能和基本的承载到底如何呢?接下来,我们作一个简单的测试。

    说是简单的测试,一点也不假,因为这确实只是最基本的测试,流程是这样的:用python写一个客户端,设定连接数,然后向我们指定的端口发起socket连接,连接成功后,向服务端发送一个字符串并一直保持连接状态,服务端在收到客户端的内容后,向它回复:bingo!i got your msg:{content}。

    好啦,有了需求,开始动手吧!把我们之前的服务端代码略作修改:

from twisted.internet.protocol import Factory,Protocol
from twisted.internet import reactor

class gameSocket(Protocol):
    #有新用户连接至服务器
    def connectionMade(self):
        print 'New Client'
    
    #客户端断开连接
    def connectionLost(self,reason):
        print 'Lost Client'
    
    #收到客户端发送数据
    def dataReceived(self, data):
        print 'Get data:' + str(data)
        #向该客户端发送数据
        self.transport.write('bingo!i got your msg:'+ str(data))

if __name__=='__main__':
    f = Factory()
    f.protocol = gameSocket
    reactor.listenTCP(5200,f)
    print 'server started...'
    reactor.run()

    接下来,是要写一个客户端来连接它,然后用消息炸弹轰炸它!为了让客户端能高并发的测试,我选择了Stackless Python,来吧:

import socket,stackless
sockIndex = 1

def connToServer ():
    global sockIndex
    #创建一个socket连接到127.0.0.1:5200,并发送内容
    conn = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    conn.connect(("127.0.0.1", 5200))
    conn.send("hi,I'm NO."+ str(sockIndex))

    print sockIndex
    sockIndex = sockIndex + 1

    while True:
        #等待服务端返回数据,并输出
        rev = conn.recv(1024)
        print 'get server msg:' + str(rev)
        stackless.schedule()

#先来500个并发试试
for i in range(0,500):
    stackless.tasklet(connToServer)()

stackless.run()

准备就绪!开火!


    毫无压力,瞬间所有的连接全部都处理完成。那我们来加大火力,将客户端代码中的500修改为3000试试看。


    悲剧了,当客户端连接成功512个之后,服务端开始报错,难道python+Twisted如此的不堪一击?非也,经过查阅Twisted的官方文档,我们会发现,twisted默认用的是select()模式,而Windows的对文件描述符(file descriptor)有一定限制,这个限制值是512,在Linux的下这个限制为1024, 如果超过这个限制值,就会出现上面的异常。如果要在windows中有更好的表现,看来得用iocp,而linux下,用epoll则是更合适的方案,而Twisted自身就已经支持了这2种模式,看看如何启用:
windows:
from twisted.internet import iocpreactor
iocpreactor.install()

linux:
from twisted.internet import epollreactor
epollreactor.install()

    我的程序是在windows上开发的,最终部署到linux上,所以得写一个简单的判断来根据系统选择对应的模式,完整的服务端代码调整为:
import os
if os.name!='nt':
    from twisted.internet import epollreactor
    epollreactor.install()    
else:
    from twisted.internet import iocpreactor
    iocpreactor.install()
from twisted.internet.protocol import Factory,Protocol
from twisted.internet import reactor

class gameSocket(Protocol):
    #有新用户连接至服务器
    def connectionMade(self):
        print 'New Client'
    
    #客户端断开连接
    def connectionLost(self,reason):
        print 'Lost Client'
    
    #收到客户端发送数据
    def dataReceived(self, data):
        print 'Get data:' + str(data)
        #向该客户端发送数据
        self.transport.write('bingo!i got your msg:'+ str(data))

if __name__=='__main__':
    f = Factory()
    f.protocol = gameSocket
    reactor.listenTCP(5200,f)
    print 'server started...'
    reactor.run()

    我们再来试试刚才的3000个连接。


    OK,这次顺利的连接上了,在我用如上代码对工作机进行简单测试时,同时上万个连接无压力,而在实际的webgame应用环境中,达到上万个连接的可能性不大,当然,这里只是简单的连接,并未处理游戏逻辑,因此不能作为最终结论。
    不过就算单台服务器处理不过来,只要程序构架合理,我们也还可以将服务端分布到不同的服务器,所以,单从socket并发这点来看,python已经达到了我的需求。我将以以上服务端代码作为原型,来尝试开发一个webgame的服务端。

#本文由刺鸟原创,欢迎转载,但请保留出处,也欢迎对本文感兴趣的同学多多交流。#

用python来开发webgame服务端(1)

作者:ciniao 时间:2011-08-26 分类:python 8 Comments

    刺鸟原创文章,转载请注明出处
    在开始之前,先简单描述一下项目的特点:我要实现的是一个mmorpg的webgame,地图上需要看到其他的玩家,战斗系统采用半回合制的模式,所谓的半回合制,即是:采用回合制的画面布局,友方和敌方分列左右,但是战斗的中途,其他的玩家可以及时的随时插入这场战斗。当然,作为一款rpgGame,装备加工,NPC对话,任务逻辑等是必不可少的了。

    在分析了需求以后,我为这款game的程序结构定义如下:客户端,毋庸置疑肯定是flash,服务端分为两块:一是通讯不需要很及时,但是会涉及到很多逻辑处理的模块(如:各UI窗口内的逻辑,NPC对话逻辑,装备加工等),我为此选择了PHP作为服务端,二是需要及时的通讯,但是逻辑处理相对简单的模块(如:地图模块,战斗系统,聊天等),从性能上考虑,要实现这些模块,首选的当然是C、C++等,但若选择这样太底层的语言,再加上当前的人员配置,必将意味着开发周期的增加。经过讨论,在ZengRong的建议下,决定尝试使用python(我选择的版本是2.6,以下代码均基于该版本)。

    首先,要测试的是python的socket处理能力,我选择了Twisted作为网络处理库,在我的开发机(windows 2003)上安装Twisted。安装过程很easy,到pypi上找到Twisted的最新版本:http://pypi.python.org/pypi/Twisted/ 下载Twisted-11.0.0.winxp32-py2.6.msi安装即可。

测试是否安装成功:
from twisted.internet import reactor
在我的电脑上,运行该脚本后提示缺少模块:
ImportError: No module named zope.interface
http://pypi.python.org/pypi/zope.interface 下载并安装最新的zope.interface模块:zope.interface-3.7.0-py2.6-win32.egg。好吧,也许很多新手看到这个“蛋”一样的egg文件,不知如何安装,其实很简单,你需要的有以下几步:

1:先下载并运行一个叫做ez_setup.py的脚本,这个脚本会自动到网上下载相关的安装程序,提示完成后,会在python安装目录的的scripts文件下生成几个exe可执行文件。
2:将zope.interface-3.6.4-py2.6-win32.egg放到{python安装目录}\Scripts下
3:开始->运行->CMD

C:\>cd Python26\Scripts
C:\Python26\Scripts>easy_install.exe zope.interface-3.6.4-py2.6-win32.egg

安装完毕。接下来写一最简单的个socket的服务器:

from twisted.internet.protocol import Factory,Protocol
from twisted.internet import reactor
class gameSocket(Protocol):
    #有新用户连接至服务器
    def connectionMade(self):
        print 'New Client'
    
    #客户端断开连接
    def connectionLost(self,reason):
        print 'Lost Client'
    
    #收到客户端发送数据
    def dataReceived(self, data):
        print 'Get data:' + str(data)
if __name__=='__main__':
    f = Factory()
    f.protocol = gameSocket
    reactor.listenTCP(5200,f)
    print 'server started...'
    reactor.run()

    你没看错,在python的世界里,一切就是这个简单,这样就实现了一个socket服务器,监听5200端口,我们来运行它试试,看能否正常工作,作为现阶段的socket客户端,最简单的当然就是telnet了:
telnet 127.0.0.1 5200
   

   BingGo!一切正常,但是它的处理能力,并发连接等性能如何呢?一切都还需要进一步的测试,不过我们开了个好头,不是吗?

#本文由刺鸟原创,欢迎转载,但请保留出处,也欢迎对本文感兴趣的同学多多交流。#

python中列表(list)和字典(dict)数据排序

作者:ciniao 时间:2011-08-25 分类:python No Comments

对字符串列表进行排序
list_str = ['blue','allen','sophia','keen']
print list_str
list_str.sort()
print list_str

#执行结果:
['blue', 'allen', 'sophia', 'keen']
['allen', 'blue', 'keen', 'sophia']

对整型数进行排序
list_int = [34,23,2,2333,45]
print list_int
list_int.sort()
print list_int

#执行结果:
[34, 23, 2, 2333, 45]
[2, 23, 34, 45, 2333]

对字典数据进行排序
dict_str = {'blue':'5555@sina.com',
                'allen':'222@163.com',
                'sophia':'4444@gmail.com',
                'ceen':'blue@263.net'}
print dict_str
# 按照key进行排序
print sorted(dict_str.items(), key=lambda d: d[0])   
# 按照value进行排序
print sorted(dict_str.items(), key=lambda d: d[1])

#执行结果:
{'blue': '5555@sina.com', 'allen': '222@163.com', 'sophia': '4444@gmail.com', 'ceen': 'blue@263.net'}
[('allen', '222@163.com'), ('blue', '5555@sina.com'), ('ceen', 'blue@263.net'),('sophia', '4444@gmail.com')]
[('allen', '222@163.com'), ('sophia', '4444@gmail.com'), ('blue', '5555@sina.com'), ('ceen', 'blue@263.net')]

python动态导入模块、判断模块是否已安装

作者:ciniao 时间:2011-08-24 分类:python No Comments

一、动态导入模块
Python的import不能接受变量,所以应该用 __import__函数来动态导入。
如下面的代码:
t = 'time'
import t

将会报错误:ImportError: No module named t

将代码修改为如下即可:
t = 'time'
__import__(t)


二、判断模块是否已安装
模块加载后,会储存在sys.modules这个字典里,只需要在这个字典里查找,即可判断是否已安装。
print sys.modules

python中list操作详解

作者:ciniao 时间:2011-08-24 分类:python No Comments

1.定义list
>>> li = ["a", "b", "mpilgrim", "z", "example"]
>>> li
['a', 'b', 'mpilgrim', 'z', 'example']
>>> li[0]                                      
'a'
>>> li[4]                                      
'example'


2.负的list 索引
>>> li
['a', 'b', 'mpilgrim', 'z', 'example']
>>> li[-1]
'example'
>>> li[-3]
'mpilgrim'
>>> li
['a', 'b', 'mpilgrim', 'z', 'example']
>>> li[1:3] 
['b', 'mpilgrim']
>>> li[1:-1]
['b', 'mpilgrim', 'z']
>>> li[0:3] 
['a', 'b', 'mpilgrim']


3.向 list 中增加元素
>>> li
['a', 'b', 'mpilgrim', 'z', 'example']
>>> li.append("new")              
>>> li
['a', 'b', 'mpilgrim', 'z', 'example', 'new']
>>> li.insert(2, "new")           
>>> li
['a', 'b', 'new', 'mpilgrim', 'z', 'example', 'new']
>>> li.extend(["two", "elements"])
>>> li
['a', 'b', 'new', 'mpilgrim', 'z', 'example', 'new', 'two', 'elements']


4.搜索 list
>>> li
['a', 'b', 'new', 'mpilgrim', 'z', 'example', 'new', 'two', 'elements']
>>> li.index("example")
5
>>> li.index("new")    
2
>>> li.index("c")      
Traceback (innermost last):
  File "<interactive input>", line 1, in ?
ValueError: list.index(x): x not in list
>>> "c" in li          
False


5.从 list 中删除元素
>>> li
['a', 'b', 'new', 'mpilgrim', 'z', 'example', 'new', 'two', 'elements']
>>> li.remove("z")  
>>> li
['a', 'b', 'new', 'mpilgrim', 'example', 'new', 'two', 'elements']
>>> li.remove("new")
>>> li
['a', 'b', 'mpilgrim', 'example', 'new', 'two', 'elements']
>>> li.remove("c")  
Traceback (innermost last):
  File "<interactive input>", line 1, in ?
ValueError: list.remove(x): x not in list
>>> li.pop()        
'elements'
>>> li
['a', 'b', 'mpilgrim', 'example', 'new', 'two']
remove 从 list 中删除一个值的首次出现。
remove 仅仅 删除一个值的首次出现。 在这里, 'new' 在 list 中出现了两次, 但 li.remove("new") 只删除了 'new' 的首次出现。
如果在 list 中没有找到值, Python 会引发一个异常来响应 index 方法。 
pop 会做两件事: 删除 list 的最后一个元素, 然后返回删除元素的值。


6.list 运算符
>>> li = ['a', 'b', 'mpilgrim']
>>> li = li + ['example', 'new']
>>> li
['a', 'b', 'mpilgrim', 'example', 'new']
>>> li += ['two']               
>>> li
['a', 'b', 'mpilgrim', 'example', 'new', 'two']
>>> li = [1, 2] * 3             
>>> li
[1, 2, 1, 2, 1, 2]


7.使用join链接list成为字符串
>>> params = {"server":"mpilgrim", "database":"master", "uid":"sa", "pwd":"secret"}
>>> ["%s=%s" % (k, v) for k, v in params.items()]
['server=mpilgrim', 'uid=sa', 'database=master', 'pwd=secret']
>>> ";".join(["%s=%s" % (k, v) for k, v in params.items()])
'server=mpilgrim;uid=sa;database=master;pwd=secret'
join 只能用于元素是字符串的 list; 它不进行任何的类型强制转换。连接一个存在一个或多个非字符串元素的 list 将引发一个异常。


8.分割字符串
>>> li = ['server=mpilgrim', 'uid=sa', 'database=master', 'pwd=secret']
>>> s = ";".join(li)
>>> s
'server=mpilgrim;uid=sa;database=master;pwd=secret'
>>> s.split(";")   
['server=mpilgrim', 'uid=sa', 'database=master', 'pwd=secret']
>>> s.split(";", 1)
['server=mpilgrim', 'uid=sa;database=master;pwd=secret']
split 与 join 正好相反, 它将一个字符串分割成多元素 list。 
注意, 分隔符 (“;”) 被完全去掉了, 它没有在返回的 list 中的任意元素中出现。
split 接受一个可选的第二个参数, 它是要分割的次数。


9.list的映射解析
>>> li = [1, 9, 8, 4]
>>> [elem*2 for elem in li]     
[2, 18, 16, 8]
>>> li                          
[1, 9, 8, 4]
>>> li = [elem*2 for elem in li]
>>> li
[2, 18, 16, 8]


10.dictionary中的解析
>>> params = {"server":"mpilgrim", "database":"master", "uid":"sa", "pwd":"secret"}
>>> params.keys()  
['server', 'uid', 'database', 'pwd']
>>> params.values()
['mpilgrim', 'sa', 'master', 'secret']
>>> params.items()
[('server', 'mpilgrim'), ('uid', 'sa'), ('database', 'master'), ('pwd', 'secret')]
>>> [k for k, v in params.items()]               
['server', 'uid', 'database', 'pwd']
>>> [v for k, v in params.items()]               
['mpilgrim', 'sa', 'master', 'secret']
>>> ["%s=%s" % (k, v) for k, v in params.items()]
['server=mpilgrim', 'uid=sa', 'database=master', 'pwd=secret']


11.列表过滤
>>> li = ["a", "mpilgrim", "foo", "b", "c", "b", "d", "d"]
>>> [elem for elem in li if len(elem) > 1]      
['mpilgrim', 'foo']
>>> [elem for elem in li if elem != "b"]        
['a', 'mpilgrim', 'foo', 'c', 'd', 'd']
>>> [elem for elem in li if li.count(elem) == 1]
['a', 'mpilgrim', 'foo', 'c']