草庐IT

node.js - 将文件流式传输到客户端后，永远不会发送 res.end()

coder 2023-11-06 原文

我基本上是在尝试将文件从 MongoDb 流式传输到客户端。文件接收没有问题，但是当流结束并且我尝试发送 request.end() 客户端永远不会收到它。 

app.post('/upload', function (req, res) {
    var db = new mongo.Db('prueba', new mongo.Server("127.0.0.1", 27017));
    db.open(function (err) {
        if (err) return handleError(err);

        var gfs = Grid(db, mongo);
        console.log(req.filename);
        var uploadedSize = 0,
            uploadProgress = 0;
        idPdf = new ObjectId();  //cliente crea un id de mongo, el cual se utilizara para traer el recurso despues
        console.log(idPdf);

        var grabarm = req.pipe(gfs.createWriteStream({
            filename: 'test',
            _id: idPdf
        }));

        grabarm.on("close", function () {

            var tbuffer = gfs.createReadStream({filename: 'test'});

            tbuffer.on('open', function () {
                // This just pipes the read stream to the response object (which goes to the client)
                res.setHeader('Content-disposition', 'attachment; filename=pdfmongo.pdf');
                res.setHeader('Content-type', 'application/pdf');

                tbuffer.pipe(res);
            });

            tbuffer.on('data', function (chunk) {
                console.log("receiving data");
            });
            tbuffer.on("close", function () {

                console.log("fin"); //can see it in console
                res.end("ok file received");//client never sees this

            });

            tbuffer.on('error', function (err) {
                res.end(err);
            });
        });

    });

});

最佳答案

当可读流完成读取时，默认情况下，它会发出 end() 事件，这将调用可写流(res 流)上的 end() 事件。在这种情况下，您无需担心调用 end()。

因此在调用 end() 事件后，您的资源将不再可写。所以，如果你想让它保持可写，只需将 end: false 选项传递给 pipe()。例如:

fs.createReadStream("./image.png").pipe(res, { end: false });

，然后稍后调用 end() 事件。

顺便说一句，对于流结束，您应该监听“结束”事件而不是“关闭”事件，因为“关闭”并不明确表示所有数据都已传输。

关于node.js - 将文件流式传输到客户端后，永远不会发送 res.end()，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/35651834/

流式nodesection39functionnode.jsmongodbhttpresponse

