$ java Server.java
Bind Port 9090
New client connected.
Received Message --> Are you OK!

$ java Client.java
Are you OK!
Send Msg --> Are you OK!
Bye
$

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

class Server {
 
 public static void main(String[] args) {
  // ServerSocket 實(shí)現(xiàn)了 AutoCloseable 接口，所以支持 try-with-resource 語句
  // 創(chuàng)建一個(gè) ServerSocket，監(jiān)聽 9090 端口
  try(ServerSocket serv = new ServerSocket(9090)){
   System.out.printf("Bind Port %d\n", serv.getLocalPort());
   Socket socket = null;
   while(true){
    // 接收連接，如果沒有連接，accept() 方法會阻塞
    socket = serv.accept();
    
    // 獲取輸入流，并使用 BufferedInputStream 和 InputStreamReader 裝飾，方便以字符流的形式處理，方便一行行讀取內(nèi)容
    try(BufferedReader in = new BufferedReader( new InputStreamReader(socket.getInputStream()) )){
     String msg = null;
     char[] cbuf = new char[1024];
     int len = 0;
     while( (len = in.read(cbuf, 0, 1024)) != -1 ){ // 循環(huán)讀取輸入流中的內(nèi)容
      msg = new String(cbuf, 0, len);
      if("Bye".equals(msg)) { // 如果檢測到 "Bye" ，則跳出循環(huán)，不再讀取輸入流中內(nèi)容。
       break;
      }
      System.out.printf("Received Message --> %s \n", msg);
     }
    }catch (IOException e){
     e.printStackTrace();
    }
    
   }
   
  }catch (IOException e){
   e.printStackTrace();
  }
 }
}
2.3 客戶端程序代碼
import java.net.*;
import java.io.*;
import java.util.*;

class Client{
 
 public static void main(String[] args){
  
  try(Socket socket = new Socket("localhost", 9090)){
   BufferedWriter out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
   Scanner scanner = new Scanner(System.in);
   scanner.useDelimiter("\r\n");
   String msg = null;
   while( !(msg = scanner.next()).equals("Bye") ){
    System.out.printf("Send Msg --> %s \n", msg);
    out.write(msg);
    out.flush(); // 立即發(fā)送，否則需要積累到一定大小才一次性發(fā)送
   }
  }catch (IOException e){
   e.printStackTrace();
  }
  
 }
 
}

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

class Server {
 
 public static void main(String[] args){
  
  // 創(chuàng)建一個(gè) DatagramPacket 實(shí)例，用來接收客戶端發(fā)送過來的 UDP 數(shù)據(jù)報(bào)，這個(gè)實(shí)例可以重復(fù)利用。
  byte[] buf = new byte[8192]; // 緩存區(qū)
  int len = buf.length;  // 要利用的緩存區(qū)的大小
  DatagramPacket pac = new DatagramPacket(buf, len);
  
  // 創(chuàng)建服務(wù)端的套接字，需要指定綁定的端口號
  try(DatagramSocket serv = new DatagramSocket(9191)){
   
   while(true){
    serv.receive(pac); // 接收數(shù)據(jù)報(bào)。如果沒有數(shù)據(jù)報(bào)發(fā)送過來，會阻塞
    System.out.println("Message --> " + new String(pac.getData(), 0, pac.getLength()));
   }
   
  }catch (IOException e){
   e.printStackTrace();
  }
 }
 
}

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

class Client {
 public static void main(String[] args){
  
  // 創(chuàng)建一個(gè)客戶端的 UDP 套接字，不需要指定任何信息
  try(DatagramSocket client = new DatagramSocket()){
   
   // 創(chuàng)建一個(gè)數(shù)據(jù)報(bào)實(shí)例，數(shù)據(jù)和長度在發(fā)送之前都會重新設(shè)置，所以這里直接置為 0 即可。 
   // 由于是發(fā)送端，所以需要設(shè)置服務(wù)端的地址和端口
   DatagramPacket pac = new DatagramPacket(new byte[0], 0, InetAddress.getByName("localhost"), 9191);
   
   // 掃描控制臺輸入
   Scanner scanner = new Scanner(System.in);
   scanner.useDelimiter("\r\n");
   String msg = null;
   while( !(msg = scanner.next()).equals("Bye") ){
    // 設(shè)置要發(fā)送的數(shù)據(jù)
    pac.setData(msg.getBytes()); 
    // 發(fā)送數(shù)據(jù)報(bào)
    client.send(pac);
    System.out.println("Sent Message --> " + msg);
   }
  }catch (IOException e){
   e.printStackTrace();
  }
  
 }
}