源地址:http://bbs.9miao.com/thread-45790-1-2.html

本例演示的是模拟游戏服务端,让角色在场景1中跳转到场景2中。在实际游戏中,client将要跳转的角色id和目标场景id发给net,net转发给gate,gate将目标场景id与角色当前所在场景id进行对比,一样则返回跳转失败,不一样则在目标场景服务器重新实例化一个角色,然后将之前的场景服务器中的角色实例删除。因为此次只是掩饰原理,所以实际中的各种验证等就不进行处理了,有问题可以在论坛发帖探讨。

1.创建工程

命令行下输入firefly-admin.py createproject communication(linux在终端输入)

<ignore_js_op>

firefly会创建一个名为communication的工程

<ignore_js_op>

2.导入工程

将工程导入到eclipse中

<ignore_js_op>

3.配置参数

配置config.json中的相应参数

  1. {
  2. "master":{"rootport":8999,"webport":9998},
  3. "servers":{
  4. "gate":{"rootport":10000,"name":"gate","app":"app.gate.gateserver"},
  5. "net":{"netport":11009,"name":"net","remoteport":[{"rootport":10000,"rootname":"gate"}],"app":"app.net.netserver"},
  6. "scene1":{"remoteport":[{"rootport":10000,"rootname":"gate"}],"name":"scene1","app":"app.scene.sceneserver"},
  7. "scene2":{"remoteport":[{"rootport":10000,"rootname":"gate"}],"name":"scene2","app":"app.scene.sceneserver"}
  8. },
  9. "db":{
  10. "host":"localhost",
  11. "user":"root",
  12. "passwd":"111",
  13. "port":3306,
  14. "db":"anheisg",
  15. "charset":"utf8"
  16. },
  17. "memcached":{
  18. "urls":["127.0.0.1:11211"],
  19. "hostname":"test"
  20. }
  21. }

复制代码

具体参数含义和配置说明详见:http://bbs.9miao.com/forum.php?m ... 6orderby%3Ddateline

4.编写代码

在上面填写的server配置的app对应路径下分别建立netserver.py、gateserver.py和sceneserver.py,这里只列出了几个重要文件,其他如User.py、UserManager.pu等详见附件。

1)netserver.py:

  1. #coding:utf8
  2. from firefly.server.globalobject import netserviceHandle,GlobalObject
  3. @netserviceHandle
  4. def login_1004(_conn,data):
  5. data = eval(data)#客户端传来的number是str型,转换成dict型
  6. pid = data.get("pid")#获取pid
  7. sid = data.get("sid")#获取sid
  8. result = GlobalObject().remote['gate'].callRemote("enterScene_1003",pid,sid)#调用root服务器(gate)的enterScene_1003方法,参数为pid,sid
  9. return result#返回结果

复制代码

2)gateserver.py:

  1. #coding:utf8
  2. from User import User
  3. from UserManager import UserManager
  4. from firefly.server.globalobject import GlobalObject,rootserviceHandle
  5. @rootserviceHandle
  6. def enterScene_1003(pid,sid):
  7. '''进入场景
  8. @param pid: int 角色id
  9. @param sid: str 要跳转的场景id
  10. '''
  11. if not UserManager().isHaveUser(pid):#如果用户管理器中没有该用户
  12. user = User(pid,sid)#实例化角色
  13. UserManager().addUser(user)#添加到用户管理器中
  14. result = GlobalObject().root.callChildByName(sid,"enterScene_1001",pid,sid)#调用node服务器(sid)的enterScene_1001方法,参数为pid,sid
  15. return result#返回结果
  16. else:#如果用户管理器中有该用户
  17. user = UserManager().getUser(pid)#获取该用户实例
  18. nowSid = user.sid#用户当前所在场景id
  19. if nowSid == sid:#用户当前所在场景id与要跳转的场景id相同
  20. return "Failure"#返回失败信息
  21. else:#否则
  22. result1 = GlobalObject().root.callChildByName(sid,"enterScene_1001",pid,sid)#调用node服务器(sid)的enterScene_1001方法,参数为pid,sid
  23. GlobalObject().root.callChildByName(nowSid,"deletePlayer_1002",pid)#调用node服务器(nowSid)的deletePlayer_1002方法,参数为pid
  24. UserManager().updateSid(pid, sid)#更新用户前所在场景id
  25. return result1#返回结果

复制代码

3)sceneserver.py

  1. #coding:utf8
  2. from firefly.server.globalobject import remoteserviceHandle
  3. from Player import Player
  4. from PlayersManager import PlayersManager
  5. @remoteserviceHandle("gate")
  6. def enterScene_1001(pid,sid):
  7. '''进入场景'''
  8. player = Player(pid,sid)#实例化角色实例
  9. PlayersManager().addPlayer(player)#将角色添加到角色管理器中
  10. return "I'm now at %s" % sid#返回跳转成功信息
  11. @remoteserviceHandle("gate")
  12. def deletePlayer_1002(pid):
  13. '''删除角色实例
  14. '''
  15. if PlayersManager().isHavePlayer(pid):#如果角色管理器中有该角色
  16. user = PlayersManager().getPlayer(pid)#获取该角色实例
  17. sid = user.sid#获取角色所在场景实例
  18. PlayersManager().dropPlayer(pid)#从角色管理器中删除该角色
  19. print 'I left %s' % sid

