java的rserve实现_Java 使用 Rserve 实现与 R 的通信

Rserve 是一个基于 TCP/IP 的服务器程序,它允许其他语言调用 R 语言。由于 Rserve 采用 C/S (客户端/服务器)的调用方式,因此客户端并不需要链接 R 语言库,客户端程序与 R 程序可以实现低耦合的目的。

为调用 R 语言,需要实现一个与 Rserve 通信的客户端程序,幸运的是目前常用的语言包括 C/C++,PHP,Java 等都实现提供与 Rserve 通信的客户端程序。

本文讲述 Java 语言如何利用 Rserve 实现与 R 语言的通信。

安装 Rserve

假设 R 的运行环境是 CentOS(CentOS 使用yum install R来安装 R),在 CentOS 我们已经安装好 R。

在 Linux 命令行中输入

R

进入 R 的交互环境,然后输入

> install.packages("Rserve")

接下来就可以安装 Rserve。

启动 Rserve

启动 Rserve 有两种方式,一种是在 R 程序中启动,另一种是在命令行中启动。

1. R 程序启动 Rserve

打开 R 的交互环境,输入以下命令:

library(Rserve)

Rserve()

执行后,Rserve 便启动起来。

2. 命令行启动 Rserve

也可以直接在命令行中输入:

R CMD Rserve

启动 Rserve。

为让 Rserve 支持远程连接,可以加入--RS-enable-remote参数:

R CMD Rserve --RS-enable-remote

Java 调用 R

使用 IntelliJ IDEA 创建一个 Maven quickstart 项目,然后在 pom.xml 中添加 Java 版本的 Rserve 客户端的依赖:

org.rosuda.REngine

Rserve

1.8.1

然后编写调用 R 的代码。

import org.rosuda.REngine.REXP;

import org.rosuda.REngine.Rserve.RConnection;

import org.rosuda.REngine.Rserve.RserveException;

import org.rosuda.REngine.REXPMismatchException;

public class RserveDemo {

public static void main ( String[] args ) throws RserveException, REXPMismatchException

{

RserveDemo rserveDemo = new RserveDemo();

rserveDemo.callRserve();

}

private void callRserve() throws RserveException, REXPMismatchException {

// 连接 Rserve

RConnection c = new RConnection("120.78.80.23");

// 输出 R 的版本

REXP x = c.eval("R.version.string");

System.out.println(x.asString());

// 获取10个随机数字

double[] arr = c.eval("rnorm(10)").asDoubles();

for (double a : arr) {

System.out.print(a + ",");

}

System.out.println();

// 调用 R 源文件

c.eval("source('/home/R/add.R')");

int sum = c.eval("myAdd(1, 2)").asInteger();

System.out.println(sum);

}

}

在上述代码中,我们首先创建了与 Rserve 的连接。由于 Java 代码与 Rserve 不在同一台机器,所以我们指定了 Rserve 的机器 IP 地址。

接下来,我们调用了 R 语言的一些方法,包括输出 R 语言的版本,获取10个随机数字。

最后,我们演示了如何调用 R 语言源代码。在 Linux 平台我们先创建一个 add.R 的文件,然后编写 R 代码:

myAdd

sum

return (sum)

}

add.R 源代码放置在目录 /home/R 下。R 语言中使用source('/home/R/add.R')可以执行源代码,在 Java 代码中,我们先执行 add.R 源代码,接下来调用了myAdd()函数。

执行以上代码,输出:

R version 3.5.0 (2018-04-23)

-2.533623370009491,0.7961512738732901,0.7122860585280386,-0.16063583146722446,-0.598315148752494,0.09854836382399271,-1.0914493041810422,-1.5425930835313806,0.584390936738569,0.35687345246533786,

3

参考资料

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/271834.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

对其他组所提建议的回复(第一阶段)

序号题目组名 1理财猫非常3加11.图片的浏览功能我们会在第二阶段完成2跑什么操running man1.我们会尽快将界面和功能整合 2.物品的分类会在后期进行中逐步完善3水骑士水骑士团队暂无4铁大云盘老司机1.我们的项目是可以显示“注册成功”的,你的建议... 2.买家卖家的聊…

数据库文档生成工具V1.0

❤️作者主页:IT技术分享社区 ❤️作者简介:大家好,我是IT技术分享社区的博主,从事C#、Java开发九年,对数据库、C#、Java、前端、运维、电脑技巧等经验丰富。 ❤️个人荣誉: 数据库领域优质创作者🏆&#x…

volatile关键字和AtomicInteger

在Java中,线程部分是一个重点,本篇文章说的JUC也是关于线程的。JUC就是java.util .concurrent工具包的简称。这是一个处理线程的工具包,JDK 1.5开始出现的。下面一起来看看它怎么使用。 一、volatile关键字与内存可见性 1、内存可见性&…

前端:JS几种常见的排序

❤️作者主页:IT技术分享社区 ❤️作者简介:大家好,我是IT技术分享社区的博主,从事C#、Java开发九年,对数据库、C#、Java、前端、运维、电脑技巧等经验丰富。 ❤️个人荣誉: 数据库领域优质创作者🏆&#x…

bzoj3747 [POI2015]Kinoman

