import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
public class UdpEchoServer {
    //這個代碼是自己搭建一個回顯服務器
    private DatagramSocket socket = null;
    public UdpEchoServer(int port) throws SocketException {
        //指定了一個端口號  讓服務器來使用
        socket = new DatagramSocket(port);
    }
    public void start() throws IOException {
        //啓動服務器
        System.out.println("服務器啓動");
        while(true){
            //循環一次  就相當於處理一次請求
            //處理請求的過程  典型的服務器都是分成三個步驟
            //1.讀取請求並解析
              //DatagramPacket表示一個UDP數據報 此處傳入的字節數組,就保存UDP載荷部分
            DatagramPacket requestPacket = new DatagramPacket(new byte[4096],4096);
            socket.receive(requestPacket);
              //把讀取到的二進制數據,轉換成字符串 只是構造有效的部分
            String request = new String(requestPacket.getData(),0,requestPacket.getLength());
            //2.根據請求 計算響應(回顯服務器最關鍵的邏輯)
              //但是此處寫的是回顯服務器,這個環節相當於省略了
            String response = process(request);    //請求等於迴應
            //3.把響應返回給客户端
              //根據response構造DatagramPacket,發送客户端
            DatagramPacket responsePacket = new DatagramPacket(response.getBytes(),response.getBytes().length,
                    requestPacket.getSocketAddress());
              //此處還不能直接發送  UDP協議自身沒有保存對方信息(不知道發給誰  需要指定目的ip和目的端口)
            socket.send(responsePacket);
            //4.打印一個日誌
            System.out.printf("[%s:%d] req: %s,rep: %s\n",requestPacket.getAddress().toString(),
                    requestPacket.getPort(),request,response);
        }
    }
    //後續要寫別的服務器  只修改這個地方就好了
    private String process(String request){
        return request;
    }
}

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.util.Scanner;
public class UdpEchoClient {
    private DatagramSocket socket = null;
    //Udp本身不保存對端信息,就自己的代碼中保存一下
    private String serverIP;
    private int serverPort;
    //和服務器不同 此處的構造方法是要指定訪問的服務器的地址
    public UdpEchoClient(String serverIP,int serverPort) throws SocketException {
        this.serverIP=serverIP;
        this.serverPort=serverPort;
        socket = new DatagramSocket();//為什麼這裏不能指定端口號呢 那個肉湯的例子
    }
    public void start() throws IOException{
        Scanner scanner = new Scanner(System.in);
        while(true){
            //1.從控制枱讀取用户輸入的內容
            System.out.println("請輸入要發送的內容:");
            if(!scanner.hasNext()){
                break;  //這個if用來終止客户端
            }
            String request = scanner.next();
            //2.把請求發送給服務器 需要構造DatagramPacket對象
            //構造過程中  不光要構造載荷 還要設置服務器的IP和端口號
            DatagramPacket requestPacket = new DatagramPacket(request.getBytes(),request.getBytes().length,
                       InetAddress.getByName(serverIP),serverPort);//這裏的服務器的IP和端口號要包裝一下 要不datagram方法裏面沒有解析這個的
            //3.發送數據報
            socket.send(requestPacket);
            //4.接收服務器的響應
            DatagramPacket responsePacket = new DatagramPacket(new byte[4096] , 4096);
            socket.receive(responsePacket);
            //5.從服務器讀取的數據進行解析 打印出來
            String response = new String (responsePacket.getData(),0,responsePacket.getLength());
            System.out.println(response);
        }
    }
    public static void main(String[] args) throws IOException {
        UdpEchoClient client = new UdpEchoClient("47.108.28.88",9090);
        client.start();
    }
}

