ceph java_java操作ceph之rbd基本操作

2023-10-14 21:10
文章标签 java 操作 基本操作 ceph rbd

本文主要是介绍ceph java_java操作ceph之rbd基本操作，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、安装librados和librbd

Ceph存储集群提供了基本的存储服务，允许Ceph在一个统一的系统中唯一地传送对象，块和文件存储。 但是，不限于使用RESTful，块或POSIX接口。 基于RADOS，Librados API使您能够创建自己的Ceph存储群集接口。Librados API使您能够与Ceph存储集群中的两种守护程序进行交互：

1)Ceph监视器，其维护集群映射的主副本。

2)Ceph OSD守护程序(OSD)，它将数据作为对象存储在存储节点上。

要安装librados-dev和librbd-dev，因为java的Rados类需要用到librados-dev，而Rbd类需要用到librbd-dev

，需要执行以下步骤：

1)安装librados和librbd。

对于Debian / Ubuntu，执行：

apt-get install librados-dev

apt-get install librbd-dev

对于 CentOS/RHEL，执行：

yum install librados2-devel

yum install librbd1-devel

为开发人员安装库后，可以在/usr/include/rados下找到C / C ++所需的头文件

也可以下载下面的4个rmp包：

wget http://vault.centos.org/7.2.1511/storage/x86_64/ceph-hammer/librados2-0.94.5-1.el7.x86_64.rpm

wget http://vault.centos.org/7.2.1511/storage/x86_64/ceph-hammer/librados2-devel-0.94.5-1.el7.x86_64.rpm

wget http://vault.centos.org/7.2.1511/storage/x86_64/ceph-hammer/librbd1-0.94.5-1.el7.x86_64.rpm

wget http://vault.centos.org/7.2.1511/storage/x86_64/ceph-hammer/librbd1-devel-0.94.5-1.el7.x86_64.rpm

然后执行：

yum install librados2-0.94.5-1.el7.x86_64.rpm librados2-devel-0.94.5-1.el7.x86_64.rpm -y

yum install librbd1-0.94.5-1.el7.x86_64.rpm librbd1-devel-0.94.5-1.el7.x86_64.rpm -y

2)克隆rados-java工程：

git clone https://github.com/ceph/rados-java.git

3)构建rados-java工程：

cd rados-java-master

mvn install-Dmaven.test.skip=true

JAR文件位于rados-java-master/target下

4)新建一个maven工程cephDemo，用来调用ceph

工程目录如下所示：

12dc4f6b8204edc379caed9b5b168af0.png

下面引用的rados-0.4.0-SNAPSHOT.jar是由上面的mvn install后生成的jar包，实情情况版本可能有变

pom.xml配置如下：

4.0.0

com.ceph.test

cephDemo

0.0.1-SNAPSHOT

cephDemo

com.ceph

rados

0.4.0-SNAPSHOT

二、应用程序调用ceph原理

下图提供了初始连接的高级流程。

017bf47baadf7bf23759c1ba1f24db4a.png

以下是java对ceph中image的基本操作示例：

