Commit 61ec3e90 authored by shajiaiming's avatar shajiaiming

test

parent 4cbe8f14
<?php
use Workerman\Worker;
use yii\console\Controller;
use yii\helpers\Console;
namespace console\controllers;
use Workerman\Worker;
use yii\helpers\Console;
use yii\console\Controller;
class WorkermanWebSocketController
class WorkermanWebSocketController extends Controller
{
public $send;
public $daemon;
......@@ -68,8 +67,22 @@ class WorkermanWebSocketController
// Emitted when data received
$wsWorker->onMessage = function ($connection, $data) {
// Send hello $data
$connection->send('dddd hello ' . $data);
// ssl需要访问443端口
$con = new \Workerman\Connection\AsyncTcpConnection("wss://stream.binance.com:9443/ws/!ticker@arr");
// 设置以ssl加密方式访问,使之成为wss
// $con->transport = 'ssl';
// $con->onConnect = function($con) {
// $data = json_encode([
// 'sub' => 'market.btcusdt.kline.1min',
// 'id' => 'depth' . time()
// ]);
// $con->send($data);
// };
$con->onMessage = function($con, $data) use($connection) {
$connection->send('hello: ' . $data);
};
$con->connect();
//$connection->send('dddd hello ' . $data);
};
// Emitted when connection closed
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment