我正在使用 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响应,并且它在后台异步继续。
问题:
- 如何关闭流?
- 我如何访问
lengthyOperation
变量来做到这一点?