java網絡編程之UDP通訊

詳細介紹了java中的網絡通信機制，尤其是UDP協議，通過對UDP的基本使用進行舉例說明如何使用UDP進行數據的發送接收，並舉了兩個小demo說明UDP的使用注意事項。

UDP協議原理圖解：

UDP協議：需要借助於InetAddress來獲取設備的IP地址，以及姓名

import java.io.IOException;
import java.net.Inet4Address;
import java.net.InetAddress;
import java.net.UnknownHostException;

public class InetAddressDemo {
    public static void main(String[] args) throws IOException {
        // InetAddress address = InetAddress.getByName("10.129.123.23");
        InetAddress address = InetAddress.getByName("ooo-PC");
        // InetAddress address = InetAddress.getByName("lpp-PC");

        // 獲取該ip地址對象的IP地址和主機名
        String name = address.getHostName();
        String ip = address.getHostAddress();

        System.out.println(name);
        System.out.println(ip);
    }
}

/*
 * 網絡通訊三要素：
 *     1.IP地址:InetAddress 網絡中設備的標識，不易記憶，可用主機名；
 *     2.端口號:用於標識進程的邏輯地址，不同進程的標識傳輸協議通訊的規則；用於標識進程的邏輯地址，不同進程的標識，
 *    有效端口：0~65535，其中0~1024系統使用或保留端口。
 *     3.常見協議：TCP，UDP。
 */

/*
 * UDP協議
 * 將數據源和目的封裝成數據包中，不需要建立連接；
 * 每個數據報的大小在限制在64k；
 * 因無連接，是不可靠協議；
 * 不需要建立連接，速度快
 */

/*
 * Socket套接字：
 * 網絡上具有唯一標識的IP地址和端口號組合在一起才能構成唯一能識別的  標識符套接字。
 * Socket原理機制：通信的兩端都有Socket。
 * 網絡通信其實就是Socket間的通信。
 * 數據在兩個Socket間通過IO傳輸。
 */




//第一部分代碼是接收端，一般是先開接收端的代碼，再開發送端
//接收端代碼的創建步驟如下：
/*
 * UDP協議接收數據：
 * 1.創建接收端socket對象
 * 2.創建一個數據包（接收數據的容器）
 * 3.調用socket的對象的接收方法接收數據
 * 4.解析數據，並顯示在控制台
 * 5.釋放資源
 */

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

/*
 * 對於里面創建對象的部分進行優化直接鏈式編程
 * java.net.BindException: Address already in use: Cannot bind
 * 該端口已經被使用了，有可能是第二次調用或者第一次調用的時候該端口被其它程序使用。
 */
public class ReceiveDemo {
    public static void main(String[] args) throws IOException {
        // 創建接收端數socket對象,指定端口。
        DatagramSocket ds = new DatagramSocket(10086);
        // 接收數據
        byte[] buf = new byte[1024];
        // int length = buf.length;
        DatagramPacket dp = new DatagramPacket(buf, buf.length);
        ds.receive(dp); // 將接受的數據放進dp數據報包中
        // 解析數據，獲取IP地址以及數據報包中的內容
        // InetAddress address = dp.getAddress();
        // String ip = address.getHostAddress();
        // byte[] bys = dp.getData();
        // int len = dp.getLength(); // 數據報包的實際長度

        String ip = dp.getAddress().getHostAddress();
        String s = new String(dp.getData(), 0, dp.getLength());

        System.out.println(ip + ":--" + s);

        // 釋放資源
        ds.close();

    }
}


//----------------------------------------
//下面是發送端的代碼，與上面分開在兩個類

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

public class SendDemo {
    public static void main(String[] args) throws IOException {
        // 發送端socket對象
        DatagramSocket ds = new DatagramSocket();

        // 數據打包
        byte[] bys = "java".getBytes();
        // int len = bys.length;
        // InetAddress address = InetAddress.getByName("lpp-PC");
        // int port = 10086;
        
        DatagramPacket dp = new DatagramPacket(bys, bys.length,
                InetAddress.getByName("lpp-PC"), 10086);

        // 發送數據
        ds.send(dp);

        // 釋放資源
        ds.close();
    }
}

/*
* 多線程實現在一個代碼里面姐發送又接受數據
* 在發送端從鍵盤錄入數據，一直讀到886結束數據的錄入發送，鍵盤錄入一句就接受一句，接收端一直開着等着數據的發送。
*/

//首先是main方法

import java.io.IOException;
import java.net.DatagramSocket;
import java.net.SocketException;

/*
 * 通過多線程
 */
public class chatRoomDemo {
    public static void main(String[] args) throws IOException {
        // 接收端，發送端socket
        DatagramSocket dsSend = new DatagramSocket();
        DatagramSocket dsReceive = new DatagramSocket(10086);

        SendThread st = new SendThread(dsSend);
        ReceiveThread rt = new ReceiveThread(dsReceive);

        // 線程開啟
        Thread sendThread = new Thread(st);
        Thread receiverThread = new Thread(rt);

        sendThread.start();
        receiverThread.start();
    }
}

//--------------------------------------------
//接收端線程的創建
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class ReceiveThread implements Runnable {
    private DatagramSocket ds;

    public ReceiveThread(DatagramSocket ds) {
        // 通過構造方法進行初始化
        this.ds = ds;
    }

    @Override
    public void run() {
        // TODO Auto-generated method stub
        while (true) {
            try {
                byte[] buf = new byte[1024];
                DatagramPacket dp = new DatagramPacket(buf, buf.length);
                ds.receive(dp);

                String ip = dp.getAddress().getHostAddress();

                String s = new String(dp.getData(), 0, dp.getLength());

                System.out.println(ip + "--->" + s);
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

//---------------------------------------
//發送端線程的創建

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class SendThread implements Runnable {
    private DatagramSocket ds;

    public SendThread(DatagramSocket ds) {
        this.ds = ds;
    }

    @Override
    public void run() {
        // TODO Auto-generated method stub
        try {
            BufferedReader br = new BufferedReader(new InputStreamReader(
                    System.in));
            String line = null;
            while ((line = br.readLine()) != null) {
                if ("886".equals(line)) {
                    break;
                }
                byte[] buf = line.getBytes();
                DatagramPacket dp = new DatagramPacket(buf, buf.length,
                        InetAddress.getByName("lpp-PC"), 10086);

                ds.send(dp);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
        // //釋放資源
        // ds.close();
    }

}