有关node.js - 将文件流式传输到客户端后，永远不会发送 res.end()的更多相关文章

  1. ruby - Highline 询问方法不会使用同一行 - 2

    设置:狂欢ruby1.9.2高线(1.6.13)描述:我已经相当习惯在其他一些项目中使用highline，但已经有几个月没有使用它了。现在，在Ruby1.9.2上全新安装时，它似乎不允许在同一行回答提示。所以以前我会看到类似的东西:require"highline/import"ask"Whatisyourfavoritecolor?"并得到:Whatisyourfavoritecolor?|现在我看到类似的东西:Whatisyourfavoritecolor?|竖线(|)符号是我的终端光标。知道为什么会发生这种变化吗？ 最佳答案

  2. ruby-on-rails - 项目升级后 Pow 不会更改 ruby​​ 版本 - 2

    我在我的Rails项目中使用Pow和powifygem。现在我尝试升级我的ruby​​版本(从1.9.3到2.0.0，我使用RVM)当我切换ruby​​版本、安装所有gem依赖项时，我通过运行railss并访问localhost:3000确保该应用程序正常运行以前，我通过使用pow访问http://my_app.dev来浏览我的应用程序。升级后，由于错误Bundler::RubyVersionMismatch:YourRubyversionis1.9.3,butyourGemfilespecified2.0.0，此url不起作用我尝试过的:重新创建pow应用程序重启pow服务器更新战俘

  3. ruby-on-rails - 使用 javascript 更改数据方法不会更改 ajax 调用用户的什么方法？ - 2

    我遇到了一个非常奇怪的问题，我很难解决。在我看来，我有一个与data-remote="true"和data-method="delete"的链接。当我单击该链接时，我可以看到对我的Rails服务器的DELETE请求。返回的JS代码会更改此链接的属性，其中包括href和data-method。再次单击此链接后，我的服务器收到了对新href的请求，但使用的是旧的data-method，即使我已将其从DELETE到POST(它仍然发送一个DELETE请求)。但是，如果我刷新页面，HTML与"new"HTML相同(随返回的JS发生变化)，但它实际上发送了正确的请求类型。这就是这个问题令我困惑的

  4. ruby-on-rails - prawnto 显示新页面时不会中断的表格 - 2

    我有可变数量的表格和可变数量的行，我想让它们一个接一个地显示，但如果表格不适合当前页面，请将其放在下一页，然后继续。我已将表格放入事务中，以便我可以回滚然后打印它(如果高度适合当前页面)，但我如何获得表格高度？我现在有这段代码pdf.transactiondopdf.table@data,:font_size=>12,:border_style=>:grid,:horizontal_padding=>10,:vertical_padding=>3,:border_width=>2,:position=>:left,:row_colors=>["FFFFFF","DDDDDD"]pdf.

  5. ruby-on-rails - 语法错误 : unexpected $end when using if/else if? - 2

    我从我的一个Controller类中收到一个错误，我不知道为什么。错误是:SyntaxErrorinTermsController#show,syntaxerror,unexpected$end,expectingkeyword_end这是terms_controller.rb:classTermsController我的展示页面目前只包含:这可能是我遗漏的一些小东西-感谢您的帮助! 最佳答案 问题是end关键字不够，它在它之前找到了$end(代表文件结尾的标记)可以找到它要找的东西——另一个end。(end关键字的解析器标记是“k

  6. ruby - 在 TCPServer (Ruby) 中，我如何从客户端获取 IP/MAC？ - 2

    我想在Ruby的TCPServer中获取客户端的IP地址。以及(如果可能的话)MAC地址。例如，Ruby中的时间服务器，请参阅评论。tcpserver=TCPServer.new("",80)iftcpserverputs"Listening"loopdosocket=tcpserver.acceptifsocketThread.newdoputs"Connectedfrom"+#HERE!HowcanigettheIPAddressfromtheclient?socket.write(Time.now.to_s)socket.closeendendendend非常感谢!

  7. ruby-on-rails - Assets 管道损坏 : Not compiling on the fly css and js files - 2

    我开始了一个新的Rails3.2.5项目，Assets管道不再工作了。CSS和Javascript文件不再编译。这是尝试生成Assets时日志的输出:StartedGET"/assets/application.css?body=1"for127.0.0.1at2012-06-1623:59:11-0700Servedasset/application.css-200OK(0ms)[2012-06-1623:59:11]ERRORNoMethodError:undefinedmethod`each'fornil:NilClass/Users/greg/.rbenv/versions/1

  8. ruby-on-rails - Rails - 理解 application.js 和 application.css - 2

    rails新手。只是想了解\assests目录中的这两个文件。例如，application.js文件有如下行://=requirejquery//=requirejquery_ujs//=require_tree.我理解require_tree。只是将所有JS文件添加到当前目录中。根据上下文，我可以看出requirejquery添加了jQuery库。但是它从哪里得到这些jQuery库呢？我没有在我的Assets文件夹中看到任何jquery.js文件——或者直接在我的整个应用程序中没有看到任何jquery.js文件？同样，我正在按照一些说明安装TwitterBootstrap(http:

  9. ruby - 可以像在 C# 中使用#region 一样在 Ruby 中使用 begin/end 吗？ - 2

    我最近从C#转向了Ruby，我发现自己无法制作可折叠的标记代码区域。我只是想到做这种事情应该没问题:classExamplebegin#agroupofmethodsdefmethod1..enddefmethod2..endenddefmethod3..endend...但是这样做真的可以吗？method1和method2最终与method3是同一种东西吗？还是有一些我还没有见过的用于执行此操作的Ruby惯用语？ 最佳答案 正如其他人所说，这不会改变方法定义。但是，如果要标记方法组，为什么不使用Ruby语义来标记它们呢？您可以使用

  10. ruby - 在不添加 "end"的情况下编写 Ruby 的任何方法？ - 2

    按照目前的情况，这个问题不适合我们的问答形式。我们希望答案得到事实、引用或专业知识的支持，但这个问题可能会引发辩论、争论、投票或扩展讨论。如果您觉得这个问题可以改进并可能重新打开，visitthehelpcenter指导。关闭11年前。Ruby是一种美丽的语言，但有一个我讨厌写很多次的关键词“结束”。有什么方法可以写出简洁的代码而不用每次都写“end”吗？

随机推荐