PHP异步编程: 基于PHP实(chao)现(xi) NODEJS web框架KOA

freewolf 发布于2019-07-01 11:07 / 2976人阅读

摘要：异步编程基于实现框架说明偶然间在上看到有赞官方仓库的手把手教你实现与。由于此前用过，对于的洋葱模型叹为观止。文档中是基于扩展进行开发，而对并不友好，向来习惯在下开发的我一鼓作气，将改写并兼容了此项目。

PHP异步编程: 基于 PHP 实(chao)现(xi) NODEJS web框架 KOA

说明

偶然间在 GITHUB 上看到有赞官方仓库的手把手教你实现co与Koa 。由于此前用过 KOA ，对于 KOA 的洋葱模型叹为观止。不由得心血来潮的看完了整个文档，接着 CTRL+C、CTRL+V 让代码跑了起来。
文档中是基于 swoole 扩展进行开发，而 swoole 对 WINDOWS 并不友好，向来习惯在 WINDOWS 下开发的我一鼓作气，将Workerman 改写并兼容了此项目。

体验

PHPKoa Demo 是使用 PHPKoa 开发 HTTP SERVER 的一个简单示例！

安装

composer require naka1205/phpkoa

使用 Hello World

υse(function(Context $ctx) {
    $ctx->status = 200;
    $ctx->body = "Hello World";
});

$app->listen(3000);

Error

υse(new Error());
$app->υse(new NotFound());
$app->υse(new Timeout(3)); //设置3秒超时

$router = new Router();

//正常访问
$router->get("/hello", function(Context $ctx, $next) {
    $ctx->status = 200;
    $ctx->body = "Hello World";
});

//访问超时
$router->get("/timeout", function(Context $ctx, $next) {
    yield async_sleep(5);
});

//访问出错
$router->get("/error", function(Context $ctx, $next) {
    $ctx->thrοw(500, "Internal Error");
    yield;
});

$app->υse($router->routes());

$app->listen(3000);

Router

υse(new Error());
$app->υse(new Timeout(5));

$router = new Router();
$router->get("/demo1", function(Context $ctx, $next) {
    $ctx->body = "demo1";
});
$router->get("/demo2", function(Context $ctx, $next) {
    $ctx->body = "demo2";
});
$router->get("/demo3/(d+)", function(Context $ctx, $next, $vars) {
    $ctx->status = 200;
    $ctx->body = "demo3={$vars[0]}";
});
$router->get("/demo4", function(Context $ctx, $next) {
    $ctx->redirect("/demo2");
});

//RESTful API
$router->post("/demo3/(d+)", function(Context $ctx, $next, $vars) {
    //设置 session
    $ctx->setSession("demo3",$vars[0]);
    //设置 cookie
    $ctx->setCookie("demo3",$vars[0]);
    $ctx->status = 200;
    $ctx->body = "post:demo3={$vars[0]}";
});
$router->put("/demo3/(d+)", function(Context $ctx, $next, $vars) {

    //获取单个 cookie
    $cookie_demo3 = $ctx->getCookie("demo3");
    //或者
    $cookies = $ctx->cookies["demo3"];

    //获取单个 session
    $session_demo3 = $ctx->getSession("demo3");
    //或者
    $session = $ctx->session["demo3"];

    $ctx->status = 200;
    $ctx->body = "put:demo3={$vars[0]}";
});
$router->delete("/demo3/(d+)", function(Context $ctx, $next, $vars) {
    //清除所有 cookie
    $ctx->clearCookie();
    //清除所有 session
    $ctx->clearSession();
    $ctx->status = 200;
    $ctx->body = "delete:demo3={$vars[0]}";
});

//文件上传
$router->post("/files/(d+)", function(Context $ctx, $next, $vars) {
    $upload_path = __DIR__ . DS .  "uploads" . DS;
    if ( !is_dir($upload_path) ) {
        mkdir ($upload_path , 0777, true);
    }
    $files = [];
    foreach ( $ctx->request->files as $key => $value) {
        if ( !$value["file_name"] || !$value["file_data"] ) {
            continue;
        }
        $file_path = $upload_path . $value["file_name"];
        file_put_contents($file_path, $value["file_data"]);
        $value["file_path"] = $file_path;
        $files[] = $value;
    }

    $ctx->status = 200;
    $ctx->body = json_encode($files);
});


$app->υse($router->routes());

$app->listen(3000);

mount("/curl", function() use ($router) {
    $client = new Client();
    $router->get("/get", function( Context $ctx, $next ) use ($client) {
        $r = (yield $client->request("GET", "http://127.0.0.1:3000/demo3/1"));
        $ctx->status = $r->getStatusCode();
        $ctx->body = $r->getBody();
    });

    $router->get("/post", function(Context $ctx, $next ) use ($client){
        $r = (yield $client->request("POST", "http://127.0.0.1:3000/demo3/2"));
        $ctx->status = $r->getStatusCode();
        $ctx->body = $r->getBody();
    });

    $router->get("/put", function( Context $ctx, $next ) use ($client){
        $r = (yield $client->request("PUT", "http://127.0.0.1:3000/demo3/3"));
        $ctx->status = $r->getStatusCode();
        $ctx->body = $r->getBody();
    });

    $router->get("/delete", function( Context $ctx, $next ) use ($client){
        $r = (yield $client->request("DELETE", "http://127.0.0.1:3000/demo3/4"));
        $ctx->status = $r->getStatusCode();
        $ctx->body = $r->getBody();
    });
});

