outputstream怎么转换成inputstream呢?不知道的小伙伴来看看小编今天的分享吧!
outputstream怎么转换成inputstream有三种方法。
方法一:使用字节数组缓存数据,输入代码:
ByteArrayOutputStream out = new ByteArrayOutputStream();
class1.putDataOnOutputStream(out);
class2.processDataFromInputStream(
new ByteArrayInputStream(out.toByteArray())
);
方法二:使用管道
第一种方法的问题是你必须有足够的内存缓存所有数据。你可以使用文件系统缓存更多数据,但无论如何可处理数据的大小还是受到限制。
解决方法是创建一个线程产生数据到PipedOutputStream。当前线程可从中读取数据。
输入代码:
PipedInputStream in = new PipedInputStream();
PipedOUtputStream out = new PipedOutputStream(in);
new Thread(
new Runnable(){
public void run(){
class1.putDataOnOutputStream(out);
}
}
).start();
class2.processDataFromInputStream(in);|||
方法三:使用循环缓存区
方法二中的两个管道流,实际上管理着一个隐藏的循环缓存区。使用一个显式的循环缓存区更易于理解。CircularBuffers 有如下优点
一个CircularBuffers类而不是两个管道类。
较于缓存所有数据和额外线程的方法更容易使用。
你可以更改缓存大小而不必受限于管道缓存区1K的固定缓存大小。
多线程情形:
CircularByteBuffer cbb = new CircularByteBuffer();
new Thread(
new Runnable(){
public void run(){
class1.putDataOnOutputStream(cbb.getOutputStream());
}
}
).start();
class2.processDataFromInputStream(cbb.getInputStream());
单线程情形
// buffer all data in a circular buffer of infinite size
CircularByteBuffer cbb = new CircularByteBuffer(CircularByteBuffer.INFINITE_SIZE);
class1.putDataOnOutputStream(cbb.getOutputStream());
class2.processDataFromInputStream(cbb.getInputStream());
以上就是小编今天的分享了,希望可以帮助到大家。
新来的实习生连InputSteam转String都不会,天天在学校混日子吧?
字符串被广泛应用于 Java 编程中,是程序经常处理的对象。以对象的方式处理字符串,使字符串更加方便灵活。Java 提供了 String 类创建和操作字符串,当我们从文件中读取数据时,常常需要将 InputStream 转换为 String,以便于下一步的处理。
鸭哥最近面了一位实习生,叫他给我说一下怎么把InputStream转换为String,这种常规的操作,他竟然都没有用过。因此,我准备结合工作经验,整理汇集出了 inputStream 到String 转换的十八般武艺,助大家闯荡 Java 江湖一臂之力。
1、使用 InputStreamReader 和 StringBuilder (JDK)
publicclassInputStream2String{publicstaticvoidmain(String[]args){try{InputStreaminputStream=newFileInputStream("E:/duckAndJava/IO/testFile.txt");//路径修改为本地文件所在的位置char[]buffer=newchar[1024];//根据需要的数组大小进行自定义StringBuilderout=newStringBuilder();Readerin=newInputStreamReader(inputStream,"UTF-8");for(intnumRead;(numRead=in.read(buffer,0,buffer.length))>0;){out.append(buffer,0,numRead);}StringmyString=out.toString();System.out.println("myString=" myString);}catch(IOExceptione){e.printStackTrace();}}
2、使用 inputStream.read() and StringBuilder
StringBuildersb=newStringBuilder();for(intch;(ch=inputStream.read())!=-1;){sb.append((char)ch);}StringmyString=sb.toString();
3、使用 ByteArrayOutputStream and inputStream.read
ByteArrayOutputStreamresult=newByteArrayOutputStream();byte[]buffer=newbyte[1024];for(intlength;(length=inputStream.read(buffer))!=-1;){result.write(buffer,0,length);}StringmyString=result.toString("UTF-8");
4、使用 BufferedInputStream 和 ByteArrayOutputStream
BufferedInputStreambis=newBufferedInputStream(inputStream);ByteArrayOutputStreambuf=newByteArrayOutputStream();for(intresult=bis.read();result!=-1;result=bis.read()){buf.write((byte)result);}StringmyString=buf.toString("UTF-8");
5、使用 BufferedReader
StringnewLine=System.getProperty("line.separator");BufferedReaderreader=newBufferedReader(newInputStreamReader(inputStream));StringBuilderresult=newStringBuilder();for(Stringline;(line=reader.readLine())!=null;){if(result.length()>0){result.append(newLine);}result.append(line);}StringmyString=result.toString();
6、使用 Stream API 或 parallel Stream API
StringmyString=newBufferedReader(newInputStreamReader(inputStream)).lines().collect(Collectors.joining("\n"));
或
StringmyString=newBufferedReader(newInputStreamReader(inputStream)).lines().parallel().collect(Collectors.joining("\n"));
7、使用 StringWriter 和IOUtils.copy (Apache Commons)
StringWriterwriter=newStringWriter();IOUtils.copy(inputStream,writer,"UTF-8");returnwriter.toString();
甚至可以直接这样用
Stringresult=IOUtils.toString(inputStream,StandardCharsets.UTF_8);
8、使用CharStreams (Google Guava)
Stringresult=CharStreams.toString(newInputStreamReader(inputStream,Charsets.UTF_8));
鸭哥同时利用jmh这款常用的性能测试工具对这些函数做了一下性能测试,关于jmh的使用可以翻鸭哥之前的文章哈。
分别按照字符串长度来进行测试。
当我们使用的是一个小字符串(length=175),得到的性能测试结果如下:
当我们使用的是一个长字符串(length=50100),得到的性能测试结果如下:
为了更加直观,我按照字符串的长度与相应函数消耗的平均时间,做了如下的表格:
更加直观的表格图,如下:
好了,鸭哥关于 InputStream 到String 转换的介绍就是这些,方法虽多,但是只要认真看懂了其中一个,再看其他的,就只是调用的类和方法不同罢了,思路都是一样的。
在实际运用中,还需要根据具体的环境,进行编码方式和换行符处理等的调整,选用最适合自己项目工程的处理方式。