百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 编程网 > 正文

java io 字节流InputStream详解 java 字节流 字符流

yuyutoo 2024-10-12 01:31 10 浏览 0 评论

概述

InputStream 为字节输入流,它本身为一个抽象类,必须依靠其子类实现各种功能,此抽象类是表示字节输入流的所有类的超类。 继承自InputStream 流是向程序中输入数据的,且数据单位为字节(8bit);

InputStream是输入字节数据用的类,所以InputStream类提供了3种重载的read方法.Inputstream类中的常用方法:

  (1) public abstract int read( ):读取一个byte的数据,返回值是高位补0的int类型值。若返回值=-1说明没有读取到任何字节读取工作结束。

  (2) public int read(byte b[ ]):读取b.length个字节的数据放到b数组中。返回值是读取的字节数。该方法实际上是调用下一个方法实现的

  (3) public int read(byte b[ ], int off, int len):从输入流中最多读取len个字节的数据,存放到偏移量为off的b数组中。

  (4) public int available( ):返回输入流中可以读取的字节数。注意:若输入阻塞,当前线程将被挂起,如果InputStream对象调用这个方法的话,它只会返回0,这个方法必须由继承InputStream类的子类对象调用才有用。

  (5) public long skip(long n):忽略输入流中的n个字节,返回值是实际忽略的字节数, 跳过一些字节来读取。

  (6) public int close( ) :我们在使用完后,必须对我们打开的流关闭。

主要的子类:

1) FileInputStream把一个文件作为InputStream,实现对文件的读取操作

2) ByteArrayInputStream:把内存中的一个缓冲区作为InputStream使用

3) StringBufferInputStream:把一个String对象作为InputStream

4) PipedInputStream:实现了pipe的概念,主要在线程中使用

5) SequenceInputStream:把多个InputStream合并为一个InputStream

6) FilterInputStream :用来“封装其它的输入流,并为它们提供额外的功能”。它的常用的子类有BufferedInputStream和DataInputStream。

BufferedInputStream的作用就是为“输入流提供缓冲功能,以及mark()和reset()功能”。

DataInputStream 是用来装饰其它输入流,它“允许应用程序以与机器无关方式从底层输入流中读取基本 Java 数据类型”。应用程序可以使用DataOutputStream(数据输出流)写入由DataInputStream(数据输入流)读取的数据。

FileInputStream 子类

FileInputStream是Java语言中抽象类InputStream用来具体实现类的创建对象。FileInputStream可以从文件系统中的某个文件中获得输入字节,获取的文件可用性取决于主机环境,提供的主要方法:

int available()

返回下一次对此输入流调用的方法可以不受阻塞地从此输入流读取(或跳过)的估计剩余字节数。

void close()

关闭此文件输入流并释放与此流有关的所有系统资源。

protected void finalize()

确保在不再引用文件输入流时调用其 close 方法。

FileChannel getChannel()

返回与此文件输入流有关的唯一 FileChannel 对象。

FileDescriptor getFD()

返回表示到文件系统中实际文件的连接的 FileDescriptor 对象,该文件系统正被此 FileInputStream 使用。

int read()

从此输入流中读取一个数据字节。

int read(byte[] b)

从此输入流中将最多 b.length 个字节的数据读入一个 byte 数组中。

int read(byte[] b, int off, int len)

从此输入流中将最多 len 个字节的数据读入一个 byte 数组中。

long skip(long n)

从输入流中跳过并丢弃 n 个字节的数据。

利用FileInputStream进行文件复制

public class FileInputStreamCopy {

public static void main(String[] args) throws IOException {

//1. 创建字节输入流对象,用来读取

FileInputStream fis = new FileInputStream("E:\\test.txt");

//2创建字节输出流对象,用来写入//没有会创建

FileOutputStream fs = new FileOutputStream(E:\\copy.txt);

//3创建一个数组用来读取

byte arr[] = new byte[1024 * 8];

int len;//用来计数

while ((len = fis.read(arr)) != -1) {

//从文件中用字节数组读取数组,存储到字节数组中

// 每读取到一个内容,就把读取到的内容写入到目的地文件

fs.write(arr,0,len);

}

//释放资源

fs.close();

fis.close();

}

}

ByteArrayInputStream 子类

ByteArrayInputStream 是字节数组输入流。它继承于InputStream。

它包含一个内部缓冲区,该缓冲区包含从流中读取的字节;通俗点说,它的内部缓冲区就是一个字节数组,而ByteArrayInputStream本质就是通过字节数组来实现的。

public void reset() 将此字节数组输出流的 count 字段重置为零,从而丢弃输出流中目前已累积的所有数据输出。

public byte[] toByteArray() 创建一个新分配的字节数组。数组的大小和当前输出流的大小,内容是当前输出流的拷贝。

public String toString() 将缓冲区的内容转换为字符串,根据平台的默认字符编码将字节转换成字符。

