After a few days of operations (roughly a few hundred connections in total, rarely more than 5 concurrent ones) the ratchet task locks up one CPU thread permanently until restarted. It keeps working though.

I installed the libevent PHP extension, but it didn't solve the problem. It doesn't even seem to be related to real workload.

I wasn't able to diagnose this problem in any way. Is there some sort of debug output one can enable?

This is the startup script: http://pastebin.com/UnFGhD5u

This is the application class: http://pastebin.com/BTBDNLxd

Both are really rather simple, I don't see anything that could end up in a loop ...

Any ideas/suggestions how to debug this?

P.S.: This is a Ubuntu 12.04 distro PHP installation.

Hello. I have used the supervisor concept to check and restart my chat server if it is stopped.

After some time interval my chat not working.When i check the console i didn't find any websocket connection fail error.

Then i use below command to check my server is running or not and see the server still running.

ps aux | grep php

So i am confused where is the issue or bug for which my chat application not working.

I've been looking and looking without much success. I see hints that there is such a thing but no real documentation or examples. Any help would be greatly appreciated.

Thanks,

Daryl

Hi cboden!

I have a ratchet chat server file

use Ratchet\Server\IoServer;
use Ratchet\WebSocket\WsServer;
use MyAppChat\Chat;
    require dirname(__DIR__) . '/vendor/autoload.php';
    $server = IoServer::factory(
        new WsServer(
            new Chat()
        )
      , 26666
    );
    $server->run();

i using JS Websocket connect success throw http

if ("WebSocket" in window) {
    var ws = new WebSocket("ws://ratchet.mydomain.org:8888");
    ws.onopen = function() {
        // Web Socket is connected. You can send data by send() method.
        ws.send("message to send");
    };
    ws.onmessage = function (evt) { 
        var received_msg = evt.data;
    };
    ws.onclose = function() { 
        // websocket is closed. 
    };
} else {
  // the browser doesn't support WebSocket.
}

I will install SSL in my webserver and try connect via SSL but failed

if ("WebSocket" in window) {
    var ws = new WebSocket("wss://ratchet.mydomain.org:8888");
    ws.onopen = function() {
        // Web Socket is connected. You can send data by send() method.
        ws.send("message to send");
    };
    ws.onmessage = function (evt) { 
        var received_msg = evt.data;
    };
    ws.onclose = function() { 
        // websocket is closed. 
    };
} else {
  // the browser doesn't support WebSocket.
}

My question is how can using ratchet for websocket SSL connection?

Thanks

Hi, I am new in ratchet web socket, and my application is like "FACEBOOK", so can i use the ratchet web socket in PHP(Laravel)? And also tell me : How many connections working concurrently? Sorry for my English...

in my project , i want to send data to some clients automatically , without receiving any request from clients.but i cant access to clients from out side of MessageComponentInterface class object. i prefer to tell to MessageComponentInterface class ; send to alive clients a message. so i need to trigger onMessage function from server-side , how can i do it ? here is my WebSocketCon class :

<?php 
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;

class WebSocketCon implements MessageComponentInterface {
    protected $clients;
    public $users;
	
    public function __construct() {
        $this->clients = new \SplObjectStorage; 
        $this->users = [];
    }

    public function onOpen(ConnectionInterface $conn) {
        $this->clients->attach($conn);
        echo "New connection! ({$conn->resourceId})\n";
    }

    public function onMessage(ConnectionInterface $from, $msg) {
        $data = json_decode($msg);
        if($data->command=="subscribe"){
            $this->users[(int)$data->uid] = $from;
            echo "New subscribe! ({$data->uid})\n";
        }
    }

    public function sendMessageToAll($msg){
        foreach ($this->clients as $client) {
            if ($from !== $client) {
                $client->send($msg);
            }
        }
    }
	
    public function sendMessageTo($idusers,$msg){
        foreach ($idusers as $idu) {
            $idu = (int) $idu;
            if(array_key_exists($idu,$this->users)){
                $this->users[$idu]->send($msg);
            }
        }
    }
	
    public function onClose(ConnectionInterface $conn) {
        $this->clients->detach($conn); 
            if (($key = array_search($conn, $this->users)) !== false) {
                unset($this->users[$key]);
            }
        echo "Connection {$conn->resourceId} has disconnected\n";
    }

