假设我们想使用 Node.js 进程池,使用 React 渲染一些 HTML。 (我并不是说这是个好主意,只是假设是这种情况,lulz)。
有没有办法将对请求/响应流的引用从 Golang 传递到 Node.js 进程?我认为 Node.js 的集群模块使用了这种技术,通过传递文件描述符或类似的东西。请注意,Node.js 进程池(可能有 3 个左右的进程)将是 Golang 进程的子进程。
最佳答案
下面是一个非常粗略的草稿,它使用 channel 来实现进程池,并展示了如何使用 Go 的 io.Reader 和 io.Writer 接口(interface)将进程和 HTTP 流连接在一起。密码也是on the playground , 便于复制粘贴。
请注意,我写的很匆忙,只是为了展示总体思路。不要在生产中使用它。我确定存在错误,尤其是与不完整的读取或写入有关的错误。空闲时退出的进程也不会得到处理。
package main
import (
"encoding/json"
"fmt"
"io"
"log"
"net/http"
"os"
"os/exec"
)
exec.Cmd.Stdin 和 exec.Cmd.Stdout 分别是 io.Reader 和 io.Writer 类型。但是,我们反过来对待他们更方便。 StdinPipe 和 StdoutPipe 方法恰好促进了这一点,但它们必须只调用一次,并且只能在进程开始之前调用。所以我们将管道与命令本身一起存储在一个简单的包装器中。这允许我们调用 nodeWrapper.Write([]byte) 将数据发送到 Node ,并调用 nodeWrapper.Read() 从其标准输出读取。这就是我在评论中所说的您通常传递 Reader 和 Writers 的意思。
type nodeWrapper struct {
*exec.Cmd
io.Writer // stdin
io.Reader // stdout
}
// mustSpawnNode returns a started nodejs process that executes render.js
func mustSpawnNode() nodeWrapper {
cmd := exec.Command("node", "render.js")
cmd.Stderr = os.Stderr
stdin, err := cmd.StdinPipe()
if err != nil {
panic(err)
}
stdout, err := cmd.StdoutPipe()
if err != nil {
panic(err)
}
if err := cmd.Start(); err != nil {
panic(err)
}
return nodeWrapper{cmd, stdin, stdout}
}
我们在这里使用一个简单的基于 channel 的环形缓冲区来实现进程池。
处理程序解析 HTTP 请求并提取呈现页面所需的信息。在这个例子中,我们只是将请求路径传递给 Node 。然后我们等待一个空闲的 Node 进程并调用渲染。 render 将直接写入 ResponseWriter。
func main() {
pool := make(chan nodeWrapper, 4) // acts as a ring buffer
for i := 0; i < cap(pool); i++ {
pool <- mustSpawnNode()
}
log.Println("listening on :3000")
log.Fatal(http.ListenAndServe(":3000", handler(pool)))
}
func handler(pool chan nodeWrapper) http.HandlerFunc {
return func(w http.ResponseWriter, r *http.Request) {
var renderArgs struct {
Path string
}
renderArgs.Path = r.URL.Path
node := <-pool
err := render(w, node, renderArgs)
if err != nil {
// Assume the node process has failed and replace it
// with a new one.
node.Process.Kill()
pool <- mustSpawnNode()
http.Error(w, err.Error(), 500)
} else {
pool <- node
}
}
}
对于渲染,我们 a) 想将一些数据传递给已经运行的 Node 进程,并且 b) 从 Node 的标准输出中读取,更重要的是,必须知道何时停止读取。
通常我们会将 Stdout 设置为我们想要的编写器,然后简单地运行该过程直至完成。但在这种情况下,进程在完成渲染后不会退出,因此它也不会关闭标准输出,我们需要替换通常的 EOF 信号。
这是我们必须发挥创意并找到适合您的解决方案的地方。我决定采用以下协议(protocol):我们将一行 JSON 编码数据写入 Node 的标准输入,然后从 Node 的标准输出解码单个 JSON 编码字符串。理想情况下,我们不会在内存中缓冲整个 HTML 文档,而是将其直接放在网络上(通过实时写入 w)。但这使 Go 代码和 render.js 都非常简单。
func render(w io.Writer, node nodeWrapper, args interface{}) error {
stdinErr := make(chan error, 1)
go func() {
stdinErr <- json.NewEncoder(node).Encode(args)
}()
var html string
if err := json.NewDecoder(node).Decode(&html); err != nil {
return err
}
if _, err := fmt.Fprint(w, html); err != nil {
return err
}
return <-stdinErr
}
最后,render.js 的内容:
let lineReader = require('readline').createInterface({input: process.stdin})
lineReader.on('line', (line) => {
let data = JSON.parse(line);
let html = "";
html += "<h1>Path: " + data.Path + "</h1>\n";
html += "<small>PID: " + process.pid + "</small>\n";
process.stdout.write(JSON.stringify(html)+"\n")
})
关于node.js - 使用 React 和 Golang 进行服务器端渲染,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49775841/