Using Channel directly, without creating HTTP worker

[plashenkov]

Hi!

I need to send a message to WebSocket worker from another PHP script. Here I've found an example how to implement it: #184 (comment)

Here we start 3 workers listening 3 ports. Is it possible to use Channel directly, without creating HTTP worker? It looks like an extra element which we can get rid of.

I tried to use Channel directly from another PHP script:

Channel\Client::connect('127.0.0.1', 2206);
Channel\Client::publish('some', 'thing');

But I had no luck with that.

[walkor]

Sorry for delay.
Channel\Client only works in workerman environment.
But we can create an new class to do that, here is the example.

<?php
namespace Channel;
class Client 
{
    /**
     * Connction to channel server.
     * @var TcpConnection
     */
    protected static $_remoteConnection = null;
    /**
     * Channel server ip.
     * @var string
     */
    protected static $_remoteIp = null;
    /**
     * Channel server port.
     * @var int
     */
    protected static $_remotePort = null;
    
    /**
     * Connect to channel server
     * @param string $ip
     * @param int $port
     * @return void
     */
    public static function connect($ip = '127.0.0.1', $port = 2206)
    {
        if(!self::$_remoteConnection)
        {
             self::$_remoteIp = $ip;
             self::$_remotePort = $port;
             self::$_remoteConnection = stream_socket_client('tcp://'.self::$_remoteIp.':'.self::$_remotePort, $code, $message, 5);
             if (!self::$_remoteConnection) {
                 throw new \Exception($message);
             }
         }    
    }
    
    /**
     * Publish.
     * @param string $events
     * @param mixed $data
     */
    public static function publish($events, $data)
    {
        self::connect();
        $body = serialize(array('type' => 'publish', 'channels'=>(array)$events, 'data' => $data));
        $buffer = pack('N', 4+strlen($body)) . $body;
        fwrite(self::$_remoteConnection, $buffer);
    }
}

Client::connect('127.0.0.1', 2206);
Client::publish('broadcast', ['content'=>'something']);

It works fine for me.

[plashenkov]

It works excellent for me too, thank you very much!
Maybe you will want to add the ability to use the Channel\Client outside of workerman environment right out of the box?

[walkor]

Done.

[plashenkov]

Cool! Tested it, works very nice.