Как сделать Рукопожатие и общение от Websocket сервера к websocket серверу workerman?

Question

[mcigorli]

Имею свой работающий websocket сервер (ubuntu 18.04) на workerman php
И вот мне нужно получить с другого WSS данные.
Вопрос:
1. Как подключится с действующего сервера WSS(1) к другому WSS(2)?
2. Как читать полученные данные с WSS(2) на WSS(1)?

Повторюсь WSS(1) мой личный сервер. WSS(2) сторонний сервер с потоком данных и возможностью их получать после подключения.

Answer 1

[Rsa97]

Через AsyncTcpConnection

Comments

[mcigorli]

Странно... но почему-то он не хочет подключаться к серверу...

$ws_connection = new AsyncTcpConnection('ws://ws.eodhistoricaldata.com/ws/crypto?api_token=demo');

В консоли получаю

[VoidVolker]

mcigorli тут список приложений, которые заняли и слушают порт, а клиент - это не сервер, он не слушает порт, он к нему подключается.

[mcigorli]

Хорошо, тогда обьясните мне пожалуйста.

<?php
require_once __DIR__ . '/vendor/autoload.php'; 
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
use Workerman\Connection \AsyncTcpConnection;

// SSL context.
$context = [ 'ssl' => [ 'local_cert' => '/etc/letsencrypt/live/utelimited.ru/fullchain.pem',
'local_pk' => '/etc/letsencrypt/live/utelimited.ru/privkey.pem',
'verify_peer' => false,
]
];

// Create a Websocket server
$ws_worker = new Worker ("websocket://0.0.0.0:2346", $context);
$worker->transport = 'ssl'; 

// Emitted when new connection come
 $ws_worker-> onConnect = function($connection)
{
 echo "New connection\n";
 };

// Emitted when data received
 $ws_worker-> onMessage = function($connection, $data)
{
 // Send hello $data
    $connection->send ('hello ' . $data);
};

// Emitted when connection closed
 $ws_worker-> onClose = function($connection)
{
 echo "Connection closed\n";
};


//===============================

$worker_wss = new Worker ();
$worker_wss ->onWorkerStart = function () {
 // Websocket protocol for client.
    $ws_connection = new AsyncTcpConnection('ws://ws.eodhistoricaldata.com/ws/crypto?api_token=demo');
 $ws_connection-> onConnect = function ($connection_wss) {
 $connection_wss-> send ('Hello');
 }; 
$ws_connection->onMessage = function ($connection_wss, $data) {
 echo "Recv:  $data\n";
 }; 
$ws_connection->onError = function ($connection_wss, $code, $msg) {
 echo "Error:  $msg\n";
 };
 $ws_connection->onClose = function ($connection_wss) {
 echo "Connection closed\n";
 }; 
$ws_connection->connect();
};

// Run worker
Worker::runAll();

Объясните пожалуйста!
Вот у меня сервер и клиент.
Как мне передать данные с клиента ws.eodhistoricaldata.com
На сервер websocket://0.0.0.0:2346 ?

Запускаю все в одном файле как видите.

[Rsa97]

mcigorli,

$ws_connection->onMessage = function ($connection_wss, $data) use ($ws_worker) {
    foreach($ws_worker->connections as $connection) {
        $connection->send($data);
    }
 };

[mcigorli]

Rsa97, Спасибо за Ваш ответ.
Но я получаю только ответ от сервера. Клиент молчит :(

<?php
require_once __DIR__ . '/vendor/autoload.php'; 
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
use Workerman\Connection\AsyncTcpConnection;

// SSL context.
$context = [ 'ssl' => [ 'local_cert' => '/etc/letsencrypt/live/utelimited.ru/fullchain.pem',
'local_pk' => '/etc/letsencrypt/live/utelimited.ru/privkey.pem',
'verify_peer' => false,
]
];

// Create a Websocket server
$ws_worker = new Worker ("websocket://0.0.0.0:100", $context);
$ws_worker->transport = 'ssl'; 


// Emitted when new connection come
$ws_worker-> onConnect = function($connection)
{
	 $connection->onWebSocketConnect = function($connection) 
    {
	 echo "New connection\n";
	 $connection->send ('Server OK: ' . $data);
	};
 };

// Emitted when data received
$ws_worker-> onMessage = function($connection, $data)
{
	// Send hello $data
    $connection->send ('hello ' . $data);
};

// Emitted when connection closed
 $ws_worker-> onClose = function($connection)
{
 echo "Connection closed\n";
};

 
//===============================

$worker_wss = new Worker ();
$worker_wss ->onWorkerStart = function ($ws_worker) {
	// Websocket protocol for client.
    $ws_connection = new AsyncTcpConnection('ws://ws.eodhistoricaldata.com/ws/crypto?api_token=demo');
	$ws_connection-> onConnect = function ($connection_wss) use (&$ws_worker) {
		//$connection_wss-> send ('Hello_WSS_NEW');
		foreach($ws_worker->connections as $connection) {
			$connection->send($data);
		}
	}; 
	$ws_connection->onMessage = function ($connection_wss, $data) use (&$ws_worker) {
		foreach($ws_worker->connections as $connection) {
			$connection->send($data);
		}
	}; 
	$ws_connection->onError = function ($connection_wss, $code, $msg) {
		echo "Error:  $msg\n";
	};
	$ws_connection->onClose = function ($connection_wss) {
		echo "Connection closed\n";
	}; 
	$ws_connection->connect();
};

// Run worker
Worker::runAll();

[mcigorli]

Rsa97, сможете помочь ?

Answer 2

[VoidVolker]

Вообще, в веб-сокетах соединения сервер-сервер не существует в принципе, т.к. сервер - это именно сервис, который ждет подключения к нему клиентов, а не сам подключается. Для подключения к другому WS серверу со стороны своего сервера необходимо использовать WS клиента - т.е., подключаем код клиента и подключаемся как клиент к стороннему серверу, получаем данные с него, конвертируем во что надо и прокидываем через свой сервер куда дальше надо.