Commit 61380317 authored by liqin's avatar liqin 💬

bug fixed

parent 1cf4544b
...@@ -9,7 +9,6 @@ import com.github.tobato.fastdfs.domain.proto.storage.DownloadByteArray; ...@@ -9,7 +9,6 @@ import com.github.tobato.fastdfs.domain.proto.storage.DownloadByteArray;
import com.github.tobato.fastdfs.service.FastFileStorageClient; import com.github.tobato.fastdfs.service.FastFileStorageClient;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.FilenameUtils; import org.apache.commons.io.FilenameUtils;
import org.csource.fastdfs.UploadCallback;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
...@@ -18,9 +17,7 @@ import javax.annotation.Resource; ...@@ -18,9 +17,7 @@ import javax.annotation.Resource;
import javax.imageio.ImageIO; import javax.imageio.ImageIO;
import java.awt.image.BufferedImage; import java.awt.image.BufferedImage;
import java.io.ByteArrayInputStream; import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import java.io.OutputStream;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
...@@ -104,22 +101,22 @@ public class FastDFSUtils { ...@@ -104,22 +101,22 @@ public class FastDFSUtils {
return new int[]{0, 0}; return new int[]{0, 0};
} }
private static class UploadFileSender implements UploadCallback { // private static class UploadFileSender implements UploadCallback {
private final InputStream is; // private final InputStream is;
//
public UploadFileSender(InputStream is) { // public UploadFileSender(InputStream is) {
this.is = is; // this.is = is;
} // }
//
@Override // @Override
public int send(OutputStream out) throws IOException { // public int send(OutputStream out) throws IOException {
byte[] b = new byte[1024]; // byte[] b = new byte[1024];
int readBytes; // int readBytes;
while ((readBytes = is.read(b)) != -1) { // while ((readBytes = is.read(b)) != -1) {
out.write(b, 0, readBytes); // out.write(b, 0, readBytes);
} // }
return 0; // return 0;
} // }
} // }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment