<script>
ws = new WebSocket("ws://12.12.12.12:2346");
ws.onopen = function() {
    console.log("connect");
    ws.send('tom');
};
ws.onmessage = function(e) {
    console.log(e.data);
   // document.write(e.data)
};

</script>

<?php
require_once __DIR__ . '/Autoloader.php';

use Workerman\Worker;
use Workerman\Lib\Timer;

define('HEARTBEAT_TIME', 25);
// 創(chuàng)建一個(gè)Worker監(jiān)聽2346端口，使用websocket協(xié)議通訊
$ws_worker = new Worker("websocket://0.0.0.0:2346");

Worker::$logFile = '/home/workerman.log';

// 啟動(dòng)4個(gè)進(jìn)程對(duì)外提供服務(wù)
$ws_worker->count = 4;

$ws_worker->onConnect = function($connection)
{
    echo 1;
    // 設(shè)置當(dāng)前連接的應(yīng)用層發(fā)送緩沖區(qū)大小為102400字節(jié)
    $connection->maxSendBufferSize = 5024000;
};

$ws_worker->onWorkerStart = function($worker) {
    Timer::add(1, function()use($worker){
        $time_now = time();
        foreach($worker->connections as $connection) {
            // 有可能該connection還沒收到過消息，則lastMessageTime設(shè)置為當(dāng)前時(shí)間
            if (empty($connection->lastMessageTime)) {
                $connection->lastMessageTime = $time_now;
                continue;
            }
            // 上次通訊時(shí)間間隔大于心跳間隔，則認(rèn)為客戶端已經(jīng)下線，關(guān)閉連接
            if ($time_now - $connection->lastMessageTime > HEARTBEAT_TIME) {
                //$connection->close();
            }
        }
    });
};

$ws_worker->onClose = function($connection)
{
    echo 2;
    $connection->send("connection closed");
};

$ws_worker->onError = function($connection, $code, $msg)
{
    echo 3;
    $connection->send("error $code $msg\n");
};

// 當(dāng)收到客戶端發(fā)來的數(shù)據(jù)后返回hello $data給客戶端
$ws_worker->onMessage = function($connection, $data)
{
    $connection->lastMessageTime = time();

    while(1){
        echo 4;
        $con = mysql_connect('localhost','root','123456') 
    or die('Could not connect to the server!');

mysql_select_db('laohu') 
    or die('Could not select a database.');

        $sql1 = "SELECT * FROM laohu_okcoin WHERE TYPE='bit'  order by create_time desc LIMIT 1";   

        $result1 = mysql_query($sql1);

        $row1 = mysql_fetch_assoc($result1);

        $sql2 = "SELECT * FROM laohu_okcoin WHERE TYPE='ltc'  order by create_time desc LIMIT 1";   

        $result2 = mysql_query($sql2);

        $row2 = mysql_fetch_assoc($result2);

        $return = $row1;
        $return = $row2;

        //mysql_close($con);
        $connection->send(json_encode($return));

        sleep(1);       
    }

};

// 運(yùn)行worker
Worker::runAll();