Class Phalcon\Socket\Server¶

<?php

  $server = new Phalcon\Socket\Server('127.0.0.1', 8989);
  $server->run(
      function(Phalcon\Socket\Client $client){
          // Connect
      },
      function(Phalcon\Socket\Client $client, $mssage){
          // Read
          echo $mssage.PHP_EOL;
      },
      function(Phalcon\Socket\Client $client){
          // Send
          $client->write("Welcome!");
      },
      function(Phalcon\Socket\Client $client){
          // Close
      },
      function(Phalcon\Socket\Client $client){
          // Error
      },
      function(){
          // Timeout
      }
  );

 class HttpServer extends Phalcon\Socket\Server {

      public function onTimeout() {
      }

      public function onError(Phalcon\Socket\Client $client) {
      }

      public function onConnection(Phalcon\Socket\Client $client) {
      }

      public function onRecv(Phalcon\Socket\Client $client) {
      }

      public function onSend(Phalcon\Socket\Client $client) {
              $client->write("HTTP/1.0 200 OK\r\nServer: webserver\r\nContent-Type: text/html\r\nConnection: close\r\n\r\nHello World");
              return FALSE;
      }

      public function onClose(Phalcon\Socket\Client $client) {
      }
 }

 $server = new HttpServer('localhost', 6000);
 $server->setOption(Phalcon\Socket::SOL_SOCKET, SO_REUSEADDR, 1);
 $server->setOption(Phalcon\Socket::SOL_SOCKET, SO_REUSEPORT, 1);
 $server->setOption(Phalcon\Socket::SOL_TCP, Phalcon\Socket::TCP_NODELAY, 1);
 $server->setOption(Phalcon\Socket::SOL_TCP, Phalcon\Socket::TCP_QUICKACK, 1);
 $server->run();

Constants¶

integer AF_UNIX

integer AF_INET

integer AF_INET6

integer SOCK_STREAM

integer SOCK_DGRAM

integer SOCK_RAW

integer SOCK_SEQPACKET

integer SOCK_RDM

integer IPPROTO_IP

integer IPPROTO_IPV6

integer SOL_SOCKET

integer SOL_TCP

integer SOL_UDP

integer SO_DEBUG

integer SO_REUSEADDR

integer SO_REUSEPORT

integer TCP_NODELAY

integer TCP_QUICKACK

Methods¶

public __construct (string $address, int $port, [int $domain], [int $type], [int $protocol])

Phalcon\Socket\Server constructor

public setTimeout (unknown $sec, [unknown $usec])

Sets the timeout

public setDaemon (unknown $daemon)

Sets the run mode

public setMaxChildren (unknown $maxChildren)

Sets the run mode

public boolean setEvent (unknown $event)

Sets the event

public int getEvent ()

Gets the event

public boolean listen ([int $backlog])

Listens for a connection on a socket

public Phalcon\Socket\Client accept ()

Accept a connection

public Phalcon\Socket\Client getClients ()

Gets all connections

public Phalcon\Socket\Client getClient (resource $socket)

Gets a connection

public boolean removeClient (resource $socket)

Remove a connection

public Phalcon\Socket\Server disconnect (resource $socket)

Close a client

public run ()

Run the Server

public resource getSocket () inherited from Phalcon\Socket

Gets the socket

protected _throwSocketException () inherited from Phalcon\Socket

Throws an socket exception

public boolean setBlocking (int $flag) inherited from Phalcon\Socket

Set the socket to blocking / non blocking

public boolean isBlocking () inherited from Phalcon\Socket

Checks the socket blocking / non blocking

public boolean setOption (int $level, int $optname, mixed $optval) inherited from Phalcon\Socket

Set the socket to blocking / non blocking

public close () inherited from Phalcon\Socket

Close the socket

public isClose () inherited from Phalcon\Socket

Check if the socket close

public __destruct () inherited from Phalcon\Socket

Cleans up the socket and the resource