我似乎有一个相对简单的问题:我确实有一些从 http 下载文件并执行解压缩操作的代码。这两个代码看起来很相似:
def downloadFile(url: URL, filename: String) {
var out: OutputStream = null
var in: InputStream = null
try {
val outPutFile = new File(filename)
if (outPutFile.exists())
{
outPutFile.delete()
}
val uc = url.openConnection()
val connection = uc.asInstanceOf[HttpURLConnection]
connection.setRequestMethod("GET")
in = connection.getInputStream()
out = new BufferedOutputStream(new FileOutputStream(filename))
copy(in, out)
} catch {
case e: Exception => println(e.printStackTrace())
}
out.close()
in.close()
}
def unzipFile(file: File): String = {
var out: OutputStream = null
val outputFileName = "uncompressed" + file.getName()
println("trying to acess " + file.getName() + file.getAbsoluteFile())
val in = new BZip2CompressorInputStream(new FileInputStream(file))
val outfile = new File(outputFileName)
if (outfile.exists()) {
outfile.delete()
}
out = new FileOutputStream(outputFileName)
copy(in, out)
in.close()
out.close()
return outputFileName
}
def copy(in: InputStream, out: OutputStream) {
val buffer: Array[Byte] = new Array[Byte](1024)
var sum: Int = 0
Iterator.continually(in.read(buffer)).takeWhile(_ != -1).foreach({ n => out.write(buffer, 0, n); (sum += buffer.length); println(sum + " written to output "); })
}
有没有办法将下载/解压缩方法重写为一种方法并分解构造函数以实现依赖注入行为?