Java Socket實現基於TCP和UDP多線程通訊

時間  2019-11-13
標籤 java socket 實現 基於 tcp udp 多線程 通訊 欄目 Java 简体版
原文   原文鏈接

一.經過Socket實現TCP編程java

1.1 TCP編程編程

　　TCP協議是面向鏈接，可靠的，有序的，以字節流的方式發送數據。基於TCP協議實現網絡通訊的類有客戶端的Socket類和服務器端的ServerSocket類。數組

1.2 服務器端套路緩存

　　1.建立ServerSocket對象，綁定監聽端口。服務器

　　2.經過accept（）方法監聽客戶端請求。網絡

　　3.鏈接創建後，經過輸入流讀取客戶端發送的請求信息。多線程

　　4.經過輸出流向客戶端發送響應信息。socket

　　5.關閉響應的資源。ide

1.3 客戶端套路this

　　1.建立Socket對象，指明須要鏈接的服務器的地址和端口號。

　　2.鏈接創建後，經過輸出流向服務器發送請求信息。

　　3.經過輸入流獲取服務器響應的信息。

　　4.關閉相應資源。

1.4 多線程實現服務器與多客戶端之間通訊步驟

　　1.服務器端建立ServerSocket，循環調用accept（）等待客戶端鏈接。

　　2. 客戶端建立一個socket並請求和服務器端鏈接。

　　3.服務器端接受客戶端請求，建立socket與該客戶創建專線鏈接。

　　4.創建鏈接的兩個socket在一個單獨的線程上對話。

　　5.服務器端繼續等待新的鏈接。

1.5 建立處理線程類ServerThread

　　這裏選擇實現runnable接口而不是繼承Thread是由於一個類只能繼承一個父類，當我須要繼承其餘類的時，父類就就很差處理了。

　　

package com.tzzh;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

public class ServerThread implements Runnable{

    Socket socket = null;//和本線程相關的Socket
        
    public ServerThread(Socket socket) {
    this.socket = socket;
}

