Non-blocking calls from java

Question

http://www.rforge.net/Rserve/index.html' docs:

Reserve 没有回调功能。您的应用程序可以通过 TCP/ IP 和 R 套接字执行回调, 但它不是 Reserv 的一部分。

这意味着我的 java 客户端可以通过连接引用在远程会话上调用函数, 但远程会话无法回拨已即时调回的 java 客户端。我如何开发这样的机制。如果它通过 R 套接字或 tcp/ ip 服务器, 那么每一个连接都会打开套接字服务器吗?

Answer 1

好吧,所以这就是我认为执行反应R是可能的。

Non-blocking calls from java

您需要将 RServe java 客户端和分解方法 < code> request 分成两部分, 共行 [1] 。第一部分向套接字写请求, 第二部分等待响应。我们需要通过一些 < code > boolean 的旗帜来选择等待。

Returning result from R

You will need some kind of active communication to Java. One possibility is to use plain sockets or something on higher level as HTTP. I thought about httpRequest package [2]. So the call from java should look like:

connection.eval(s"""simplePostToHost(
"192.168.12.12","/listener/results/",
try(eval(parse(text="$code")),silent=TRUE),port=8080""")

Listening for result in Java

The request and response should share some kind of unique ID so we know which response is for which request. You should run some service that listen on path /listener/results for incoming results and tells Java that result is ready. It should also enable to reuse RConnection that previously should be marked as "busy". I recommend to use it this part scala Promise[T] .

希望它能帮助某人一旦我公司需要我可能会执行它

[1] [1]https://github.com/s-u/REngine/blob/a74e184c051c2c2d2le850430cd2d2do052656d3a6c48//Rserve/protocol/RTalk.java#L211

[2]https://cran.r-project.org/web/packages/httprequest/httprequest.pdf

Answer 2

以下是我在>http://statweb.stanford.edu/~lpekelis/13_datafest_cart/13_datafest_r_talk.pdf 上和在。

以 R 实例开始

Rengine re= new Rengine(args, false, new TextConsole());

Here is the code you can see for the call back:

Also, check the links for further reference. I didn t got who is the author otherwise I would have mentioned it.

Non-blocking calls from java

Returning result from R

Listening for result in Java

友情链接