Android IO简化之Okio库

2021-01-22 08:30:02

Android IO简化之Okio库

概要

如果之前有使用过Okhttp,那么你一定知道底层的IO读取是由square公司开发的Okio库。它补充了Java.io和java.nio的不足,以便能够更加方便,快速的访问、存储和处理你的数据。而在一般的开发中,我们也可以使用Okio来做IO读写,非常方便深得我心。

核心概念

在日常的开发过程中,Okio的使用非常方便,在于相比java.io库它简化了很多繁杂而且我们平时又使用不到的东西。这其中最核心的两个类便是 Sink, Source。Source可以简单的理解为InputStream 而Sink则对应为OutPutStream。这两个接口都继承Closeable接口,所以在使用结束我们可以当做正常的IO关闭。

Okio工程结构

  • Sink

    它有一子类接口 BufferedSink,BufferedSink的实现类为RealBufferedSink。BufferedSink中定义了一系列写入缓存区的方法,比如write方法写byte数组,writeUtf8写字符串,还有一些列的writeByte,writeString,writeShort,writeInt,writeLong,writeDecimalLong等等方法;

  • Source

    它有一子类接口 BufferedSource。 BufferedSource的实现类为RealBufferedSource,BufferedSource中定义了一系列读取方法,对应上面的写入方法read方法写byte数组,readUtf8写字符串。

两个支持缓冲区的接口的实现类RealBufferedSink和RealBufferedSource都是通过包装一个Sink+Buffer或者Source+Buffer来进行实现的。

说了这么多,直接上代码吧。所有的IO操作,核心代码就只有两行。

示例代码1  如何读取数据

        BufferedSource bufferedSource = null;
        try {
            File file = new File("txt");
            bufferedSource = Okio.buffer(Okio.source(file));
            String content = bufferedSource.readUtf8();
            System.out.println(content);
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            closeQuietly(bufferedSource);
        }

实例代码2 如何写入数据

 BufferedSink bufferedSink = null;
        try {
            File file = new File("txt");
            bufferedSink = Okio.buffer(Okio.Sink(file));
            bufferedSink.writeUtf8("i am zhangsan");
        } catch (Exception e) {
        } finally {
            closeQuietly(bufferedSink);
        }

实例代码3 如何追加文件内容

 BufferedSink bufferedSink = null;
        try {
            File file = new File("txt");
            bufferedSink = Okio.buffer(Okio.appendSink(file));
            bufferedSink.writeUtf8("i am zhengyan");
        } catch (Exception e) {
        } finally {
            closeQuietly(bufferedSink);
        }

最后

我自己在尝试用了再也不想看到Java.io这么臃肿的库,上面展示了比较简单的IO操作,当然Okio还能做的更多。如果你仔细留意会发现我们用的最多的BufferedSink BufferedSource里面都会存在一个Buffer类来支持这缓冲区,我将在下章讲解Buffered类在Okio是如何工作原理的,以及Okio的一些源码分析,谢谢大家阅读。



  • 2020-12-07 15:19:00

    响应式邮件的编写插件介绍mjml

    以前做项目碰到发邮件的需求,邮件模板的编辑就是一件头疼的事。因为虽说邮件是支持 HTML 的,但是确是 HTML 子集程度的支持,所以存在必须通过 <table> 排版的恶心之处,还有很多兼容性的坑。本质上是各家邮件商的标准有差异吧。

  • 2020-12-07 16:14:22

    nodejs队列实现amqplib,rabbitmq

    其中StartConsumer 会在项目启动时启动,在整个生命周期中一直保持监听状态,在程序结束时mq的链接关闭。需要注意的是 noAck 这个参数,当为false是表示消息出队后不会自动删除,如果设置成true,则无论消息处理成功与否此消息会被删除。注意到在消息不成功是,调用了ch.nack(msg)),此方法是将消息重新入队。

  • 2020-12-07 16:15:46

    RabbitMQ详解

    当前市面上mq的产品很多,比如RabbitMQ、Kafka、ActiveMQ、ZeroMQ和阿里巴巴捐献给Apache的RocketMQ。甚至连redis这种NoSQL都支持MQ的功能。 ActiveMQ ActiveMQ是apache出品,最流行的,能力强劲的开源消息总线,并且它一个完全支持JMS规范的消息中间件。其丰富的API、多种集群构建模式使得它成为业界老牌消息中间件,在中小型企业中应用广泛。

  • 2020-12-07 16:17:53

    nodejs用redis实现队列操作

    其实nodejs实现队列的方式又很多中,也有很多开源的插件和队列数据库可以使用,但是呢,如果我们一个简单的项目,完全可以使用redis来实现队列, 这样再不增加技术难度的同事,我们也就可以完美的实现一个队列

  • 2020-12-07 22:02:44

    intellij idea远程开发的几个想法

    我之前是用idea上面自带的stfp来做的本地开发同步到linux服务器编译,但是我发现这个如果多个客户端同时开发,或者多个同事一起开发,服务器上的就不能更新到本地。是不能增量更新到本地,必须全部下载,比对下载也行,但是工程量打了就特别慢。

  • 2020-12-07 22:06:13

    System Extension Blocked - warning

    After upgrading your macOS computer to High Sierra 10.13.4 or higher (starting in April 2018), you may see a message about a System Extension Blocked. At Williams we have seen this warning appear for these programs: