Сервер считывает csv-файл и передает его на клиент для графического вывода

  //Сервер считывает csv-файл и передает его на клиент для графического вывода  
  //csv-файл содержит данные о таблице  
  //Формат данных соответствует RFC-4180  
  //Строка таблицы имеет вид: a,b,c CRLF  
  //Для работы с примером файл нужно создать самостоятельно  

package serverCSV;

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

public class NetServerCSV {

public static String readPage(String fileName, String strPage)
     throws UnsupportedEncodingException, FileNotFoundException, IOException
    {
            StringBuilder sb=new StringBuilder();
            String filename2 = fileName;
            String str="";
    InputStreamReader inputstream = null;
    try {
             inputstream = new InputStreamReader(new FileInputStream(fileName)
                        , "utf-8");
                BufferedReader in = new BufferedReader(inputstream);

                 while (((str = in.readLine()) != null)) {
                    strPage=strPage+""+str+"";
                 }

            } catch (IOException ex) {

            }
            return strPage;
    }
public static String writeToFile(String filename, String strPage ){
    PrintWriter writer = null;
try {


    writer = new PrintWriter(new OutputStreamWriter(
            new FileOutputStream(filename), "utf-8"));
           writer.write(strPage);
            writer.close();
        } catch (Exception ex) {
        }
return strPage;
}
    public static void main(String [] args) {

        ServerSocket serverSocket = null;
        Socket clientSocket;
        int portnumber = 1234;
        if (args.length >= 1){
            portnumber = Integer.parseInt(args[0]);
        }

        try {
            serverSocket = new ServerSocket(portnumber);
        } catch (IOException ie) {
            System.out.println("Сокет не открывается " + ie);
            System.exit(1);
        }
        System.out.println("Сокет создан " + serverSocket);
        while(true) {

            try {

                System.out.println("Ожидание соединения...");
                clientSocket = serverSocket.accept();

                System.out.println("Соединен...");
                String clientHost = clientSocket
                        .getInetAddress().getHostAddress();
                int clientPort = clientSocket.getPort();
                System.out.println("Клиентский хост = "
                        + clientHost + " порт = " + clientPort);
                InputStream clientIn = clientSocket.getInputStream();
                BufferedReader br = new BufferedReader(new
                        InputStreamReader(clientIn));
                OutputStream clientOut = clientSocket.getOutputStream();
                    PrintWriter pw = new PrintWriter(clientOut, true);
                String messageFromClient = br.readLine();
                System.out.println("Сообщение от клиента = "
                        + messageFromClient);
                String answerMessage ="";
                String strPage="";
if ((messageFromClient != null)
                        &&(messageFromClient.startsWith("write"))
                        ) {
      //Убираем заголовок сообщения  
    messageFromClient=messageFromClient.replace("write ", "");

   System.out.println("Сообщение от клиента = "+messageFromClient);
  messageFromClient= messageFromClient.replaceAll("CRLF", "CRLF"+"\n");
   writeToFile("/MyDir/csv.txt",
           messageFromClient);

                answerMessage =strPage;
                pw.println(answerMessage);

                }
 if ((messageFromClient != null)
                        &&(messageFromClient.startsWith("read"))
                        ) {
       //Чтение csv-файла  
     strPage=
     readPage("/MyDir/csv.txt"
                       , strPage) ;

                answerMessage =strPage;
                pw.println(answerMessage);

                }


            } catch (IOException ie) {
            }
        }
    }
}
13.02.2009