kzykhys / coroutine-io
Fast socket server implementation using *Generator*
v0.1.0
2013-11-27 10:26 UTC
Requires
- php: >=5.5.0
This package is not auto-updated.
Last update: 2024-11-05 03:00:03 UTC
README
Fast socket server implementation using Generator. This project is heavily inspired by @nikic's great post.
Following project shows the possibility of CoroutineIO.
- kzykhys/coupe - Coupé - A Handy HTTP/HTTPS Server written in PURE PHP
Requirements
- PHP5.5+
Installation
Create or update your composer.json and run composer update
{ "require": { "kzykhys/coroutine-io": "~0.1.0" } }
Example (HTTP Server)
- Run
php example.php
- Open
http://localhost:8000
in browser and hold down the F5 key - Watch the console output
php example.php
::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
example.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 namespace CoroutineIO\Example; use CoroutineIO\Exception\Exception; use CoroutineIO\Server\Server; /** * Simple HTTP Server Implementation */ class HttpServer extends Server { /** * {@inheritdoc} */ public function createSocket($address = 'localhost:8000') { $socket = @stream_socket_server('tcp://' . $address, $no, $str); if (!$socket) { throw new Exception("$str ($no)"); } return $socket; } }
Class HttpHandler
<?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
Author
Kazuyuki Hayashi (@kzykhys)