美文网首页Java
Java程序员不缺对象,缺的是对象存储

Java程序员不缺对象,缺的是对象存储

作者: 程序花生 | 来源:发表于2020-08-27 16:28 被阅读0次

    前言

    文件服务器是一个应用必要的组件之一。最早我搞过FTP,然后又用过FastDFS,接私活的时候我用MongoDB也凑合凑合。现如今时代不同了,开始流行起了OSS。

    什么是 OSS

    全称为Object Storage Service,也叫对象存储服务,是一种解决和处理离散单元的方法,可提供基于分布式系统之上的对象形式的数据存储服务,具有可拓展、可管理、低成本等特点,支持中心和边缘存储,能够实现存储需求的弹性伸缩,主要应用于海量数据管理的各类场景。

    这概念真是够难以理解的。简单说点我知道的吧,平常我们的文件地址都是 /User/felord/video/xxx.mp4的目录树结构,系统先要找到User,然后一级一级往下找一直到目标为止,这是一种结构化的存储方式。对象存储就不一样了,所有的文件都放在一个特定的池子里,只不过文件的携带有它自己的元信息,通过元信息去检索文件。这里举一个形象的例子:

    {"oss":[

    {"file":"xxxxx","meta":{"id":"1111"},"type":""},

    {"content":"xxxxx","meta":{"id":"1211"},"type":"","created":"","name":""},

    ]}

    上图的oss就是一个对象存储,它里面存了携带信息不一样、甚至结构都不一样的东西,我们可以根据其元信息meta检索它们。OSS具有以下特点:

    效率更高。不受复杂目录系统对性能的影响。

    可扩展性更强。分布式架构,更便于进行水平扩展,从而容纳进任意大规模的数据。

    可用性更强。数据一般都会有多个位于不同机器的复制,确保数据不丢失。

    平台无关,可以通过Restful接口进行操作对象。

    OSS通常被用来存储图片、音视频等文件,以及对这些文件的处理。

    哪些 OSS 可以使用

    通常我们有两种选择,花钱买或者自己搞。

    充钱才能变得更强

    这句话这里也是很实用的,目前几乎所有的云厂商都有自己的对象存储产品,你可以对比一下花钱购买它们,通过配合CDN能达到非常好的用户体验,胖哥的felord.cn就使用了云厂商的对象存储。购买他们的服务

    可靠性强,数据丢失可能性低。

    免维护,不需要自行维护。

    可配合其它一些特色功能,比如缩略图、CDN 等等。

    自己动手丰衣足食

    不想花钱就只能自己动手了,目前我知道的开源方案有两种。

    一种是Ceph,一个分布式存储系统,高可用,高扩展性。但是一般人玩不转,就连开源中国的红薯都被坑惨了 。

    大半年后红薯被Ceph玩坏了

    另一种是Minio,用Golang写的。我目前还没发现有什么坑,文档居然还有中文文档!我用Docker不到三分钟就玩起来了,居然还自带控制台!其它功能也挺齐全,各种客户端SDK齐全。

    因为安装过于简单就不演示了。

    整合到 Spring Boot

    无论你花钱还是自己搞都可以,这两种方式各有各的好处。所以我要把这两种方式整合到kono Spring Boot脚手架项目中。这种组件封装成为Spring Boot Starter再好不过了。在日常开发中这种基础组件都建议做成Starter。参考我的 最强自定义 Spring Boot Starter 教程里的方式,我将aliyun的OSS SDK和Minio SDK封装成Starter了。

    达到了开箱即用。而且非常灵活,你配置哪种使用哪种,可以二选一,也可以全都要,还可以全都不要。

    获取到项目后通过Maven命令mvn install安装到本地依赖库,或者你发布到你的远程私有Maven仓库。然后再引用Starter,切记先后步骤:

    <!--  一定要先拉取项目通过 mvn install 安装到本地  -->

    cn.felord

    oss-spring-boot-starter

    1.0.0.RELEASE

    Minio 配置流程(可选)

    接着就是使用了,先在你Minio的控制台上创建一个bucket,可以理解为一个对象池。

    创建 bucket

    然后把策略设置为可读写。

    编辑名称为img的bucket的策略 可读写策略

    搞完开始在项目中配置,application.yaml中:

    @Autowired

    @Qualifier("minioStorage")

    Storage storage;

    @Test

    publicvoidtestOss()throwsException{

    File file =newFile("./456.jpg");

    InputStream inputStream =newFileInputStream(file);

    storage.putObject("img","pic_122",inputStream, MimeTypeUtils.IMAGE_JPEG_VALUE);

    }

    aliyun OSS 配置流程(可选)

    额外引入依赖:

    com.aliyun.oss

    aliyun-sdk-oss

    2.5.0

    com.aliyun

    aliyun-java-sdk-core

    4.3.8

    这是必须的步骤。

    去ali OSS 控制台申请跟Minio差不多的几样东西用来配置:

    oss:

    aliyun:

    active: true

    access-key-id: LTAI4GH4EQXtKEbJDrADvWNH

    access-key-secret: XjDpNn5JqHAHPDXGL6xIebyUkyFAZ7

    endpoint: oss-cn-beijing.aliyuncs.com

    Starter 的使用

    以下是我对OSS操作的抽象接口:

    packagecn.felord.oss;

    importjava.io.InputStream;

    /**

    * The interface Storage.

    *

    *@authorfelord.cn

    *@since2020 /8/24 19:54

    */

    publicinterfaceStorage{

    /**

        * 存放对象

        *

    *@parambucketName  bucket  名称

    *@paramobjectName  自定义对象名称

    *@paraminputStream  对象的输入流

    *@paramcontentType  参考http 的 MimeType 值

    *@throwsException the exception

        */

    voidputObject(String bucketName, String objectName, InputStream inputStream, String contentType)throwsException;

    /**

        *  获取对象

        *

    *@parambucketName the bucket name

    *@paramobjectName the object name

    *@returnthe object

        */

    InputStreamgetObject(String bucketName, String objectName)throwsException;

    /**

        *  获取对象的URL

        *

    *@parambucketName the bucket name

    *@paramobjectName the object name

    *@returnthe object url

        */

    StringgetObjectUrl(String bucketName, String objectName)throwsException;

    /**

        *  删除对象

        *

    *@parambucketName the bucket name

    *@paramobjectName the object name

        */

    voidremoveObject(String bucketName, String objectName)throwsException;

    }

    然后分别使用了以上两种OSS进行了实现。

    对应的两种实现

    并分别以aliyunStorage、minioStorage为名称将AliyunStorage和MinioStorage注入Spring IoC。

    使用起来非常简单:

    @Autowired

    @Qualifier("minioStorage")

    Storage storage;

    @Test

    publicvoidtestOss()throwsException{

    File file =newFile("./456.jpg");

    InputStream inputStream =newFileInputStream(file);

    storage.putObject("img","pic_122",inputStream, MimeTypeUtils.IMAGE_JPEG_VALUE);

    }

    总结

    今天的整合与往常不太一样,主要是一些通用功能的组件化封装的实际演示,另外简单描述了对象存储的功能和使用场景,希望对你有用。

    作者: 码农小胖哥

    地址:https://stor.51cto.com/art/202008/624600.htm#topx

    相关文章

      网友评论

        本文标题:Java程序员不缺对象,缺的是对象存储

        本文链接:https://www.haomeiwen.com/subject/poacsktx.html