note 114920 deleted from sockets.examples by cmb
| From: | cmb@php.net | Date: | Sun, 05 Jan 2020 08:40:03 +0000 |
| Subject: | note 114920 deleted from sockets.examples by cmb | ||
| References: | 1 | Groups: | php.notes |
| Request: | Send a blank email to php-notes+get-213761@lists.php.net to get a copy of this message | ||
Note Submitter: Anonymous
----
A more object oriented example of the server
#!/usr/bin/env php
<?php
class MySocketServer
{
protected $socket;
protected $clients = [];
protected $changed;
function __construct($host = 'localhost', $port = 9000)
{
set_time_limit(0);
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
//bind socket to specified host
socket_bind($socket, 0, $port);
//listen to port
socket_listen($socket);
$this->socket = $socket;
}
function __destruct()
{
foreach($this->clients as $client) {
socket_close($client);
}
socket_close($this->socket);
}
function run()
{
while(true) {
$this->waitForChange();
$this->checkNewClients();
$this->checkMessageRecieved();
$this->checkDisconnect();
}
}
function checkDisconnect()
{
foreach ($this->changed as $changed_socket) {
$buf = @socket_read($changed_socket, 1024, PHP_NORMAL_READ);
if ($buf !== false) { // check disconnected client
continue;
}
// remove client for $clients array
$found_socket = array_search($changed_socket, $this->clients);
socket_getpeername($changed_socket, $ip);
unset($this->clients[$found_socket]);
$response = 'client ' . $ip . ' has disconnected';
$this->sendMessage($response);
}
}
function checkMessageRecieved()
{
foreach ($this->changed as $key => $socket) {
$buffer = null;
while(socket_recv($socket, $buffer, 1024, 0) >= 1) {
$this->sendMessage(trim($buffer) . PHP_EOL);
unset($this->changed[$key]);
break;
}
}
}
function waitForChange()
{
//reset changed
$this->changed = array_merge([$this->socket], $this->clients);
//variable call time pass by reference req of socket_select
$null = null;
//this next part is blocking so that we dont run away with cpu
socket_select($this->changed, $null, $null, null);
}
function checkNewClients()
{
if (!in_array($this->socket, $this->changed)) {
return; //no new clients
}
$socket_new = socket_accept($this->socket); //accept new socket
$first_line = socket_read($socket_new, 1024);
$this->sendMessage('a new client has connected' . PHP_EOL);
$this->sendMessage('the new client says ' . trim($first_line) . PHP_EOL);
$this->clients[] = $socket_new;
unset($this->changed[0]);
}
function sendMessage($msg)
{
foreach($this->clients as $client)
{
@socket_write($client,$msg,strlen($msg));
}
return true;
}
}
(new MySocketServer())->run();
?>