Действительно ли это возможно к gzip, и загрузите эту строку на Amazon S3, никогда не будучи записанным в диск?
Я знаю, что это - вероятно, возможные Потоки использования, но я не был уверен правильный синтаксис.
Я хотел бы передать строку методу Сохранения и иметь его gzip строка и загрузить его на Amazon S3, никогда не будучи записанным в диск. Существующий метод неэффективно читает/пишет в промежуточный диск.
S3 PutObjectRequest имеет конструктора с входом InputStream как опция.
import java.io.*;
import java.util.zip.GZIPOutputStream;
import com.amazonaws.auth.PropertiesCredentials;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3Client;
import com.amazonaws.services.s3.model.PutObjectRequest;
public class FileStore {
public static void Save(String data) throws IOException
{
File file = File.createTempFile("filemaster-", ".htm");
file.deleteOnExit();
Writer writer = new OutputStreamWriter(new FileOutputStream(file));
writer.write(data);
writer.flush();
writer.close();
String zippedFilename = gzipFile(file.getAbsolutePath());
File zippedFile = new File(zippedFilename);
zippedFile.deleteOnExit();
AmazonS3 s3 = new AmazonS3Client(new PropertiesCredentials(
new FileInputStream("AwsCredentials.properties")));
String bucketName = "mybucket";
String key = "test/" + zippedFile.getName();
s3.putObject(new PutObjectRequest(bucketName, key, zippedFile));
}
public static String gzipFile(String filename) throws IOException
{
try {
// Create the GZIP output stream
String outFilename = filename + ".gz";
GZIPOutputStream out = new GZIPOutputStream(new FileOutputStream(outFilename));
// Open the input file
FileInputStream in = new FileInputStream(filename);
// Transfer bytes from the input file to the GZIP output stream
byte[] buf = new byte[1024];
int len;
while ((len = in.read(buf)) > 0) {
out.write(buf, 0, len);
}
in.close();
// Complete the GZIP file
out.finish();
out.close();
return outFilename;
} catch (IOException e) {
throw e;
}
}
}
2 ответа
Я бы использовал что-то вроде следующего:
ByteArrayOutputStream byteOut = new ByteArrayOutputStream();
GZipOuputStream gzipOut = new GZipOutputStream(byteOut);
// write your stuff
byte[] bites = byteOut.toByteArray();
//write the bites to the amazon stream
Вы записываете заархивированные значения в поток байтов, а затем, взяв значения байтов, вы можете записать их в другой поток. Вы также можете перенести поток на сайт Amazon (то есть поток вывода из HTTP-соединения или чего-то подобного) и избежать всего ByteArrayOutputStream.
Edit: Я заметил вашу последнюю фразу - бах. Вы можете взять созданные вами байты, создать с ними ByteArrayInputStream, а затем передать его как входной поток:
ByteArrayInputStream byteInStream = new ByteArrayInputStream(bites);
Он должен читать из входного потока в выходной поток, если я правильно понимаю, что вы описываете. В противном случае вы можете просто записать в выходной поток.
По сути, это то, что предлагал Аперкинс. Я не знаю интерфейса AS3, поэтому его предложение создать ByteArrayInputStream поверх массива байтов, вероятно, будет правильным решением.
import java.io.*;
import java.util.zip.GZIPOutputStream;
import com.amazonaws.auth.PropertiesCredentials;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3Client;
import com.amazonaws.services.s3.model.PutObjectRequest;
public class FileStore {
public static void Save(String data) throws IOException {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
Writer writer = new OutputStreamWriter(baos);
writer.write(data);
writer.flush();
writer.close();
byte[] zippedBytes = gzipFile(baos.toByteArray());
AmazonS3 s3 = new AmazonS3Client(new PropertiesCredentials(
new FileInputStream("AwsCredentials.properties")));
String bucketName = "mybucket";
String key = "test/" + zippedFile.getName();
s3.putObject(new PutObjectRequest(bucketName, key,
new ByteArrayInputStream(zippedBytes));
}
public static byte[] gzipFile(byte[] bytes) throws IOException {
try {
ByteArrayOutputStream baos = new ByteArrayOutputStream();
GZIPOutputStream out = new GZIPOutputStream(baos);
out.write(bytes, 0, bytes.length);
// Complete the GZIP file
out.finish();
out.close();
return baos.toByteArray();
} catch (IOException e) {
throw e;
}
}
}