AI 助理
备案控制台
开发者社区 数据库 文章 正文

easyswoole快速实现一个网站的api接口程序

2022-12-09 185
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
RDS MySQL Serverless 高可用系列，价值2615元额度，1个月
云数据库 RDS MySQL，高可用系列 2核4GB
简介： easyswoole快速实现一个网站的api接口程序

目前，easyswoole已经成为了最知名的swoole框架之一，本人也用easyswoole开发过很多个项目了，现在就来讲一讲如何用easyswoole快速实现一个网站的curd功能的接口。

安装easyswoole和相关组件

环境方面本人不多做说明，可以去官方文档查看。

新增composer.json文件

{
    "require": {
        "easyswoole/easyswoole": "^3.2",
        "easyswoole/mysqli": "^1.2",
        "tioncico/curd-automatic-generation": "^1.0"
    },
    "autoload": {
        "psr-4": {
            "App\\\": "Application/"
        }
    }
}

然后输入以下命令进行引入，安装组件库：

composer up
mkdir -p Application/HttpController
php ./vendor/easyswoole/easyswoole/bin/easyswoole install

设计数据表

假设我们需要做一个简单的文章管理系统，需要用户，文章，评论，置顶，分类，这5个表：

新增文件 test.php

<?php
/**
 * Created by PhpStorm.
 * User: tioncico
 * Date: 19-7-27
 * Time: 上午11:40
 */
