import java.io.BufferedReader;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.InetAddress;

import java.net.Socket;

public class BufferedSocketClient {

  public static void main(String args[]) throws Exception {

    Socket socket1;

    int portNumber = 1777;

    String str = "initialize";

    socket1 = new Socket(InetAddress.getLocalHost(), portNumber);

    BufferedReader br = new BufferedReader(new InputStreamReader(socket1.getInputStream()));

    PrintWriter pw = new PrintWriter(socket1.getOutputStream(), true);

    pw.println(str);

    while ((str = br.readLine()) != null) {

      System.out.println(str);

      pw.println("bye");

      if (str.equals("bye"))

        break;

    }

    br.close();

    pw.close();

    socket1.close();

  }

}

///

import java.io.BufferedReader;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.ServerSocket;

import java.net.Socket;

public class BufferedSocketServer {

  public static void main(String args[]) throws Exception {

    int cTosPortNumber = 1777;

    String str;

    ServerSocket servSocket = new ServerSocket(cTosPortNumber);

    System.out.println("Waiting for a connection on " + cTosPortNumber);

    Socket fromClientSocket = servSocket.accept();

    PrintWriter pw = new PrintWriter(fromClientSocket.getOutputStream(), true);

    BufferedReader br = new BufferedReader(new InputStreamReader(fromClientSocket.getInputStream()));

    while ((str = br.readLine()) != null) {

      System.out.println("The message: " + str);

      if (str.equals("bye")) {

        pw.println("bye");

        break;

      } else {

        str = "Server returns " + str;

        pw.println(str);

      }

    }

    pw.close();

    br.close();

    fromClientSocket.close();

  }

}