    public function onError(ConnectionInterface $conn, \Exception $e) {
        echo "An error has occurred: {$e->getMessage()}\n";

        $conn->close();
    }
}

and here is my cmd.php :

<?php
require 'vendor/autoload.php';

use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer; 
require 'classes/WebSocketCon.php';

$server = IoServer::factory(
    new HttpServer(
        new WsServer(
            new WebSocketCon()
        )
    ),
    8081
);

$server->run();
?>

Hi,

Im trying to share session data beetwen the socket server and Symfony using handlers (File) but he get only the session id:

My socket file:

        $loop   = \React\EventLoop\Factory::create();
        $pusher = new \Comunicacao\ComunicadorBundle\Topic\WampChatTopic();

        // Listen for the web server to make a ZeroMQ push after an ajax request
        $context = new \React\ZMQ\Context($loop);
        $pull = $context->getSocket(\ZMQ::SOCKET_PULL);
        $pull->bind('tcp://127.0.0.1:5555'); 
        $pull->on('message', array($pusher, 'onChatMessage'));

        $webSock = new \React\Socket\Server($loop);
        $webSock->listen(8080, '0.0.0.0'); 

        $session = new SessionProvider(
            new \Ratchet\Wamp\WampServer($pusher)
          , new Handler\NativeFileSessionHandler()
        );

        $webServer = new \Ratchet\Server\IoServer(
            new \Ratchet\Http\HttpServer(
                new \Ratchet\WebSocket\WsServer(
                    $session
                )
            ),
            $webSock
        );

        $loop->run();

On the topic implementation have:

        public function onOpen(ConnectionInterface $conn) {
            print_r($conn->WebSocket->request->getCookies());
        }

i get de session id (are the same on browser) but the data? nothing...

is possible to do something like that? In my local server works fine, but the serivor the cloud instantly disconnects

https://github.com/Celtico/QuChat/blob/master/src/QuChat/Server/QuChat.php

thanks!

Greetings! Very happy to be reporting in on an issue here, hope I'm useful. It appears, as though there was a lack of SSL support (especially for WSS) (in the past and now), due to lack of such support in reactphp/socket, however now there is a way of implementing this (via the SecureServer component in react), so I was wondering if there are any plans on implementing this?

One of the main reasons is that there are many scenarios where this library becomes a no-deal because of this bug, for example if you are creating a WebRTC chat client, it is not possible to work with this library, despite the fact that it is the BEST library for PHP which offers this functionality (WebRTC has to be hosted on HTTPS, which can only request WSS, which ratchet does not support).

I would be glad to fix this myself, but I was wondering: (a) Is this fixed already but undocumented? and (b) Are there any reasons why this shouldn't be fixed?

Thanks a lot! Regards :)

Hello,

I started to learn and use Ratchet recently and I have some issue in managing some libraries with composer.json. So, i started a project and installed composer. The content looks like this:

{
    "autoload": 
     {
        "psr-0": 
        {
            "MyApp": "src"
        }
    },
    "require": {
        "cboden/ratchet": "0.3.*",
        "react/zmq": "0.2.*|0.3.*"
    }
}

It seems that the ratchet libraries are well managed since i have no problem to include them in my php scripts (ex. use Ratchet\Server\IoServer, etc) but for the rest of the libraries i have a problem.

For the first case, when i try to include my application in a php script with: use MyApp\TheClassName

it throws an error: "Class 'MyApp\PDG' not found in /srv/www/htdocs/pdg_realtime/bin/PDG_server.php on line 13"

so i have to add:

require dirname(DIR) . '/src/MyApp/PDG.php'; on the top of the document in order to work properly.

As for the second case, I have installed ZeroMQ. I have put the zmq library in vendor/react folder, unpacked it and installed it from there. The folder name is zmq as it is initialized on the composer.json file. However when i try to include a library from zmq like:

use React\ZMQ\Context; (the pusher example on the Ratchet portal )

it gives:

PHP Fatal error: Class 'React\ZMQ\Context' not found in /srv/www/htdocs/pdg_realtime/bin/PDG_server.php on line 16

on the line 16 i have: "$context = new React\zmq\Context($loop);"

it seems that composer.jason library does not manage zmq libraries well.

Any suggestions about these issues?

P.S The second case is much more important to me at the moment.

On Chrome console, I receive the following message: "chatroom.php:72 WebSocket connection to 'ws://localhost:8080/' failed: Error during WebSocket handshake: Unexpected response code: 302"; "Connection Closed!"