//http://127.0.0.1:5000/files
$router->get("/files", function(Context $ctx, $next ) {
    $client = new Client();
    $r = ( yield $client->request("POST", "http://127.0.0.1:3000/files/2", [
        "multipart" => [
            [
                "name"     => "file_name",
                "contents" => fopen( __DIR__ . "/file.txt", "r")
            ],
            [
                "name"     => "other_file",
                "contents" => "hello",
                "filename" => "filename.txt",
                "headers"  => [
                    "X-Foo" => "this is an extra header to include"
                ]
            ]
        ]
    ]));
    
    $ctx->status = $r->getStatusCode();
    $ctx->body = $r->getBody();
});

// $router->get("/curl/(w+)", function(Context $ctx, $next, $vars) {
//     $method = strtoupper($vars[0]);
//     $client = new Client();
//     $r = (yield $client->request($method, "http://127.0.0.1:3000/demo3/123"));
//     $ctx->status = $r->getStatusCode();
//     $ctx->body = $r->getBody();
// });

$app->υse($router->routes());
$app->listen(5000);

Template


    {title}
    {time}

υse(new Error());
$app->υse(new Timeout(5));

$router = new Router();
$router->get("/hello", function(Context $ctx) {
    $ctx->status = 200;
    $ctx->state["title"] = "HELLO WORLD";
    $ctx->state["time"] = date("Y-m-d H:i:s", time());;
    yield $ctx->render(__DIR__ . "/hello.html");
});
$app->υse($router->routes());

$app->listen(3000);


    {title}
    
      Name Age
  
      
      
         {name} 
         {age}

get("/info", function(Context $ctx) {
    $info = array("name" => "小明", "age" => 15);
    $ctx->status = 200;
    $ctx->state["title"] = "这是一个学生信息";
    $ctx->state["info"] = $info;
    yield $ctx->render(__DIR__ . "/info.html");
});


    {title}
    
      Name Age
  
      
      
         {name} 
         {age}

get("/table", function(Context $ctx) {
    $table = array(
        array("name" => "小明", "age" => 15),
        array("name" => "小花", "age" => 13),
        array("name" => "小刚", "age" => 17)
    );
    $ctx->status = 200;
    $ctx->state["title"] = "这是一个学生名单";
    $ctx->state["table"] = $table;
    yield $ctx->render(__DIR__ . "/table.html");
});

中间件

静态文件处理中间件 PHPKoa Static




    
    PHPkoa Static

υse(new Error());
$app->υse(new Timeout(5));
$app->υse(new NotFound()); 
$app->υse(new StaticFiles(__DIR__ . DS .  "static" )); 

$router = new Router();

$router->get("/index", function(Context $ctx, $next) {
    $ctx->status = 200;
    yield $ctx->render(__DIR__ . "/index.html");
});

$app->υse($router->routes());

$app->listen(3000);

云服务器 GPU云服务器 php的web框架时出现php nodejs-koa php调用短网址实

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/29853.html

前端周报：前端面试题及答案总结；JavaScript参数传递的深入理解

摘要：前端面试题及答案总结掘金技术征文金三银四，金九银十，用来形容求职最好的几个月。因为的存在，至少在被标准化的那一刻起，就支持异步编程了。然而异步编程真正发展壮大，的流行功不可没。 showImg(https://segmentfault.com/img/bVVQOH?w=640&h=319); 1、2017前端面试题及答案总结 |掘金技术征文金三银四，金九银十，用来形容求职最好的几个月...

ermaoL 2019-08-21 16:46 评论0 收藏0
nodejs异步编程详解

摘要：四异步编程解决方案模式模式一定程度上缓解了嵌套回调的问题，只会处在未完成完成态失败态中的一种，只会从未完成转化为完成态或者失败态，不能逆转。一、从一个简单的案例开始 fs.readdir(path.join(__dirname, ./index.js), (err, files) => { files.foreach((filename, index) => { ...

inapt 2019-08-20 16:00 评论0 收藏0
全栈最后一公里 - Node.js 项目的线上服务器部署与发布

摘要：没有耐心阅读的同学，可以直接前往学习全栈最后一公里。我下面会罗列一些，我自己录制过的一些项目，或者其他的我觉得可以按照这个路线继续深入学习的项目资源。 showImg(https://segmentfault.com/img/bVMlke?w=833&h=410); 本文技术软文，阅读需谨慎，长约 7000 字，通读需 5 分钟大家好，我是 Scott，本文通过提供给大家学习的方法，...

Nosee 2019-06-26 17:14 评论0 收藏0
【全文】狼叔：如何正确的学习Node.js

摘要：感谢大神的免费的计算机编程类中文书籍收录并推荐地址，以后在仓库里更新地址，声音版全文狼叔如何正确的学习简介现在，越来越多的科技公司和开发者开始使用开发各种应用。说明 2017-12-14 我发了一篇文章《没用过Node.js，就别瞎逼逼》是因为有人在知乎上黑Node.js。那篇文章的反响还是相当不错的，甚至连著名的hax贺老都很认同，下班时读那篇文章，竟然坐车的还坐过站了。大家可以很...

Edison 2019-08-30 14:14 评论0 收藏0