Twisted+Flex实现简单MMORPG的DEMO

服务端 server.py

# -*- coding: UTF-8 -*-
  #Twisted MMORPG
  from twisted.internet.protocol import Factory
  from twisted.protocols.basic import LineOnlyReceiver
  from twisted.internet import reactor
  import random
  import string

  class Game(LineOnlyReceiver):
     def lineReceived(self, data):
         self.factory.sendAll("%s" % (data))
     def getId(self):
         return str(self.transport.getPeer())
     def connectionMade(self):
         print "New User Login:", self.getId()
         self.transport.write("欢迎来到MMO世界！\n")
         self.factory.addClient(self)
     def connectionLost(self, reason):
         self.factory.delClient(self)

class GameFactory(Factory):
     protocol = Game
     def __init__(self):
         self.clients = []
         self.player = []
         self.msg=''
         self.x = range(100,700)
         self.y = range(100,500)
     def getPlayerId(self):
         return len(self.player)
     def addClient(self, newclient):
            self.clients.append(newclient)
     def delClient(self, client):
         self.clients.remove(client)
     def sendAll(self, data):
         #print data
         if data.find('')!=-1:
             proto.transport.write('\0')
         else:
             arr = data.split(':')
             prefix = arr[0]
             content = arr[1]
             if prefix.find('player')!=-1:
                  newPlayer = [content,str(random.randrange(200, 600)),str(random.randrange(150,350)),str(random.randrange(1,5))]
                  self.player.append(newPlayer)
                  self.msg = ' 玩家 '+content+' 进入游戏!'
                  #广播所有玩家的位置
                  temp = []
                  playerData = ':::'
                  for pos in self.player:
                      temp.append(string.join(pos,'---'))
                  playerData = playerData+string.join(temp,'***')
                  for proto in self.clients:
                      proto.transport.write('[系统]: '+self.msg+'\n')
                      proto.transport.write(playerData)
             elif prefix.find('pos')!=-1:
                 playerName,x,y = content.split('---')
                 i = 0
                 for p in self.player:
                     if p[0]==playerName:
                         p[1]=x
                         p[2]=y
                 for proto in self.clients:
                     proto.transport.write(data)
             else:
                 self.msg = data
                 for proto in self.clients:
                      proto.transport.write(self.msg+'\n')

reactor.listenTCP(8006, GameFactory())
reactor.run()

客户端 client.mxml

 

width="850" height="510" horizontalScrollPolicy="off" verticalScrollPolicy="off" applicationComplete="init();">





import mx.containers.Canvas;

import mx.controls.Alert;

import mx.controls.TextArea;

import flash.net.Socket;

import flash.utils.ByteArray;

import flash.events.SecurityErrorEvent;

import flash.events.IOErrorEvent;

import flash.events.ProgressEvent;

import mx.controls.Image;

import mx.effects.Move;



public var oSocket:Socket = new Socket();

[Bindable]

public var nickName:String = '';

//初始化，监听SOCKET事件

private function init():void {

//监听socket事件

oSocket.addEventListener(Event.CLOSE,fooClosed);

oSocket.addEventListener(Event.CONNECT,fooConnected);

oSocket.addEventListener(IOErrorEvent.IO_ERROR,fooError);

oSocket.addEventListener(SecurityErrorEvent.SECURITY_ERROR,fooSecurity);

oSocket.addEventListener(ProgressEvent.SOCKET_DATA,fooGetData);

}



//连接关闭事件响应

public function fooClosed(e:Event):void{

Alert.show('连接已断开！','Disconnected');

game.setVisible(false);

login.setVisible(true);

}

//登陆状态事件响应

public function fooConnected(e:Event):void{

text_c.setVisible(false);

btn_connect.enabled = true;

login.setVisible(false);

game.setVisible(true);

}



//SOCKET错误事件响应

public function fooError(e:IOErrorEvent):void{

Alert.show('IO错误：'+e.text,'Socket connect Error');

text_c.text = 'Socket connect Error!';

btn_connect.enabled = true;

}



//安全沙箱事件响应

public function fooSecurity(e:SecurityErrorEvent):void{

Alert.show('安全错误：'+e.text,'Security Error');

text_c.text = 'Security Error!';

btn_connect.enabled = true;

}



