我编写应用程序以通过Node.js发送文件多播
我逐块读取文件,然后像这样在块中发送

for (var block = 1; block <= number_of_block; block++) {
                   sendBlock(FILEPATH, block)


CHUNK函数sendBlock

function sendBlock(file, block) {
           fs.open(file, 'r', function(err, fp) {
            if (err) {
                return;
            }
            var buf = new Buffer(4 + CHUNK_SIZE);
            fs.read(fp, buf, 4, CHUNK_SIZE, (block - 1) * CHUNK_SIZE, function(err, bytesRead) {
                if (err) {

                }
                buf[0] = 0;
                buf[1] = opcodes.OPCODE_DATA;
                buf[2] = (block >> 8) & 0xFF;
                buf[3] = block & 0xFF;
                udpserver.send(buf, 0, 4 + bytesRead, PORT, MULTICAST_IP_ADDRESS);
                fs.close(fp);
            });
        });


我创建客户端以接收消息

fs.open(fileName, 'a', function(e, id) {
                if (4 + CHUNK_SIZE > message.length) {
                    fs.write(fd, message, 4, message.length - 4, (block - 1) * CHUNK_SIZE, function() {
                        fs.close(fd, function() {
                            console.log('file closed', block);
                            send("miss block:" + missArray);
                        });
                    });
                } else {
                    console.log("message length:", message.length)
                    console.log((block - 1) * CHUNK_SIZE)

                    fs.write(fd, message, 4, CHUNK_SIZE, (block - 1) * CHUNK_SIZE, function() {
                        fs.close(fd, function() {
                            console.log('1file closed', block);
                            if (block % NUMBER_BLOCK == 0) {
                                if (blockArray.length > 0) {
                                    missArray = missArray.concat(blockArray);
                                }
                                blockArray = range(block + 1, NUMBER_BLOCK)
                            }

                            //udpserver.send(block+1)
                        });
                    });
                }
            });


但是当服务器发送超过1000条消息时,客户端无法捕获全部消息
服务器发送

block -- 6907
block -- 6908
block -- 6909
block -- 6910
block -- 6911
block -- 6912
block -- 6913


客户反叛和写作

block ------  1008
block ------  1009
block ------  1010
block ------  1011


我测试接收的最大文件为10.4 MB。

如何从发件人接收所有数据?

最佳答案

Node.js受到基础操作系统的限制。操作系统对进程可以同时持有的未处理句柄的数量进行限制。

您可能耗尽了可用文件描述符的数量。我建议使用连接池来减少应用程序尝试使用的文件描述符的数量。因此,与其尝试一次发送1000个事物,不如将您的程序限制为一次只能有100个连接的池。

npm提供了几种连接池库-一种流行的选择是poolr

08-17 13:03
查看更多