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

转载请注明出处：

1.Eggjs 特性：

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

1. 框架内置了基于约定的目录结构、约定的扩展机制和一些常用的插件，可以帮助开发者快速搭建应用。
2. Egg.js 遵循 MVC 的分层架构，使代码更加清晰易于维护。
3. Egg.js 通过插件机制提供了丰富的功能扩展，例如：数据库访问、模板引擎、Session、身份验证、安全等。
4. Egg.js 提供了一套完善的开发调试工具，例如：自动重启、自动刷新、自动测试等。
5. 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(`ｓｅｌｅｃｔ * from user where id='${id}'`);    }    async ｕｐｄａｔｅ(id, user) {      return influx.writePoints([        {          measurement: 'user',          tags: { id },          fields: {            name: user.name,            age: user.age          }        }      ]);    }    async ｄｅｌｅｔｅ(id) {      return influx.query(`ｄｅｌｅｔｅ 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 ｕｐｄａｔｅ() {    const { ctx } = this;    const { id } = ctx.params;    const { name, age } = ctx.request.body;    await ctx.service.user.ｕｐｄａｔｅ(id, { name, age });    ctx.body = { success: true };  }  async ｄｅｌｅｔｅ() {    const { ctx } = this;    const { id } = ctx.params;    await ctx.service.user.ｄｅｌｅｔｅ(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.ｕｐｄａｔｅ);  router.ｄｅｌｅｔｅ('/user/:id', controller.home.ｄｅｌｅｔｅ);};

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 ｄｅｌｅｔｅ 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