28

我正在使用 express 在 Node.js 中做一个项目。这是我的目录结构：

root
|-start.js
|-server.js
|-lib/
|    api/
|        user_getDetails.js
|        user_register.js

该lib/api/目录有许多与 API 相关的 JS 文件。我需要做的是制作一种挂钩系统，每当从 express HTTP 服务器请求一个 API 函数时，它都会执行相应 API 处理程序中指定的任何操作。这可能令人困惑，但希望你能明白这一点。

  1. Larry 通过 POST 发送请求以获取用户详细信息。
  2. 服务器查找lib/api与该请求关联的函数。
  3. 服务器执行操作并将数据发送回拉里。

希望你能帮助我。我在想它可以使用原型来完成，但不确定。

谢谢！

4

3 回答 3

34

如果您知道您的脚本在哪里，即您有一个初始目录，例如DIR，那么您可以使用fs，例如：

服务器.js

var fs = require('fs');
var path_module = require('path');
var module_holder = {};

function LoadModules(path) {
    fs.lstat(path, function(err, stat) {
        if (stat.isDirectory()) {
            // we have a directory: do a tree walk
            fs.readdir(path, function(err, files) {
                var f, l = files.length;
                for (var i = 0; i < l; i++) {
                    f = path_module.join(path, files[i]);
                    LoadModules(f);
                }
            });
        } else {
            // we have a file: load it
            require(path)(module_holder);
        }
    });
}
var DIR = path_module.join(__dirname, 'lib', 'api');
LoadModules(DIR);

exports.module_holder = module_holder;
// the usual server stuff goes here

现在您的脚本需要遵循以下结构（因为该require(path)(module_holder)行），例如：

user_getDetails.js

function handler(req, res) {
    console.log('Entered my cool script!');
}

module.exports = function(module_holder) {
    // the key in this dictionary can be whatever you want
    // just make sure it won't override other modules
    module_holder['user_getDetails'] = handler;
};

现在，在处理请求时，您可以：

// request is supposed to fire user_getDetails script
module_holder['user_getDetails'](req, res);

这应该将所有模块加载到module_holder变量中。我没有测试它，但它应该可以工作（除了错误处理！！！）。您可能想要更改此功能（例如制作module_holder树，而不是单层字典），但我认为您会掌握这个想法。

此函数应在每次服务器启动时加载一次（如果您需要更频繁地触发它，那么您可能正在处理动态服务器端脚本，这是一个 baaaaaad 想法，恕我直言）。您现在唯一需要做的就是导出module_holder对象，以便每个视图处理程序都可以使用它。

于 2012-06-06T13:43:05.083 回答
7

应用程序.js

var c_file = 'html.js';

var controller = require(c_file);
var method = 'index';

if(typeof controller[method] === 'function')
    controller[method]();

html.js

module.exports =
{
    index: function()
    {
        console.log('index method');
    },
    close: function()
    {
        console.log('close method');    
    }
};

稍微动态化这段代码，你可以做一些神奇的事情：D

于 2012-09-04T08:56:02.993 回答
3

下面是一个 REST API Web 服务的示例，它根据发送到服务器的 url 动态加载处理程序 js 文件：

服务器.js

var http = require("http");
var url = require("url");

function start(port, route) {
   function onRequest(request, response) {
       var pathname = url.parse(request.url).pathname;
       console.log("Server:OnRequest() Request for " + pathname + " received.");
       route(pathname, request, response);
   }

   http.createServer(onRequest).listen(port);
   console.log("Server:Start() Server has started.");
}

exports.start = start;

路由器.js

function route(pathname, req, res) {
    console.log("router:route() About to route a request for " + pathname);

    try {
        //dynamically load the js file base on the url path
        var handler = require("." + pathname);

        console.log("router:route() selected handler: " + handler);

        //make sure we got a correct instantiation of the module
        if (typeof handler["post"] === 'function') {
            //route to the right method in the module based on the HTTP action
            if(req.method.toLowerCase() == 'get') {
                handler["get"](req, res);
            } else if (req.method.toLowerCase() == 'post') {
                handler["post"](req, res);
            } else if (req.method.toLowerCase() == 'put') {
                handler["put"](req, res);
            } else if (req.method.toLowerCase() == 'delete') {
                handler["delete"](req, res);
            }

            console.log("router:route() routed successfully");
            return;
        } 
    } catch(err) {
        console.log("router:route() exception instantiating handler: " + err);
    }

    console.log("router:route() No request handler found for " + pathname);
    res.writeHead(404, {"Content-Type": "text/plain"});
    res.write("404 Not found");
    res.end();

}

exports.route = route;

index.js

var server = require("./server");
var router = require("./router");

server.start(8080, router.route);

就我而言，处理程序位于 /TrainerCentral 子文件夹中，因此映射的工作方式如下：

localhost:8080/TrainerCentral/Recipe 将映射到 js 文件 /TrainerCentral/Recipe.js localhost:8080/TrainerCentral/Workout 将映射到 js 文件 /TrainerCentral/Workout.js

这是一个示例处理程序，它可以处理用于检索、插入、更新和删除数据的 4 个主要 HTTP 操作中的每一个。

/TrainerCentral/Workout.js

function respond(res, code, text) {
    res.writeHead(code, { "Content-Type": "text/plain" });
    res.write(text);
    res.end();
}

module.exports = {
   get: function(req, res) {
       console.log("Workout:get() starting");

       respond(res, 200, "{ 'id': '123945', 'name': 'Upright Rows', 'weight':'125lbs' }");
   },
   post: function(request, res) {
       console.log("Workout:post() starting");

       respond(res, 200, "inserted ok");
   },
   put: function(request, res) {
       console.log("Workout:put() starting");

       respond(res, 200, "updated ok");
   },
   delete: function(request, res) {
       console.log("Workout:delete() starting");

       respond(res, 200, "deleted ok");
   }
};

使用“node index.js”从命令行启动服务器

玩得开心！

于 2013-10-30T00:00:37.037 回答