//从服务端获取返回信息并根据不同的协议号进行不同的处理

public function fooGetData(erogressEvent):void{

var aMsg:Array = [];

while(oSocket.bytesAvailable){

aMsg.push(oSocket.readMultiByte(oSocket.bytesAvailable,'utf-8'));

}

var sMsg:String = aMsg.join('').replace(/\r/g,'');

if(sMsg.indexOf(':::')!=-1){

var Arr:Array;

var Arr1:String ;

var Arr2:Array ;

var play:Array ;

var i:int;

Arr = sMsg.split(':::');

fooShowMsg(Arr[0]);

Arr1 = Arr[1]

Arr2 = Arr1.split('***');

for(i=0;i

play = Arr2.split('---');



//检查玩家是否已存在

var tempObj:Object = game.getChildByName(play[0]);

if(tempObj == null){

//画玩家容器

var people:Canvas = new Canvas();

people.name = play[0];

people.id = play[0];

people.x = play[1];

people.y = play[2];

people.width = 80;

people.height = 100;

game.addChild(people);



//画玩家名字

var playerNameabel = new Label();

playerName.text = play[0];

playerName.x = 15;

playerName.y = 5;

people.addChild(playerName);



//画玩家图片

var player:Image = new Image();

player.name = 'img'+play[0];

player.id= 'img'+play[0];

player.x = 10;

player.y = 20;

player.width = 64;

player.height = 64;

player.source = '../images/'+play[3]+'.png';

people.addChild(player);



//如果是自己，标注坐标

if(play[0]==nickName){

pos.text = '当前坐标：（'+play[1]+','+play[2]+')';

}

}





}

}else if(sMsg.indexOf('pos')!=-1){

//玩家移动

var arr:Array;

var arr2:Array;

arr = sMsg.split(':');

arr2 = arr[1].split('---');

if(arr2[0]==nickName){

//自己不用处理

}else{

//移动

var thePlayer:Object = game.getChildByName(arr2[0]);

moveTo(thePlayer,arr2[1],arr2[2])

}

}else{

fooShowMsg(sMsg);

}

}



//显示聊天信息

public function fooShowMsg(sMsg:String):void{

var sTemp:String = msg.text;

msg.text = sTemp+sMsg;

//聊天框自动滚动到最下面

msg.verticalScrollPosition = msg.maxVerticalScrollPosition;

}

//发送信息到服务端

public function fooCommand(sMsg:String):void{

var bMsg:ByteArray = new ByteArray();

if(sMsg.length>0){

bMsg.writeUTFBytes(sMsg+'');

oSocket.writeBytes(bMsg);

oSocket.flush();

}

}



//发送聊天

public function sendChat(msg:String):void{

var tempMsg:String = '['+nickName+']: '+msg;

fooCommand(tempMsg);

input.text='';

}



//登陆连接游戏

public function fooConnect():void{

var sIP:String = ip_text.text;

var sPort:Number = Number(port_text.text);

var sUser:String = user_text.text;

var sCode:String = code_text.text;

var sPlayer:String = user_name.text;

if(!(sIP&&sPort)){

Alert.show('服务器地址和端口号必填！','Warning:');

}else{

text_c.text = 'Connecting......';

text_c.setVisible(true);

btn_connect.enabled = false;

oSocket.connect(sIP,sPort);

if(sUser) fooCommand('user '+sUser);

if(sCode) fooCommand('pass '+sCode);

if(sPlayer) fooCommand('player:'+sPlayer);

nickName = user_name.text;

}

}



//断开链接，退出游戏

public function fooDisConnect():void{

oSocket.close();

game.setVisible(false);

login.setVisible(true);

}



//玩家移动自己

private function movePlayer():void {

var x:int = mou***-64;

var y:int = mouseY-90;

if(y<43){

y = 43;

}

if(y>255 && x<195){

return;

}

//发送最新坐标给服务端

fooCommand('pos:'+nickName+'---'+x+'---'+y);

pos.text = '当前坐标：（'+x+','+y+')';

var mySelf:Object = game.getChildByName(nickName);

moveTo(mySelf,x,y);

}



//移动玩家

private function moveTo(obj:Object,x:int,y:int):void{

var move:Move = new Move(obj);

move.duration = 1000;

move.xTo = x;

move.yTo = y;

move.play();

}

]]>