include "./vendor/autoload.php";
//会员列表
$result = \\EasySwoole\\Mysqli\\DDLBuilder\\DDLBuilder::table('user_list', function (\\EasySwoole\\Mysqli\\DDLBuilder\\Blueprints\\TableBlueprint $blueprint) {
    $blueprint->colInt('id', '11')->setColumnComment('主键id')->setIsPrimaryKey()->setIsAutoIncrement();
    $blueprint->colVarChar('userAccount', '32')->setColumnComment('会员账号');
    $blueprint->colVarChar('userName', '32')->setColumnComment('会员昵称');
    $blueprint->colVarChar('userPassword', '32')->setColumnComment('会员密码');
    $blueprint->colDateTime('addTime')->setColumnComment('新增时间');
    $blueprint->colTinyInt('isAdmin', 1)->setColumnComment('是否会管理员')->setDefaultValue(0);
    $blueprint->setTableComment('会员列表');
    $blueprint->setTableEngine(\\EasySwoole\\Mysqli\\DDLBuilder\\Enum\\Engines::INNODB);
    $blueprint->setTableCharset(\\EasySwoole\\Mysqli\\DDLBuilder\\Enum\\Character::UTF8\_GENERAL\_CI);
    $blueprint->indexNormal('userAccount', \['userAccount'\]);
});
echo $result;
//文章分类列表
$result = \\EasySwoole\\Mysqli\\DDLBuilder\\DDLBuilder::table('article_list', function (\\EasySwoole\\Mysqli\\DDLBuilder\\Blueprints\\TableBlueprint $blueprint) {
    $blueprint->colInt('id', '11')->setColumnComment('主键id')->setIsPrimaryKey()->setIsAutoIncrement();
    $blueprint->colInt('pid', 11)->setColumnComment('上级id');
    $blueprint->colVarChar('categoryName', '64')->setColumnComment('分类名称');
    $blueprint->setTableComment('分类列表');
    $blueprint->setTableEngine(\\EasySwoole\\Mysqli\\DDLBuilder\\Enum\\Engines::INNODB);
    $blueprint->setTableCharset(\\EasySwoole\\Mysqli\\DDLBuilder\\Enum\\Character::UTF8\_GENERAL\_CI);
});
echo $result;
//文章列表
$result = \\EasySwoole\\Mysqli\\DDLBuilder\\DDLBuilder::table('article_list', function (\\EasySwoole\\Mysqli\\DDLBuilder\\Blueprints\\TableBlueprint $blueprint) {
    $blueprint->colInt('id', '11')->setColumnComment('主键id')->setIsPrimaryKey()->setIsAutoIncrement();
    $blueprint->colInt('categoryId', 11)->setColumnComment('分类id');
    $blueprint->colVarChar('title', '64')->setColumnComment('标题');
    $blueprint->colVarChar('keyword', '64')->setColumnComment('关键字');
    $blueprint->colVarChar('description', '255')->setColumnComment('简介');
    $blueprint->colVarChar('author', '32')->setColumnComment('作者');
    $blueprint->colText('content')->setColumnComment('内容');
    $blueprint->colDateTime('addTime')->setColumnComment('新增时间');
    $blueprint->colTinyInt('isOriginal', 1)->setColumnComment('是否原创')->setDefaultValue(1);
    $blueprint->setTableComment('文章列表');
    $blueprint->setTableEngine(\\EasySwoole\\Mysqli\\DDLBuilder\\Enum\\Engines::INNODB);
    $blueprint->setTableCharset(\\EasySwoole\\Mysqli\\DDLBuilder\\Enum\\Character::UTF8\_GENERAL\_CI);
    $blueprint->indexNormal('title', \['title'\]);
});
echo $result;
//评论列表
$result = \\EasySwoole\\Mysqli\\DDLBuilder\\DDLBuilder::table('comment_list', function (\\EasySwoole\\Mysqli\\DDLBuilder\\Blueprints\\TableBlueprint $blueprint) {
    $blueprint->colInt('id', '11')->setColumnComment('主键id')->setIsPrimaryKey()->setIsAutoIncrement();
    $blueprint->colInt('articleId', 11)->setColumnComment('文章id');
    $blueprint->colInt('commentPid', 11)->setColumnComment('评论父id')->setDefaultValue(0);
    $blueprint->colInt('userId', 11)->setColumnComment('评论会员id');
    $blueprint->colVarChar('userName', '64')->setColumnComment('评论会员名');
    $blueprint->colVarChar('content', '255')->setColumnComment('评论内容');
    $blueprint->colDateTime('addTime')->setColumnComment('评论时间');
    $blueprint->setTableComment('文章评论列表');
    $blueprint->setTableEngine(\\EasySwoole\\Mysqli\\DDLBuilder\\Enum\\Engines::INNODB);
    $blueprint->setTableCharset(\\EasySwoole\\Mysqli\\DDLBuilder\\Enum\\Character::UTF8\_GENERAL\_CI);
    $blueprint->indexNormal('articleId', \['articleId'\]);
    $blueprint->indexNormal('commentPid', \['commentPid'\]);
    $blueprint->indexNormal('userId', \['userId'\]);
});
echo $result;
//评论列表
$result = \\EasySwoole\\Mysqli\\DDLBuilder\\DDLBuilder::table('top_list', function (\\EasySwoole\\Mysqli\\DDLBuilder\\Blueprints\\TableBlueprint $blueprint) {
    $blueprint->colInt('id', '11')->setColumnComment('主键id')->setIsPrimaryKey()->setIsAutoIncrement();
    $blueprint->colInt('articleId', 11)->setColumnComment('文章id');
    $blueprint->setTableComment('文章置顶列表');
    $blueprint->setTableEngine(\\EasySwoole\\Mysqli\\DDLBuilder\\Enum\\Engines::INNODB);
    $blueprint->setTableCharset(\\EasySwoole\\Mysqli\\DDLBuilder\\Enum\\Character::UTF8\_GENERAL\_CI);
    $blueprint->indexNormal('articleId', \['articleId'\]);
});
echo $result;

该文件作用是直接通过easyswoole的mysqli建表工具生成建表sql，运行sql直接建表

配置数据库

在dev.php文件中新增以下配置：

'MYSQL'       => \[
    'host'            => '127.0.0.1',
    'port'            => 3306,
    'user'            => 'root',
    'password'        => 'test',
    'database'        => 'article',
    'timeout'         => 30,
    'charset'         => 'utf8mb4',
    'connect_timeout' => '5',//连接超时时间
\],

注册数据库连接池：

在easyswooleEvent.php的initialize方法中，注册数据库连接池：

