JAVA 中怎么对CephFS进行操作,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。
添加MAVEN依赖
<dependency>
<groupId>com.ceph</groupId>
<artifactId>libcephfs</artifactId>
<version>0.80.5</version>
</dependency>
例子代码
import com.ceph.fs.CephMount;
import java.io.IOException;
public class CephFSTest {
public static void main(String[] args){
//admin是ceph的admin用户
CephMount mount = new CephMount("admin");
//10.112.101.141;10.112.101.142;10.112.101.143是ceph集群的mon节点,有多少个写多少个
mount.conf_set("mon_host", "10.112.101.141;10.112.101.142;10.112.101.143");
System.out.println(mount.conf_get("mon_host"));
//以下的key来自于ceph环境的/etc/ceph/ceph.client.admin.keyring里面的key
mount.conf_set("key","AQAfN2dZzp19OhAAKlQz2rKKoBATIuGdBkXD0A==");
//在创建目录之前必须先mount到根目录
mount.mount("/");
//在根目录下面创建子目录 mysqlDB,0777是对目录的权限控制,这个可以改成别的,不过最好要让目录具有读写权限
try {
mount.mkdirs("/mongoDB/",0777);
} catch (IOException e) {
e.printStackTrace();
}
//创建完后断掉mount
mount.unmount();
System.out.println("success");
}
}
看完上述内容,你们掌握JAVA 中怎么对CephFS进行操作的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注天达云行业资讯频道,感谢各位的阅读!