Kód: Vybrať všetko

<?php
//potrebné pre knižnicu Ratchet
require __DIR__ . '/vendor/autoload.php';
use Ratchet\Server\IoServer;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

$server = IoServer::factory(new ClientConnection(), 8080); //prijímaj pripojenia na porte 8080, predávaj ich instanciám triedy ClientConnection
$server->run(); //očakávaj pripojenia

$queue = array(); //do $queue sa budú ukladať pripojenia a ich nastavenia čo sa týka hry ktorú chcú hrať
class ClientConnection implements MessageComponentInterface {
	public function onOpen(ConnectionInterface $conn) {
		$conn->send(json_encode(array("status" => "Connected"))); //informuj klienta správou, že sme prijali pripojenie
		array_push($queue, array("connection" => $conn)); //ulož si klienta v zozname
    }

    public function onMessage(ConnectionInterface $from, $msg) {
		$arr = json_decode($msg, true); //dekóduj JSON dáta
		if($arr['action']=="find") { //klient chce začať vyhľadávať hráčov na spárovanie
			$from->send(json_encode(array("status" => "Looking for match"))); //začíname hľadať
			//hľadaj zhodu na spárovanie v $queue
			$from->send(json_encode(array("status" => "Match found"))); //ak sme našli zhodu, informuj klienta
                        //pošli informácie o zhode klientovi
                        //ak sa zhoda nenašla, neinformuj klienta pokým sa nenájde
			for(...) {
				if(/*ľudia ktorí hľadajú spoločnú hru (v istom limite)*/)
					$queue[$i]['connection']->send(array("status" => "Match found"))); /*informuj o nájdení zhody*/
			}
		} else if($arr['action']=="cancel") { //klient chce byť vymazaný zo zoznamu čakajúcich
			//vymaž z queue
			for($i = count($queue);i > 0;i--) {
				if($queue[i]['ip']==/*nejaký identifikátor, najlepšie niečo unikátne v hashi*/)
				unset($queue[i]);
				break;
			}
		}
    }

    public function onClose(ConnectionInterface $conn) {
		/*vymaž z $queue*/
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
		/*ak sa dá, upozorni, a vymaž z queue*/
    }
}
?>

Kód: Vybrať všetko

var socket;
$("#search").click(function() { //po kliknutí na tlačidlo vyhľadávať sa ...
	var socket = new WebSocket("ws://serv.er:8080/server"); //pripoj sa na server na port 8080
	socket.onopen = function() {
		//stav sa môže niekde uložiť
	}
	socket.onmessage = function(msg) { //dostali sme správu od serveru
		var response = JSON.parse(msg); //nebodaj nám konečne našiel nejakú zhodu?
		if(response.status=="Connected") { //nie, smola.
			//pripojenie bolo úspešné
		} else if(response.status=="Match found") { //á! presne toto chceme!
			//našla sa zhoda
		} else if(response.status=="Looking for match") {
			//informuj užívateľa že sa hľadá zhoda
		}
	}
	socket.send(JSON.stringify({"action": "find"})); //povedz serveru, že chceme začať vyhľadávať
});

$("#cancel").click(function() {
	socket.send(JSON.stringify({"action": "cancel"})); //nie, už nemáme záujem o túto hru
});

Kód: Vybrať všetko

$server = IoServer::factory(new ClientConnection(), 8080);

Kód: Vybrať všetko

<!-- bez formulára -->
<div id="connect">
    .....
    <input type="text" id="moje_meno" />
    <button onclick="pripoj()">Pripoj sa</button>
</div>
<div id="search">
    .....
    <input type="text" id="hladane_meno" />
    <button onclick="vyhladavaj()">Vyhľadaj</button>
</div>
<div id="status">
	Žiadna aktivita.
</div>

Kód: Vybrať všetko

var socket;
function pripoj() {
	socket = new WebSocket("ws://adresa:8080");
	socket.onopen = function() {
		$("#status").html("Pripájam sa");
		socket.send("PRIPOJ " + $("#moje_meno").attr('value'));
	}
}
function vyhladavaj() {
	var data = false;
	socket.onmessage = function(evt) {
		if(data) {
			$("#status").html("Nájdená zhoda, ID:" + evt.data);
		} if(evt.data=="ZHODA") {
			data = true;
		} else (evt.data=="NIC") {
			$("#status").html("Nebola nájdená žiadna zhoda");
		}
	}
	
	socket.send("HLADAJ " + $("#hladane_meno").attr('value'));
}

Kód: Vybrať všetko

<?php
//potrebné pre knižnicu Ratchet
require __DIR__ . '/vendor/autoload.php';
use Ratchet\Server\IoServer;
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

$server = IoServer::factory(new ClientConnection(), 8080); //prijímaj pripojenia na porte 8080, predávaj ich instanciám triedy ClientConnection
$server->run(); //očakávaj pripojenia

$hraci = array();
$id = 0;
class ClientConnection implements MessageComponentInterface {
    public function onMessage(ConnectionInterface $from, $msg) {
		$arr = explode(" ", $msg);
		switch($arr[0]) {
			case "PRIPOJ":
				array_push($hraci, array('id' => $id, 'meno' => $arr[1]));
				$id++;
				break;
			case "HLADAJ":
				$found = false;
				foreach($hraci as $hrac)
					if($hrac['meno']==$arr[1]) {
						$found = true;
						$from->send("ZHODA");
						$from->send("".$hrac['id']);
						break;
					}
				
				if(!$found)
					$from->send("NIC");
				break;
		}
    }
}
?>