2

我正在使用 Node.js 连接到使用gRPC执行长时间运行任务的服务器。

服务器在作业进行时向客户端（Node.js 应用程序）发送单向流。我需要实现一个停止按钮，并被告知关闭gRPC 流将停止正在进行的工作。

这是目前我的代码：

let express = require('express'),
    router = express.Router(),
    grpc = require('grpc'),
    srv = grpc.load(__dirname + '/job_handler.proto').ns;

let startJob = (jobID, parameters) => srv.createJob(jobID, parameters);

router.post('/jobs', (req, res) => {
    let lengthyOperation = startJob(jobID, parameters);
    lengthyOperation.on('data', (data) => {
        console.log(`Data from lengthy operation: ${data}`);
    });

    lengthyOperation.on('end', () =>
        console.log('Lengthy operation completed');
    });

    res.setHeader('Location', `/jobs/${jobID}`);
    res.status(202).send();
});

如您所见，我在创建作业时向客户端发送了HTTP 202响应，并且它在后台异步继续。

问题：

  1. 如何关闭流？
  2. 我如何访问lengthyOperation变量来做到这一点？
4

1 回答 1

2

该lengthyOperation对象有一个cancel取消调用的方法。因此，当您想停止流时，只需调用lengthyOperation.cancel().

请注意，执行此操作时，将导致调用以错误结束。我建议添加一个lengthyOperation.on('error', ...)处理程序来处理该错误。

于 2015-12-04T20:36:42.670 回答