DatagramPacket responsePacket = new      DatagramPacket(response.getBytes(),response.getBytes().length,
        requestPacket.getSocketAddress());

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class TcpEchoServer {
    private ServerSocket serverSocket = null;
    //這裏和UDP服務器類似 也是在構造對象的時候 綁定端口號
    public TcpEchoServer(int port) throws IOException{
        serverSocket = new ServerSocket(port);
    }
    public void start() throws IOException {
        System.out.println("啓動服務器");
        while(true) {//服務器7*24運行
            //tcp來説  需要先處理客户端發來的連接
            // 通過讀寫clientSocket 和客户端進行通信
            //如果沒有客户端發起連接  此時accpet就會阻塞
            Socket clientSocket = serverSocket.accept();
            processConnection(clientSocket);//因為代碼邏輯比較複雜 單獨包裝成一個方法
        }
    }
    //處理一個客户端的連接
    //真實情況是可能要涉及到多個客户端的請求和響應
    private void processConnection(Socket clientSocket) throws IOException {
        System.out.printf("[%s:%d] 客户端上線！\n",clientSocket.getInetAddress(),clientSocket.getPort());
        //獲取客户端的輸入流和輸出流
        try(InputStream inputStream = clientSocket.getInputStream();
            OutputStream outputStream = clientSocket.getOutputStream()){
            //為什麼套層？ 在Java網絡編程中,i和o是字節流，它們直接操作原始字節（byte數組）
            //而Scanner和PrintWriter是字符流（Character Stream） 可以更加方便的處理文本數據（String）
            //如果是二進制傳輸的話（如文件 圖片） 直接使用i和o  如果是文本數據傳輸（Http 聊天消息）推薦使用Scanner PrintWriter
            //針對InputStream套了一層
            Scanner scanner = new Scanner(inputStream);//直接用scanner讀取請求裏面的內容
            //針對OutputStream套了一層
            PrintWriter writer = new PrintWriter(outputStream);
            //分成三個步驟
            while(true){
                //1.讀取請求並解析  可以直接read 也可以藉助
                if(!scanner.hasNext()){//這個表明條件如果是沒有下個數據可以了
                    //連接斷開了
                    //也打印一個日誌吧
                    System.out.printf("[%s:%d] 客户端上線！\n",clientSocket.getInetAddress(),clientSocket.getPort());
                    break;
                }
               String request = scanner.next();
                //2.根據請求計算響應
                String response = process(request);
                //3.返回響應到客户端
                //outputStream.write(response.getBytes());
                writer.println(response);
                //這裏省略了具體實現 直接讀取請求  然後返回原樣
                //打印日誌
                System.out.printf("[%s:%d] req: %s,rep: %s\n",clientSocket.getInetAddress(),clientSocket.getPort(),request,response);
            }
        }catch(IOException e){
            throw new RuntimeException(e)
        }
    }
    private String process(String request) {
        return request;//這裏還是講解的回顯服務器  所以requst和response相同
    }
}

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
public class TcpEchoClient {
    private Socket socket = null;
    public TcpEchoClient(String serverIp, int serverPort) throws IOException {
        //這裏直接就可以把字符串的IP地址和端口設置進來
        //127.0.0.1 這種字符串
        socket = new Socket(serverIp,serverPort);
    }
    public void start() throws IOException {
        Scanner scanner = new Scanner(System.in);
        try(InputStream inputStream = socket.getInputStream();
        OutputStream outputStream= socket.getOutputStream()){
            //為了使用方便  套殼操作
            Scanner scannerNet = new Scanner(inputStream);
            PrintWriter writer = new PrintWriter(outputStream);
            //從控制枱讀取請求，發送給服務器
            while(true){
                //1.從控制枱讀取用户輸入
                String request = scanner.next();
                //2.發送請求給服務器
                writer.println(request);
                //3.讀取服務器返回的響應
                String response = scannerNet.next();
                //4.打印到控制枱
                System.out.println(response);
            }
        }catch (IOException e){
            throw new RuntimeException(e);
        }
    }
    public static void main(String[] args) throws IOException {
        TcpEchoClient client = new TcpEchoClient("127.0.0.1",9090);
        client.start();
    }
}