socket编程

package MIME;
import java.io.*;

import java.net.*;

public class TalkClient {
    public static void main(String args[]) throws Exception {  
          Socket client = new Socket("127.0.0.1", 9093);
          client.setSoTimeout(3000);
          Writer writer = new OutputStreamWriter(client.getOutputStream());  
          writer.write("Hello aaa.");  
          InputStream inputStream = client.getInputStream();
//          BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
//          StringBuffer sb = new StringBuffer();
//          while(true){
//              sb.append(bufferedReader.readLine());
//              System.out.println(sb.toString());
//              if(-1==sb.indexOf("end")){
//                  break;
//              }
//          } 
//          System.out.println(sb.toString());
          writer.flush();
          writer.close();
       }  
}

package MINE;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.Writer;
import java.net.ServerSocket;
import java.net.Socket;

public class TalkServer {

    public static void main(String args[]) throws IOException {  
          ServerSocket server = new ServerSocket(9093);
          System.out.println("服务器监听启动！");
          while (true) {  
             Socket socket = server.accept();  
             new Thread(new Handler(socket)).start();  
          }  
       }  
    
    static class Handler implements Runnable{
        private Socket socket;
        public Handler(Socket socket) {
            this.socket = socket;
        }
        public void run() {
            try {
                dobiz();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        
        private void dobiz() throws IOException {
             InputStream inputStream = socket.getInputStream();
             InputStreamReader inputStreamReader = new InputStreamReader(inputStream);
             BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
              StringBuilder sb = new StringBuilder();
              while (true) {
                 String line = bufferedReader.readLine();
                 if(line==null){
                     break;
                 }
                 if(-1 != line.indexOf("end")){
                     break;
                 }
                 sb.append(line);
              }  
              System.out.println("from client: " + sb);  
              Writer writer = new OutputStreamWriter(socket.getOutputStream());  
              writer.write("Hello client.");
              writer.write("end
");
              writer.flush();
              writer.close(); 
              socket.close(); 
        }
        
        
    }

}