EchoService

 
public class ClientMain {
    public static void main(String[] args) {
        ClientNode clientNode = new ClientNode();
        clientNode.startClient();
    }
}
 

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
 
public class ClientWriter implements Runnable {
    private Socket socket;
    private BufferedWriter bw;
    
    public ClientWriter(Socket socket) {
        this.socket = socket;
        try {
            this.bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    @Override
    public void run() {
        // TODO Auto-generated method stub
        BufferedReader input = new BufferedReader(new InputStreamReader(System.in));
        
        String readLine;
        try {
            while((readLine = input.readLine()) != null) {
                
                bw.write(readLine);
                bw.newLine();
                bw.flush();
                
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
 
}
 

 
public class EchoServerMain {
    
    public static void main(String[] args) {
        ServerAccepter server = new ServerAccepter();
        server.readyServer();
    }
}
 

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
 
public class ServerAccepter {
    private final int PORT = 12345;
    private ServerSocket serverSocket;
    private ExecutorService threadPool;
    
    public ServerAccepter() {
        try {
            serverSocket = new ServerSocket(PORT);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        this.threadPool = Executors.newFixedThreadPool(10);
        
    }
    
    public void readyServer() {
        try {
            while(true) {
 
                Socket socket = serverSocket.accept();
                this.threadPool.submit(new ServerNode(socket));
 
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        this.threadPool.shutdown();
    }
}
 

import java.net.Socket;
 
public class ServerNode implements Runnable {
    private Socket socket;
    
    public ServerNode(Socket socket) {
        this.socket = socket;
    }
    
    
    @Override
    public void run() {
        // TODO Auto-generated method stub
        Thread th = new Thread(new ServerReader(socket));
        th.start();
        try {
            th.join();
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    
}
 

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
public class ServerReader implements Runnable {
	private BufferedReader br;
	private BufferedWriter bw;
	
	public ServerReader(Socket socket) {
		try {
			this.br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			this.bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
	@Override
	public void run() {
		// TODO Auto-generated method stub
		String readLine;
		try {
			while((readLine = br.readLine()) != null) {
				
				System.out.println(readLine);
				bw.write(readLine);
				bw.newLine();
				bw.flush();
				
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	
}

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
 
public class ServerWriter implements Runnable {
    private BufferedReader br;
    
    public ServerWriter(Socket socket) {
        try {
            this.br =  new BufferedReader(new InputStreamReader( socket.getInputStream()));
            
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
 
    @Override
    public void run() {
        // TODO Auto-generated method stub
        String readLine;
        try {
            while((readLine = br.readLine()) != null) {
                
                System.out.println(readLine);
                
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    
}