packagecom.ceph.rbd;importjava.io.File;importjava.util.Arrays;importjava.util.List;importcom.ceph.rados.IoCTX;importcom.ceph.rados.Rados;importcom.ceph.rados.exceptions.RadosException;importcom.ceph.rbd.jna.RbdImageInfo;importcom.ceph.rbd.jna.RbdSnapInfo;public classRbdDao {private staticRados rados;private staticIoCTX ioctx;private staticRbd rbd;/*** 连接上ceph环境*/

public static voidconnectCeph(){try{

rados= new Rados("admin");//rados.confSet("mon_host", "10.111.131.125");//rados.confSet("key", "AQBngfhYpHvLKhAAtmVZTyR3NJxx1WOVeLo5pQ==");

rados.confSet("mon_host", "172.16.60.41");

rados.confSet("key", "AQCdP9pYGI4jBBAAc96J8/OconCkVKWPBNU2vg==");

rados.connect();

ioctx= rados.ioCtxCreate("rbd");

rbd= newRbd(ioctx);

System.out.println("successs connetc");

}catch(Exception e) {

e.printStackTrace();//TODO: handle exception

}

}/*** 返回所有的image,并展示其详细信息

*@return

*/

public static ListimageList(){

List imageList=null;try{

imageList=Arrays.asList(rbd.list());for(String s:imageList){

showDetailOfImage(s);

}

}catch(RbdException e) {//TODO Auto-generated catch block

e.printStackTrace();

}returnimageList;

}/*** 显示image的详细信息

*@paramimageName*/

public static voidshowDetailOfImage(String imageName){

RbdImage image;try{

image=rbd.open(imageName);

RbdImageInfo info=image.stat();

System.out.println("=================================================================");

System.out.println("imageName: "+imageName);

System.out.println("imageSize: "+info.size);

System.out.println("order: "+info.order);

rbd.close(image);

}catch(RbdException e) {//TODO Auto-generated catch block

e.printStackTrace();

}

}/*** 以格式1创建image

*@paramimageName 名称

*@paramimageSize　大小*/

public static void createRbd_format1(String imageName, longimageSize){try{

rbd.create(imageName, imageSize);

RbdImage image=rbd.open(imageName);boolean oldFormat =image.isOldFormat();

System.out.println("imageFormat:==========================="+oldFormat);

rbd.close(image);

}catch(RbdException e) {

System.out.println(e.getMessage()+ ": " +e.getReturnValue());

}

}/*** 以格式2创建image，ceph 仅支持克隆 format 2 映像(即用 rbd create –format 2 创建的)，而且内核 rbd 模块还不支持。

所以现在你 只能用 QEMU/KVM 或 librbd直接访问克隆品

*@paramimageName 名称

*@paramimageSize　大小*/

public static void createRbd_format2(String imageName, longimageSize){try{int features = (1<<0);

System.out.println("features=============="+features);

rbd.create(imageName, imageSize,features,0);

RbdImage image=rbd.open(imageName);boolean oldFormat =image.isOldFormat();

System.out.println("imageFormat:==========================="+oldFormat);

rbd.close(image);

image.flatten();

}catch(RbdException e) {

System.out.println(e.getMessage()+ ": " +e.getReturnValue());

}

}/*** 方法创建一个image并对重设置大小为初始化大小的2倍

*@paramimageName*/

public static voidresizeImage(String imageName){long initialSize = 10485760;long newSize = initialSize * 2;try{int features = (1<<0);

System.out.println("features=============="+features);

rbd.create(imageName, initialSize,features,0);

RbdImage image=rbd.open(imageName);

image.resize(newSize);

rbd.close(image);

}catch(RbdException e) {

System.out.println(e.getMessage()+ ": " +e.getReturnValue());

}

}/*** 创建映像的快照

*@paramimageName 映像名称

*@paramsnapName 快照名称*/

public static voidcreateSnap(String imageName,String snapName){try{

RbdImage image=rbd.open(imageName);//创建快照

image.snapCreate(snapName);//保护快照可以防止快照被删除

image.snapProtect(snapName);//返回一个image的所有快照

List snaps =image.snapList();for(RbdSnapInfo rbds:snaps){

System.out.println("快照名称："+rbds.name);

System.out.println("快照大小："+rbds.size);

}

}catch(RbdException e) {//TODO Auto-generated catch block

e.printStackTrace();

}

}/*** 通过快照克隆出新的image

*@paramparentImageName 快照对应的image名称

*@paramsnapName 快照的名称

*@paramnewImageName 生成的新的image的名称*/

public static voidcopySnapToNewImage(String parentImageName,String snapName,String newImageName){int features = (1<<0);try{

rbd.clone(parentImageName, snapName, ioctx, newImageName, features,0);

}catch(RbdException e) {//TODO Auto-generated catch block

e.printStackTrace();

}

}/*** 删除某个image的名叫 snapName的快照,需要注意的是要删除快照，必须保证快照没有copy的子image，否则会删除失败。

*@paramimageName

*@paramsnapName*/

public static voiddeleteSnap(String imageName,String snapName){try{

RbdImage image=rbd.open(imageName);

image.snapUnprotect(snapName);

image.snapRemove(snapName);

}catch(RbdException e) {//TODO Auto-generated catch block

e.printStackTrace();

}

}/*** 删除某一个image

*@paramr

*@paramio

*@paramimageName

*@throwsRadosException

*@throwsRbdException*/

public static voidcleanupImage(Rados r, IoCTX io, String imageName) {try{if (r != null) {if (io != null) {

Rbd rbd= newRbd(ioctx);

RbdImage image=rbd.open(imageName);

rbd.close(image);

rbd.remove(imageName);

}

}

}catch(Exception e) {//TODO: handle exception

}

}public static voidmain(String[] args){

connectCeph();//createRbd_format1("mysql-hzb-2",10737418240l);//createRbd_format2("imageformat2",10485760);//cleanupImage(rados,ioctx,"mysql-hzb");//resizeImage("mysql-hzb");//createSnap("imageformat3","imageformat3-snap");//copySnapToNewImage("imageformat3","imageformat3-snap","imageformat3-copy");//deleteSnap("imageformat3","imageformat3-snap");

imageList();

}

}

