您当前的位置： 首页 > 慢生活 > 程序人生 网站首页程序人生

workerman使用文本协议上传文件

发布时间：2021-11-28 20:05:06编辑：雪饮阅读（）

 协议定义

json+换行，json中包含了文件名以及base64_encode编码（会增大1/3的体积）的文件数据
大是肯定大的，具体为什么是增大1/3就没有过多研究了。
协议样本
{"file_name":"logo.png","file_data":"PD9waHAKLyo......"}\n
注意末尾为一个换行符，在PHP中用双引号字符"\n"标识
协议实现TextTransfer.php：
<?php
namespace Workerman\Protocols;
class TextTransfer
{
public static function input($recv_buffer)
{
$recv_len = strlen($recv_buffer);
if($recv_buffer[$recv_len-1] !== "\n")
{
return 0;
}
return strlen($recv_buffer);
}
 
public static function decode($recv_buffer)
{
// 解包
$package_data = json_decode(trim($recv_buffer), true);
// 取出文件名
$file_name = $package_data['file_name'];
// 取出base64_encode后的文件数据
$file_data = $package_data['file_data'];
// base64_decode还原回原来的二进制文件数据
$file_data = base64_decode($file_data);
// 返回数据
return array(
'file_name' => $file_name,
'file_data' => $file_data,
);
}
 
public static function encode($data)
{
// 可以根据自己的需要编码发送给客户端的数据，这里只是当做文本原样返回
return $data;
}
}
 
 
 
 
服务端协议使用示例start.php:
<?php
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';
 
$worker = new Worker('TextTransfer://0.0.0.0:8333');
// 保存文件到tmp下
$worker->onMessage = function(TcpConnection $connection, $data)
{
    $save_path = '/tmp/'.$data['file_name'];
    file_put_contents($save_path, $data['file_data']);
    $connection->send("upload success. save path $save_path");
};
 
Worker::runAll();
 
 
 
 
用php模拟文件上传的客户端的实现textclient.php：
<?php
/** 上传文件客户端 **/
// 上传地址
$address = "127.0.0.1:8333";
// 检查上传文件路径参数
if(!isset($argv[1]))
{
    exit("use php client.php \$file_path\n");
}
// 上传文件路径
$file_to_transfer = trim($argv[1]);
// 上传的文件本地不存在
if(!is_file($file_to_transfer))
{
    exit("$file_to_transfer not exist\n");
}
// 建立socket连接
$client = stream_socket_client($address, $errno, $errmsg);
if(!$client)
{
    exit("$errmsg\n");
}
//阻塞模式
stream_set_blocking($client, 1);
// 文件名
$file_name = basename($file_to_transfer);
// 文件二进制数据
$file_data = file_get_contents($file_to_transfer);
// base64编码
$file_data = base64_encode($file_data);
// 数据包
$package_data = array(
    'file_name' => $file_name,
    'file_data' => $file_data,
);
// 协议包 json+回车
$package = json_encode($package_data)."\n";
// 执行上传
fwrite($client, $package);
// 打印结果
echo fread($client, 8192),"\n";
 
 
 
 
 
 
 
服务端启动
[root@localhost workerman]# php -c /usr/local/php734/lib/php/php.ini start.php start
Workerman[start.php] start in DEBUG mode
--------------------------------------------- WORKERMAN ---------------------------------------------
Workerman version:4.0.22          PHP version:7.3.4
---------------------------------------------- WORKERS ----------------------------------------------
proto   user            worker          listen                         processes    status
tcp     root            none            textTransfer://0.0.0.0:8333    1             [OK]
-----------------------------------------------------------------------------------------------------
Press Ctrl+C to stop. Start success.
 
 
 
 
 
客户端上传测试
[root@localhost ~]# ls
1.html  anaconda-ks.cfg  cs2.php  cs.php  dump.rdb  dump.rdb.bk  harbor-offline-installer-v1.4.0.tgz  package.xml  redis-5.3.5RC1  redis-5.3.5RC1.tgz  worker_test_log.txt
[root@localhost ~]# php -c /usr/local/php734/lib/php/php.ini /workerman/textclient.php package.xml
[root@localhost ~]# ls -lsh /tmp | grep package
 52K -rw-r--r-- 1 root root 50K Nov 28 06:57 package.xml