Pour les besoins d’Expantion, j’ai du modifier le serveur de socket Oregano. La première chose que j’ai modifié, est l’intégration du patch de Jens Halm sur le problème de connections persistantes. La deuxième chose concerne l’ajout d’un port d’admin pouvant être attaqué depuis le serveur par différents langages. La problématique que j’avais était la suivante. Expantion étant partiellement un jeu au tour par tour, j’avais besoin qu’a la fin du calcule du tour, le serveur puisse pusher certaines info aux clients flash connectés. J’avais également besoin de pouvoir pusher de la même façon n’importe quoi à n’importe quel moment. Par exemple si j’ai envie de faire tomber la nuit d’un coup. Pour cela cette version d’oregano a un nouveau port d’ouvert, le 1890. Ce port est de type telnet et attend une connexion. Une fois la connexion établie, il attend un message et coupe la connexion après réception de celui-ci. Les messages sont du type suivant :

serverEvent monEvent

Ici monEvent va etre dispatché à tous les joueurs connectés à oregano via org.omus.msg.Messenger.

Coté flash il ne reste plus qu’a implémenter un comportement en rapport avec monEvent.

Trêve de blabla, voici un exemple concret : Pour la partie cliente, j’ai créé une classe qui va se charger d’établir la connexion avec oregano en PHP.

@@<?php /* OreganoAdmin 0.1 by David Mouton based on PHPTELNET class by Antone Roundy public domain */ class OreganoAdmin { 	var $show_connect_error=1; 	var $use_usleep=0;	// change to 1 for faster execution 		// don't change to 1 on Windows servers unless you have PHP 5 	var $sleeptime=125000; 	var $loginsleeptime=1000000; 	var $fp=NULL; 	var $loginprompt; 	var $conn1; 	var $conn2; 	/* 	0 = success 	1 = couldn't open network connection 	2 = unknown host 	3 = login failed 	4 = PHP version too low 	*/ 	function Connect($server,$port) { 		$rv=0; 		$vers=explode('.',PHP_VERSION); 		$needvers=array(4,3,0); 		$j=count($vers); 		$k=count($needvers); 		if ($k<$j) $j=$k; 		for ($i=0;$i<$j;$i++) { 			if (($vers$i+0)>$needvers$i) break; 			if (($vers$i+0)<$needvers$i) { 				$this->ConnectError(4); 				return 4; 			} 		} 		$this->Disconnect(); 		if (strlen($server)) { 			if (preg_match('/^0-9./',$server)) { 				$ip=gethostbyname($server); 				if ($ip==$server) { 					$ip=''; 					$rv=2; 				} 			} else $ip=$server; 		} else $ip='127.0.0.1'; 		if (strlen($ip)) { 			if ($this->fp=fsockopen($ip,$port)) { 			} else $rv=1; 		} 		if ($rv) $this->ConnectError($rv); 		return $rv; 	} 	function Disconnect($exit=1) { 		if ($this->fp) { 			if ($exit) $this->DoCommand('exit',$junk); 			fclose($this->fp); 			$this->fp=NULL; 		} 	} 	function DoCommand($c,&$r) { 		if ($this->fp) { 			fputs($this->fp,"$c\r"); 			$this->Sleep(); 			$this->GetResponse($r); 			$r=preg_replace("/^.*?\n(.*)\n^\n*$/","$1",$r); 		} 		return $this->fp?1:0; 	} 	function GetResponse(&$r) { 		$r=''; 		do { 			$r.=fread($this->fp,1000); 			$s=socket_get_status($this->fp); 		} while ($s'unread_bytes'); 	} 	function Sleep() { 		if ($this->use_usleep) usleep($this->sleeptime); 		else sleep(1); 	} 	function OreganoAdmin() { 		$this->conn1=chr(0xFF).chr(0xFB).chr(0x1F).chr(0xFF).chr(0xFB). 			chr(0x20).chr(0xFF).chr(0xFB).chr(0x18).chr(0xFF).chr(0xFB). 			chr(0x27).chr(0xFF).chr(0xFD).chr(0x01).chr(0xFF).chr(0xFB). 			chr(0x03).chr(0xFF).chr(0xFD).chr(0x03).chr(0xFF).chr(0xFC). 			chr(0x23).chr(0xFF).chr(0xFC).chr(0x24).chr(0xFF).chr(0xFA). 			chr(0x1F).chr(0x00).chr(0x50).chr(0x00).chr(0x18).chr(0xFF). 			chr(0xF0).chr(0xFF).chr(0xFA).chr(0x20).chr(0x00).chr(0x33). 			chr(0x38).chr(0x34).chr(0x30).chr(0x30).chr(0x2C).chr(0x33). 			chr(0x38).chr(0x34).chr(0x30).chr(0x30).chr(0xFF).chr(0xF0). 			chr(0xFF).chr(0xFA).chr(0x27).chr(0x00).chr(0xFF).chr(0xF0). 			chr(0xFF).chr(0xFA).chr(0x18).chr(0x00).chr(0x58).chr(0x54). 			chr(0x45).chr(0x52).chr(0x4D).chr(0xFF).chr(0xF0); 		$this->conn2=chr(0xFF).chr(0xFC).chr(0x01).chr(0xFF).chr(0xFC). 			chr(0x22).chr(0xFF).chr(0xFE).chr(0x05).chr(0xFF).chr(0xFC).chr(0x21); 	} 	function ConnectError($num) { 		if ($this->show_connect_error) switch ($num) { 		case 1: echo '<br />PHP Telnet <a href="http://www.geckotribe.com/php-telnet/errors/fsockopen.php">Connect failed: Unable to open network connection</a><br />'; break; 		case 2: echo '<br />PHP Telnet <a href="http://www.geckotribe.com/php-telnet/errors/unknown-host.php">Connect failed: Unknown host</a><br />'; break; 		case 3: echo '<br />PHP Telnet <a href="http://www.geckotribe.com/php-telnet/errors/login.php">Connect failed: Login failed</a><br />'; break; 		case 4: echo '<br />PHP Telnet <a href="http://www.geckotribe.com/php-telnet/errors/php-version.php">Connect failed: Your server\'s PHP version is too low for PHP Telnet</a><br />'; break; 		} 	} } ?>@@

Une application PHP va s’écrire comme ceci :

@@<?php require_once "OreganoAdmin.php"; $telnet = new OreganoAdmin(); $result = $telnet->Connect('127.0.0.1','1890'); echo $result; if ($result == 0) { $telnet->DoCommand('serverEvent KICKALL', $result); echo $result; } ?>@@

Enfin coté client flash nous allons faire ceci pour intercepter l’évent et le traiter :

@@public function init():Void{ 		trace("OreganoUtils : Initialisation"); 		//On ecoute le messager 		var ecouteur:Object = ; 		ecouteur.onMessage = Delegate.create(this,receiveMessage); 		Messenger.getInstance().addListener(ecouteur); 	} private function receiveMessage(recepMsg:Message):Void{ 		trace("OreganoUtils : Receiving message..."); 		if(recepMsg.getSubject() == "KICKALL"){ 			trace("OreganoUtils : Reception d'un status : KICKALL"); 			//DO ACTION HERE 		} 	}@@

Je proposerais prochainement une version plus élaborée du système, plus dynamique au niveau de Oregano, comme la possibilité de configurer la chose, celle de faire des extensions, etc …

Telecharger archive RAR

This entry was posted on Lundi, septembre 24th, 2007 at 10 h 18 min and is filed under Divers. You can follow any responses to this entry through the RSS 2.0 feed. You can leave a response, or trackback from your own site.