How do I listen to a UNIX domain socket in a single-process HTTP/Web socket server ?

[henrywood]

This is my simple HTTP server:

$server = new \Swoole\HTTP\Server("127.0.0.1", 9501);

$server->set([
        'backlog' => 128,       // TCP backlog connection number
]);

// Triggered when new worker processes starts
$server->on("WorkerStart", function($server, $workerId)
{
        echo "Worker Started: $workerId\n";
});

// Triggered when the HTTP Server starts, connections are accepted after this callback is executed
$server->on("Start", function($server)
{
        echo "HTTP Server Started @ 127.0.0.1:8501\n";
});

// The main HTTP server request callback event, entry point for all incoming HTTP requests
$server->on('Request', function(Swoole\Server\Request $request, Swoole\Server\Response $response)
{

        // Handle request from TCP
        $response->header("Content-Type", "text/plain");
        $response->end("Hello, TCP World!\n");
});

$server->on('message', function($server, $data) {

        var_dump($data);

});

$server->on('receive', function($server, $data) {

        var_dump(func_get_args());

});




// Triggered when the server is shutting down
$server->on("Shutdown", function($server)
{
        echo "Server shutting down...\n";
});

// Triggered when worker processes are being stopped
$server->on("WorkerStop", function($server)
{
        echo "Worker Stopped: $workerId\n";
});

$server->start();

I need for my server to listen to the UNIX domain socket /var/run/myserver.sock

How can I change the code to support this also (in a single process) ?

Thanks !

[NathanFreeman]

$server = new \Swoole\HTTP\Server("127.0.0.1", 9501);
$server->addlistener("/var/run/myserv.sock", 0, SWOOLE_UNIX_STREAM); //UnixSocket Stream

[NathanFreeman]

Swoole\Server->addListener(string $host, int $port, int $sockType): bool|Swoole\Server\Port

If addListener returns false, it means the operation has failed. If it returns Swoole\Server\Port, it indicates a successful operation.

[henrywood]

Ah so I just needed to be 'root' when running the server.
Thanks for your help !

[henrywood]

Damn !

I just cannot get it to work...

The socket:

henrik@HSLAPTOP-ASUS:/tmp$ ls -la /var/run/myserv.sock
srwxrwxrwx 1 root root 0 Apr 30 04:38 /var/run/myserv.sock

Client:

<?php
use Swoole\Coroutine\Client;
use function Swoole\Coroutine\go;
use function Swoole\Coroutine\run;
use Swoole\Constant;

run(function() {

        $settings = [
                Constant::OPTION_OPEN_LENGTH_CHECK     => 1,
                Constant::OPTION_PACKAGE_LENGTH_TYPE   => 'N',
                Constant::OPTION_PACKAGE_LENGTH_OFFSET => 0,
                Constant::OPTION_PACKAGE_BODY_OFFSET   => 4,
        ];

        go(function () use ($settings) {
                $client = new Client(SWOOLE_SOCK_UNIX_STREAM);
                $client->set($settings);
                $client->connect('/var/run/myserv.sock');
                $requestMessage = 'Unix socket';
                $client->send(pack('N', strlen($requestMessage)) . $requestMessage);
                $responseMessage = $client->recv();
                $responseMessage = substr($responseMessage, 4, unpack('N', substr($responseMessage, 0, 4))[1]); // @phpstan-ignore-line
                echo $responseMessage, PHP_EOL;
                $client->close();
        });

});

The server:

<?php
$server = new \Swoole\HTTP\Server("0.0.0.0", 8501);

$unixSocket = $server->addlistener("/var/run/myserv.sock", 0, SWOOLE_UNIX_STREAM); //UnixSocket Stream

$unixSocket->on('Receive', function($server, int $fd, int $reactorId, string $data) {

        var_dump($data); // This closure seems never to be called ???
});


var_dump($unixSocket);

$server->set([
        'backlog' => 128,       // TCP backlog connection number
]);

//posix_setuid(1000);