public static function initialize()
{
    // TODO: Implement initialize() method.
    date\_default\_timezone_set('Asia/Shanghai');
    $mysqlConfig = new \\EasySwoole\\Mysqli\\Config(\\EasySwoole\\EasySwoole\\Config::getInstance()->getConf('MYSQL'));
    \\EasySwoole\\MysqliPool\\Mysql::getInstance()->register('mysql',$mysqlConfig);
}

初始化basemodel和basecontroller：

新增init.php文件：

<?php
/**
 * Created by PhpStorm.
 * User: tioncico
 * Date: 19-7-27
 * Time: 上午11:59
 */
include "./vendor/autoload.php";
\\EasySwoole\\EasySwoole\\Core::getInstance()->initialize();
$init = new \\AutomaticGeneration\\Init();
$init->initBaseModel();
$init->initBaseController();

该脚本可在App目录中生成基础的baseModel和baseController

新增AdminBase，IndexBase，UserBase控制器，用于控制登录权限

分别在//Application/HttpController/Api/Admin,/Api/User,/Api/Index中新增Base.php文件：

<?php
/**
 * Created by PhpStorm.
 * User: tioncico
 * Date: 19-7-27
 * Time: 下午12:14
 */
namespace App\\HttpController\\Api\\Admin;
use App\\Model\\UserBean;
use EasySwoole\\Http\\Message\\Status;
class Base extends \\App\\HttpController\\Base
{
    protected $who;
    //session的cookie头
    protected $tokenName = 'adminSession';
    //白名单，用于用户请求login方法时，不会因为没有登录而拒绝访问
    protected $whiteList = \['login'\];
    /**
     * onRequest
     * @param null|string $action
     * @return bool|null
     * @throws \\Throwable
     * @author yangzhenyu
     * Time: 13:49
     */
    function onRequest(?string $action): ?bool
    {
        if (parent::onRequest($action)) {
            //白名单判断
            if (in_array($action, $this->whiteList)) {
                return true;
            }
            //获取登入信息，如果没有登录，则不让访问，只有Admin和User需要
            if (!$this->getWho()) {
                $this->writeJson(Status::CODE_UNAUTHORIZED, '', '登入已过期');
                return false;
            }
            return true;
        }
        return false;
    }
    /**
     * getWho
     * @return bool
     * @author yangzhenyu
     * Time: 13:51
     */
    function getWho(): ?UserBean
    {
        if ($this->who instanceof UserBean) {
            return $this->who;
        }
        $sessionKey = $this->request()->getRequestParam($this->tokenName);
        if (empty($sessionKey)) {
            $sessionKey = $this->request()->getCookieParams($this->tokenName);
        }
        if (empty($sessionKey)) {
            return null;
        }
        //这里需要自己实现，通过用户传来的token，去获取用户信息，如果获取失败，则代表没有登录
        return $this->who;
    }
    protected function getValidateRule(?string $action): ?\\EasySwoole\\Validate\\Validate
    {
        // TODO: Implement getValidateRule() method.
    }
}

批量新增curd控制器，表操作model

新增createTable.php文件：

<?php
/**
 * Created by PhpStorm.
 * User: tioncico
 * Date: 19-7-27
 * Time: 上午11:59
 */
