Commit eb1c5912 authored by shajiaiming's avatar shajiaiming

fix

parent 61ec3e90
......@@ -13,8 +13,8 @@ class WorkermanWebSocketController extends Controller
// 这里不需要设置,会读取配置文件中的配置
public $config = [];
private $ip = '127.0.0.1';
private $port = '2346';
private $ip = '0.0.0.0';
private $port = '8080';
public function options($actionID)
{
......@@ -68,9 +68,9 @@ class WorkermanWebSocketController extends Controller
// Emitted when data received
$wsWorker->onMessage = function ($connection, $data) {
// ssl需要访问443端口
$con = new \Workerman\Connection\AsyncTcpConnection("wss://stream.binance.com:9443/ws/!ticker@arr");
$con = new \Workerman\Connection\AsyncTcpConnection("ws://stream.binance.com:9443/ws/!ticker@arr");
// 设置以ssl加密方式访问,使之成为wss
// $con->transport = 'ssl';
$con->transport = 'ssl';
// $con->onConnect = function($con) {
// $data = json_encode([
// 'sub' => 'market.btcusdt.kline.1min',
......@@ -78,11 +78,11 @@ class WorkermanWebSocketController extends Controller
// ]);
// $con->send($data);
// };
$con->onMessage = function($con, $data) use($connection) {
$connection->send('hello: ' . $data);
$connection->send(date("Y-m-d H:i:s") . ' : ' . $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