// Triggered when new worker processes starts
$server->on("WorkerStart", function($server, $workerId)
{
        echo "Worker Started: $workerId\n";
});

// Triggered when the HTTP Server starts, connections are accepted after this callback is executed
$server->on("Start", function($server)
{
        echo "Swoole HTTP Server Started @ 127.0.0.1:8501\n";
});

// The main HTTP server request callback event, entry point for all incoming HTTP requests
$server->on('Request', function(Swoole\Http\Request $request, Swoole\Http\Response $response)
{

        // Handle request from TCP
        $response->header("Content-Type", "text/plain");
        $response->end("Hello, TCP World!\n");
});

// Triggered when the server is shutting down
$server->on("Shutdown", function($server)
{
        echo "Server shutting down...\n";
});

// Triggered when worker processes are being stopped
$server->on("WorkerStop", function($server)
{
        echo "Worker Stopped: $workerId\n";
});

$server->start();

Running the server:

henrik@HSLAPTOP-ASUS:/tmp$ sudo php server.php

object(Swoole\Server\Port)#5 (19) {
  ["onConnect":"Swoole\Server\Port":private]=>
  NULL
  ["onReceive":"Swoole\Server\Port":private]=>
  object(Closure)#7 (1) {
    ["parameter"]=>
    array(4) {
      ["$server"]=>
      string(10) "<required>"
      ["$fd"]=>
      string(10) "<required>"
      ["$reactorId"]=>
      string(10) "<required>"
      ["$data"]=>
      string(10) "<required>"
    }
  }
  ["onClose":"Swoole\Server\Port":private]=>
  NULL
  ["onPacket":"Swoole\Server\Port":private]=>
  NULL
  ["onBufferFull":"Swoole\Server\Port":private]=>
  NULL
  ["onBufferEmpty":"Swoole\Server\Port":private]=>
  NULL
  ["onRequest":"Swoole\Server\Port":private]=>
  NULL
  ["onHandshake":"Swoole\Server\Port":private]=>
  NULL
  ["onOpen":"Swoole\Server\Port":private]=>
  NULL
  ["onMessage":"Swoole\Server\Port":private]=>
  NULL
  ["onDisconnect":"Swoole\Server\Port":private]=>
  NULL
  ["onBeforeHandshakeResponse":"Swoole\Server\Port":private]=>
  NULL
  ["host"]=>
  string(20) "/var/run/myserv.sock"
  ["port"]=>
  int(0)
  ["type"]=>
  int(5)
  ["sock"]=>
  int(6)
  ["ssl"]=>
  bool(false)
  ["setting"]=>
  NULL
  ["connections"]=>
  object(Swoole\Connection\Iterator)#6 (0) {
  }
}
Swoole HTTP Server Started @ 127.0.0.1:8501
Worker Started: 0

Sending data via socat:

henrik@HSLAPTOP-ASUS:/tmp$ echo "HELLO" | socat UNIX-CONNECT:/var/run/myserv.sock -

Sending via client.php:

henrik@HSLAPTOP-ASUS:/tmp$ sudo php client.php

The problem is that nothing is received in server.php ?

Any ideas ?

[NathanFreeman]

<?php
$server = new Swoole\Http\Server("0.0.0.0", 8501);
$server->set([
    'backlog' => 128,
]);

$unixSocket = $server->addlistener("/var/run/myserv.sock", 0, SWOOLE_UNIX_STREAM); //UnixSocket Stream
$unixSocket->set([]);
$unixSocket->on('Receive', function(Swoole\Server $server, int $fd, int $reactorId, string $data) {
    $server->send($data);
});

$server->on('Request', function(Swoole\Http\Request $request, Swoole\Http\Response $response) {
    $response->header("Content-Type", "text/plain");
    $response->end("Hello, TCP World!\n");
});

$server->start();

call the $unixSocket->set([]); method to override the settings of the main server
see https://wiki.swoole.com/en/#/server/port?id=httpwebsocket

[henrywood]

@NathanFreeman Now it works !

Thank you for all your help !