kzykhys/coroutine-io

Fast socket server implementation using *Generator*

CoroutineIO

, _(*1)

Fast socket server implementation using Generator. This project is heavily inspired by @nikic's great post., _(*2)

Following project shows the possibility of CoroutineIO., _(*3)

• [kzykhys/coupe][2] - Coupé - A Handy HTTP/HTTPS Server written in PURE PHP

Requirements

• PHP5.5+

Installation

Create or update your composer.json and run composer update, _(*4)

``` json { "require": { "kzykhys/coroutine-io": "~0.1.0" } }, <sub>(*5)</sub>

Example (HTTP Server)
---------------------

1. Run `php example.php`
2. Open `http://localhost:8000` in browser and hold down the F5 key
3. Watch the console output

php example.php, <sub>(*6)</sub>

::1:50531 GET / HTTP/1.1 Host: localhost:8000 User-Agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10.9; rv:25.0) Gecko/20100101 Firefox/25.0 Accept: text/html,application/xhtml+xml,application/xml;q=0.9,/;q=0.8 Accept-Language: ja,en-us;q=0.7,en;q=0.3 Accept-Encoding: gzip, deflate DNT: 1 Connection: keep-alive, <sub>(*7)</sub>

### example.php

``` php
<?php

use CoroutineIO\Example\HttpHandler;
use CoroutineIO\Example\HttpServer;

require __DIR__ . '/vendor/autoload.php';

$server = new HttpServer(new HttpHandler());
$server->run();

Class HttpServer

``` php <?php, <sub>(*8)</sub>

namespace CoroutineIO\Example;, <sub>(*9)</sub>

use CoroutineIO\Exception\Exception; use CoroutineIO\Server\Server;, <sub>(*10)</sub>

/** * Simple HTTP Server Implementation */ class HttpServer extends Server {, <sub>(*11)</sub>

/**
 * {@inheritdoc}
 */
public function createSocket($address = 'localhost:8000')
{
    $socket = @stream_socket_server('tcp://' . $address, $no, $str);

    if (!$socket) {
        throw new Exception("$str ($no)");
    }

    return $socket;
}

}, <sub>(*12)</sub>

### Class HttpHandler

``` php
<?php

namespace CoroutineIO\Example;

use CoroutineIO\Server\HandlerInterface;
use CoroutineIO\Socket\ProtectedStreamSocket;
use CoroutineIO\Socket\StreamSocket;

/**
 * Simple HTTP Server Implementation
 */
class HttpHandler implements HandlerInterface
{

    /**
     * {@inheritdoc}
     */
    public function handleClient(StreamSocket $socket)
    {
        $socket->block(false);
        $data = (yield $socket->read(8048));

        $response = $this->handleRequest($data, new ProtectedStreamSocket($socket));

        yield $socket->write($response);
        yield $socket->close();
    }

    /**
     * {@inheritdoc}
     */
    public function handleRequest($input, ProtectedStreamSocket $socket)
    {
        // Displays request information
        echo $socket->getRemoteName() . "\n";
        echo $input;

        return "HTTP/1.1 200 OK\nContent-Type: text/plain\nContent-Length: 5\n\nHello";
    }

}

License

The MIT License, <sub>(*13)</sub>

Author

Kazuyuki Hayashi (@kzykhys), <sub>(*14)</sub>