这篇里是如何定义接口，我们一般访问接口如：post请求调用http://127.0.0.1:11000/webapi/userinfo/user 这个接口，成功返回用户信息，如果失败要返回失败原因等。
首先分析一下 /webapi/userinfo/login 接口。从这里可以看出 webapi是一个类，userinfo也是一个类，user是一个方法。再接合post、delete、put、get请求可以得到四个方法了，这样就可以实现增、删、改、查的功能。
@H_301_7@const UserInfo = require('./UserInfo');
module.exports = {
userinfo: new UserInfo(),};
再就是创建UserInfo.js，里面的内容：
/** * 用户信息类 * * @class UserInfo */
class UserInfo {
constructor(DbHelper,Utility) {
this.DbHelper = DbHelper;
this.Utility = Utility;
}
post_login(request,response,options) {
}
get_user(request,options) {
response.Send({ msg: '这是一个get请求',options });
}
post_user(request,options) {
response.Send({ msg: '这是一个 post 请求',options });
}
delete_user(request,options) {
response.Send({ msg: '这是一个 delete 请求',options });
}
put_user(request,options) {
response.Send({ msg: '这是一个 put 请求',options });
}
}
module.exports = UserInfo;
光这样写还是不行的啦，还要修改在上上篇中router里的代码，要不是调用不了接口的。
我们得还要建一个 index.js文件
// 这个是之前引用进来，这个就是/webapi部分
const webapi = require('./webapi');
// const order = require('./orderapi'); http://xxx/orderapi/list
// const car = require('./carapi'); http://xxx/car/goods
// const DealBusiness = require('./DealBusiness');
// ...
//
module.exports = {
webapi,// order,car,DealBusiness: new DealBusiness(),...
}
创建完这个文件好了后，在router里从require(index.js)文件了。通过匹配url路径中的匹配到定义好的接口。找了就调用相应的接口，没有找到的就向返回400等信息
定好了，就可以先用postman来试一下接口定义是否可以用了。下图是调用get请求的情况。
下面这张图是调用post请求返回的信息
这样接口调用基本就搞定啦。
这里完整把router.js里router类在这里放一下
class routes {
constructor(req,res) {
this.ApiInfo = api;
this.res = res;
this.req = req;
}
initHeader() {
this.res.setHeader("Content-Type","application/json;charset=utf-8");
this.res.setHeader("Access-Control-Allow-Origin","*");
this.res.setHeader("access-control-allow-headers","x-pingother,origin,x-requested-with,content-type,accept,xiaotuni,systemdate");
this.res.setHeader("access-control-allow-methods","GET,POST,PUT,DELETE,OPTIONS");
this.res.setHeader("Access-Control-Expose-Headers","date,token,systemdate");
this.res.setHeader('systemdate',new Date().getTime());
const { method } = this.req;
if (method && method === 'OPTIONS') {
this.res.end();
return;
}
this.processRequestMethod(method);
}
processRequestMethod(method) {
const PathInfo = path.parse(this.req.url);
if (!this.judgeIsCallApi(PathInfo)) {
return;
}
this.Method = method.toLocaleLowerCase();
this.parseUrlParams();
this.__ProcessApi(PathInfo);
}
__ProcessApi(PathInfo) {
const methodInfo = { pathname: this.UrlInfo.pathname,method: this.Method };
// 以utf-8的形式接受body数据
this.req.setEncoding('utf8');
let __ReData = "";
// 这里接受用户调用接口时，向body发送的数据
this.req.on('data',(data) => {
__ReData += data;
});
const __self = this;
this.req.on('end',() => { // 监听数据接受完后事件。
// 查询用户定义好的接口。
const { func,ctrl } = __self.__FindMethod(PathInfo) || {};
const data = __ReData && __ReData !== '' ? JSON.parse(__ReData) : {};
if (func) {
func.apply(ctrl,[__self.req,__self.res,{ params: __self.QueryParams,data }]);
return;
}
const _db = new DbHelper(); // 实例化一个数据库操作类
__self.ApiInfo.DealBusiness.Process(_db,__self.req,{ methodInfo,params: __self.QueryParams,data });
});
}
judgeIsCallApi(PathInfo) {
if (PathInfo.ext === '') {
return true;
}
let charset = "binary";
switch (PathInfo.ext) {
case ".js":
this.res.writeHead(200,{ "Content-Type": "text/javascript" });
break;
case ".css":
this.res.writeHead(200,{ "Content-Type": "text/css" });
break;
case ".gif":
charset = "binary";
this.res.writeHead(200,{ "Content-Type": "image/gif" });
break;
case ".jpg":
charset = "binary";
this.res.writeHead(200,{ "Content-Type": "image/jpeg" });
break;
case ".png":
charset = "binary";
this.res.writeHead(200,{ "Content-Type": "image/png" });
break;
default:
this.res.writeHead(200,{ "Content-Type": "application/octet-stream" });
}
const { dir,ext,name } = PathInfo;
const __abs = path.join(dir,name + ext);
const _pathInfo = [path.join('./server/',__abs),path.join('.',__abs)];
const __self = this;
let __fileIsExist = false;
for (let i = 0; i < _pathInfo.length; i++) {
const dir = _pathInfo[i];
__fileIsExist = fs.existsSync(dir);
if (__fileIsExist) {
fs.readFile(dir,(err,data) => {
if (err) {
__self.res.Send({ code: -1,msg: err.toString() });
} else {
__self.res.write(data,charset);
}
__self.res.end();
});
return false;
}
}
if (!__fileIsExist) {
__self.res.end();
}
return false;
}
parseUrlParams() {
const _url = url.parse(this.req.url);
this.UrlInfo = _url;
const { query } = _url;
this.QueryParams = querystring.parse(query);
}
__FindMethod(PathInfo,isSendMsg) {
const { pathname } = this.UrlInfo;
const pathList = pathname.split('/');
pathList.shift();
if (pathList.length === 1) {
if (isSendMsg) {
this.res.Send_404({ status: 404,msg: pathname + '接口没有找到' });
}
return null;
}
const __last = pathList.pop();
let __CallApi = this.ApiInfo[pathList[0]];
let __ApiIsExist = true;
for (let i = 1; i < pathList.length; i++) {
__CallApi = __CallApi[pathList[i]];
if (!__CallApi) {
__ApiIsExist = false;
break;
}
}
if (!__ApiIsExist) {
if (isSendMsg) {
this.res.Send_404({ status: 404,msg: pathname + '接口没有找到' });
}
return null;
}
const Controller = __CallApi;
__CallApi = __CallApi[this.Method + '_' + __last]
if (!__CallApi) {
if (isSendMsg) {
this.res.Send_404({ status: 404,msg: pathname + '接口没有找到' });
}
return null;
}
return { func: __CallApi,ctrl: Controller };
}
}
module.exports = routes ;
现在接口的调用基本就OK了。
如果有什么不清楚，可以查看 https://github.com/xiaotuni/angular-map-http2 这里项目里具体写了怎么实现接口调用的
