Que faire si le flux d'entrée tamponné est tronqué ?

package com.java.utils.charactor; import java.io.BufferedInputStream; import java.io.BufferedReader; import java.io.DataInputStream; import java.io.File; import java.io.FileInputStream; import java.io.InputStreamReader; import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; /** * 简繁体转换 * * @author pengjianbo  * $Id$ */ public class SimTradConvert { public SimTradConvert() throws Exception { File simplFile = new File( "D:\\android\\JavaUtils\\src\\com\\java\\utils\\charactor\\simplified.txt"); FileInputStream simplFis = new FileInputStream(simplFile); BufferedInputStream simplBis = new BufferedInputStream(simplFis); BufferedReader simplBr = new BufferedReader(new InputStreamReader(simplBis)); StringBuffer simplsb = new StringBuffer(); byte[] simplb = new byte[1024]; while ((simplBis.read(simplb)) != -1) { simplsb.append(new String(simplb)); } simplFis.close(); simplBis.close(); File tradFile = new File( "D:\\android\\JavaUtils\\src\\com\\java\\utils\\charactor\\traditional.txt"); FileInputStream tradFis = new FileInputStream(tradFile); BufferedInputStream tradBis = new BufferedInputStream(tradFis); StringBuffer tradsb = new StringBuffer(); byte[] tradb = new byte[1024]; while ((tradBis.read(tradb)) != -1) { tradsb.append(new String(tradb)); } tradBis.close(); tradFis.close(); System.out.println(simplsb.toString()); /*CnGetPinyin pinyin = new CnGetPinyin(); //连接SQLite的JDBC Class.forName("org.sqlite.JDBC"); Connection conn = DriverManager.getConnection("jdbc:sqlite:pai.db"); Statement stat = conn.createStatement(); for(int i = 0; i < simplsb.length() -1; i++ ) { stat.executeUpdate( "insert into CNLang(pinyin,simp,trad) values('" + pinyin.getPinyin(simplsb.substring(i, i + 1)) + "','" + simplsb.substring(i, i + 1) + "','" + tradsb.substring(i, i + 1) + "')"); System.out.println("正在添加:" + simplsb.substring(i, i + 1) + "-->" + tradsb.substring(i, i + 1)); if( i > simplsb.length() -1 ) { stat.close(); conn.close(); } }*/ } public static void main(String[] args) throws Exception { new SimTradConvert(); } }

package com.pocketdigi; import java.io.BufferedInputStream; import java.io.BufferedOutputStream; import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStreamReader; public class Main { public static void main(String[] args) throws IOException { File f = new File("d:/a.txt"); FileOutputStream fos = new FileOutputStream(f); // 构建FileOutputStream对象,文件不存在会自动新建 BufferedOutputStream bos = new BufferedOutputStream(fos); bos.write("1我是中文".getBytes()); bos.close(); // 关闭输出流,写入数据,如果下面还要写用flush(); // 因为是BufferOutputStream链接到FileOutputStream,只需关闭尾端的流 // 所以不需要关闭FileOutputStream; FileInputStream fis = new FileInputStream(f); BufferedInputStream bis = new BufferedInputStream(fis); BufferedReader reader = new BufferedReader (new InputStreamReader(bis)); //之所以用BufferedReader,而不是直接用BufferedInputStream读取,是因为BufferedInputStream是InputStream的间接子类, //InputStream的read方法读取的是一个byte,而一个中文占两个byte,所以可能会出现读到半个汉字的情况,就是乱码. //BufferedReader继承自Reader,该类的read方法读取的是char,所以无论如何不会出现读个半个汉字的. StringBuffer result = new StringBuffer(); while (reader.ready()) { result.append((char)reader.read()); } System.out.println(result.toString()); reader.close(); } }