javaInputStream文件读写网络UDP/TCP

java io流 传输操作

字节流和字符流的区别&＃xff1a;

读写单位不同&＃xff1a;字节流以字节&＃xff08;8bit&＃xff09;为单位&＃xff0c;字符流以字符为单位&＃xff0c;字符流就是 &＃xff1a; 字节流&＃43;编码表。

处理对象不同&＃xff1a;字节流能处理所有类型的数据&＃xff08;如图片、avi等&＃xff09;&＃xff0c;而字符流只能处理字符类型的数据。

纯文本数据优先考虑字符流 别的 字节流

常用    字节流&＃xff1a;

FileInputStream                 //字符流读文件

FileOutputStream              //字符流写文件

BufferedInputStream         //带缓冲区的 读文件

BufferedOutputStream       //带缓冲区    写文件

字符流&＃xff1a;

Writer Reader

FileReader                //文件读

FileWriter                //文件写

BufferedReader        //缓存读操作

BufferedWriter         //缓存写操作

创建一个可以往文件中写入字符数据的字符输出流对象&＃xff0c;如果文件不存在&＃xff0c;则会自动创建。如果文件存在&＃xff0c;则会被覆盖。

因为不同系统换行符号不同所以&＃xff0c;可以调用系统函数获得换行符号&＃xff0c;便于不同系统移植

private static final String LINE_SEPARATOR &＃61; System.getProperty("line.separator");  //换行符

FileWriter fw &＃61; new FileWriter("demo.txt",true);  //创建一个文件
fw.write("abcde"&＃43;LINE_SEPARATOR&＃43;"hahaha");        //数据写入到临时存储缓冲区中。
fw.flush();                                       //数据缓冲区刷到文件中
fw.close();                                       //这个其实会自动调用 flush&＃xff1b;上面那样写 可以实时保存

读文件 单个字符模式

FileReader fr &＃61; new FileReader("demo.txt");      //打开要读的文件
int ch &＃61; 0;
while((ch&＃61;fr.read())!&＃61;-1){                       //文件结束符 为 -1 &＃xff0c;获得单个字符System.out.println((char)ch);                
}
fr.close();

单个字符读&＃xff0c;操作次数多&＃xff0c;浪费资源&＃xff0c;于是出现多个字符缓冲区方式读取

FileReader fr &＃61; new FileReader("demo.txt");
char[] buf &＃61; new char[1024];                  //一次读取 1024字节
int len &＃61; 0;
while((len&＃61;fr.read(buf))!&＃61;-1){System.out.println(new String(buf,0,len));
}
fr.close();

一个文件读取写入另一个文件  规范的写法 考虑抛异常

FileReader fr &＃61; null;
FileWriter fw &＃61; null;
try {fr &＃61; new FileReader("a.txt");fw &＃61; new FileWriter("b.txt");char[] buf &＃61; new char[BUFFER_SIZE];//缓冲区。 int len &＃61; 0;while((len&＃61;fr.read(buf))!&＃61;-1){fw.write(buf, 0, len);}} catch (Exception e) {throw new RuntimeException("读写失败");
}finally{if(fw!&＃61;null)  //证明打开的文件不为空try {fw.close();} catch (IOException e) {e.printStackTrace();}if(fr!&＃61;null)try {fr.close();} catch (IOException e) {e.printStackTrace();}
}

java本身带了缓存对象&＃xff0c;可以直接调用  文件打开 操作

FileWriter fw &＃61; new FileWriter("buf.txt");
BufferedWriter bufw &＃61; new BufferedWriter(fw);    //
String line &＃61; null;
while((line&＃61;bufr.readLine())!&＃61;null){          //一次 读一行System.out.println(line);
}FileWriter fw &＃61; new FileWriter("buf.txt");
BufferedWriter bufw &＃61; new BufferedWriter(fw);
bufw.write("abcdef"&＃43;x);
bufw.newLine();
bufw.flush();
bufw.close();                           //关闭缓冲区 防止内存泄露  这个不需要关闭 文件

字节流例子

FileInputStream fis &＃61; new FileInputStream("bytedemo.txt");
byte[] buf &＃61; new byte[1024];
int len &＃61; 0;while((len&＃61;fis.read(buf))!&＃61;-1){                    //文件没结束System.out.println(new String(buf,0,len));
}FileOutputStream fos &＃61; new FileOutputStream("bytedemo.txt");fos.write("abcdefg".getBytes());          //文件中写入数据
//fos.flush();
fos.close();//关闭资源动作要完成。

拷贝一首MP3文件

FileInputStream fis &＃61; new FileInputStream("c:\\0.mp3");
BufferedInputStream bufis &＃61; new BufferedInputStream(fis);      //缓冲区方式FileOutputStream fos &＃61; new FileOutputStream("c:\\2.mp3");
BufferedOutputStream bufos &＃61; new BufferedOutputStream(fos);int ch &＃61; 0;
while((ch&＃61;bufis.read())!&＃61;-1){bufos.write(ch);
}bufos.close();                //关闭缓存区
bufis.close();

字符/字节流直接的转换   InputStreamReader、OutputStreamWriter

BufferedReader bufr &＃61; new BufferedReader(new InputStreamReader(System.in));    字节流到字符流

BufferedWriter bufw &＃61; new BufferedWriter(new OutputStreamWriter(new FileOutputStream("b.txt")));

字符流道字节流  转换桥

java网络通信 UDP函数

DatagramSocket ds &＃61; new DatagramSocket(10000);         //UDP 绑定端口while(true){byte[] buf &＃61; new byte[1024];DatagramPacket dp &＃61; new DatagramPacket(buf,buf.length);       //UDP包对象ds.receive(dp);//阻塞式的。//4&＃xff0c;通过数据包对象的方法&＃xff0c;解析其中的数据,比如&＃xff0c;地址&＃xff0c;端口&＃xff0c;数据内容。String ip &＃61; dp.getAddress().getHostAddress();int port &＃61; dp.getPort();String text &＃61; new String(dp.getData(),0,dp.getLength());    //数据System.out.println(ip&＃43;":"&＃43;port&＃43;":"&＃43;text);
}ds.close();

UDPsend

DatagramSocket ds &＃61; new DatagramSocket();           BufferedReader bufr &＃61; new BufferedReader(new InputStreamReader(System.in));
String line &＃61; null;while((line&＃61;bufr.readLine())!&＃61;null){byte[] buf &＃61; line.getBytes();   DatagramPacket dp &＃61; new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.1.100"),10000);  //udp发送包ds.send(dp);    if("886".equals(line))break;
}ds.close();

TCP通信对象  客户端

Socket socket &＃61; new Socket("192.168.1.100",10002);          //服务器IP 端口OutputStream out &＃61; socket.getOutputStream();  //输出的信息
out.write("tcp 输出".getBytes());InputStream in &＃61; socket.getInputStream();        //接收到的信息
byte[] buf &＃61; new byte[1024];int len &＃61; in.read(buf);String  text &＃61; new String(buf,0,len);System.out.println(text);                socket.close();

服务器端

ServerSocket ss &＃61; new ServerSocket(10002);Socket s &＃61; ss.accept();                             //获得客户端对象String ip &＃61; s.getInetAddress().getHostAddress();   //获得客户端IPInputStream in &＃61; s.getInputStream();    //接收到的客户端数据
byte[] buf &＃61; new byte[1024];int len &＃61; in.read(buf);
String text &＃61; new String(buf,0,len);
System.out.println(ip&＃43;":"&＃43;text);OutputStream out &＃61; s.getOutputStream();   //发送到客户端数据
out.write("收到".getBytes());s.close();
ss.close();