Sending File to fast and receving too slow

What exception?

It has a socket closed exception if i close the socket or it will enter while loop and realise it can't read any thing and jump back and forth entering while loop and exception.

in what code?

Java

> can't read or write on both clientserver.

Can't read or write what?

I mean after file transferred is done. it can't resume the usual read and write of simple text.

Basically i have a server inclusive of Server (JFrame), Listener Thread(to listen for incoming client request) and Server Thread to proceed with i/o of message.

I have a client inclusive of a Client(Jframe) and a ClientThread for i/o of message.

When the client decide to send file, it will select from filechooser and open up filestream and send and close the stream. Then the server will open filechooser to save the file.

The problem lies when in the client i select file and send, immediately after sending it will jump to read input fail exception and while loop etc then the server side will go into this kind of state as well.

Ckgala at 2007-7-12 2:31:46 >

Client (JFrame Code)

private void SendFileActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_SendFileActionPerformed

// TODO add your handling code here:

JFileChooser fileChooser = new JFileChooser();

fileChooser.setFileSelectionMode(JFileChooser.FILES_ONLY);

int result = fileChooser.showDialog(this,"Send");

if (result == JFileChooser.CANCEL_OPTION)

return;

File fileName = fileChooser.getSelectedFile();

if (fileName == null || fileName.getName().equals("")){

JOptionPane.showMessageDialog(this, "Invalid File Name", "Invalid",

JOptionPane.ERROR_MESSAGE);

}else{

try{

// sendfile

output.writeUTF("FILE TRANSFER\n");

output.flush();

byte [] mybytearray = new byte [(int)fileName.length()];

System.out.println(mybytearray.length);

FileInputStream fis = new FileInputStream(fileName);

BufferedInputStream bis = new BufferedInputStream(fis);

bis.read(mybytearray,0,mybytearray.length);

int i;

for(i=0; i<mybytearray.length; i++){

System.out.println(mybytearray + " ");

}

setOutputFile(getSocket().getOutputStream());

getOutputFile().write(mybytearray,0,mybytearray.length);

displayMessage("Sending ... \n" + fileName.toString() + "\n");

output.writeUTF(fileName.toString());

System.out.println("Sending...");

getOutputFile().write(4444);

getOutputFile().flush();

getOutputFile().close();

//socket.close();

}catch (IOException io){

displayMessage("Error in File Transfer\n");

//System.exit(-1);

}

}

ClientThread Code (Exception Read Failed and Enter While Loop etc)

public void run() {

System.out.println("come to ClientThread");

try{

client.displayMessage("Inside the ClientThread\n");

client.input = new DataInputStream(client.getSocket().getInputStream());

client.output = new DataOutputStream(client.getSocket().getOutputStream());

client.displayMessage("Creating the input and output streams\n");

client.output.writeUTF("Connecion Established !\n");

} catch (IOException e) {

client.displayMessage("Failed to create input or output Stream\n");

//System.exit(-1);

}

while(true){

try{

System.out.println("Enter the while loop waiting");

//server.displayMessage("\nEnter the loop waiting\n");

String message = client.input.readUTF();

client.displayMessage(message);

System.out.println("Client read success at the try-catch loop @ thread");

} catch (IOException e) {

System.out.println("Read failed");

//System.exit(-1);

}

}

ServerThread(Receiving File and Read Failed and Enter While Loop)

public void run(){

System.out.println("come to serverthread");

String line;

input = null;

//output = null;

//server.displayMessage("Connection Established !\n");

try{

server.displayMessage("Inside the ServerThread\n");

input = new DataInputStream(welcomeSocket.getInputStream());

server.output = new DataOutputStream(welcomeSocket.getOutputStream());

server.displayMessage("Creating the input and output streams\n");

server.output.writeUTF("Connecion Established !\n");

//inputFile = client.getInputStream();

//server.displayMessage("\nStarted the inputFile Stream\n");

} catch (IOException e) {

server.displayMessage("Failed to create input or output Stream\n");

//System.exit(-1);

}

while(true){

try{

System.out.println("Enter the while loop waiting");

//server.displayMessage("\nEnter the loop waiting\n");

String message = input.readUTF();

System.out.println("Fine and smooth");

server.displayMessage(message);

System.out.println("Fine and smooth");

System.out.println("okay");

setInputFile(welcomeSocket.getInputStream());

if(message.equalsIgnoreCase("FILE TRANSFER\n")){

System.out.println("working");

while(inputFile.read() != 4444){

System.out.println("getting in");

int filesize=1024;

int bytesRead;

int current = 0;

byte [] mybytearray = new byte [filesize];

//server.saveFile();

FileOutputStream fos = new FileOutputStream("aaa.txt");

System.out.println("getting the data from File1");

BufferedOutputStream bos = new BufferedOutputStream(fos);

System.out.println("getting the data from File2");

inputFile.read(mybytearray,0,mybytearray.length);

int j;

for(j=0; j><mybytearray.length; j++){

System.out.println(mybytearray[j] + " ");

}

System.out.println("getting the data from File3");

bos.write(mybytearray,0,mybytearray.length);

BufferedInputStream bis = new BufferedInputStream(fis);

bis.read(mybytearray,0,mybytearray.length);

int i;

for(i=0; i><mybytearray.length; i++){

System.out.println(mybytearray + " ");

}

setOutputFile(getSocket().getOutputStream());

getOutputFile().write(mybytearray,0,mybytearray.length);

displayMessage("Sending ... \n" + fileName.toString() + "\n");

output.writeUTF(fileName.toString());

System.out.println("Sending...");

getOutputFile().flush();

output.writeUTF("ACCOMPLISHED\n");

getOutputFile().close();*/

System.out.println("File Transfer accomplished");

server.displayMessage("File Transfer accomplished\n");

server.output.writeUTF("File Transfer accomplished\n");

bos.close();

}

System.out.println("Server read success at the try-catch loop @ thread");

}else if (message.equalsIgnoreCase("DISCONNECT\n") == true){

server.displayMessage("Get into disconnecting stage\n");

input.close();

server.output.close();

server.displayMessage("Client Disconnected from Server\n");

server.ListenSocket();

}

} catch (IOException e) {

System.out.println("Server Read failed");

//System.exit(-1);

}

}>

Ckgala at 2007-7-12 2:31:46 >