Socket server = null;
OutputStream outToServer = null;
DataOutputStream out = null;
InputStream inFromServer = null;
DataInputStream in = null;

if(msg != null){
try
{
    server = new Socket(serverIp, serverPort);
    server.setSoTimeout(1000 * 60 * timeoutInMins); //set to 30 mins
    outToServer = server.getOutputStream();
    out = new DataOutputStream(outToServer);
    out.writeUTF(msg);
    out.flush();

    // now wait for Server reply
    inFromServer = server.getInputStream();
    in = new DataInputStream(inFromServer);
    responseString = in.readUTF();
    // do something with response
}

ServerSocket serverSocket = null;
Socket client = null;
try{
serverSocket = new ServerSocket(port);
} catch (Exception e) {//log this}
try
{
  while(true)
  {
    client = serverSocket.accept();

    if(client.getRemoteSocketAddress() != null){
        try{
            ReqObject request = getRequest(client);
            // do processing. this may take upto 10-15 mins at max
            sendBackResponse(client, request);
        }

        // do remaining


private void sendBackResponse(Socket client, ReqObject result) throws IOException {
    DataOutputStream out = null;
    try{
        out = new DataOutputStream(client.getOutputStream());
        String outToClient = result.toString();
        out.writeUTF(outToClient);
        out.flush();
    } finally {
        try{out.close();}catch(IOException e){}
    }
}

private ReqObject getRequest(Socket client) throws IOException {
    DataInputStream in = null;
    in = new DataInputStream(client.getInputStream());
    String incoming = in.readUTF();
    return convertMessageToRequest(incoming);
}