단일 연결 Tcp 서버 구현

  
  
  
  

   
   
   
   
import java.io.BufferedReader; 
   
   
   
   
import java.io.IOException; 
   
   
   
   
import java.io.InputStreamReader; 
   
   
   
   
import java.io.PrintWriter; 
   
   
   
   
import java.net.ServerSocket; 
   
   
   
   
import java.net.Socket; 
   
   
   
   
 
   
   
   
   
public class TcpServer { 
   
   
   
   
     
   
   
   
   
    private int port; 
   
   
   
   
    private ServerSocket serverSocket = null; 
   
   
   
   
    private Socket connected; 
   
   
   
   
    private PrintWriter outToClient; 
   
   
   
   
     
   
   
   
   
    private boolean bRunning = true; 
   
   
   
   
     
   
   
   
   
    public TcpServer(String strPort) { 
   
   
   
   
        this.port = Integer.parseInt(strPort); 
   
   
   
   
    } 
   
   
   
   
     
   
   
   
   
    public void start() { 
   
   
   
   
        System.out.println("TCPServer waiting for client on port: " + port); 
   
   
   
   
 
   
   
   
   
        try { 
   
   
   
   
            serverSocket = new ServerSocket(port); 
   
   
   
   
        } catch (IOException e) { 
   
   
   
   
            e.printStackTrace(); 
   
   
   
   
        } 
   
   
   
   
         
   
   
   
   
        ServerThread thread = new ServerThread(); 
   
   
   
   
        thread.start(); 
   
   
   
   
    } 
   
   
   
   
 
   
   
   
   
    public void stop() { 
   
   
   
   
        bRunning = false; 
   
   
   
   
         
   
   
   
   
        try { 
   
   
   
   
            connected.close(); 
   
   
   
   
        } catch (IOException e) { 
   
   
   
   
            e.printStackTrace(); 
   
   
   
   
        } 
   
   
   
   
    } 
   
   
   
   
     
   
   
   
   
    class ServerThread extends Thread { 
   
   
   
   
         
   
   
   
   
        public void run() { 
   
   
   
   
            try { 
   
   
   
   
                while (bRunning) { 
   
   
   
   
                    //TODO:  （ BindException）， serverSocket  
   
   
   
   
                    connected = serverSocket.accept(); 
   
   
   
   
                    System.out.println(" THE CLIENT" + " " 
   
   
   
   
                            + connected.getInetAddress() + ":" 
   
   
   
   
                            + connected.getPort() + " IS CONNECTED "); 
   
   
   
   
     
   
   
   
   
                    BufferedReader inFromClient = new BufferedReader( 
   
   
   
   
                            new InputStreamReader(connected.getInputStream(), "gb2312")); 
   
   
   
   
                     
   
   
   
   
                    //BufferedReader inFromClient = new BufferedReader( 
   
   
   
   
                    //      new InputStreamReader(connected.getInputStream())); 
   
   
   
   
                     
   
   
   
   
                    //InputStream is = connected.getInputStream(); 
   
   
   
   
                     
   
   
   
   
                    outToClient = new PrintWriter( 
   
   
   
   
                            connected.getOutputStream(), true); 
   
   
   
   
     
   
   
   
   
                    while (bRunning) { 
   
   
   
   
                        System.out.println("SEND(Type Q or q to Quit):"); 
   
   
   
   
                         
   
   
   
   
                        String fromclient = inFromClient.readLine(); 
   
   
   
   
                        System.out.println("received: " + fromclient); 
   
   
   
   
                                             
   
   
   
   
                        if (fromclient != null) { 
   
   
   
   
                            if (fromclient.equals("quit")) { 
   
   
   
   
                                TcpServer.this.stop(); 
   
   
   
   
                                break; 
   
   
   
   
                            } else { 
   
   
   
   
                                //  fromclient 
   
   
   
   
                            } 
   
   
   
   
                             
   
   
   
   
                        } 
   
   
   
   
                    } 
   
   
   
   
                } 
   
   
   
   
            } catch (IOException ex) { 
   
   
   
   
                ex.printStackTrace(); 
   
   
   
   
            } 
   
   
   
   
     
   
   
   
   
        } 
   
   
   
   
    } 
   
   
   
   
     
   
   
   
   
    public void send(String req) { 
   
   
   
   
        sendReply(req); 
   
   
   
   
    } 
   
   
   
   
 
   
   
   
   
    public void sendReply(String cmd) { 
   
   
   
   
        if (outToClient != null) { 
   
   
   
   
            outToClient.println(cmd); 
   
   
   
   
            outToClient.flush(); 
   
   
   
   
        } 
   
   
   
   
    } 
   
   
   
   
}