Flex Socket Communication

Flex Socket Communication：

<?xml version="1.0" encoding="utf-8"?>
<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute" creationComplete="init()">
<mx:Script>
	<![CDATA[
		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;
		
		public var oSocket:Socket = new Socket();
		
		public function init():void{
			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');
			msg_box.text = '';
			panel_2.setVisible(false);
			panel_1.setVisible(true);
		}
		public function fooConnected(e:Event):void{
			text_c.setVisible(false);
			btn_connect.enabled = true;
			panel_1.setVisible(false);
			panel_2.setVisible(true);
			fooShowMsg('连接已建立！');
		}
		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(e:ProgressEvent):void{
			var aMsg:Array = [];
			while(oSocket.bytesAvailable){
				aMsg.push(oSocket.readMultiByte(oSocket.bytesAvailable,'utf8'));
			}
			var sMsg:String = aMsg.join('').replace(/\r/g,'');
			fooShowMsg(sMsg);
		}
		public function fooShowMsg(sMsg:String):void{
			var sTemp:String = msg_box.text;
			msg_box.text = sMsg+'\n'+sTemp;
		}
		public function fooCommand(sMsg:String):void{
			var bMsg:ByteArray = new ByteArray();
			bMsg.writeUTFBytes(sMsg+'\r\n');
			oSocket.writeBytes(bMsg);
			oSocket.flush();
		}
		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;
			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);
			}
		}
		public function fooDisConnect():void{
			oSocket.close();
			msg_box.text = '';
			panel_2.setVisible(false);
			panel_1.setVisible(true);
		}
	]]>
</mx:Script>
	<mx:Panel width="382" height="232" layout="absolute" title="Socket communication" horizontalCenter="0" verticalCenter="-78" id="panel_1">
		<mx:Label x="10" y="24" text="服务器地址：*" width="95" fontSize="12" textAlign="right"/>
		<mx:Label x="10" y="52" text="端口：*" width="95" fontSize="12" textAlign="right"/>
		<mx:Label x="10" y="80" text="用户名：" width="95" fontSize="12" textAlign="right"/>
		<mx:Label x="10" y="108" text="密码：" fontSize="12" width="95" textAlign="right"/>
		<mx:Button x="123" y="158" label="连接" fontSize="12" width="116" id="btn_connect" click="fooConnect()"/>
		<mx:TextInput x="120.5" y="24" width="170" borderStyle="inset" borderColor="#B7BABC" id="ip_text"/>
		<mx:TextInput x="120.5" y="52" width="170" id="port_text"/>
		<mx:TextInput x="120.5" y="80" width="170" id="user_text"/>
		<mx:TextInput x="120.5" y="108" width="170" displayAsPassword="true" id="code_text"/>
		<mx:Text x="120" y="138" text="Connecting......" width="170.5" color="#16AD21" id="text_c" visible="false"/>
	</mx:Panel>
	<mx:Panel x="10" y="10" width="712" height="373" layout="absolute" title="Message box" id="panel_2" visible="false">
		<mx:TextInput x="342" y="301" id="msg_text"/>
		<mx:Button x="510" y="299" label="发送指令" fontSize="12" id="btn_command" click="fooCommand(msg_text.text)"/>
		<mx:Button x="604" y="299" label="断开连接" fontSize="12" id="btn_disconnect" click="fooDisConnect()"/>
		<mx:TextArea x="10" y="10" width="672" height="272" fontSize="12" id="msg_box" editable="false"/>
	</mx:Panel>
	
</mx:Application>

843.php：

<?php
// Server
// 设置错误处理
error_reporting(E_ALL);
// 设置运行时间
set_time_limit(0);
// 启用缓冲
ob_implicit_flush();
// IP地址
$ip = "10.1.1.74";
// 端口号
$port = 843;
// 创建SOCKET
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("socket_create failed.\n");
//SO_REUSEADDR 允许重用本地地址和端口，使得在使用http方式运行时，服务端关闭后，避免重开时产生端口已被占用的错误！
socket_set_option($socket,SOL_SOCKET,SO_REUSEADDR,1) or die("socket_set_option failed.\n");
// 绑定SOCKET
$bind = socket_bind($socket, $ip, $port) or die("socket_bind failed.\n");
// 监听SOCKET
socket_listen($socket);
//监听中...
while(true){
    $client = socket_accept($socket);// 接受Client
    if(!$client){
        echo "socket_accept() failed.\n";
        break;
    }
	if(socket_getpeername($client,$ip,$port)){
		echo $ip.":".$port." connected\n";
	}
    while(true){
		if(!($command = socket_read($client, 1024, PHP_BINARY_READ))) break;//接收客户端数据
		$command = strtoupper(trim($command));
        if($command=="<POLICY-FILE-REQUEST/>"){
				$writer = "<?xml version=\"1.0\"?><cross-domain-policy><site-control permitted-cross-domain-policies=\"all\"/><allow-access-from domain=\"*\" to-ports=\"*\"/></cross-domain-policy>\0";
				socket_write($client, $writer, strlen($writer));
				break;
		}
    }
	echo $ip.":".$port." diconnected\n";
    socket_close($client);
}
socket_close($socket);// 关闭端口
?>

20156.php：

<?php
// Server
// 设置错误处理
error_reporting(E_ALL);
// 设置运行时间
set_time_limit(0);
// 启用缓冲
ob_implicit_flush();
// IP地址
$ip = "10.1.1.74";
// 端口号
$port = 20156;
// 创建SOCKET
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("socket_create failed.\n");
//SO_REUSEADDR 允许重用本地地址和端口，使得在使用http方式运行时，服务端关闭后，避免重开时产生端口已被占用的错误！
socket_set_option($socket,SOL_SOCKET,SO_REUSEADDR,1) or die("socket_set_option failed.\n");
// 绑定SOCKET
$bind = socket_bind($socket, $ip, $port) or die("socket_bind failed.\n");
// 监听SOCKET
socket_listen($socket);
//多用户连接
$clients = array($socket);
//监听中...
while(true){
	$read = $clients;
	if(socket_select($read, $write = NULL, $except = NULL, 0) < 1){
		continue;
	}
	if(in_array($socket, $read)){
		$clients[] = $client = socket_accept($socket);
		if(socket_getpeername($client,$ip,$port)){
			echo $ip.":".$port." connected\n";
		}
		$key = array_search($socket, $read);
		unset($read[$key]);
	}
	foreach($read as $read_sock){
		$data = socket_read($read_sock, 1024, PHP_BINARY_READ);
		$data = trim($data);
		socket_getpeername($read_sock,$ip,$port);
		if($data==false){
			$key = array_search($read_sock, $clients);
			echo $ip.":".$port." diconnected\n";
			unset($clients[$key]);
			continue;
		}else{
			socket_write($$read_sock, $data."\0", strlen($data));
			foreach($clients as $send_sock){
				socket_write($send_sock, $data."\0", strlen($data));
			}
		}
	}
}
socket_close($socket);// 关闭端口
?>