Swoole接口

<?php

// 编写自己的http服务器
/**
 * 第1个参数， 0.0.0.0 表示监听本机所有的网址地址
 * 第2参数，6060 表示监听端口号  当前建议1-1024之间是系统保留不要去用
 */
$http = new swoole_http_server('0.0.0.0', 6060);

// 设置
$http->set([
    // 工作的进程数量
    'worker_num'  => 2,
    // 一个进程请求的最大次数
    'max_request' => 1000
]);

// 相关事件的监听
// 开始事件
$http->on('start', function (swoole_server $server) {
    echo "服务启动了！\n";
});

// 处理请求事件
/**
 * $request 请求对象  服务器请求得到客户发过来的数据对象
 * $response 响应对象 服务器向客户发送数据所用的对象
 */
$http->on('request', function (swoole_http_request $request, swoole_http_response $response) {

    // 得到客户端过来的请求
    // 得到请求的类型
    $method = strtolower($request->server['request_method']);
    // 请求的uri
    $uri = $request->server['request_uri'];

    // 列表请求是要用GET请求的方式
    if ('get' == $method) {

        // 文章列表
        if ('/api/v1/articles' == $uri) {

            $offset = $request->get['offset'] ?? 0;
            $limit  = $request->get['limit'] ?? 10;

            // 操作数据库  协程
            $db = new \Swoole\Coroutine\MySQL();
            $db->connect([
                'host'     => '127.0.0.1',
                'port'     => '3306',
                'charset'  => 'utf8',
                'user'     => 'root',
                'password' => 'admin888',
                'database' => 'test'
            ]);

            // 编写sql
            $sql = "select * from articles limit $offset,$limit";
            $ret = $db->query($sql);

            // 加上头信息
            $response->header('Content-Type', 'application/json;charset=utf-8');
            $response->end(json_encode($ret,JSON_UNESCAPED_UNICODE));
        }



    }


});

// 启动服务
$http->start();