剛剛在java中寫了一個客戶端 - 服務器程序。 現在,所有的程序做:客戶端發送截圖,comprass圖像,將其發送到服務器,該服務器在一個目錄保存圖像。只有圖像的一部分被保存而不是整個圖像,我該怎麼修復?
出於某種原因,由服務器保存的圖像是局部的,這意味着並非所有的屏幕截圖保存在服務器端。
在客戶端側的屏幕截圖:
相關的代碼:
private static void screenshot(){
try {
BufferedImage image = new Robot().createScreenCapture(new Rectangle(Toolkit.getDefaultToolkit().getScreenSize()));
File compressedImageFile = new File("C:\\Gilad\\Screenshots\\compress.jpg");
OutputStream os = new FileOutputStream(compressedImageFile);
Iterator<ImageWriter> writers = ImageIO.getImageWritersByFormatName("jpg");
ImageWriter writer = (ImageWriter) writers.next();
ImageOutputStream ios = ImageIO.createImageOutputStream(os);
writer.setOutput(ios);
ImageWriteParam param = writer.getDefaultWriteParam();
param.setCompressionMode(ImageWriteParam.MODE_EXPLICIT);
param.setCompressionQuality(1f);
writer.write(null, new IIOImage(image, null, null), param);
os.close();
ios.close();
writer.dispose();
Path path = Paths.get("C:\\Images\\Screenshots\\compress.jpg");
byte[] compressedImage = Files.readAllBytes(path);
serverThread.sendOutput(compressedImage); //serverThread is object of type ThreadForServer
} catch (HeadlessException | AWTException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
從ThreadForServer類發送圖像:
outputThread = new Thread(new Runnable(){
@Override
public void run() {
byte[] imageAr;
//ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
int len;
byte[] lenAr;
try{
while(true){
if(outputs.isEmpty()) Thread.sleep(10);
else{
imageAr = outputs.remove();
len = imageAr.length;
System.out.println("length: " + len);
lenAr = ByteBuffer.allocate(4).putInt(len).array();
System.out.println("length array: " + lenAr + " " + System.currentTimeMillis());
socketOutput.write(lenAr);
System.out.println("Image array: " + imageAr + " " + System.currentTimeMillis());
socketOutput.write(imageAr);
socketOutput.flush();
System.out.println("Flushed: " + System.currentTimeMillis());
}
}
}catch(InterruptedException | IOException e){ e.printStackTrace(); }
}
});
InputThread在服務器端:
inputThread = new Thread(new Runnable(){
@Override
public void run() {
byte[] imageAr;
byte[] lenAr = new byte[4];
int len;
try{
while(running){
System.out.println("Server input thread: " + System.currentTimeMillis());
socketInput.read(lenAr);
len = ByteBuffer.wrap(lenAr).asIntBuffer().get();
System.out.println("length: " + len);
imageAr = new byte[len];
socketInput.read(imageAr);
inputs.add(imageAr);
break;
}
}catch(IOException e){
e.printStackTrace();
}
}
});
服務器保存圖像:
private static void startClientThreadHandler(ThreadForClient clientThread){
new Thread(new Runnable(){
@Override
public void run() {
try{
while(true){
byte[] image = clientThread.getInput();
if(image == null){
Thread.sleep(10);
continue;
}
ByteArrayInputStream in = new ByteArrayInputStream(image);
BufferedImage buffImage = ImageIO.read(in);
ImageIO.write(buffImage, "jpg", new File(IMAGE_DESTINATION + "\\image" + counter));
++counter;
}
}catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}).start();;
}
提前感謝!
謝謝!固定 – MuffinsDev
@MuffinsDev,如果這確實是您的問題,那麼請考慮將此標記爲正確答案。 –