include "./vendor/autoload.php";
\\EasySwoole\\EasySwoole\\Core::getInstance()->initialize();
go(function () {
    $db = \\EasySwoole\\MysqliPool\\Mysql::defer('mysql');
    $result = $db->rawQuery("show tables;");
    $tableList = array\_column($result,'Tables\_in_article');
    var_dump($tableList);
    //生成所有的bean，model
    foreach ($tableList as $tableName){
        var_dump($tableName);
        $mysqlTable = new \\AutomaticGeneration\\MysqlTable($db, \\EasySwoole\\EasySwoole\\Config::getInstance()->getConf('MYSQL.database'));
        $tableColumns = $mysqlTable->getColumnList($tableName);
        $tableComment = $mysqlTable->getComment($tableName);
        $path = '';
        $beanConfig = new \\AutomaticGeneration\\Config\\BeanConfig();
        $beanConfig->setBaseNamespace("App\\\Model".$path);
        $beanConfig->setTablePre('');
        $beanConfig->setTableName($tableName);
        $beanConfig->setTableComment($tableComment);
        $beanConfig->setTableColumns($tableColumns);
        $beanBuilder = new \\AutomaticGeneration\\BeanBuilder($beanConfig);
        $result = $beanBuilder->generateBean();
        var_dump($result);
        $path = '';
        $modelConfig = new \\AutomaticGeneration\\Config\\ModelConfig();
        $modelConfig->setBaseNamespace("App\\\Model".$path);
        $modelConfig->setTablePre("");
        $modelConfig->setExtendClass(\\App\\Model\\BaseModel::class);
        $modelConfig->setTableName("user_list");
        $modelConfig->setTableComment($tableComment);
        $modelConfig->setTableColumns($tableColumns);
        $modelBuilder = new \\AutomaticGeneration\\ModelBuilder($modelConfig);
        $result = $modelBuilder->generateModel();
        var_dump($result);
        $path='\\\Api\\\Admin';
        $controllerConfig = new \\AutomaticGeneration\\Config\\ControllerConfig();
        $controllerConfig->setBaseNamespace("App\\\HttpController".$path);
        $controllerConfig->setTablePre('');
        $controllerConfig->setTableName($tableName);
        $controllerConfig->setTableComment($tableComment);
        $controllerConfig->setTableColumns($tableColumns);
        $controllerConfig->setExtendClass("App\\\HttpController".$path."\\\Base");
        $controllerConfig->setModelClass($modelBuilder->getClassName());
        $controllerConfig->setBeanClass($beanBuilder->getClassName());
        $controllerConfig->setMysqlPoolClass(EasySwoole\\MysqliPool\\Mysql::class);
        $controllerConfig->setMysqlPoolName('mysql');
        $controllerBuilder = new \\AutomaticGeneration\\ControllerBuilder($controllerConfig);
        $result = $controllerBuilder->generateController();
        var_dump($result);
        $path='\\\Api\\\Index';
        $controllerConfig = new \\AutomaticGeneration\\Config\\ControllerConfig();
        $controllerConfig->setBaseNamespace("App\\\HttpController".$path);
        $controllerConfig->setTablePre('');
        $controllerConfig->setTableName($tableName);
        $controllerConfig->setTableComment($tableComment);
        $controllerConfig->setTableColumns($tableColumns);
        $controllerConfig->setExtendClass("App\\\HttpController".$path."\\\Base");
        $controllerConfig->setModelClass($modelBuilder->getClassName());
        $controllerConfig->setBeanClass($beanBuilder->getClassName());
        $controllerConfig->setMysqlPoolClass(EasySwoole\\MysqliPool\\Mysql::class);
        $controllerConfig->setMysqlPoolName('mysql');
        $controllerBuilder = new \\AutomaticGeneration\\ControllerBuilder($controllerConfig);
        $result = $controllerBuilder->generateController();
        var_dump($result);
        $path='\\\Api\\\User';
        $controllerConfig = new \\AutomaticGeneration\\Config\\ControllerConfig();
        $controllerConfig->setBaseNamespace("App\\\HttpController".$path);
        $controllerConfig->setTablePre('');
        $controllerConfig->setTableName($tableName);
        $controllerConfig->setTableComment($tableComment);
        $controllerConfig->setTableColumns($tableColumns);
        $controllerConfig->setExtendClass("App\\\HttpController".$path."\\\Base");
        $controllerConfig->setModelClass($modelBuilder->getClassName());
        $controllerConfig->setBeanClass($beanBuilder->getClassName());
        $controllerConfig->setMysqlPoolClass(EasySwoole\\MysqliPool\\Mysql::class);
        $controllerConfig->setMysqlPoolName('mysql');
        $controllerBuilder = new \\AutomaticGeneration\\ControllerBuilder($controllerConfig);
        $result = $controllerBuilder->generateController();
        var_dump($result);
    }
    exit;
});