复制代码

4)最后编写客户端——client.py:

  1. #coding:utf8
  2. from socket import AF_INET,SOCK_STREAM,socket
  3. import struct
  4. import time
  5. def sendData(sendstr,commandId):
  6. '''定义协议头
  7. '''
  8. HEAD_0 = chr(0)
  9. HEAD_1 = chr(0)
  10. HEAD_2 = chr(0)
  11. HEAD_3 = chr(0)
  12. ProtoVersion = chr(0)
  13. ServerVersion = 0
  14. sendstr = sendstr
  15. data = struct.pack('!sssss3I',HEAD_0,HEAD_1,HEAD_2,\
  16. HEAD_3,ProtoVersion,ServerVersion,\
  17. len(sendstr)+4,commandId)
  18. senddata = data+sendstr
  19. return senddata
  20. def resolveRecvdata(data):
  21. '''解析数据,根据定义的协议头解析服务器返回的数据
  22. '''
  23. head = struct.unpack('!sssss3I',data[:17])
  24. lenght = head[6]
  25. message = data[17:17+lenght]
  26. return message
  27. if __name__ == "__main__":
  28. HOST='localhost'
  29. PORT=11009
  30. ADDR=(HOST , PORT)
  31. client = socket(AF_INET,SOCK_STREAM)
  32. client.connect(ADDR)#建立socket连接
  33. client.sendall(sendData("{'pid':100001,'sid':'scene1'}",1004))#向服务器发送消息
  34. message = client.recv(1024)#接收服务器返回的消息
  35. message = resolveRecvdata(message)#解析消息
  36. print message
  37. time.sleep(3)
  38. client.sendall(sendData("{'pid':100001,'sid':'scene2'}",1004))#向服务器发送消息
  39. message = client.recv(1024)#接收服务器返回的消息
  40. message = resolveRecvdata(message)#解析消息
  41. print message
  42. time.sleep(3)
  43. client.sendall(sendData("{'pid':100001,'sid':'scene2'}",1004))#向服务器发送消息
  44. message = client.recv(1024)#接收服务器返回的消息
  45. message = resolveRecvdata(message)#解析消息
  46. print message
  47. client.close()

复制代码

5.运行程序

1)运行服务器,打开附件下载的communication文件夹,打开命令行窗口,输入python startmaster.py,回车,如图:

<ignore_js_op>

2)运行客户端,第一次登陆时,角色进入了场景1,成功;第二次由场景1台转到场景2,成功;第三次由场景2跳转到场景2,失败。

<ignore_js_op>

最新文章

  1. 一个小型的CMS后台管理平台发布啦~
  2. Android性能优化之UncaughtExceptionHandler定制自己的错误日志系统
  3. sql语句 之聚合函数
  4. HoloLens开发手记 - Vuforia开发概述 Vuforia development overview
  5. POJ 2635 The Embarrassed Cryptographer
  6. Tomcat热部署方法(3种)【转】
  7. angularjs中展示富文本编辑器文本,向DOM中插入元素
  8. [win]AD域组策略wifi自动配置
  9. 1874 素数和最大 - Wikioi
  10. 当可以设置src时,不必发ajax请求,如果没有参数设置src即可
  11. django: db - display
  12. 判断Table表中是否含有某一列
  13. 通过Web Api 和 Angular.js 构建单页面的web 程序
  14. MyEclipse的Expressions没有结果的解决办法
  15. java数据库编程之事务、视图、索引、备份、恢复
  16. db2服务器端授权
  17. SpringMVC源码情操陶冶-AbstractUrlHandlerMapping
  18. 关于String类型中==和equals的区别。
  19. jquery validate 校验使用总结
  20. SpringMVC学习 十三 拦截器栈

热门文章

  1. 函数 datediff(根据objid 获取同name 同年度最近的4条记录)
  2. Android应用源码基于安卓的校园二手交易系统客户端+服务端+数据库
  3. 关于web请求中 获取真实IP
  4. 8个应该去逛逛JQuery的学习网站
  5. C++ 的template
  6. bzoj 1040 骑士
  7. [java学习笔记]java语言核心----面向对象之static关键字
  8. 【转载】分享下多年积累的对JAVA程序员成长之路的总结
  9. 3dmax详细讲解全套攻略在线视频教程
  10. [转]主键冲突的话就更新否则插入 (ON DUPLICATE KEY UPDATE )