    @Override
    public void run() {
        InputStream is = null;
        InputStreamReader isr = null;
        BufferedReader br = null;
        OutputStream os = null;
        PrintWriter pw = null;
        try {
            //與客戶端創建通訊，獲取輸入流，讀取取客戶端提供的信息
            is = socket.getInputStream();
            isr = new InputStreamReader(is,"GBK");
            br = new BufferedReader(isr);
            String data = null;
            while((data=br.readLine()) != null){//循環讀取客戶端的信息
                System.out.println("我是服務器，客戶端提交信息爲："+data);
            }
            socket.shutdownInput();//關閉輸入流
            
            //獲取輸出流，響應客戶端的請求
            os = socket.getOutputStream();
            pw = new PrintWriter(os);
            pw.write("服務器端響應成功！");
            pw.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            //關閉資源即相關socket
            try {
                if(pw!=null)
                    pw.close();
                if(os!=null)
                    os.close();
                if(br!=null)
                    br.close();
                if(isr!=null)
                    isr.close();
                if(is!=null)
                    is.close();
                if(socket!=null)
                    socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            
        }
        
    }

}

 

1.6 建立服務器端類

　　使用while以達到能夠循環偵聽不一樣客戶端的鏈接請求。由於這是一個死循環，因此不用關閉也沒有機會去關閉serverSocket。設置count值，用於記錄服務器端被鏈接過的次數並顯示客戶端所在ip值。若是線程處理類是繼承Thread類，那麼建立新線程代碼能夠改成ServerThread serverThread = new ServerThread(socket);serverThread.start();

package com.tzzh;

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

public class Server {
    public static void main(String[] args) {
        try {
            //建立一個服務器端的Socket，即ServerSocket,綁定須要監聽的端口
            ServerSocket serverSocket = new ServerSocket(8888);
            Socket socket = null;
            //記錄鏈接過服務器的客戶端數量
            int count = 0;
            System.out.println("***服務器即將啓動，等待客戶端的鏈接***");
            while(true){//循環偵聽新的客戶端的鏈接
                //調用accept（）方法偵聽，等待客戶端的鏈接以獲取Socket實例
                socket = serverSocket.accept();
                //建立新線程
                Thread thread = new Thread(new ServerThread(socket));
                thread.start();

                count++;
                System.out.println("服務器端被鏈接過的次數："+count);
                InetAddress address = socket.getInetAddress();
                System.out.println("當前客戶端的IP爲："+address.getHostAddress());
            }            
            //serverSocket.close();一直循環監聽，不用關閉鏈接
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

 1.7 建立客戶端類

　　在後面的關閉資源中，我把輸入輸出相關的流關閉註釋了，是由於對於同一個Socket，關閉socket的時候也會把輸入輸出流關閉，直接關閉socket就行，固然保留也是能夠的。

package com.tzzh;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {
    public static void main(String[] args) {
        try {
            //建立客戶端Socket，指定服務器地址和端口
            Socket socket = new Socket("localhost", 8888);
            //創建鏈接後，獲取輸出流，向服務器端發送信息
            OutputStream os = socket.getOutputStream();
            //輸出流包裝爲打印流
            PrintWriter pw = new PrintWriter(os);
            //向服務器端發送信息
            pw.write("用戶名：zzh;密碼：123");//寫入內存緩衝區
            pw.flush();//刷新緩存，向服務器端輸出信息
            socket.shutdownOutput();//關閉輸出流
            
            //獲取輸入流，接收服務器端響應信息
            InputStream is = socket.getInputStream();
            BufferedReader br = new BufferedReader(new InputStreamReader(is, "GBK"));
            String data = null;
            while((data=br.readLine())!= null){
                System.out.println("我是客戶端，服務器端提交信息爲："+data);
            }
            
            //關閉其餘資源
//            br.close();
//            is.close();
//            pw.close();
//            os.close();
            socket.close();
        
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

 

1.8 先運行服務器端，在運行客戶端

 

此時在看服務器控制檯：服務器端一直在循環偵聽客戶端的鏈接

 

 1.9 進行第二個客戶端的鏈接

　　修改相應信息將用戶名zzh改成admin。運行客戶端，打開服務端控制檯

　　

輸出客戶端的ip都爲127.0.0.1，是由於服務器和客戶端都是本機，在真實的環境中會顯示客戶端的ip地址信息。

 

二. 經過Socket實現UDP編程

2.1 UDP編程

　　UDP協議又叫用戶數據報協議，是無鏈接，不可靠的，無序的。特色是傳輸速度相對要快，UDP協議以數據報做爲數據傳輸的載體。當進行數據傳輸時，首先須要將要傳輸的數據定義成數據報（Datagram），在數據報中指明數據所要達到的Socket（主機地址和端口號），而後再將數據報發送出去。相關操做類有：DatagramPacket數據報包，DatagramSocket進行端到端通訊的類。

2.2 服務器端實現套路

　　1.建立DatagramSocket，指定端口號。2.建立DatagramPacket。3.接收客戶端發送的數據信息。4.讀取數據。

2.3 客戶端實現套路

　　1.定義發送信息，好比發送地址，端口號和內容。2. 建立DatagramPacket，包含將要發送的信息。3.建立DatagramSocket。4.發送數據。

2.4 多線程實現服務器與多客戶端之間通訊步驟

　　1.服務器端建立DatagramSocket的實例socket，循環調用receive（）方法，此方法在接收到數據報以前會一直阻塞。

　　2.客戶端建立DatagramSocket，將含有地址，端口號和內容的數據報包發送出去。

　　3. 服務器端收到數據報包packet，經過DatagramSocket和packet與客戶端創建一個線程

　　4. 服務器端繼續等待新的數據報包。

　　5. 發送方的DatagramPacket構造方法傳遞四個參數包含數據內容，數據大小，地址和端口號。接收方的DatagramPacket構造方法有兩個參數接收數據和數據大小。

2.5 建立服務器線程處理類UDPThread

　　注意，DatagramSocket的實例socket不能關閉，會出現SocketException。讀取數據用到的new String(packet.getData(), 0, packet.getLength())，參數表示數據報中的字節數組，位置和長度。

package com.uzzh;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class UDPThread implements Runnable{
    
    DatagramSocket socket = null;
    DatagramPacket packet = null;
    

    public UDPThread(DatagramSocket socket,DatagramPacket packet) {
        this.socket = socket;
        this.packet = packet;
    }

    @Override
    public void run() {
        String info = null;
        InetAddress address = null;
        int port = 8800;
        byte[] data2 = null;
        DatagramPacket packet2 = null;
        try {
            info = new String(packet.getData(), 0, packet.getLength());
            System.out.println("我是服務器，客戶端說："+info);
            
            address = packet.getAddress();
            port = packet.getPort();
            data2 = "我在響應你！".getBytes();
            packet2 = new DatagramPacket(data2, data2.length, address, port);
            socket.send(packet2);
        } catch (IOException e) {
            e.printStackTrace();
        }
        //socket.close();不能關閉         
    }

}

 

 

2.6 建立服務器端類

package com.uzzh;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class UDPServer {
    public static void main(String[] args) throws IOException {
        DatagramSocket socket = new DatagramSocket(8800);
        DatagramPacket packet = null;
        byte[] data = null;
        int count = 0;
        System.out.println("***服務器端啓動，等待發送數據***");
        while(true){
            data = new byte[1024];//建立字節數組，指定接收的數據包的大小
            packet = new DatagramPacket(data, data.length);
            socket.receive(packet);//此方法在接收到數據報以前會一直阻塞
            Thread thread = new Thread(new UDPThread(socket, packet));
            thread.start();
            count++;
            System.out.println("服務器端被鏈接過的次數："+count);
            InetAddress address = packet.getAddress();
            System.out.println("當前客戶端的IP爲："+address.getHostAddress());
            
        }
        
    }
}

以前我將new DatagramSocket放入了while循環中，報了java.net.BindException: Address already in use: Cannot bind，才知道不能在while中連續建立新的DatagramSocket對象。

2.7 建立客戶端類

package com.uzzh;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class UDPClient {
    public static void main(String[] args) throws IOException {
        //定義服務器的地址，端口號，數據
        InetAddress address = InetAddress.getByName("localhost");
        int port = 8800;
        byte[] data = "用戶名：admin;密碼：123".getBytes();//將字符串轉換爲字節數組
        //建立數據報
        DatagramPacket packet = new DatagramPacket(data, data.length, address, port);
        //建立DatagramSocket，實現數據發送和接收
        DatagramSocket socket = new DatagramSocket();
        //向服務器端發送數據報
        socket.send(packet);
        
        //接收服務器響應數據
        byte[] data2 = new byte[1024];
        DatagramPacket packet2 = new DatagramPacket(data2, data2.length);
        socket.receive(packet2);
        String info = new String(data2, 0, packet2.getLength());
        System.out.println("我是客戶端，服務器說："+info);
        socket.close();
    }
}

 

2.8 先運行服務器端，在運行客戶端

2.9 修改客戶端信息，再次運行客戶端

 

 服務器控制檯：服務器端一直在循環等待接收客戶端的數據。

 

三. 總結

　　這兩個例子只是簡單的實現了基於TCP和UDP的socket編程，其中像多線程的優先級等都暫且沒作考慮，不過依然要強調一下，服務器與多個客戶端進行通訊，由於是死循環，不設置多線程優先級，可能會致使運行時速度很是慢，優先級的範圍1-10，默認爲5，咱們能夠適當下降線程的優先級，好比thread.setPriority(4);

　　對於同一個socket，若是關閉了輸出流好比（pw.close()），則與該輸出流關聯的socket也會關閉，因此通常不須要關閉輸出流，當關閉socket的時候，輸出流也會關閉，直接關閉socket就行。

　　在使用TCP通訊傳輸信息時，更可能是使用對象的形式來傳輸，可使用ObjectOutputStream對象序列化流來傳遞對象，好比ObjectOutputStream os = new ObjectOutputStream（socket.getOutputStream()）;User user = new User("admin","123"); os.writeObject(user);

　　但願這篇文章能讓你有所獲，麻煩點贊或關注我，謝謝觀看！

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程