faeez/mxmbsocket
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Repo. Project Releases Wiki Activity

[Server] Methods over closures, StreamSelectLoop

Browse Source
This commit is contained in:
Chris Boden 2012-05-10 22:24:47 -04:00
parent 3a1ee0313f
commit 55e11bac7e
1 changed files with 52 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
src/Ratchet/Server/IoServer.php
View File

@ -6,6 +6,7 @@ use React\EventLoop\LoopInterface;
use React\Socket\ServerInterface; use React\Socket\ServerInterface;
use React\EventLoop\Factory as LoopFactory; use React\EventLoop\Factory as LoopFactory;
use React\Socket\Server as Reactor; use React\Socket\Server as Reactor;
use React\EventLoop\StreamSelectLoop;
/** /**
* Creates an open-ended socket to listen on a port for incomming connections. Events are delegated through this to attached applications * Creates an open-ended socket to listen on a port for incomming connections. Events are delegated through this to attached applications
@ -16,35 +17,39 @@ class IoServer {
*/ */
public $loop; public $loop;
/**
* @var Ratchet\MessageComponentInterface
*/
public $app;
/**
* Array of React event handlers
* @var array
*/
protected $handlers = array();
/**
* @param Ratchet\MessageComponentInterface The Ratchet application stack to host
* @param React\Socket\ServerInterface The React socket server to run the Ratchet application off of
* @param React\EventLoop\LoopInterface The React looper to run the Ratchet application off of
*/
public function __construct(MessageComponentInterface $app, ServerInterface $socket, LoopInterface $loop) { public function __construct(MessageComponentInterface $app, ServerInterface $socket, LoopInterface $loop) {
$this->loop = $loop; $this->loop = $loop;
$this->app = $app;
$that = $this; $socket->on('connect', array($this, 'handleConnect'));
$socket->on('connect', function($conn) use ($app, $that) { $this->handlers['data'] = array($this, 'handleData');
$decor = new IoConnection($conn, $that); $this->handlers['end'] = array($this, 'handleEnd');
$this->handlers['error'] = array($this, 'handleError');
$decor->resourceId = (int)$conn->socket;
$decor->remoteAddress = '127.0.0.1'; // todo
$app->onOpen($decor);
$conn->on('data', function($data) use ($decor, $app) {
$app->onMessage($decor, $data);
});
$conn->on('error', function($e) use ($decor, $app) {
$app->onError($decor, $e);
});
$conn->on('end', function() use ($decor, $app) {
$app->onClose($decor);
});
});
} }
public static function factory(MessageComponentInterface $component, $port = 80, $address = '0.0.0.0') { public static function factory(MessageComponentInterface $component, $port = 80, $address = '0.0.0.0') {
$loop = LoopFactory::create(); // Enable this after we fix a bug with libevent
// $loop = LoopFactory::create();
$loop = new StreamSelectLoop;
$socket = new Reactor($loop); $socket = new Reactor($loop);
$socket->listen($port, $address); $socket->listen($port, $address);
$server = new static($component, $socket, $loop); $server = new static($component, $socket, $loop);
@ -55,4 +60,29 @@ class IoServer {
public function run() { public function run() {
$this->loop->run(); $this->loop->run();
} }
public function handleConnect($conn) {
$conn->decor = new IoConnection($conn, $this);
$conn->decor->resourceId = (int)$conn->socket;
$conn->decor->remoteAddress = '127.0.0.1'; // todo
$this->app->onOpen($conn->decor);
$conn->on('data', $this->handlers['data']);
$conn->on('end', $this->handlers['end']);
$conn->on('error', $this->handlers['error']);
}
public function handleData($data, $conn) {
$this->app->onMessage($conn->decor, $data);
}
public function handleEnd($conn) {
$this->app->onClose($conn->decor);
}
public function handleError(\Exception $e, $conn) {
$this->app->onError($conn->decor, $e);
}
} }