Good evening. I'm trying to read all files from a directory on a machine (client) and send it to another machine (server) using Java Socket. However, at the end of the transfer I get the following error in the "server" application: java.io.StreamCorruptedException: invalid stream header: 00000000.
Client.java (Sends a file (serialized) at a time through).
public boolean listar (File file) throws FileNotFoundException, IOException {
FileInputStream fis;
if(file.isDirectory()) {
File info = new File(file.getPath());
File afile[] = info.listFiles();
if (afile.length != 0) {
int i = 0;
for (int j = afile.length; i < j; i++) {
File arquivos = afile[i];
if(arquivos.getName() != "") {
//System.out.println(file.getPath() + "\" + arquivos.getName());
long kbSize = arquivos.length() / 1024;
byte[] bFile = new byte[(int) arquivos.length()];
fis = new FileInputStream(arquivos);
fis.read(bFile);
fis.close();
arquivo = new Diretorio();
arquivo.setConteudo(bFile);
arquivo.setDataHoraUpload(new Date());
arquivo.setNome(arquivos.getName());
arquivo.setTamanhoKb(kbSize);
arquivo.setDiretorioDestino(diretorioServidor);
BufferedOutputStream bf = new BufferedOutputStream(conn.getOutputStream());
byte[] bytea = serializarArquivo();
bf.write(bytea);
bf.flush();
bf.close();
conn.close();
}
}
}
String[] subDiretorio = file.list();
if(subDiretorio != null) {
for (String dir : subDiretorio) {
listar(new File(file + File.separator + dir));
}
}
}
return true;
}
Server.java (Receives one file at a time and writes the file to the destination directory)
public class ServerStart implements Runnable
{
@Override
public void run()
{
try
{
//server = new ServerSocket(3587, 1, InetAddress.getLocalHost());
//conn = server.accept();
ServerSocket srvSocket = new ServerSocket(3000);
System.out.println("Aguardando envio de arquivo ...");
Socket socket = srvSocket.accept();
while (true)
{
try
{
byte[] objectAsByte = new byte[socket.getReceiveBufferSize()];
BufferedInputStream bf = new BufferedInputStream(socket.getInputStream());
bf.read(objectAsByte);
/*Diretorio diretorio = (Diretorio) getObjectFromByte(objectAsByte);
String dir = diretorio.getNome();
System.out.println(dir);*/
Diretorio diretorio = (Diretorio) getObjectFromByte(objectAsByte);
String dir = diretorio.getDiretorioDestino().endsWith("/") ? diretorio.getDiretorioDestino() + diretorio.getNome() : diretorio.getDiretorioDestino() + "\" + diretorio.getNome();
System.out.println("Escrevendo arquivo " + dir);
FileOutputStream fos = new FileOutputStream(dir);
fos.write(diretorio.getConteudo());
//fos.close();
Thread.sleep(200);
} catch (Exception ex) {
try {
Thread.sleep(3000);
System.exit(0);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
catch (Exception ex)
{
try
{
Thread.sleep(3000);
System.exit(0);
}catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
private static Object getObjectFromByte(byte[] objectAsByte) {
Object obj = null;
ByteArrayInputStream bis = null;
ObjectInputStream ois = null;
try {
bis = new ByteArrayInputStream(objectAsByte);
ois = new ObjectInputStream(bis);
obj = ois.readObject();
bis.close();
ois.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return obj;
}
The files contained in the client folder are sent to the server folder, however the above error is triggered and applications close.
class directory:
public class Diretorio implements Serializable {
private static final long seralVersionUID = 2L;
private String nome;
private byte[] conteudo;
private transient long tamanhoKb;
private transient Date dataHoraUpload;
private transient long data;
private transient String ipDestino;
private transient String ipLocal;
private transient String portaDestino;
private String diretorioDestino;
private transient String status;
private boolean pronto;
public synchronized String getNome() throws InterruptedException {
while(pronto) {
wait();
}
notify();
return nome;
}
public synchronized void setNome(String nome) throws InterruptedException {
while(pronto) {
wait();
}
this.nome = nome;
notify();
}
public synchronized byte[] getConteudo() throws InterruptedException {
while(pronto) {
wait();
}
notify();
return conteudo;
}
public synchronized String getStatus() throws InterruptedException {
while(pronto) {
wait();
}
notify();
return status;
}
public synchronized void setStatus(String status) throws InterruptedException {
while(pronto) {
wait();
}
this.status = status;
notify();
}
public synchronized void setConteudo(byte[] conteudo) throws InterruptedException {
while(pronto) {
wait();
}
this.conteudo = conteudo;
notify();
}
public synchronized long getTamanhoKb() throws InterruptedException {
while(pronto) {
wait();
}
notify();
return tamanhoKb;
}
public synchronized void setTamanhoKb(long tamanhoKb) throws InterruptedException {
while(pronto) {
wait();
}
this.tamanhoKb = tamanhoKb;
notify();
}
public synchronized long getData() throws InterruptedException {
while(pronto) {
wait();
}
notify();
return data;
}
public synchronized void setData(long data) throws InterruptedException {
while(pronto) {
wait();
}
this.data = data;
notify();
}
public synchronized Date getDataHoraUpload() throws InterruptedException {
while(pronto) {
wait();
}
notify();
return dataHoraUpload;
}
public synchronized void setDataHoraUpload(Date dataHoraUpload) throws InterruptedException {
while(pronto) {
wait();
}
this.dataHoraUpload = dataHoraUpload;
notify();
}
public synchronized String getIpDestino() throws InterruptedException {
while(pronto) {
wait();
}
notify();
return ipDestino;
}
public synchronized void setIpDestino(String ipDestino) throws InterruptedException {
while(pronto) {
wait();
}
this.ipDestino = ipDestino;
notify();
}
public synchronized String getIpLocal() throws InterruptedException {
while(pronto) {
wait();
}
notify();
return ipLocal;
}
public synchronized void setIpLocal(String ipDestino) throws InterruptedException {
while(pronto) {
wait();
}
this.ipLocal = ipLocal;
notify();
}
public synchronized String getPortaDestino() {
while(pronto) {
try {
wait();
} catch (InterruptedException ex) {
Logger.getLogger(Diretorio.class.getName()).log(Level.SEVERE, null, ex);
}
}
notify();
return portaDestino;
}
public synchronized void setPortaDestino(String portaDestino) throws InterruptedException {
while(pronto) {
wait();
}
this.portaDestino = portaDestino;
notify();
}
public synchronized String getDiretorioDestino() throws InterruptedException {
while(pronto) {
wait();
}
notify();
return diretorioDestino;
}
public synchronized void setDiretorioDestino(String diretorioDestino) throws InterruptedException {
while(pronto) {
wait();
}
this.diretorioDestino = diretorioDestino;
notify();
}
}