Transferring image via socket

[Dinesh Kumar Ramakrishnan]

Hi to all...!
I am trying to write a code for transfer a image file through socket the sever reads the image and stores in a byte array. and the problem is while writing a byte array to client the connection was reset in client side..



The Operations are:
1.Client Send the image File name to server
2.Server read the image and send the image size to the client
3.then client receive the image size and allocate the receiving Byte array in client side
4.then server start write the image byte array to the client then connection was reset by client

Here My Code
Sever File

import java.io.*;
import java.net.*;
public class sim_sock
{
	public sim_sock()
	{
		try {
    		ServerSocket ss=new ServerSocket(8006);
    		System.out.println ("Waiting for request");
    		Socket s=ss.accept();
    		System.out.println ("Connected With"+s.getInetAddress().toString());
    	ObjectInputStream	ois = new ObjectInputStream(s.getInputStream());
    ObjectOutputStream  oos = new ObjectOutputStream(s.getOutputStream());
    	
    	String req=(String)ois.readObject();
    	System.out.println (req);
    	
    	File f=new File(req);
    	FileInputStream fin=new FileInputStream(f);
    	
    	int c;
    	int sz=(int)f.length();
		byte b[]=new byte [sz];
		oos.writeObject(new Integer(sz));
		oos.flush();
	int	j=0;
  	          while ((c = fin.read()) != -1) {
            	
                b[j]=(byte)c;
                j++;
            }
            /*for (int i = 0; i<sz; i++)
            {
            	System.out.print(b[i]);
            }*/
    	
    	
    	
    	fin.close();
    	oos.flush();
    	oos.write(b,0,b.length);
    	oos.flush();
    	System.out.println ("Size "+sz);
    	System.out.println ("buf size"+ss.getReceiveBufferSize());
    	oos.writeObject(new String("Ok"));
         oos.flush();
         ss.close();
		}
		catch (Exception ex) {
			System.out.println ("Error"+ex);
		}
	}
	public static void main (String[] args) {
		sim_sock ob=new sim_sock();
}
}

Client Side

import java.net.*;
import java.io.*;

public class sim_clin
{
	 public static void main(String argv[]) {
      ObjectOutputStream oos = null;
      ObjectInputStream ois = null;
      Socket socket = null;
      java.util.Date date = null;
      try {
      
        socket = new Socket("localhost", 8006);
     
        oos = new ObjectOutputStream(socket.getOutputStream());
        ois = new ObjectInputStream(socket.getInputStream());
       
        oos.flush();
        oos.writeObject(new String("Desert.jpg"));
       
        oos.flush();
        oos.reset();
        int sz=(Integer )ois.readObject();
        System.out.println ("Receving "+(sz/1024)+" Bytes From Sever");
        
        byte b[]=new byte [sz];
        int bytesRead = ois.read(b, 0, b.length);
          for (int i = 0; i<sz; i++)
            {
            	System.out.print(b[i]);
            }
            FileOutputStream fos=new FileOutputStream(new File("demo.jpg"));
            fos.write(b,0,b.length);
        System.out.println ("From Server : "+ois.readObject());
        oos.close();
        ois.close();
      } catch(Exception e) {
        System.out.println(e.getMessage());
        e.printStackTrace();
      }
}
}

I am using ObjectOutputStream class for my socket..
Please help me to solve the problem the connection was reset by client everytime

[Stephan van Hulst]

Why, what problem are you having? What's not working? TellTheDetails please.

Welcome to CodeRanch!

[Dinesh Kumar Ramakrishnan]

Stephan van Hulst wrote:Why, what problem are you having? What's not working? TellTheDetails please.

Welcome to CodeRanch!

While Transmitting the size it was working well the client was able to receive the size and allocate the byte array..

when i was start transmit the image byte array the client was receive the half of the byre array and server shows the error Connection Was Reset...

[naved momin]

Dinesh here wrote:

Stephan van Hulst wrote:Why, what problem are you having? What's not working? TellTheDetails please.

Welcome to CodeRanch!

While Transmitting the size it was working well the client was able to receive the size and allocate the byte array..

when i was start transmit the image byte array the client was receive the half of the byre array and server shows the error Connection Was Reset...

You are making your way difficult, use my way of doing this

1. load an image using ImageIO.read(inputstream)
2. cast bufferedImage to Image
3. put Image in ImageIcon c'tor
4. use serialization to to send ImageIcon object via Socket

Client side
1. readObject will get you the imageIcon
2. play with it

----------------------------------------------------------------------------------------------------------------------
solution to your way of doing it , ....use objectOutputStream.reset() after flushing your data (give this a try and see if this works )

[Dinesh Kumar Ramakrishnan]

No ObjetOutputStream.reset() is not working

it shows an exception
Errorjava.net.SocketException: Connection reset by peer: socket write error

[naved momin]

