1.php 文件代碼如下
<?php
use \Workerman\Worker;
require_once __DIR__ . '/../../Workerman/Autoloader.php';
$ws_worker = new Worker("websocket://0.0.0.0:2346"); // 創(chuàng)建一個(gè)Worker 代理監(jiān)聽本地2346端口,使用websocket協(xié)議通訊
$ws_worker->onMessage = function($connection, $data)
{
// 向客戶端發(fā)送hello $data
var_dump($data);
$connection->send('hello ' . $data);
};
if(!defined('GLOBAL_START'))
{
Worker::runAll();
}
2.php 文件如下
use \Workerman\Worker;
use \Workerman\Connection\AsyncTcpConnection;
require_once __DIR__ . '/../../Workerman/Autoloader.php';
$task = new Worker();
// 進(jìn)程啟動(dòng)時(shí)異步建立一個(gè)到www.baidu.com連接對(duì)象,并發(fā)送數(shù)據(jù)獲取數(shù)據(jù)
$task->onWorkerStart = function($task)
{
$connection_to_baidu = new AsyncTcpConnection('tcp://127.0.0.1:2346');
//onMessage 當(dāng)有客戶端的連接上有數(shù)據(jù)發(fā)來時(shí)觸發(fā)
$connection_to_baidu->onMessage = function($connection_to_baidu, $http_buffer)
{
//echo json_encode($http_buffer);
//echo $http_buffer;
//$connection_to_baidu->send('hello ' .$http_buffer);
var_dump('1111111111'); var_dump($http_buffer);
};
// 運(yùn)行worker
Worker::runAll();
請(qǐng)問大大 如何讓2.php 長(zhǎng)連接到 1,php 后 并接收到 來自1.php 的數(shù)據(jù)呢?????
我測(cè)試了兩天了 都接不到數(shù)據(jù)呢????
幫幫忙看看哦! 謝謝了??!