一對一通信：

服務器端：

public class ServerDemo {
    public static void main(String[] args) {
        ServerSocket serverSocket = null;
        Socket socket = null;
        BufferedReader reader = null;
        try {
            //設置服務端的端口號
            serverSocket = new ServerSocket(8081);
            //等待客戶端發送請求
            socket = serverSocket.accept();
            //接收客戶端發來的請求
            reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            boolean flag = true;
            while (flag){
                String read = reader.readLine();
                if("結束".equals(read)){
                    flag = false;
                }
                System.out.println("服務器接收消息："+read);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                reader.close();
                socket.close();
                serverSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}


客戶端：

public class ClientDemo {
    public static void main(String[] args) {
        Socket socket = null;
        //使用PrintWriter時，調用println、print的方法時，可以不再調用flush方法進行刷新
        PrintWriter writer = null;
        try {
            //客戶端socket指定服務器的地址和端口號
            socket = new Socket("127.0.0.1", 8081);
            //發送消息到服務器
            writer = new PrintWriter(new BufferedWriter(new OutputStreamWriter(
                    socket.getOutputStream())));
            for (int i = 0; i < 10; i++) {
                writer.println("發送消息 " + i);
            }
            writer.println("結束");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                System.out.println("close......");
                writer.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

多客戶端通信
 
服務端1：

public class ServerDouble {
    public static void main(String[] args) {
        ServerSocket serverSocket = null;
        Socket socket = null;
        try {
            //設置服務端的端口號
            serverSocket = new ServerSocket(8081);
            //等待客戶端發送請求
            System.out.println("正在等待連接……");
            while (true){
                socket = serverSocket.accept();
                System.out.println("連接上了："+socket.getPort());
                new ServerDoubleDemo(socket);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                socket.close();
                serverSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}
服務端2：

public class ServerDoubleDemo extends Thread {
    Socket socket = null;
    BufferedReader reader = null;
    public ServerDoubleDemo(Socket socket) {
        this.socket = socket;
        try {
            reader = new BufferedReader(new InputStreamReader( socket.getInputStream()));
            start();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    @Override
    public void run() {
        try {
            boolean flag = true;
            while (flag){
                String str = reader.readLine();
                if("結束".equals(str)){
                    flag = false;
                }
                System.out.println("接收消息："+str);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                reader.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

客戶端同上：

public class ClientDemo {
    public static void main(String[] args) {
        Socket socket = null;
        //使用PrintWriter時，調用println、print的方法時，可以不再調用flush方法進行刷新
        PrintWriter writer = null;
        try {
            //客戶端socket指定服務器的地址和端口號
            socket = new Socket("127.0.0.1", 8081);
            //發送消息到服務器
            writer = new PrintWriter(new BufferedWriter(new OutputStreamWriter(
                    socket.getOutputStream())));
            for (int i = 0; i < 10; i++) {
                writer.println("發送消息 " + i);
            }
            writer.println("結束");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                System.out.println("close......");
                writer.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

Java實現Socket通信