雅荷心语
心之所向便是光

首页
前端之旅
后端之路
软件工具
心灵鸡汤
心路历程
视频资料
关于我们
- 关于我
- 关于我
微信平台
- 业务合作

首页
前端之旅
后端之路
软件工具
心灵鸡汤
心路历程
视频资料
关于我们
- 关于我
- 关于我
微信平台
- 业务合作
关注本站
- 微信
- 微博
- 腾讯微博
- Twitter
- Facebook
- RSS订阅

php微任务及队列处理的几种方法

2019-10-31 分类：后端之路阅读(1636) 评论(0)

第一种方法: 使用websocket (workMan)

服务端:

use Workerman\Worker;
require_once __DIR__ .'/vendor/autoload.php';

$worker = new Worker('Text://0.0.0.0:5678');
$worker->count = 1;
$worker->name = 'Test';
$worker->onMessage = function($connection, $buffer) {
  $data = json_decode($buffer, true);
  sleep(3);
  // 返回推送结果
  $connection->send(json_encode($data));
};
$worker->listen();
Worker::runAll();

use Workerman\Worker;

require_once __DIR__ .'/vendor/autoload.php';

$worker = new Worker('Text://0.0.0.0:5678');

$worker->count = 1;

$worker->name = 'Test';

$worker->onMessage = function($connection, $buffer) {

$data = json_decode($buffer, true);

sleep(3);

// 返回推送结果

$connection->send(json_encode($data));

};

$worker->listen();

Worker::runAll();

客户端:

// 建立socket连接到内部推送端口
$client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1);
// 推送的数据，包含uid字段，表示是给这个uid推送
$data = array('uid'=>'uid1', 'percent'=>'tianming');
// 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
fwrite($client, json_encode($data)."\n");
// 读取推送结果
echo fread($client, 8192);

// 建立socket连接到内部推送端口

$client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1);

// 推送的数据，包含uid字段，表示是给这个uid推送

$data = array('uid'=>'uid1', 'percent'=>'tianming');

// 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符

fwrite($client, json_encode($data)."\n");

// 读取推送结果

echo fread($client, 8192);

第二种: 使用 http 请求 (swoole)

服务端:

<?php
$http = new Swoole\Http\Server("127.0.0.1", 9501);
$http->on("start", function ($server) {
    echo "Swoole http server is started at http://127.0.0.1:9501\n";
});
$http->on("request", function ($request, $response) {
    $response->header("Content-Type", "text/plain");
    $response->end("Hello World\n");
});
$http->start();

<?php

$http = new Swoole\Http\Server("127.0.0.1", 9501);

$http->on("start", function ($server) {

echo "Swoole http server is started at http://127.0.0.1:9501\n";

});

$http->on("request", function ($request, $response) {

$response->header("Content-Type", "text/plain");

$response->end("Hello World\n");

});

$http->start();

客户端:

file_get_contents('http://127.0.0.1:5678');

1	file_get_contents('http://127.0.0.1:5678');

第三种: Task 微任务

客户端:

$server = new Swoole\Server("127.0.0.1", 9502);
$server->set(array('task_worker_num' => 4));
$server->on('receive', function($server, $fd, $reactor_id, $data) {
  $task_id = $server->task("Async");
  print_r($fd);
  print_r($reactor_id);
  echo "收到Task消息: [id=$task_id]\n";
  print_r($data);
});
$server->on('task', function ($server, $task_id, $reactor_id, $data) {
  echo "Task[id=$task_id]\n";
  print_r($reactor_id);
  $server->finish(json_encode($data));
});
$server->on('finish', function ($server, $task_id, $data) {
  echo "AsyncTask[$task_id] finished: {$data}\n";
});
$server->start();

$server = new Swoole\Server("127.0.0.1", 9502);

$server->set(array('task_worker_num' => 4));

$server->on('receive', function($server, $fd, $reactor_id, $data) {

$task_id = $server->task("Async");

print_r($fd);

print_r($reactor_id);

echo "收到Task消息: [id=$task_id]\n";

print_r($data);

});

$server->on('task', function ($server, $task_id, $reactor_id, $data) {

echo "Task[id=$task_id]\n";

print_r($reactor_id);

$server->finish(json_encode($data));

});

$server->on('finish', function ($server, $task_id, $data) {

echo "AsyncTask[$task_id] finished: {$data}\n";

});

$server->start();

服务端:

// 建立socket连接到内部推送端口
$client = stream_socket_client('tcp://127.0.0.1:9502', $errno, $errmsg, 1);
// 推送的数据，包含uid字段，表示是给这个uid推送
$data = array('uid'=>'uid1', 'percent'=>'88%');
// 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
fwrite($client, json_encode($data)."\n");
echo '任务投递完成';
print_r($errmsg);
print_r($errno);