Flexでtwistedのソケットサーバーを試す

TwistdはコマンドであってやっぱTwistedでいいということに気がつきタイトル変更しました。

２つ前のポストからtwistdのソケットサーバーのコードを紹介したので、今回はクライアント側のFlashはどういうものかというののコードです。Flashのはまとまった奴がなかったので、Flexのです。

ポイントというかハマりどころはデリミタ（どこが１つのメッセージの終わりなのかを示すキャラクタ）です。そこのところだけ取り出すとこうです。

sock.writeMultiByte(string + "\r\n", "UTF-8");

これでいけるはず。というわけで、Flashでソケット通信やるなら、２つ前のポストのところからコピペしてもらえれば、とりあえずのプロトタイプはさくっといけるのではないかと期待しています。

twistdですが、実際に使うシーンではポリシーサーバーはそのままでも良さそうですが、チャットサーバーの方はいろいろプログラムを変更することになります。たとえばAさんとBさんで通信させ中に、CさんとDさんで通信させ、２つは混線しない、みたいなことをやるとか、もっとも基本的にはAさんが送った内容はAさんには帰って来ないで他全員にブロードキャストするとか、そういうのプログラムしていくことになります。

twistdの安定性についてですが、ちゃんと試験したことはないです。以前バッチで沢山コネクションを張って見たことがあったのですが、ほとんど記録がありません。クライアントが増えれば単に送信するデータ量が増え反応が遅くはなったと記憶しています。でも落ちたりはしなかったように思います。

些細な記憶から強烈にサバ読みも含めていえば１００コネクションくらいなら結構快適で３００コネクションあたりで遅せーなとかだったような記憶があります。それから知らない間にサーバーが落ちているということはなく、安定しているという印象を持っています。

twistd。コードも簡単だしすばらしいです。

<?xml version="1.0" encoding="utf-8"?> <mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute" width="160" height="300" backgroundColor="#FFFFFF" horizontalScrollPolicy="off" verticalScrollPolicy="off" creationComplete="init();"> <mx:Script> <![CDATA[ import mx.core.UIComponent; import mx.events.FlexEvent; import flash.net.Socket; import flash.external.ExternalInterface; [Bindable] public var sock:Socket; [Bindable] public var hostText:String = 'localhost'; [Bindable] public var portText:String = "10000"; [Bindable] private var debugText:String = ""; [Bindable] private var sendText:String = ""; [Bindable] private var receivedText:String = ""; private function init():void { if(ExternalInterface.available){ ExternalInterface.addCallback("onBeforeUnload", onBeforeUnload); } } public function onBeforeUnload():void { removeAll(); } private function connect():void { if(sock == null){ sock = new Socket(); sock.addEventListener(ProgressEvent.SOCKET_DATA,handleSocketData); sock.addEventListener(Event.CONNECT,handleSocketConnect); sock.addEventListener(Event.CLOSE,handleSocketClose); sock.addEventListener(ErrorEvent.ERROR, handleSocketError); sock.addEventListener(IOErrorEvent.IO_ERROR,handleSocketIOError); sock.addEventListener(SecurityErrorEvent.SECURITY_ERROR, handleSecurityError); sock.addEventListener(Event.DEACTIVATE, handleSocketDeactivate); sock.connect( hostText, parseInt(portText) ); } } private function handleSocketConnect(e:Event):void{ receivedText = "connected.\n"; sock.removeEventListener(Event.CONNECT,arguments.callee); } private function handleSocketClose(e:Event):void{ receivedText = "closed.\n"; removeAll(); } private function handleSocketDeactivate(e:Event):void{ receivedText = "socket deactivated.\n"; } private function handleSocketError(e:ErrorEvent):void{ receivedText = "socket error.\n"; //removeAll(); } private function handleSocketIOError(e:IOErrorEvent):void{ receivedText = "io error.\n"; //removeAll(); } private function handleSecurityError(e:SecurityErrorEvent):void{ receivedText = "security error.\n"; //removeAll(); } private function handleSocketData(e:ProgressEvent):void{ var string:String = sock.readMultiByte(sock.bytesAvailable, 'UTF-8'); receivedText += string + "\n"; } private function writeData(string:String):void{ if( sock != null && sock.connected ){ sock.writeMultiByte(string + "\r\n", "UTF-8"); sock.flush(); } } private function sendMessage():void{ if(0 < send.text.length){ writeData(send.text); } } private function disconnect():void{ if(sock != null){ sock.close(); removeAll(); receivedText = "disconnect.\n"; } } private function removeAll():void{ if(sock != null){ sock.removeEventListener(ProgressEvent.SOCKET_DATA,handleSocketData); sock.removeEventListener(Event.CONNECT,handleSocketConnect); sock.removeEventListener(Event.CLOSE,handleSocketClose); sock.removeEventListener(ErrorEvent.ERROR, handleSocketError); sock.removeEventListener(IOErrorEvent.IO_ERROR,handleSocketIOError); sock.removeEventListener(SecurityErrorEvent.SECURITY_ERROR, handleSecurityError); if(sock.connected) sock.close(); sock = null; } } ]]> </mx:Script> <mx:Canvas id="mainCanvas" width="100%" height="100%" horizontalScrollPolicy="off" verticalScrollPolicy="off"> <mx:TextInput id="send" x="10" y="100" width="140" text="{sendText}"/> <mx:TextArea id="received" x="10" y="160" width="140" height="127" text="{receivedText}"/> <mx:TextInput id="host" x="10" y="10" width="140" text="{hostText}"/> <mx:TextInput id="port" x="10" y="40" width="140" text="{portText}"/> <mx:Button x="10" y="70" label="接続" width="65" click="connect();"/> <mx:Button x="83" y="70" label="解除" width="65" click="disconnect();"/> <mx:Button x="10" y="130" label="送信" width="140" click="sendMessage();"/> </mx:Canvas> </mx:Application>