|
@@ -406,23 +406,15 @@ use Workerman\Worker;
|
|
|
|
|
|
|
|
$worker = new Worker('tcp://0.0.0.0:6161');
|
|
$worker = new Worker('tcp://0.0.0.0:6161');
|
|
|
|
|
|
|
|
-$worker->onWorkerStart = function() {
|
|
|
|
|
- global $client;
|
|
|
|
|
- $loop = Worker::getEventLoop();
|
|
|
|
|
- $factory = new React\Dns\Resolver\Factory();
|
|
|
|
|
- $dns = $factory->createCached('8.8.8.8', $loop);
|
|
|
|
|
- $factory = new React\HttpClient\Factory();
|
|
|
|
|
- $client = $factory->create($loop, $dns);
|
|
|
|
|
-};
|
|
|
|
|
-
|
|
|
|
|
$worker->onMessage = function($connection, $host) {
|
|
$worker->onMessage = function($connection, $host) {
|
|
|
- global $client;
|
|
|
|
|
|
|
+ $loop = Worker::getEventLoop();
|
|
|
|
|
+ $client = new \React\HttpClient\Client($loop);
|
|
|
$request = $client->request('GET', trim($host));
|
|
$request = $client->request('GET', trim($host));
|
|
|
$request->on('error', function(Exception $e) use ($connection) {
|
|
$request->on('error', function(Exception $e) use ($connection) {
|
|
|
$connection->send($e);
|
|
$connection->send($e);
|
|
|
});
|
|
});
|
|
|
$request->on('response', function ($response) use ($connection) {
|
|
$request->on('response', function ($response) use ($connection) {
|
|
|
- $response->on('data', function ($data, $response) use ($connection) {
|
|
|
|
|
|
|
+ $response->on('data', function ($data) use ($connection) {
|
|
|
$connection->send($data);
|
|
$connection->send($data);
|
|
|
});
|
|
});
|
|
|
});
|
|
});
|