CODEWITHSUNDEEP
androidmultithreadingsockets
jane1012
jane1012

Reputation: 111

Socket, Read and Write threads

Using socket connection i need to have two threads, one for reading and one for writing. I found other questions about socket connections but I don't understand how i can use the same socket in two different threads.
I have to create a socket in a different thread from the UI thread, so i need to start a thread to create the socket. Where can i start the two threads?

Upvotes: 2

Views: 1694

Answers (2)

Sreejith B Naick
Sreejith B Naick

Reputation: 1188

Sample code structure to give you an idea.

public class SocketActivity extends Activity {
    Socket s;
    OutputStream dout;
    String ip = "127.0.0.1";
    int port = 8080;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    s = new Socket(ip, port);
                    new Thread(new ReaderRunnable(s));
                    new Thread(new WriteRunnable(s));
                } catch (IOException e) {
                    e.printStackTrace();
                    //Handle error state
                }
            }
        });
    }

    // You can put this class outside activity with public scope
    class ReaderRunnable implements Runnable {
        Socket socket;

        public ReaderRunnable(Socket socket) {
            this.socket = socket;
        }

        @Override
        public void run() {
            if (socket != null && socket.isConnected()) {
                try {
                    OutputStream out = new BufferedOutputStream(socket.getOutputStream());
                    //Do reader code
                } catch (IOException e) {
                    e.printStackTrace();
                }

            } else {
                //Handle error case
            }
        }
    }

    // You can put this class outside activity with public scope
    class WriteRunnable implements Runnable {
        Socket socket;

        public WriteRunnable(Socket socket) {
            this.socket = socket;
        }

        @Override
        public void run() {
            if (socket != null && socket.isConnected()) {
                try {
                    InputStream out = new BufferedInputStream(socket.getInputStream());
                    //Do writer code
                } catch (IOException e) {
                    e.printStackTrace();
                }
            } else {
                //Handle error case
            }
        }
    }
}

Upvotes: 2

TD092854
TD092854

Reputation: 111

Judging by your question this is client side. You don't have to use the socket itself in two different threads. For the read thread you use the InputStream of the socket, and for the write thread you use the OutputStream. That way you don't have to create a seperate thread just for the socket. Both the read and write threads can be started from the UI thread. For creating the threads i refer you to the Android Documentation Processes and Threads.

Upvotes: 0

Related Questions