That Exception you got because you are trying to reset the stream before all the data has been written to the stream, so what you have to do is after you do

 objectOutputStream.flush();

do

Thread.join();

and then reset the stream , it will work ....

[Dinesh Kumar Ramakrishnan]

naved momin wrote:That Exception you got because you are trying to reset the stream before all the data has been written to the stream, so what you have to do is after you do

 objectOutputStream.flush();

do

Thread.join();

and then reset the stream , it will work ....

i change my server code like your advice but is not working...!

oos.write(byte array,0,length);
	Thread t=Thread.currentThread();
	t.join();
	oos.flush();

The image array half of the content will received correctly. But reaming 75% of the image data is only zeros...! please Help ME

[naved momin]

you are doing it all wrong , i told you first write using

oos.write(whatever);

2nd flush the stream like

 oos.flush();

3rd join for joining use only this code

Thread.join();

there is no need to get instance of current Thread , and finally 4th reset the stream

oos.reset();

[Dinesh Kumar Ramakrishnan]

It Shows an error.when i was write code like this

        oos.write(byte array);
    	oos.flush();
	Thread.join();
    	oos.reset();

Error:
sim_sock.java:46: non-static method join() cannot be referenced from a static context
Thread.join();
^

I think it needs instance..!(But it will not work)

[naved momin]

can you post your code ..i wanted to see what actually you are doing now ....

[Dinesh Kumar Ramakrishnan]

naved momin wrote:can you post your code ..i wanted to see what actually you are doing now ....

Here My Code
Server

import java.io.*;
import java.net.*;

public class sim_sock
{
	public sim_sock()
	{
		try {
    		ServerSocket ss=new ServerSocket(8006);
    		System.out.println ("Waiting for request");
    		Socket s=ss.accept();
    		System.out.println ("Connected With"+s.getInetAddress().toString());
    	ObjectInputStream	ois = new ObjectInputStream(s.getInputStream());
    ObjectOutputStream  oos = new ObjectOutputStream(s.getOutputStream());
    	 //oos.writeObject(new java.util.Date());
    	// oos.writeObject(new String("Hello"));
    	String req=(String)ois.readObject();
    	System.out.println (req);
    	
    	File f=new File(req);
    	FileInputStream fin=new FileInputStream(f);
    	
    	int c;
    	int sz=(int)f.length();
     
		byte b[]=new byte [sz];
		oos.writeObject(new Integer(sz));
		oos.flush();
	int	j=0;
  	          while ((c = fin.read()) != -1) {
            	
                b[j]=(byte)c;
                j++;
            }
            for (int i = 0; i<sz; i++)
            {
            	System.out.print(b[i]);
            }
    	
    	
    	
    	fin.close();
    	oos.flush();
    	oos.write(b);
    	oos.flush();
    	//Thread.join();
    	
    	System.out.println ("Size "+sz);
    	System.out.println ("buf size"+ss.getReceiveBufferSize());
    
  
         ss.close();
		}
		catch (Exception ex) {
			System.out.println ("Error"+ex);
		}
	}
	public static void main (String[] args) {
		sim_sock ob=new sim_sock();
}
}

Client

import java.net.*;
import java.io.*;

public class sim_clin
{
	 public static void main(String argv[]) {
      ObjectOutputStream oos = null;
      ObjectInputStream ois = null;
      Socket socket = null;
      
      try {
        
        socket = new Socket("localhost", 8006);
        
      socket.setReceiveBufferSize(10000);
        oos = new ObjectOutputStream(socket.getOutputStream());
        ois = new ObjectInputStream(socket.getInputStream());
        System.out.println ("Time"+socket.getSoTimeout());
        oos.flush();
        oos.writeObject(new String("pi.png"));
       
        oos.flush();
       
        int sz=(Integer )ois.readObject();
        System.out.println ("Receving "+sz+" Bytes From Sever");
       oos.flush();
        byte b[]=new byte [sz];
      ois.read(b);
         
           
            FileOutputStream fos=new FileOutputStream(new File("demo.png"));
            fos.write(b,0,b.length);
            for (int i = 0; i<sz; i++)
            {
            	System.out.print(b[i]);
            }
     
        oos.close();
        ois.close();
      } catch(Exception e) {
        System.out.println(e.getMessage());
        e.printStackTrace();
      }
}
}

[naved momin]

Your way of doing is completely wrong( sorry to say ) , what i briefy understand is that you are reading a file and sending it to server ?
if thats your requirement then do this instead of what you are currently doing

understand the steps before coding , it will help
server

follow this pseudo code

after accepting the connection
read Object and cast it to Byte
use ImageIcon to construct a new image using new ImageIcon(byte[] byte) c'tor
display the new image in frame or do whatever ....


client

create new FileInputStream fis
get the bytes of data from the above stream
and write it using OOS.write(byte[] data)
remember to do flush OOS.flush();