`

io之DataStream

    博客分类:
  • java
阅读更多
package com.laien.io;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;

/**
 * 节点流:可以跟文件直接关联,如:FileOutputStream
 * 过滤流:用以包装节点流,如:DataOutputStream,BufferedOutputStream
 * 
 * @author Administrator
 *
 */
public class DataStreamTest {
	public static void main(String[] args) throws IOException {

		DataOutputStream dos = new DataOutputStream(new BufferedOutputStream(
				new FileOutputStream("d:/data.txt")));
		byte b = 3;
		int i = 12;

		char ch = 'c';
		float f = 3.14f;

		// 写成二进制流
		dos.writeByte(b);
		dos.writeInt(i);
		dos.writeChar(ch);
		dos.writeFloat(f);

		dos.close();

		/***** 读数据 *********/
		DataInputStream dis = new DataInputStream(new BufferedInputStream(
				new FileInputStream("d:/data.txt")));
		
		
		//与写数据的顺序要一致		
		System.out.println(dis.readByte());
		System.out.println(dis.readInt());
		System.out.println(dis.readChar());
		System.out.println(dis.readFloat());
		
		dis.close();
	}

}

 

分享到:
评论

相关推荐

    57-IO流(操作基本数据类型的流对象DataStream).avi

    57-IO流(操作基本数据类型的流对象DataStream).avi

    通俗易懂之Flink DataStream API开发

    本篇将深入探讨流处理的基本概念,以及Flink DataStream API的使用,包括算子操作、水印机制、状态管理、容错机制、异步IO、端对端一次性语义、Streaming file sink的运用,以及综合案例的开发。 1. **流处理基础**...

    flink datastream api 示例大全

    1. **异步IO(Asynchronous I/O)**:在Flink中,异步IO允许用户在执行读写操作时避免阻塞主线程,提高系统效率。例如,当从远程服务读取数据或写入存储系统时,可以使用异步接口来并发处理多个请求。 2. **Join**:...

    java io流PPT课件.pptx

    除了基本的字节流和字符流,Java还提供了许多其他类型的流,如过滤流(FilterStream)、缓冲流(BufferedStream)、数据流(DataStream)等,它们为基本的输入输出流提供了额外的功能,如数据校验、缓冲优化等。...

    Java IO文件操作类与复制文件实例.rar

    Java IO文件操作类与复制文件实例,有关文本编辑、FileWriter文件写入、FileReade文件读娶DataStream文件数据流、BufferedReader文件暂存器、FileViewer文件浏览器、复制文件Copy等方面的操作要领,仅供学习参考。

    java io 2nd

    - **数据流类DataStream**:`DataInputStream`和`DataOutputStream`类支持读写Java的原始数据类型,例如,`readInt()`, `writeFloat()`等。 ### 内存中的流Streams in Memory 内存中的流用于在应用程序的不同部分...

    DataStream.html

    在IO包中提供了两个与平台无关的数据操作流 数据输出流:DataOutputStream 数据输入流:DataInputStream 通常按照一定格式将输入输出,再按照一定格式将数据输入。 要想使用数据输出流和输入流,则肯定要...

    Visual C# 2005 文件IO与数据存取秘诀(章立民研究室著) 源代码 CH2-CH3

    6. **数据流(DataStream)**:数据流是将数据从一个位置传输到另一个位置的过程。`BinaryReader`和`BinaryWriter`是两个常用的类,用于在二进制流中读写基本数据类型。 7. **文件流与数据流结合**:通常我们会将`...

    visual basic2005文件IO与数据存取秘诀第9章范例

    1. 文件I/O基础:在VB2005中,可以使用`System.IO`命名空间中的类来处理文件操作。`StreamReader`用于读取文本文件,而`StreamWriter`则用于写入文本文件。例如,`File.OpenRead`和`File.OpenWrite`方法用于打开文件...

    java8stream源码-io.tusk:io.tusk

    java8流源码#DataStream 通过函数式编程为大数据提供动力 大数据总是很棒。 但是使用mapper、reducer组合器编写hadoop很糟糕。 为什么我们不让我们的分布式 hadoop 生活更轻松,并将权力交还给 java 开发人员? 受...

    flink入门到精通视频教程

    10.Flink进阶 异步IO,背压,内存管理 11.Flink Table API与SQL 课程目录介绍 第一章 Flink简介 01.Flink的引入 02.什么是Flink 03.Flink流处理特性 04.Flink基石 05.批处理与流处理 第二章 Flink架构体系 01.Flink...

    java的输入输出流

    Java.io包还包含了许多其他类型的流,如FilterStream、BufferedStream和DataStream等,它们提供了一种过滤、缓冲和处理结构化数据的能力。FilterStream是所有过滤流的基类,可以添加额外的功能或修改基础流的行为。...

    lixuemin.github.io:个人博客

    Flink的核心概念包括DataStream API、DataSets API、状态管理以及事件时间窗口。在博客中,李雪敏可能会分享如何使用Flink构建实时数据管道,处理流数据,以及如何利用Flink的容错机制确保数据的一致性。 Redisson...

    vs2010中应用get,post与http通信实例

    using System.IO; using System.Net; public class Program { public static void Main() { string url = "http://example.com"; HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url); request....

    项目7-Flink-高级特性和新特性1

    \n - **API使用**:创建一个Keyed或Non-Keyed DataStream,然后创建BroadcastedStream,接着使用`connect`方法将两者连接。对于Keyed Stream,使用`KeyedBroadcastProcessFunction`;对于Non-Keyed Stream,使用`...

    C#获取POP3邮件

    在处理附件时,通常需要获取附件的`DataStream`,然后将其保存到本地文件。 ```csharp Mail_Message mime; try { mime = Mail_Message.ParseFromByte(message.MessageToByte()); // 处理附件 if (mime....

    Python-使用PythonElasticsearch和Kibana进行实时异常检测的开源框架

    使用`datastream.io-master`这样的开源项目,可以实现实时数据流的处理和发送到Elasticsearch。这类工具通常会监听特定的输入源(如日志文件、网络套接字等),然后将数据转化为适合Elasticsearch处理的格式。 4. ...

    flink-local-train:flink入门到项目实践

    文章会对Flink中基本API如:DataSet、DataStream、Table、Sql和常用特性如:Time&Window、窗口函数、Watermark、触发器、分布式缓存、异步IO、侧输出、广播和高级应用如:ProcessFunction、状态管理等知识点进行整理...

    HttpPostGet请求工具(C#)

    using System.IO; using System.Net; using System.Text; public class HttpPostExample { public static void Main() { string url = "http://example.com/api"; string postData = "key1=value1&key2=value2...

    C# HTTP请求示例(采用原始函数实现,运行稳定)

    using System.IO; using System.Net; public class HttpRequestDemo { public static void Main() { string url = "http://example.com"; HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url); ...

Global site tag (gtag.js) - Google Analytics