public void write(int w) 将指定的字节写入此字节数组输出流。

public void write(byte []b, int off, int len) 将指定字节数组中从偏移量 off 开始的 len 个字节写入此字节数组输出流。

public void writeTo(OutputStream outSt) 将此字节数组输出流的全部内容写入到指定的输出流参数中。

使用例子代码:

public class ByteArrayInputStreamTest{

public static void main(String[] args) throws Exception {

ByteArrayOutputStream out = new ByteArrayOutputStream();

//字节值被放入内部数组

out.write("abc中文".getBytes());

out.close();

byte[] a = out.toByteArray();

System.out.println(Arrays.toString(a));

InputStreamReader in = new InputStreamReader(

new ByteArrayInputStream(a));

int c;

while ((c = in.read()) != -1) {

System.out.println((char) c);

}

in.close();

}

}

PipedInputStream 子类

PipedInputStream类管道输入流,它是可以连接管道输出流,管道输入流提供了要写入管道输出流的所有数据的字节。

PipedInputStream类方法有:

int read():读取数据的下一个字节。

int read(byte []b,int off,int len):读取len个字节数据到一个字节数组,off参数表示偏移量,len表示读取数据的长度。

void receive(int b):接受一个字节的数据。

void connect(PipedOutputStream src):表示管道输入流连接到管道输出流src

int available():表示没有什么阻碍从输入流中读取字节数。

void close():表示关闭流。

例子代码:

public class PipedInputStreamTest  { 
public static void main(String[] args) throws Exception { 
//创建PipedInputStream对象 
final PipedInputStream in=new PipedInputStream(); 
final PipedOutputStream out=new PipedOutputStream(); 
//两个类进行连接 
in.connect(out); 
new Thread(new Runnable(){ 
        public void run(){ 
            BufferedReader br=new BufferedReader(new InputStreamReader(System.in)); 
            //通过键盘读取数据写入管道流 
            PrintStream ps=new PrintStream(out); 
            System.out.print(Thread.currentThread().getName()+"请输入内容:"); 
            try { 
                ps.println(br.readLine()); 
            } catch (IOException e) { 
                e.printStackTrace(); 
            } 
        } 
},"发送数据的线程").start(); 
new Thread(new Runnable(){ 
        public void run(){ 
            BufferedReader br=new BufferedReader(new InputStreamReader(in)); 
            try { 
                System.out.println(Thread.currentThread().getName()+"收到的内容:"+br.readLine()); 
            } catch (IOException e) { 
                e.printStackTrace(); 
            } 
        } 
},"接受数据的线程").start(); 
  } 
} 

FilterInputStream 子类

FilterInputStream 的作用是用来“封装其它的输入流,并为它们提供额外的功能”。它的常用的子类有BufferedInputStream和DataInputStream。
BufferedInputStream的作用就是为“输入流提供缓冲功能,以及mark()和reset()功能”。
DataInputStream 是用来装饰其它输入流,它“允许应用程序以与机器无关方式从底层输入流中读取基本 Java 数据类型”。应用程序可以使用DataOutputStream(数据输出流)写入由DataInputStream(数据输入流)读取的数据。

提供的常法方法:

int available()

此方法返回可以从此输入流中读取(或跳过)的字节数的估计值,而不会被此输入流的方法的下一个调用方阻塞。

void close()

此方法关闭此输入流并释放与该流关联的所有系统资源。

void mark(int readlimit)

此方法标记此输入流中的当前位置。

boolean markSupported()

此方法测试此输入流是否支持标记和重置方法。

int read()

此方法从此输入流中读取下一个数据字节。

int read(byte [] b)

此方法将此输入流中的byte.length字节数据读入字节数组。

int read(byte [] b,int off,int len)

此方法将此输入流中最多len个字节的数据读入一个字节数组。

void reset()

此方法将此流重新定位到上次在此输入流上调用mark方法时的位置。

long skip(long n)

此方法跳过并从此输入流中丢弃n个字节的数据。

例子代码:

public class FilterInputStreamDemo {

public static void main(String[] args) throws Exception {

InputStream is = null;

FilterInputStream fis = null;

boolean bool = false;

try{

is = new FileInputStream("E:\\test.txt");

fis = new BufferedInputStream(is);

bool = fis.markSupported();

System.out.print("返回值: "+bool);

} catch(IOException e){

e.printStackTrace();

} finally {

if (is!=null)

is.close();

if(fis!=null)

fis.close();

}

}

}

SequenceInputStream子类

SequenceInputStream 可以将两个或多个其他 InputStream 合并为一个。 首先,SequenceInputStream 将读取第一个 InputStream 中的所有字节,然后读取第二个 InputStream 中的所有字节。 这就是它被称为 SequenceInputStream 的原因,因为 InputStream 实例是按顺序读取的。

构造方法