运行，根据提示去输入需要在getAll时查询的关键字字段，不填也行：

image.png

当前台传入keyword=“测试”，那么sql语句将会生成 title like "%测试%"

完善接口

当这个文件运行完之后，一个文章管理系统的基本api已经是生成好了，大概是这样：

image.png

我们下一步要做的是：

1：完善用户登录接口

2：把User里面所有控制器的update，add等方法删除（普通用户没权限管理文章，文章分类等等，当然评论有权限）

3：每个方法都需要去修改下，毕竟自动生成工具不是那么智能，只能自己继续完善了，但是，已经是很好了，不是吗？

4：每个控制器的getValidateRule方法需要自己完善，这个是用于验证用户传入的基础参数是否正确的方法

给你们看看curd的各种方法自动生成后的截图：





image.png

image.png

image.png

image.png

image.png

这些都是自动生成的哦！

其他：

建表工具文档：https://www.easyswoole.com/Cn/Components/Mysqli/createTable.html

自动生成curd控制器组件地址：https://github.com/tioncico/curdAutomaticGeneration

easyswoole mysql-pool组件：https://www.easyswoole.com/Cn/Components/mysqlPool.html

easyswoole官方文档：https://www.easyswoole.com/Cn/Introduction/environment.html

文章标签：
云数据库 RDS MySQL 版
SQL
数据安全/隐私保护
API
数据库
关键词：
API接口
网站API
API程序
API网站
网站API接口
相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发，帮助IT从业者们通过“阿里云Web应用上云解决方案”，了解一个企业级Web应用上云的常见架构，了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品：云数据库RDS MySQL 版 阿里云关系型数据库RDS（Relational Database Service）是一种稳定可靠、可弹性伸缩的在线数据库服务，提供容灾、备份、恢复、迁移等方面的全套解决方案，彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
仙士可
目录
相关文章
一个幽默的程序员
|
1月前
|
数据可视化 测试技术 API
从接口性能到稳定性：这些API调试工具，让你的开发过程事半功倍
在软件开发中，接口调试与测试对接口性能、稳定性、准确性及团队协作至关重要。随着开发节奏加快，传统方式已难满足需求，专业API工具成为首选。本文介绍了Apifox、Postman、YApi、SoapUI、JMeter、Swagger等主流工具，对比其功能与适用场景，并推荐Apifox作为集成度高、支持中文、可视化强的一体化解决方案，助力提升API开发与测试效率。
一个幽默的程序员
417 122
技术交流18179014480
|
9天前
|
JSON API 数据安全/隐私保护
Python采集淘宝拍立淘按图搜索API接口及JSON数据返回全流程指南
通过以上流程，可实现淘宝拍立淘按图搜索的完整调用链路，并获取结构化的JSON商品数据，支撑电商比价、智能推荐等业务场景。
技术交流18179014480
113 4
体育数据Lynne
|
18天前
|
JSON 前端开发 API
如何调用体育数据足篮接口API
本文介绍如何调用体育数据API：首先选择可靠服务商并注册获取密钥，接着阅读文档了解基础URL、端点、参数及请求头，然后使用Python等语言发送请求、解析JSON数据，最后将数据应用于Web、App或分析场景，同时注意密钥安全、速率限制与错误处理。
体育数据Lynne
125 2
技术交流18179014480
|
28天前
|
JSON API 数据安全/隐私保护
Python采集淘宝评论API接口及JSON数据返回全流程指南
Python采集淘宝评论API接口及JSON数据返回全流程指南
技术交流18179014480
989 6
winx_19970108018
|
1月前
|
JSON 供应链 监控
1688商品详情API技术深度解析：从接口架构到数据融合实战
1688商品详情API（item_get接口）可通过商品ID获取标题、价格、库存、SKU等核心数据，适用于价格监控、供应链管理等场景。支持JSON格式返回，需企业认证。Python示例展示如何调用接口获取商品信息。
winx_19970108018
164 6
向量引擎
|
18天前
|
人工智能 运维 监控
阿里云 API 聚合实战：破解接口碎片化难题，3 类场景方案让业务响应提速 60%
API聚合破解接口碎片化困局，助力开发者降本增效。通过统一中间层整合微服务、第三方接口与AI模型，实现调用次数减少60%、响应提速70%。阿里云实测：APISIX+函数计算+ARMS监控组合，支撑百万级并发，故障定位效率提升90%。
向量引擎
178 0
技术交流18179014480
|
18天前
|
JSON 自然语言处理 监控
淘宝关键词搜索与商品详情API接口（JSON数据返回）
通过商品ID（num_iid）获取商品全量信息，包括SKU规格、库存、促销活动、卖家信息、详情页HTML等。
技术交流18179014480
159 0
向量引擎api
|
23天前
|
人工智能 API 监控
告别多接口拼凑！阿里云 API 模型聚合实现技术能力协同跃迁
API聚合整合400+国内外AI模型，统一接口、屏蔽差异，降低开发与维护成本，提升效率与系统稳定性，助力开发者高效应对多API调用困境。
向量引擎api
184 0
技术交流18179014480
|
25天前
|
人工智能 供应链 API
淘宝API商品详情接口全解析：从基础数据到深度挖掘
淘宝API商品详情接口不仅提供基础数据，更通过深度挖掘实现从数据到洞察的跨越。开发者需结合业务场景选择合适分析方法，利用AI标签、区块链溯源等新技术，最终实现数据驱动的电商业务创新。
技术交流18179014480
158 0
技术交流18179014480
|
1月前
|
JSON 算法 API
干货！电商API接口（淘宝商品评论）json数据返回
要获取淘宝商品评论的JSON数据，需通过淘宝开放平台的商品评论API接口实现。以下是详细步骤及代码示例
技术交流18179014480
49 0

