flex与twisted通过socket通信

　　flex端代码    Array = []; while(oSocket.bytesAvailable){ aMsg.push(oSocket.readMultiByte(oSocket.bytesAvail able,'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;iArray; 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+''); bMsg.writeUTFBytes('\r\n'); oSocket.writeBytes(bMsg); oSocket.flush(); } } //发送聊天 public function sendChat(msg:String):void{ var tempMsg:String = '['+nickName+']: '+msg; fooCommand(tempMsg); input.text=''; Alert.show("aaa") } //登陆连接游戏 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 = mouseX-64; var y:int = mouseY-90; if(y255 && x                      twisted端代码 # -*- 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("\0") 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: self.clients[0].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, '***') self.clients[0].transport.write('[系统]: ' + self.msg + '\n') self.clients[0].transport.write(playerData) elif prefix.find('pos') != -1: playerName, x, y = content.split('---') i = 0 for p in self.player: if p[i][0] == playerName: p[i][1] = x p[i][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(8555, GameFactory()) reactor.run()  以上代码通过服务器端直接将 crossdomain的内容返回到flex中。 上一篇文章已经介绍过，flex会先请求843这个端口下是否会返回crossdomain的信息因此可以通过部署端口为843的服务在解决flex跨域（8043 安全沙箱的问题）的问题
　　843端口的服务代码为： from twisted.internet import reactor from twisted.internet.protocol import Factory, Protocol class PolicySocketProtocol(Protocol): def dataReceived(self, data): self.transport.write("\0") class PolicyFactory(Factory): def __init__(self): self.protocol = PolicySocketProtocol; if __name__ == '__main__': reactor.listenTCP(843, PolicyFactory(), interface="127.0.0.1") reactor.run()