SequenceInputStream(InputStream s1, InputStream s2): 通过两个参数初始化新创建的 SequenceInputStream(将按顺序读取这两个参数,先读取 s1,然后读取 s2)

SequenceInputStream(Enumeration extends InputStream> e): 通过枚举对象来初始化新创建的 SequenceInputStream,该参数必须是生成运行时类型为 InputStream 对象的 Enumeration 型参数。

例子代码:

public class SequenceInputStreamTest {

public static void main(String[] args) throws IOException {

InputStream s1 = new FileInputStream("E:\\text1.txt");

InputStream s2 = new FileInputStream("E:\\text1.txt");

SequenceInputStream sis = new SequenceInputStream(s1, s2);

InputStreamReader isr = new InputStreamReader(sis);

BufferedReader br = new BufferedReader(isr);

BufferedWriter bw = new BufferedWriter(new FileWriter("E:\\text3.txt"));

String line = null;

while((line = br.readLine()) != null) {

bw.write(line);

bw.newLine();

bw.flush();

}

s1.close();

s2.close();

br.close();

bw.close();

}

}

相关推荐

ETCD 故障恢复(etc常见故障)

概述Kubernetes集群外部ETCD节点故障,导致kube-apiserver无法启动。...

在Ubuntu 16.04 LTS服务器上安装FreeRADIUS和Daloradius的方法

FreeRADIUS为AAARadiusLinux下开源解决方案,DaloRadius为图形化web管理工具。...

如何排查服务器被黑客入侵的迹象(黑客 抓取服务器数据)

---排查服务器是否被黑客入侵需要系统性地检查多个关键点,以下是一份详细的排查指南,包含具体命令、工具和应对策略:---###**一、快速初步检查**####1.**检查异常登录记录**...

使用 Fail Ban 日志分析 SSH 攻击行为

通过分析`fail2ban`日志可以识别和应对SSH暴力破解等攻击行为。以下是详细的操作流程和关键分析方法:---###**一、Fail2ban日志位置**Fail2ban的日志路径因系统配置...

《5 个实用技巧,提升你的服务器安全性,避免被黑客盯上!》

服务器的安全性至关重要,特别是在如今网络攻击频繁的情况下。如果你的服务器存在漏洞,黑客可能会利用这些漏洞进行攻击,甚至窃取数据。今天我们就来聊聊5个实用技巧,帮助你提升服务器的安全性,让你的系统更...

聊聊Spring AI Alibaba的YuQueDocumentReader

序本文主要研究一下SpringAIAlibaba的YuQueDocumentReaderYuQueDocumentReader...

Mac Docker环境,利用Canal实现MySQL同步ES

Canal的使用使用docker环境安装mysql、canal、elasticsearch,基于binlog利用canal实现mysql的数据同步到elasticsearch中,并在springboo...

RustDesk:开源远程控制工具的技术架构与全场景部署实战

一、开源远程控制领域的革新者1.1行业痛点与解决方案...

长安汽车一代CS75Plus2020款安装高德地图7.5

不用破解原车机,一代CS75Plus2020款,安装车机版高德地图7.5,有红绿灯读秒!废话不多讲,安装步骤如下:一、在拨号状态输入:在电话拨号界面,输入:*#518200#*(进入安卓设置界面,...

Zookeeper使用详解之常见操作篇(zookeeper ui)

一、Zookeeper的数据结构对于ZooKeeper而言,其存储结构类似于文件系统,也是一个树形目录服务,并通过Key-Value键值对的形式进行数据存储。其中,Key由斜线间隔的路径元素构成。对...

zk源码—4.会话的实现原理一(会话层的基本功能是什么)

大纲1.创建会话...

Zookeeper 可观测性最佳实践(zookeeper能够确保)

Zookeeper介绍ZooKeeper是一个开源的分布式协调服务,用于管理和协调分布式系统中的节点。它提供了一种高效、可靠的方式来解决分布式系统中的常见问题,如数据同步、配置管理、命名服务和集群...

服务器密码错误被锁定怎么解决(服务器密码错几次锁)

#服务器密码错误被锁定解决方案当服务器因多次密码错误导致账户被锁定时,可以按照以下步骤进行排查和解决:##一、确认锁定状态###1.检查账户锁定状态(Linux)```bash#查看账户锁定...

zk基础—4.zk实现分布式功能(分布式zk的使用)

大纲1.zk实现数据发布订阅...

《死神魂魄觉醒》卡死问题终极解决方案:从原理到实战的深度解析

在《死神魂魄觉醒》的斩魄刀交锋中,游戏卡死犹如突现的虚圈屏障,阻断玩家与尸魂界的连接。本文将从技术架构、解决方案、预防策略三个维度,深度剖析卡死问题的成因与应对之策,助力玩家突破次元壁障,畅享灵魂共鸣...

取消回复欢迎 发表评论: