代碼如下：

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) throws IOException {
        //創(chuàng)建服務(wù)端，并指定端口號
        ServerSocket serverSocket = new ServerSocket(8888);

        //等待客戶端發(fā)送消息來獲取管道對象
        Socket socket = serverSocket.accept();
        //通過管道對象再來獲取到讀取流對象
        InputStream inputStream = socket.getInputStream();
        //再將低級流轉(zhuǎn)化為高級流
        DataInputStream dis = new DataInputStream(inputStream);
        String s = dis.readUTF();
        System.out.println(s);

        //關(guān)閉資源
        dis.close();
        socket.close();

    }
}

運行結(jié)果：

????????客戶端發(fā)送數(shù)據(jù)，服務(wù)端接收數(shù)據(jù)的代碼就實現(xiàn)了。

? ? ? ? 2.4?實現(xiàn) TCP 網(wǎng)絡(luò)通信（多發(fā)多收）

? ? ? ? 2.4.1 客戶端的開發(fā)

? ? ? ? 將以上客戶端的代碼輸出數(shù)據(jù)進行循環(huán)即可，每次輸出完數(shù)據(jù)之后，最好刷新一下。

代碼如下：

import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;

public class MyClient {
    //TCP 實現(xiàn)多發(fā)多收
    public static void main(String[] args) throws IOException {
        //創(chuàng)建管道對象
        Socket socket = new Socket("127.0.0.1",8888);
        //獲取寫數(shù)據(jù)流
        OutputStream os = socket.getOutputStream();
        //將低級流轉(zhuǎn)換為高級流
        DataOutputStream dos = new DataOutputStream(os);
        Scanner scanner = new Scanner(System.in);

        while (true) {
            String msg = scanner.nextLine();
            if ("exit".equals(msg)){
                System.out.println("退出成功!!!!");
                //關(guān)閉資源
                dos.close();
                socket.close();
                break;
            }
            //寫數(shù)據(jù)
            dos.writeUTF(msg);
            //刷新數(shù)據(jù)，將緩存的數(shù)據(jù)進行刷新
            dos.flush();
        }
    }
}

? ? ? ? 2.4.2 服務(wù)端的開發(fā)

? ? ? ? 將以上服務(wù)端的輸入數(shù)據(jù)的代碼加上循環(huán)即可，需要注意的是：在客戶端管道一端假設(shè)要斷開連接的時候，此時服務(wù)端還在連接著管道，這就會導致服務(wù)端一端會報異常，因此，需要對服務(wù)端輸入數(shù)據(jù)這一段代碼加上 try-catch 捕獲異常處理。

代碼如下：

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

public class MyServer {
    public static void main(String[] args) throws IOException {
        //創(chuàng)建服務(wù)端管道對象
        ServerSocket serverSocket = new ServerSocket(8888);

        //等待接收客戶端，創(chuàng)建管道對象
        Socket socket = serverSocket.accept();
        //創(chuàng)建完管道之后，就要創(chuàng)建字節(jié)流
        InputStream inputStream = socket.getInputStream();
        //再將低級流升級為高級流
        DataInputStream dis = new DataInputStream(inputStream);

        while (true) {
            try {
                //接著就可以讀數(shù)據(jù)了
                String s = dis.readUTF();
                System.out.println(s);
                //通過管道對象來獲取到發(fā)送消息的IP對象
                InetAddress clientInetAddress = socket.getInetAddress();
                //socket.getRemoteSocketAddress()
                //通過管道對象就可以獲取到端口號
                int clientPort = socket.getPort();
                //通過IP對象就可以獲取到IP地址
                String address = clientInetAddress.getHostAddress();
                //通過IP對象就可以獲取到IP名字
                String clientName = clientInetAddress.getHostName();
                System.out.println("端口號: "+ clientPort + " ，IP名字: " + clientName + " ，IP地址: " + address);
                System.out.println("=====================");
            } catch (IOException e) {
                System.out.println(" IP名字: " + socket.getInetAddress().getHostName() + " ，IP地址: " + socket.getInetAddress().getHostAddress() + " 離線了!!!");
                dis.close();
                socket.close();
                break;
            }
        }
    }
}

? ? ? ? 2.5 實現(xiàn) TCP 網(wǎng)絡(luò)通信（支持與多個客戶端通信）

? ? ? ? 實現(xiàn)思路：當前服務(wù)端只有主線程負責一個客戶端進行通信，那么實現(xiàn)服務(wù)端與多個客戶端實現(xiàn)通信需要實現(xiàn)多線程，在服務(wù)端中創(chuàng)建多個線程，每一個線程都對應(yīng)一個客戶端進行通信，而主線線程將將接收到的 Socket 對象通過構(gòu)造方法交給線程類來創(chuàng)建線程對象。至于客戶端沒有其他要改動的地方。

客戶端代碼如下：

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

public class Client {
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("127.0.0.1",9999);

        OutputStream os = socket.getOutputStream();
        DataOutputStream dos = new DataOutputStream(os);
        Scanner scanner = new Scanner(System.in);
        while (true){
            System.out.println("請輸入:");
            String str = scanner.nextLine();

            if ("exit".equals(str)){
                System.out.println("退出成功!!!!");
                dos.close();
                socket.close();
                break;
            }
            dos.writeUTF(str);
            //刷新數(shù)據(jù)
            dos.flush();
        }
    }
}

服務(wù)端代碼如下：

繼承 Thread 類：

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;

