initialize() method start a processes without ends

[alissonpelizaro]

Hello!

I can connect on my Socket Server with this library, but the method initialize() never ends on browser... It keep a proccess running and dont call the next methods ( emit() and close() ).

How can I solve that?

$client = new Client(new Version2X('https://myurl.com:2021', [
  'context' => [
    'ssl' => [
      'verify_peer' => false,
      "verify_peer_name"=>false,
      'allow_self_signed'=> false
    ]
  ]
]));
      
$client->initialize();
$client->emit('alert', 'Hello world!');
$client->close();

Thanks a lot!

[peter279k]

Fix typo: the title should change into initialize() method start a processes without ends.

[peter279k]

@alissonpelizaro, thank you for your reply.

Do you run the example codes on elephant.io/example/socket.io/2.x/emitter-with-private-socket-id?

It's worked for me that it can initialize connection, emit headers and close connection.

[alissonpelizaro]

@peter279k, I dont run because in my case the Socket Server isn't Socket.io of JS. I built it with PHPSocket.io library.

Clients from Sokect.io.js can connect in this server without problems... But clients os this library keep this process when is called initializae() method.

[peter279k]

@alissonpelizaro, thank you for your reply.

If possible, could you provide sample codes that you execute socket server/client?

And I can try reproducing issue.

[alissonpelizaro]

@peter279k, sure.

Server (working):

require_once '../vendor/autoload.php';
use Workerman\Worker;
use Workerman\WebServer;
use Workerman\Autoloader;
use PHPSocketIO\SocketIO;

// ssl context
$context = array(
  'ssl' => array(
    'local_cert'  => '/etc/letsencrypt/live/security/cert.pem',
    'local_pk'    => '/etc/letsencrypt/live/security/privkey.pem',
    'verify_peer' => false,
  )
);

$io = new SocketIO(2021, $context);
$io->on('connection', function($socket){
  echo "[info]: New client (".$socket->id.")\n";

  $socket->on('alert', function ($data)use($socket){
    echo "[info]: I received an alert!\n";
  });
});

Worker::runAll();

Client JavaScript Socket.io (working):
[running on client side]

var hostname = "https://myurl.com:2021";
var socket = io.connect(hostname, {
  secure: true,
  reconnect: true,
  rejectUnauthorized : false
});

socket.on('connect', function () {
  socket.on('alert', function (data) {
    alert(data);
  });

  socket.on('disconnect', function () {
    console.log('disconnected');
  });
});

Client PHP Elephant.io (not work):
[running on server side]

require_once 'vendor/autoload.php';
use ElephantIO\Client;
use ElephantIO\Engine\SocketIO\Version2X AS Version2X;

$client = new Client(new Version2X('https://localhost:2021', [
  'context' => [
    'ssl' => [
      'verify_peer' => false,
      "verify_peer_name"=>false,
      'allow_self_signed'=> false
      ]
    ]
  ]));

$client->initialize();
$client->emit('alert', 'Hello world!');
$client->close();

I've tried with the three versions. The Version0X not work, the Version1X and Version2X can connect on the server, but keep the process alive at initialize() method.

Thanks a lot for your time with this issue. 😊

[peter279k]

@alissonpelizaro, thank you for your reply.

I try reproducing issue and got the following errors. The approach is as follows:

Firstly, we create the web socket server without SSL.

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

use Workerman\Worker;
use PHPSocketIO\SocketIO;

$io = new SocketIO(2021, []);
$io->on('connection', function($socket){
  echo "[info]: New client (".$socket->id.")\n";

  $socket->on('alert', function ($data)use($socket){
    echo "[info]: I received an alert!\n";
  });
});

Worker::runAll();

Second, create the client with elephant.io.

<?php

require_once './vendor/autoload.php';
use ElephantIO\Client;
use ElephantIO\Engine\SocketIO\Version2X AS Version2X;

$client = new Client(new Version2X('http://localhost:2021', []));

$data = [
    'message' => 'Hello world!',
];

var_dump($client->initialize());
var_dump($client->emit('alert', $data));
$client->close();

Finally, I got the following fatal error message:

PHP Fatal error:  Uncaught UnexpectedValueException: The server returned an unexpected value. Expected "HTTP/1.1 101", had "HTTP/1.1 403" in /home/lee/elephant.io/src/Engine/SocketIO/Version1X.php:290
Stack trace:
#0 /home/lee/elephant.io/src/Engine/SocketIO/Version1X.php(77): ElephantIO\Engine\SocketIO\Version1X->upgradeTransport()
#1 /home/lee/elephant.io/src/Client.php(59): ElephantIO\Engine\SocketIO\Version1X->connect()
#2 /home/lee/elephant.io/client.php(13): ElephantIO\Client->initialize()
#3 {main}
  thrown in /home/lee/elephant.io/src/Engine/SocketIO/Version1X.php on line 290

It looks like the elephant.io client is only available for the socket.io server at this moment.

If we want to support the workerman socker server, we have to add other methods about building another requests to support the workerman server.

[Taluu]

Yup, only socket.io is supported at the moment. Feel free to provide an implementation for workerman.

[Taluu]

Actually (didn't read the whole ticket...) this shouldn't be a problem, as js clients can properly connect. From @peter279k's "debug", we can see that it returns a 403, which is another matter... Is there any logs from the workerman / phpsocketio ?

[peter279k]

@Taluu, thank you for your reply. The Worker server message log is as follows:

Workerman[server.php] start in DEBUG mode
------------------------------------------- WORKERMAN -------------------------------------------
Workerman version:3.5.19          PHP version:7.3.5-1+ubuntu18.04.1+deb.sury.org+1
-------------------------------------------- WORKERS --------------------------------------------
proto   user            worker          listen                     processes    status           
tcp     lee             PHPSocketIO     socketIO://0.0.0.0:2021    1             [OK]            
-------------------------------------------------------------------------------------------------
Press Ctrl+C to stop. Start success.
[info]: New client (5585bbf03b36d74103b63d34)

The server has received connection message correctly.

And it looks like the client send the incorrect requests to worker socket server.

[alissonpelizaro]

Yes @peter279k. The method initialize() keep a procecess in the foreground on the client and the PHP Fatal error (HTTP/1.1 403) appears after the connection timeout. While this procecess is running, if we stop the server, the client Elephant.io is closed instantly before this Fatal error. In other words, the connection was successful. Isn't it?

Should I change the title to "Workerman connection problem", or somethig like this?

Once again, thank you very much for your personal help.

[peter279k]

Yes @peter279k. The method initialize() keep a procecess in the foreground on the client and the PHP Fatal error (HTTP/1.1 403) appears after the connection timeout. While this procecess is running, if we stop the server, the client Elephant.io is closed instantly before this Fatal error. In other words, the connection was successful. Isn't it?

Should I change the title to "Workerman connection problem", or somethig like this?

Once again, thank you very much for your personal help.

I think it's about the Workerman connection problem.

The HTTP response result is 403 means some requests are invalid for Workerman server.

[alissonpelizaro]

I really agree that Workerman service is not compatible with this library, I'll fork and send a pull request if I find a solution.

Thank you very much for your help once again.

God blesses.