热门文章

最新文章

  • 1
    Python采集淘宝评论API接口及JSON数据返回全流程指南
  • 2
    基于Spring AI Alibaba + Spring Boot + Ollama搭建本地AI对话机器人API
  • 3
    从接口性能到稳定性：这些API调试工具，让你的开发过程事半功倍
  • 4
    告别旅行规划的"需求文档地狱"！这个AI提示词库，让你像调API一样定制完美旅程
  • 5
    什么是API？进行API对接的5大常见误区！
  • 6
    汽车配件：使用VIN码查询API精准匹配车型配件，提升用户信任
  • 7
    淘宝/天猫：使用支付宝API实现多场景支付，覆盖用户偏好
  • 8
    小红书笔记详情 API 实战指南：从开发对接、场景落地到收益挖掘（附避坑技巧）
  • 9
    API协议全景图：从REST到MCP的选型指南
  • 10
    Java新特性：使用Stream API重构你的数据处理
  • 1
    鸿蒙开发：基于最新API，如何实现组件化运行
    133
  • 2
    微服务架构下的电商API接口设计：策略、方法与实战案例
    197
  • 3
    电商API接口性能优化技术揭秘：缓存策略与负载均衡详解
    192
  • 4
    RESTful与GraphQL：电商API接口设计的技术细节与适用场景
    180
  • 5
    电商API接口开发：基础架构搭建全攻略
    188
  • 6
    未来电商趋势：API技术在智能供应链中的应用
    107
  • 7
    实时数据分析：如何利用API优化营销决策
    156
  • 8
    利用通义大模型构建个性化推荐系统——从数据预处理到实时API部署
    628
  • 9
    基于通义大模型的智能客服系统构建实战：从模型微调到API部署
    1230
  • 10
    淘宝商品评论API接口，json数据示例参考
    167

    • 相关电子书

    更多
  • Java Spring Boot开发实战系列课程【第15讲】：Spring Boot 2.0 API与Spring REST Docs实战
  • Spring Boot2.0实战Redis分布式缓存
  • CUDA MATH API

    • 相关实验场景

    更多
  • 基于Assistant Api的旅游助手
  • 快速体验智能体API应用
    • 下一篇
    oss教程