为什么我的请求和响应消息有问题？

Question

我正在阅读一本教你 Node.JS 基础知识的书，并且我创建了几个程序 - 一个响应者和一个请求者。

响应者：

"use strict";

const fs = require("fs");
const zmq = require("zmq");
const responder = zmq.socket("rep"); // Create socket to reply to client requests

// Handle incoming requests
responder.on("message", function(data) {
    // Parse incoming message
    let request = JSON.parse(data);
    console.log("Received request to get: " + request.path);

    // Read file and reply with content
    fs.readFile(request.path, function(err, content) {
        console.log("Sending response content");
        responder.send(JSON.stringify({
            content: content.toString(),
            timestamp: Date.now(),
            pid: process.pid
        }));
    });
});

// Listen on TCP port 5433
responder.bind("tcp://127.0.0.1:5433", function(err) {
    console.log("Listening for zmq requesters...");
});

// Close the responder when the Node process ends
process.on("SIGINT", function() {
    console.log("Shutting down...");
    responder.close();
});

请求者：

"use strict";

const zmq = require("zmq");
const filename = process.argv[2];
const requester = zmq.socket("req"); // Create request endpoint

// Handle replies from responder
requester.on("message", function(data) {
    let response = JSON.parse(data);
    console.log("Received response:", response);
});

requester.connect("tcp://localhost:5433");

// Send request for content
for (let i=1; i <= 3; i++) {
    console.log("Sending request " + i + " for " + filename);
    requester.send(JSON.stringify({
        path: filename
    }));
}

所以我运行启动良好的响应程序，然后像这样运行请求程序（target.txt 已经存在于文件系统中）：

> node requester.js target.txt

奇怪的是，鉴于 Node.js 的单线程，我希望输出总是是：

Sending request 1 for target.txt
Sending request 2 for target.txt
Sending request 3 for target.txt
Received response: { ...

但是，有时我会这样，但有时我会：

Sending request 1 for target.txt
Sending request 2 for target.txt
Received response: { ...
Sending request 3 for target.txt

这怎么可能？事件循环正在执行我的for 循环，这应该意味着“发送请求”行得到输出，然后它有机会调用响应处理程序。为什么有时会在记录第三个请求之前记录响应？

Answer 1

很明显，只有在send 实现中调用提供给on 的回调时，才会发生您看到的行为。

zmq 模块包含本机代码。它以本机代码接收响应，然后将它们提供给 JavaScript 主机。它对响应的接收不依赖于 JavaScript 事件循环。似乎在send 实现中，如果响应可用，则调用提供给on 的回调。据推测，任何未在send 调用中传递给回调的响应都会在下一轮通过事件循环传递。

Answer 2

在responder 函数中读取文件时，您使用fs.readFile 这是一个异步非阻塞函数（它将在新线程中读取文件）。这意味着它在接受新请求之前不会等待文件被读取。

如果你想使用同步函数，你可以使用

fs.readFileSync

这将等待文件被完全读取，然后发送响应。