nodejs(koa)中封装网络请求

发表于 | 分类于 | 评论数： | 阅读次数：

#1
封装 axios

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
const axios = require("axios");

// // axios 配置
// axios.defaults.timeout = 5000;
// // axios.defaults.withCredentials = true;
// // axios.defaults.baseURL = "https://api.github.com";

// // http request 拦截器
// axios.interceptors.request.use(
//   config => {
//     // config.headers['content-type'] = "application/json";
//     return config;
//   },
//   err => {
//     return Promise.reject(err);
//   }
// );
// axios.interceptors.response.use(
//   res => {
//     return Promise.resolve(res);
//   },
//   err => {
//     return Promise.reject(err);
//   }
// );
// function post(url, body = "", path = "") {
//   return new Promise((resolve, reject) => {
//     axios
//       .post(url + path, body)
//       .then(res => {
//         resolve(res);
//       })
//       .catch(err => {
//         reject(err);
//       });
//   });
// }
module.exports = {
  get: (url, params = "", path = "") => {
    return new Promise((resolve, reject) => {
      axios
        .get(url + path, {
          params: params
        })
        .then(res => {
          resolve(res.data);
        })
        .catch(err => {
          reject(err);
        });
    });
  },
  post:(url, body = "", path = "")=> {
  return new Promise((resolve, reject) => {
    axios
      .post(url + path, body)
      .then(res => {
        resolve(res);
      })
      .catch(err => {
        reject(err);
      });
  });
};

#2
封装 api

1
2
3
4
5
6
7
const ip = require("./../config/config");
const methods = require("./index");
module.exports = {
  auth: async params => {
    return methods.get(ip.sessionIp, params);
  }
};

3

调用网络请求

1
2
3
4
5
6
module.exports = {
  async auth(ctx) {
    let [err, res] = await utils.awaitWrap(api.auth(ctx.request.query));
    ctx.body = res;
  }
};
1
2
3
4
5
6
7
//util.js
//用到了 es6 的解构赋值,确保可以获取到 data 或者 err
module.exports = {
  awaitWrap: promise => {
    return promise.then(data => [null, data]).catch(err => [err, null]);
  }
};
thank u !