0

我正在尝试在 R 中设置一个服务器,该服务器读取 JSON(字符串)消息,对其进行处理并返回 JSON 字符串消息。
我在使用标准时遇到了很多困难,socketConnection所以我想我会尝试这个svSocket包。

如果我正确阅读了文档,那么我应该能够startSocketServer使用自定义procfun参数来做到这一点。

这是我在服务器端的代码

library(svSocket)

processTestSocket <-
function (msg, socket, serverport, ...) 
{
    cat("Message was:",msg,"\n")
    output <- paste0("message:",msg)
    return(output)
}

options(debug.Socket=TRUE)
startSocketServer(port=12525,server.name="EAServer",
                  procfun=processTestSocket)

我使用ncto 作为测试客户端。

$ sudo ss -tlunp |fgrep 12525
tcp   LISTEN 0      4096         0.0.0.0:12525      0.0.0.0:*    users:(("R",pid=70992,fd=6))                                                            
tcp   LISTEN 0      4096            [::]:12525         [::]:*    users:(("R",pid=70992,fd=7))                                                            
$ nc localhost 12525
Hello
$ sudo ss -tlunp |fgrep 12525
tcp   LISTEN 0      4096         0.0.0.0:12525      0.0.0.0:*    users:(("R",pid=70992,fd=6))                                                            
tcp   LISTEN 0      4096            [::]:12525         [::]:*    users:(("R",pid=70992,fd=7)) 

端口已打开并正在侦听。但是,nc在我点击返回后立即返回,并且 R 控制台上没有输出(即使我已经设置了调试选项)。

为什么我的procfun不工作?

我在 Pop_OS 20.4 上运行 R 4.1.2。

4

0 回答 0