这篇关于ceph java_java操作ceph之rbd基本操作的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/213167。

相关文章

JSON字符串转成java的Map对象详细步骤

JSON字符串转成java的Map对象详细步骤

《JSON字符串转成java的Map对象详细步骤》：本文主要介绍如何将JSON字符串转换为Java对象的步骤,包括定义Element类、使用Jackson库解析JSON和添加依赖,文中通过代码介绍... 目录步骤 1: 定义 Element 类步骤 2: 使用 Jackson 库解析 jsON步骤 3: 添
阅读更多...
Java中注解与元数据示例详解

Java中注解与元数据示例详解

《Java中注解与元数据示例详解》Java注解和元数据是编程中重要的概念,用于描述程序元素的属性和用途,：本文主要介绍Java中注解与元数据的相关资料,文中通过代码介绍的非常详细,需要的朋友可以参... 目录一、引言二、元数据的概念2.1 定义2.2 作用三、Java 注解的基础3.1 注解的定义3.2 内
阅读更多...
Java中使用Java Mail实现邮件服务功能示例

Java中使用Java Mail实现邮件服务功能示例

《Java中使用JavaMail实现邮件服务功能示例》：本文主要介绍Java中使用JavaMail实现邮件服务功能的相关资料,文章还提供了一个发送邮件的示例代码,包括创建参数类、邮件类和执行结... 目录前言一、历史背景二编程、pom依赖三、API说明（一）Session （会话）（二）Message编程客
阅读更多...
Java中List转Map的几种具体实现方式和特点

Java中List转Map的几种具体实现方式和特点

《Java中List转Map的几种具体实现方式和特点》：本文主要介绍几种常用的List转Map的方式,包括使用for循环遍历、Java8StreamAPI、ApacheCommonsCollect... 目录前言1、使用for循环遍历：2、Java8 Stream API：3、Apache Commons
阅读更多...
JavaScript中的isTrusted属性及其应用场景详解

JavaScript中的isTrusted属性及其应用场景详解

《JavaScript中的isTrusted属性及其应用场景详解》在现代Web开发中,JavaScript是构建交互式应用的核心语言,随着前端技术的不断发展,开发者需要处理越来越多的复杂场景,例如事件... 目录引言一、问题背景二、isTrusted 属性的来源与作用1. isTrusted 的定义2. 为
阅读更多...
Java循环创建对象内存溢出的解决方法

Java循环创建对象内存溢出的解决方法

《Java循环创建对象内存溢出的解决方法》在Java中,如果在循环中不当地创建大量对象而不及时释放内存,很容易导致内存溢出（OutOfMemoryError）,所以本文给大家介绍了Java循环创建对象... 目录问题1. 解决方案2. 示例代码2.1 原始版本（可能导致内存溢出）2.2 修改后的版本问题在
阅读更多...
PyCharm接入DeepSeek实现AI编程的操作流程

PyCharm接入DeepSeek实现AI编程的操作流程

《PyCharm接入DeepSeek实现AI编程的操作流程》DeepSeek是一家专注于人工智能技术研发的公司,致力于开发高性能、低成本的AI模型,接下来,我们把DeepSeek接入到PyCharm中... 目录引言效果演示创建API key在PyCharm中下载Continue插件配置Continue引言
阅读更多...
使用Python实现操作mongodb详解

使用Python实现操作mongodb详解

《使用Python实现操作mongodb详解》这篇文章主要为大家详细介绍了使用Python实现操作mongodb的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录一、示例二、常用指令三、遇到的问题一、示例from pymongo import MongoClientf
阅读更多...
Java CompletableFuture如何实现超时功能

Java CompletableFuture如何实现超时功能

《JavaCompletableFuture如何实现超时功能》：本文主要介绍实现超时功能的基本思路以及CompletableFuture（之后简称CF）是如何通过代码实现超时功能的,需要的... 目录基本思路CompletableFuture 的实现1. 基本实现流程2. 静态条件分析3. 内存泄露 bug
阅读更多...
Java中Object类的常用方法小结

Java中Object类的常用方法小结

《Java中Object类的常用方法小结》JavaObject类是所有类的父类,位于java.lang包中,本文为大家整理了一些Object类的常用方法,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1. public boolean equals(Object obj)2. public int ha
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2