public class ThreadServer extends Thread{
    private final Socket socket ;
    public ThreadServer(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        try {
            InputStream inputStream = socket.getInputStream();
            DataInputStream dis = new DataInputStream(inputStream);
            while (true){
                try {
                    String str = dis.readUTF();
                    System.out.println(" 來自主機IP為:"+socket.getInetAddress().getHostAddress() +
                            " ，主機名為:" + socket.getInetAddress().getHostName() + ",端口號為:" + socket.getPort() + "發(fā)送的信息:"+str);
                } catch (IOException e) {
                    System.out.println(socket.getRemoteSocketAddress()+" 已下線了 !!!!");
                    dis.close();
                    socket.close();
                    break;
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

服務(wù)端代碼：

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(9999);

        while (true){
            Socket socket = serverSocket.accept();
            new ThreadServer(socket).start();
            System.out.println(socket.getRemoteSocketAddress() + " 已上線啦!!!!");
        }

    }
}

????????這就實現(xiàn)了服務(wù)端可以與多個客戶端進行通信了。

? ? ? ? 2.6 實現(xiàn) TCP 網(wǎng)絡(luò)通信（綜合案例：群聊）

? ? ? ? 比如說：微信群聊，客戶端一方發(fā)送了一條消息，不僅當前客戶端可以看到這條消息，其他在群內(nèi)的客戶端也可以看得見這條消息。

? ? ? ? 實現(xiàn)思路：想要實現(xiàn)客戶端發(fā)送的消息，群里的客戶端都可以看見，那么需要將客戶端發(fā)送的這條消息先要發(fā)送給服務(wù)端，再有服務(wù)端分發(fā)給其他群里的客戶端即可。

? ? ? ? 2.6.1 客戶端的開發(fā)

? ? ? ? 對于客戶端來說，既可以有發(fā)送消息的功能，也有接收消息的能力。那么就可以再創(chuàng)建一個線程來負責接收消息。

代碼如下：

繼承 Thread 類：

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;

public class ThreadClient extends Thread{
    private Socket socket;
    public ThreadClient(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        try {
            //開始接收數(shù)據(jù)
            InputStream inputStream = socket.getInputStream();
            DataInputStream dis = new DataInputStream(inputStream);
            while (true){
                try {
                    String str = dis.readUTF();
                    System.out.println( " : " + str);
                } catch (IOException e) {
                    System.out.println(" 本機已離線!!! ");
                    dis.close();
                    socket.close();
                    break;
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }

    }
}

客戶端代碼：

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

public class Client {
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("127.0.0.1",9999);
        //負責接收消息的線程
        new ThreadClient(socket).start();

        //主線程負責發(fā)送消息
        OutputStream os = socket.getOutputStream();
        DataOutputStream dos = new DataOutputStream(os);
        Scanner scanner = new Scanner(System.in);
        while (true){
            System.out.println("請輸入:");
            String str = scanner.nextLine();
            String sign = "exit";
            if (sign.equals(str)){
                System.out.println("退出成功!!!!");
                dos.close();
                socket.close();
                break;
            }
            dos.writeUTF(str);
            //刷新數(shù)據(jù)
            dos.flush();
        }
    }
}

? ? ? ? 2.6.2 服務(wù)端的開發(fā)

????????首先需要記住群內(nèi)都有哪些客戶端對象，可以用數(shù)組來接收這些客戶端對象，每一個客戶端上線的時候，將該客戶端對象放到數(shù)組容器中。再接收完某一個客戶端發(fā)送的消息后，再將其數(shù)組進行遍歷發(fā)送消息即可。

代碼如下：

繼承 Thread 類：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class ThreadServer extends Thread{
    private Socket socket ;
    public ThreadServer(Socket socket){
        this.socket = socket;
    }
    @Override
    public void run() {
        try {
            InputStream inputStream = socket.getInputStream();
            DataInputStream dis = new DataInputStream(inputStream);
            while (true){
                try {
                    String str = dis.readUTF();
                    System.out.println(" 來自主機IP為:"+socket.getInetAddress().getHostAddress() +
                            " ，主機名為:" + socket.getInetAddress().getHostName() + ",端口號為:" + socket.getPort() + "發(fā)送的信息:"+str);

                    //將消息發(fā)送到每個客戶端中
                    sendClient(str);
                } catch (IOException e) {
                    System.out.println(socket.getRemoteSocketAddress()+" 已下線了 !!!!");
                    Server.socketList.remove(socket);
                    dis.close();
                    socket.close();
                    break;
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private void sendClient(String str) throws IOException {
        for (Socket s : Server.socketList) {
            OutputStream os = s.getOutputStream();
            DataOutputStream dos = new DataOutputStream(os);
            dos.writeUTF(str);
            dos.flush();
        }
    }
}

服務(wù)端代碼：

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;

public class Server {
    public static List<Socket> socketList = new ArrayList<>();
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(9999);

        while (true){
            Socket socket = serverSocket.accept();
            new ThreadServer(socket).start();
            socketList.add(socket);
            System.out.println(socket.getRemoteSocketAddress() + " 已上線啦!!!!");
        }

    }
}

運行結(jié)果：

服務(wù)端的運行輸出的結(jié)果：

客戶端 1 運行輸出的結(jié)果：

客戶端 2 運行輸出的結(jié)果：

客戶端 3 運行輸出的結(jié)果：

? ? ? ? 這就是實現(xiàn)了群聊了，一共有三個客戶端，每個客戶端發(fā)消息給服務(wù)器，然后由服務(wù)器再分發(fā)送消息給三個客戶端。如果有某一個客戶端先斷開連接，輸出 "exit" 就可以斷開與服務(wù)器的連接，那么數(shù)組中就會刪除退出的 Socket 對象，其它客戶端不受影響。

? ? ? ? 由于 IP 的限制（IP 為內(nèi)網(wǎng)），不能讓其他的機器連接目前的機器，所以只能本機的程序連接本地的程序。如果 IP 為外網(wǎng)，就可以讓其他機器來連接了，實現(xiàn)跨主機通信了。

文章來源地址http://www.zghlxwxcb.cn/news/detail-858562.html

到了這里，關(guān)于JavaEE 初階篇-深入了解 UDP 通信與 TCP 通信（綜合案例：實現(xiàn) TCP 通信群聊）的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！