如何在Node.js中退出函數

Question

我希望程序停止監聽請求，並在代碼成功加載一次頁面後繼續執行代碼。我曾嘗試在代碼的末尾放置一個break;，但它表示這是非法中斷。我不知道我應該用什麼來代替休息。

我該如何導致它退出該功能？

在此先感謝。

---

我使用從this site下面的代碼使用的是Node.js：

var http = require("http"); 
var port = 3000; 
var serverUrl = "localhost"; 

var Kafka = require('no-kafka'); 
var connString = ' kafka://192.168.0.108:9092, 192.168.0.108:9092 ' 
var consumer = new Kafka.SimpleConsumer({ connectionString: connString }); 

var message = ["start"]; 

var server = http.createServer(function(req, res) { 
    console.log("Request: " + req.url); 
    var now = new Date(); 
    var html = "<p>Hello World, the time is " + now + "- Messages: " + message + ".</p>"; 
    res.end(html); 
    console.log("a"); 
    server.close(); 
    console.log("b"); 
}); 

// data handler function can return a Promise 
var dataHandler = function (messageSet, topic, partition) { 
    messageSet.forEach(function (m) { 
     console.log('topic received: '); 
     console.log({ 
      'topic':topic, 
      'partition': partition, 
      'offset': m.offset, 
      'message': m.message.value.toString('utf8')  
     }); 
     message.push(m.message.value.toString('utf8')); 

     console.log("Listening at " + serverUrl + ":" + port); 
     server.listen(port, serverUrl); 

     console.log("c"); 
    }); 
}; 

return consumer.init() 
.then(function() { 
    return consumer.subscribe('temp', 0, dataHandler); 
}); 

Answer 1

你不是退出功能（這將是return，不break），你告訴在端口上監聽的對象停止這樣做。

如果您希望服務器停止監聽新連接，請使用其close method。

var http = require("http"); 
var port = 3000; 
var serverUrl = "localhost"; 

var server = http.createServer(function(req, res) { 

    console.log("Request: " + req.url); 

    var now = new Date(); 
    var html = "<p>Hello World, the time is " + now + ".</p>"; 
    res.end(html); 
    server.close(); // <======================================= 
    // *** If you want to do something else at this point, call it from here *** 
}); 

console.log("Listening at " + serverUrl + ":" + port); 
server.listen(port, serverUrl); 

請注意，服務器不會立即關閉。 http.Server#close來電net.Server.close，其中說：

停止服務器接受新的連接，並保持現有的連接。此功能是異步的，當所有連接結束並且服務器發出事件時，服務器最終關閉。一旦發生'close'事件，將會調用可選callback。與該事件不同，如果服務器在關閉時未打開，它將以Error作爲唯一參數進行調用。

在我的快速本地測試中，這需要一段時間。你可以把它更加積極主動，如果你攔截通過'connection'事件as described in this answer連接，並摧毀連接以及關閉服務器：

var http = require("http"); 
var port = 3000; 
var serverUrl = "localhost"; 

var connections = []; 
var server = http.createServer(function(req, res) { 

    console.log("Request: " + req.url); 

    var now = new Date(); 
    var html = "<p>Hello World, the time is " + now + ".</p>"; 
    res.end(html); 
    connections.forEach(function(con) { // *** 
     con.destroy();     // *** 
    });         // *** 
    server.close();      // *** 
    // *** If you want to do something else at this point, call it from here *** 
}); 
server.on("connection", function(con) { // *** 
    connections.push(con);    // *** 
});          // *** 

console.log("Listening at " + serverUrl + ":" + port); 
server.listen(port, serverUrl); 

Answer 2

您可以通過調用server.close()聽停止服務器。