nodejs使用eggjs创建项目，接入influxdb完成单表增删改查-世界热议

转载请注明出处：

1.Eggjs 特性：

Eggjs 是 Node.js 服务端应用开发框架，它提供了一套约定，使开发者能够快速搭建、开发和部署应用。以下是 Egg.js 的一些特性和作用：

框架内置了基于约定的目录结构、约定的扩展机制和一些常用的插件，可以帮助开发者快速搭建应用。Egg.js 遵循 MVC 的分层架构，使代码更加清晰易于维护。Egg.js 通过插件机制提供了丰富的功能扩展，例如：数据库访问、模板引擎、Session、身份验证、安全等。Egg.js 提供了一套完善的开发调试工具，例如：自动重启、自动刷新、自动测试等。Egg.js 提供了一套完整的部署方案，例如：多进程部署、负载均衡等。2..使用egg初始化项目

首先需要保证本地具有nodej的环境，使用egg初始化项目

(相关资料图)

npm init egg --type=simple

在执行该命令的中间过程，需要输入 项目名称、项目描述、项目作者以及安全的配置key

创建之后的项目导入vscode之后如下图所示：

3.约定规则　　

1 app/router.js：用于配置URL路由规则；　　2 app/controller/** ：用于解析用户的输入，处理后返回相应的结果；　　3 app/service/： 用于编写业务逻辑层；　　4 app/public/： 用于放置静态资源；　　5 config/config.{env}.js： 用于编写配置文件；　　6 config/plugin.js 用于配置需要加载的插件；

4.接入InfluxDB配置

egg提供5种配置文件：

config.default.js：默认配置文件；　　　　config.local.js：开发环境下的配置，与默认配置合并，同名则覆盖默认配置；　　　　config.prod.js：生产环境下的配置，与默认配置合并，同名则覆盖默认配置；　　　　config.test.js：测试环境下的配置，与默认配置合并，同名则覆盖默认配置；　　　　config.unittest.js：单元测试环境下的配置，与默认配置合并，同名则覆盖默认配置；

在 config.default.js 中添加influxdb相关的配置文件，并设置日志级别

config.influxdb = {    host: "influx_db_host",    port: 8086,    database: "influx_db",    username: "influx_user",    password: "influx_pwd"  }  config.log = {    level: "DEBUG",    consoleLevel: "DEBUG",  }

5. 创建user表

在app/model/user.js中创建user表：

module.exports = app => {  const { InfluxDB } = require("influx");  const { host, port, database, username, password } = app.config.influxdb;  const influx = new InfluxDB({    host,    port,    database,    username,    password,    schema: [      {        measurement: "user",        fields: {          name: InfluxDB.FieldType.STRING,          age: InfluxDB.FieldType.INTEGER,        },        tags: [          "id"        ]      }    ]  });  class User extends app.Service {    async create(user) {      return influx.writePoints([        {          measurement: "user",          tags: { id: user.id },          fields: {            name: user.name,            age: user.age          }        }      ]);    }    async find(id) {      return influx.query(`select * from user where id="${id}"`);    }    async update(id, user) {      return influx.writePoints([        {          measurement: "user",          tags: { id },          fields: {            name: user.name,            age: user.age          }        }      ]);    }    async delete(id) {      return influx.query(`delete from user where id="${id}"`);    }  }  return User;};

6. user表的增删改查

在app/controller/home.js中编写增删改查的接口：

const Controller = require("egg").Controller;class HomeController extends Controller {  async create() {    const { ctx } = this;    const { id, name, age } = ctx.request.body;    await ctx.service.user.create({ id, name, age });    ctx.body = { success: true };  }  async find() {    const { ctx } = this;    const { id } = ctx.query;    const result = await ctx.service.user.find(id);    ctx.body = result;  }  async update() {    const { ctx } = this;    const { id } = ctx.params;    const { name, age } = ctx.request.body;    await ctx.service.user.update(id, { name, age });    ctx.body = { success: true };  }  async delete() {    const { ctx } = this;    const { id } = ctx.params;    await ctx.service.user.delete(id);    ctx.body = { success: true };  }}module.exports = HomeController;

7.在app/router.js中配置路由

module.exports = app => {  const { router, controller } = app;  router.post("/user", controller.home.create);  router.get("/user", controller.home.find);  router.put("/user/:id", controller.home.update);  router.delete("/user/:id", controller.home.delete);};

8.启动并测试

启动

开发环境：npm run dev生产环境：npm start

使用curl命令测试接口：

# 创建user$ curl -X POST -H "Content-type: application/json" -d "{"id": "1", "name": "Alice", "age": 20}" http://localhost:7001/user# 查找user$ curl http://localhost:7001/user?id=1# 更新user$ curl -X PUT -H "Content-type: application/json" -d "{"name": "Bob", "age": 30}" http://localhost:7001/user/1# 删除user$ curl -X DELETE http://localhost:7001/user/1

9.目录结构及所有文件

egg-influxdb-demo├── app│ ├── controller│ │ └── home.js│ ├── model│ │ └── user.js│ ├── router.js│ ├── service│ │ └── user.js│ └── view│     └── home.tpl├── config│ ├── config.default.js│ └── plugin.js├── package.json└── README.md

关键词：