线段树&#xff0c;记录next[i]下一部与当前电影一样的位置&#xff0c;然后枚举区间左端点i&#xff0c;询问线段树最大值后删除i到next[i-1]这段区间的观影值&#xff0c;且增加next[i]到next[next[i]]-1这段区间的观影值。 代码&#xff0c;跑的有点慢 1 #include<cstdio…

java_poi教程.pdf,如何使用POI转换.DOC / .DOCX为PDF在Java ..?

how to convert ms-document to PDF, is there any example pls sharewith me.. thanks.解决方案If you are requiered to use POI i guess you should take a look at org.apache.poi.hwpf.converterI never tried this, but i guess its worth a try atleast.It seems like y…

在线语音转文字工具V1.0

在线语音转文字工具V1.0介绍在线语音转文字工具V1.0&#xff0c;采用C#开发语音基于Framework4.5开发&#xff0c;主要采用百度语音识别SDK&#xff0c;实现了在线文本转语音的功能&#xff0c;可以转换后直接播放。有需要的朋友可以下载学习一下。如果遇到问题的可以留言或者私…

超媒体

“超媒体”是超级媒体的缩写。超媒体是一种采用非线性网状结构对块状多媒体信息&#xff08;包括文本、图像、视频等&#xff09;进行组织和管理的技术。 超媒体在本质上和超文本是一样的&#xff0c;只不过超文本技术在诞生的初期管理的对象是纯文本&#xff0c;所以叫做超文本…

java局部刷新session过期_Ajax局部页面刷新和History API结合的陷阱

ajax在现代网站已经得到非常普遍地应用&#xff0c;主要的好处大家都知道(异步加载数据&#xff0c;不用刷新整个浏览器&#xff0c;更小的数据传输尺寸)。对于那些老网站或者老项目来说全盘改造成ajax并不现实&#xff0c;于是就有了“局部页面刷新”这个解决方案。如果不知道…

Java通过Netty,实现Websocket消息推送只需要简单几步

前言 曾几何时&#xff0c;不知道大家有没有在项目里遇到过需要服务端给客户端推送消息的需求&#xff0c;是否曾经苦恼过、纠结过&#xff0c;我们知道要想实现这样的需求肯定离不开websocket长连接方式&#xff0c;那么到底是该选原生的websocket还是更加高级的netty框架呢&a…

53.Maximum Subarray

/** 53.Maximum Subarray * 2016-5-7 by Mingyang * 如果我们从头遍历这个数组。对于数组中的其中一个元素&#xff0c;它只有两个选择&#xff1a; 1.* 要么加入之前的数组加和之中&#xff08;跟别人一组&#xff09; * 2. 要么自己单立一个数组&#xff08;自己单开一组&…

java 创建者设计模式_Java设计模式之创建者模式分享热爱编程,程序人生

PS:今天的23中设计模式中的创建者方式&#xff0c;至此告一段落。我今天带来的技术分享为创建者模式以及原型模式。当然在Java中这两种方式很常见&#xff0c;只不过我们写的次数确实有点低而已&#xff0c;但是这不是我不学它的借口&#xff01;&#xff01;&#xff01;创建者…

一文读懂电感器的原理、结构、作用及分类

电感器是能够把电能转化为磁能而存储起来的元件。电感器的结构类似于变压器&#xff0c;但只有一个绕组。电感器具有一定的电感&#xff0c;它只阻碍电流的变化。 如果电感器在没有电流通过的状态下&#xff0c;电路接通时它将试图阻碍电流流过它&#xff1b;如果电感器在有电流…

final关键字与static对比

final关键字与static对比 static关键字修饰变量时&#xff0c;会使该变量在类加载时就会被初始化&#xff0c;不会因为对象的创建再次被加载&#xff0c;当变量被static 修饰时就代表该变量只会被初始化一次 例如图中所示&#xff0c;被static修饰的变量j&#xff0c;虽然创建…

juce中的BailOutChecker

界面库中值得注意的一点就是对象响应事件的时候自身被删除了&#xff0c;那么后续的访问自然就会出问题&#xff0c;所以需要在响应事件之后先添加引用&#xff0c;相关处理之后再查看自身是否已经被删除&#xff0c;如果已经被删除那么就直接退出。juce中通过BailOutChecker来…

java quartz 跳过_Java Quartz计划作业-禁止同时执行作业

我正在使用Quartz Job执行特定任务。我也在我的Main应用程序类中安排它的执行&#xff0c;而我试图完成的工作是不允许同时执行此作业的实例。因此&#xff0c;调度程序仅应在其先前实例完成后才执行作业。这是我的工作班级&#xff1a;public class MainJob implements Job {s…

mac USB串口工具配置

安装USB serial 驱动 我的usb serial芯片是 pl2303, 先到官网上下载对应驱动&#xff0c;并安装。安装完成之后会要求重启。 http://www.prolific.com.tw/admin/Technology/GetFile.ashx?fileID238 安装 minicom https://alioth.debian.org/projects/minicom/ 下载源码&…

macpro生成公钥并查看公钥

打开macpro的终端输入以下命令&#xff1a; $ cd ~/.ssh $ ls 此时发现没有那个id_rsa.pub文件&#xff0c;没有&#xff0c;就需要创建公钥 用ssh-keygen创建公钥 此时已经有了