使用ssejson实现对象流的SSE序列化与解析

ssejson 适用于在Mac/Linux平台通过EventSource API实现服务器发送的事件（SSE）对象流的序列化与解析。在服务器端，使用 ssejson.serialize() 将对象流转换为 SSE；在浏览器客户端，使用 ssejson.fromEventSource() 将其解析回对象流。该方法格式简单，将每个对象块编码为 JSON，并由模块序列化和解析。示例代码如下：

var http = require('http');

var fs = require('fs');

var ssejson = require('ssejson');

var csv = require('csv-parser');



http.createServer(function (req, res) {

  fs.createReadStream('data.csv')

    .pipe(csv())

    .pipe(ssejson.serialize())

    .pipe(res);

}).listen(3000);

在上面的例子中，服务器将CSV文件流通过 ssejson.serialize() 转换为 SSE，浏览器则通过 EventSource API 来解析事件。