qxsch/multi-process-server

Runs a multi threaded server.

MultiProcessServer

, _(*1)

, _(*2)

A multithreaded server for PHP, _(*3)

The TCPServer class provides a very simple interface to communicate with a client. You can control how many processes should be allowed to run concurrently. The TCPServer can be fully observed., _(*4)

The TCPClient class provides a very simple interface to communicate with a server., _(*5)

You can send any data between the client and the server that can be serialized., _(*6)

TLS Encryption with server and client certificate is supported (mutual authentication)., _(*7)

A simple example

Server Code:, _(*8)

<?php

$server = new \QXS\MultiProcessServer\TCPServer(12345);  // setup the server for 127.0.0.1 on port 12345
// UNCOMMENT THE NEXT LINE TO ADD IMPERSONATION
//$server->runAsUser("nobody");
$server->attach(new \QXS\MultiProcessServer\Observers\EchoObserver());
$server->create(new \QXS\MultiProcessServer\ClosureServerWorker(
    /**
     * @param \QXS\MultiProcessServer\SimpleSocket $serverSocket the socket to communicate with the client
     */
    function(\QXS\MultiProcessServer\SimpleSocket $serverSocket) {
        // receive data and send it back
        $data=$serverSocket->receive();
        echo "$data\n";
        $serverSocket->send($data);
    }
));

Client Code:, _(*9)

<?php

$client = new \QXS\MultiProcessServer\TCPClient(12345);  // connect to 127.0.0.1 on port 12345
$client->send("hi");

echo $client->receive() ."\n";