And on Windows command prompt, I receive the following message: "Fatal error: Uncaught RuntimeException: Failed to listen on "tcp://0.0.0.0:8080": An attempt was made to access a socke t in a way forbidden by its access permissions."

It's common for Websocket services to operate behind a reverse proxy, such as can be provided by Nginx or Apache. A common use case is to create this proxy connection over Unix Domain sockets rather than TCP because

1. UDS typically has somewhat better throughput and lower latency, sometimes significantly better.
2. Each time a new client connects the the forward facing service (Nginx/Apache), the proxy must create a new connection from itself into the Websocket service, effectively doubling the amount of TCP connections on the OS

This is possible in other high-level websocket frameworks such as socket.io and Django, and is also possible in Ratchet and should likely have first class support. For example:

$react_loop = React\EventLoop\Loop::get();

$sock = new React\Socket\UnixServer('/var/www/ratchet_proxy.sock');

$chat_module = new Chat();

$server = new Ratchet\Server\IoServer(
            new Ratchet\Http\HttpServer( 
                new Ratchet\WebSocket\WsServer( $chat_module ) 
            ),
            $sock, $react_loop
         );

$server->run();

Apache conf (ratchet_proxy.sock wouldn't live in /var/www if the code above is started as a deamon): In this example any requests / ws connections on http://<domain>/api will be proxied into ratchet while all others are handled by using mod_php or PHP-FPM depending on configuration.

<VirtualHost *:80>
     ProxyPass /api unix:/var/www/ratchet_proxy.sock|http://192.168.56.103/api
  
     DocumentRoot /var/www/html

     <Directory /var/www/html>
         Options -Indexes +FollowSymLinks
         AllowOverride All
         Require all granted
     </Directory>
 
      ErrorLog ${APACHE_LOG_DIR}/error.log
      CustomLog ${APACHE_LOG_DIR}/access.log combined  
</VirtualHost>

Additionally this is also possible in ratchetphp/Pawl, however the Ratchet\Client\Connector forces a ws/wss uri. UDS works in pawl with a hackish work around (this is just for example purpose).

ws_client.php

<?php

require __DIR__ . '/vendor/autoload.php';

$reactConnector = new \React\Socket\Connector();

$connector = new React\Socket\Connector();

$loop = \React\EventLoop\Loop::get();
$connector = new \Ratchet\Client\Connector($loop, $reactConnector);

$connector('unix:///tmp/ws.sock')
->then(function(\Ratchet\Client\WebSocket $conn) {
    $conn->on('message', function(\Ratchet\RFC6455\Messaging\MessageInterface $msg) use ($conn) {
        echo "Received: {$msg}\n";
        //$conn->close();
    });

    $conn->on('close', function($code = null, $reason = null) {
        echo "Connection closed ({$code} - {$reason})\n";
    });

    $conn->send('Hello World!');
}, function(\Exception $e) use ($loop) {
    echo "Could not connect: {$e->getMessage()}\n";
    $loop->stop();
});

hack: in ratchet/pawl/src/Connector.php replace lines 38 - 53 the following (note the spoofed uri in generateRequest() ):

        if(str_starts_with($url, 'unix'))
        {
            $uriString = $url;
            $connector = $this->_connector;
            $request = $this->generateRequest('ws://localhost', $subProtocols, $headers);
        
        }else
        {         
            try {
                $request = $this->generateRequest($url, $subProtocols, $headers);
                $uri = $request->getUri();
            } catch (\Exception $e) {
                return new RejectedPromise($e);
            }


            $secure = 'wss' === substr($url, 0, 3);
            $connector = $this->_connector;

            $port = $uri->getPort() ?: ($secure ? 443 : 80);

            $scheme = $secure ? 'tls' : 'tcp';

            $uriString = $scheme . '://' . $uri->getHost() . ':' . $port;
        }

        $connecting = $connector->connect($uriString);

Creation of dynamic property React\Socket\Connection::$decor is deprecated in /vendor/cboden/ratchet/src/Ratchet/Server/IoServer.php:86

https://php.watch/versions/8.2/dynamic-properties-deprecated#exempt

How can I do for share connections between two servers ? , When I use single server everything works well because the data is saved in a array , but when they are two or more servers the connection objects don't share , I know that using Redis or Memcached i could make it , but How could i save the object connections?

I would like to ask how to implement the three function from the title. I tried reading the documents but not really getting it. below is my implementation with laravel 8.

<?php

namespace App\WebSockets\SocketHandler;

use App\Websockets\SocketHandler\ChatMessageEventHandler;
use Ratchet\ConnectionInterface;
use Ratchet\RFC6455\Messaging\MessageInterface;
use Ratchet\Wamp\WampServerInterface;
use Ratchet\WebSocket\MessageComponentInterface;


class WebSocketHandler implements MessageComponentInterface, WampServerInterface
{
    function onOpen(ConnectionInterface $conn)
    {
    }

    function onClose(ConnectionInterface $conn)
    {
    }

    function onError(ConnectionInterface $conn, \Exception $e)
    {
    }

    function onMessage(ConnectionInterface $conn, MessageInterface $msg)
    {
    }

    public function onPublish(ConnectionInterface $conn, $topic, $event, array $exclude, array $eligible)
    {
    }

    public function onCall(ConnectionInterface $conn, $id, $topic, array $params)
    {
    }

    public function onSubscribe(ConnectionInterface $conn, $topic)
    {
    }

    public function onUnSubscribe(ConnectionInterface $conn, $topic)
    {
    }
}

<?php

namespace App\Console\Commands;

use App\WebSockets\SocketHandler\WebSocketHandler;
use Illuminate\Console\Command;
use Ratchet\Http\HttpServer;
use Ratchet\Http\OriginCheck;
use Ratchet\Http\Router;
use Ratchet\Server\IoServer;
use Ratchet\WebSocket\WsServer;
use React\EventLoop\Loop;
use React\Socket\SocketServer;
use Symfony\Component\Routing\Matcher\UrlMatcher;
use Symfony\Component\Routing\RequestContext;
use Symfony\Component\Routing\Route;
use Symfony\Component\Routing\RouteCollection;

class WebSocketServer extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'websockets:serve';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Initializing Websocket server to receive and manage connections';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return void
     */
    public function handle()
    {
        $port = 6001;
        echo "Ratchet server started on 127.0.0.1:{$port} \n";
        $address = '0.0.0.0'; // Client address to accept. (0.0.0.0 means receive connections from any)
        $loop = Loop::get();
        $socket = new SocketServer("{$address}:{$port}", [], $loop);
        $routes = new RouteCollection();

        echo "App ws websocket running on 127.0.0.1:{$port}/ws/chat \n";
        $customWebsocketOneServer = new WsServer(new WebSocketHandler());
        $customWebsocketOneServer->enableKeepAlive($loop); // Enable message ping:pong
        $routes->add('ws', new Route('/ws/chat', [
            '_controller' => $customWebsocketOneServer,
        ]));

        $urlMatcher = new UrlMatcher($routes, new RequestContext());
        $router = new Router($urlMatcher);
        $originCheck = new OriginCheck($router, ['127.0.0.1']);
        $socket = new IoServer(new HttpServer($router), $socket, $loop); // Pass $originCheck to filter origin
        $socket->run();
    }
}

Javascript

const socket = new WebSocket(`wss://${window.location.hostname}/ws/chat`);
socket.onopen = function (event) {
    // console.log("on open", event);
};

socket.onmessage = function (event) {
    event = JSON.parse(event.data);
    console.log("websocket message", event);
};

socket.onclose = function (event) {
    // console.log("on close", event);
};

socket.send(
    JSON.stringify({
        access_token: access_token,
        payload: {
            type: "get-users",
        },
    })
);

With this setup, I can send and receive message from client to server using the send and onmessage function in javascript. How should I make my users use/trigger subscribe and unsubscribe function? publish? There are no tutorials found on the internet.

PHP version: 7.4

When sending HTTP request headers to Telnet, If '/' is missing from GET HTTP/1.1 An error has occurred.

An error occurs when creating GuzzleHttp\Psr7\Request instance in Message:parseRequest if the version parameter is null

PHP Fatal error:  Uncaught TypeError: GuzzleHttp\Psr7\Request::__construct(): Argument #5 ($version) must be of type string, null given, ...
/guzzlehttp/psr7/src/Request.php:35

From HttpRequestParser:parse Error parsing http header to guzzlehttp/psr7/Message library.

It seems that the header verification process is necessary before parsing.