網路編程（inetAddress類的概述和使用----UDP發送和接受資料）-有解無憂

* 如果一個類沒有構造方法：
* A:成員全部是靜態的(Math,Arrays,Collections)
* B:單例設計模式(Runtime)
* C:類中有靜態方法回傳該類的物件(InetAddress)
* class Demo {
* private Demo(){}
*
* public static Demo getXxx() {
* return new Demo();
* }
* }
*
* 看InetAddress的成員方法：
* public static InetAddress getByName(String host):根據主機名或者IP地址的字串表示得到IP地址物件
*/

package cn.itcast_01;

import java.net.InetAddress;
import java.net.UnknownHostException;

/*
 * 如果一個類沒有構造方法：
 * A:成員全部是靜態的(Math,Arrays,Collections)
 * B:單例設計模式(Runtime)
 * C:類中有靜態方法回傳該類的物件(InetAddress)
 *         class Demo {
 *             private Demo(){}
 * 
 *             public static Demo getXxx() {
 *                 return new Demo();
 *             }
 *         }
 * 
 * 看InetAddress的成員方法：
 * public static InetAddress getByName(String host):根據主機名或者IP地址的字串表示得到IP地址物件
 */
public class InetAddressDemo {
    public static void main(String[] args) throws UnknownHostException {
        // public static InetAddress getByName(String host)
        // InetAddress address = InetAddress.getByName("liuyi");
        // InetAddress address = InetAddress.getByName("192.168.12.92");
        InetAddress address = InetAddress.getByName("192.168.12.63");

        // 獲取兩個東西：主機名，IP地址
        // public String getHostName()--------獲取主機名
        String name = address.getHostName();
        // public String getHostAddress()----回傳 IP 地址字串（以文本表現形式），
        String ip = address.getHostAddress();
        System.out.println(name + "---" + ip);
    }
}

UDP進行代碼測驗時---首先運行接受資料---然后運行發送資料

UDP發送資料

/*
* UDP協議發送資料：
* A:創建發送端Socket物件
* B:創建資料，并把資料打包
* C:呼叫Socket物件的發送方法發送資料包
* D:釋放資源
*/

package Day26;

import java.io.IOException;
import java.net.*;
/*
 * UDP協議發送資料：
 * A:創建發送端Socket物件
 * B:創建資料，并把資料打包
 * C:呼叫Socket物件的發送方法發送資料包
 * D:釋放資源
 */

public class SendDemo {
    public static void main(String[] args) throws IOException {
        // 創建發送端Socket物件
        //public class DatagramSocketextends Object此類表示用來發送和接收資料報包的套接字
        // DatagramSocket()
        DatagramSocket tt = new DatagramSocket();

        //創建資料并把資料打包
        //public final class DatagramPacket  extends Object此類表示資料報
        //public DatagramPacket(byte[] buf,int length,InetAddress address,int port)
        //buf - 包資料，
        //length - 包長度，
        //address - 目的地址，
        //port - 目的埠號，
        // 構造資料報包，用來將長度為 length 的包發送到指定主機上的指定埠

        //包資料---創建資料
        byte [] buf = "hello你好".getBytes();//---將字串型別的資料轉換為位元組陣列
        //獲取包長度
        int a= buf.length;
        //目的地地址
        //得到IP地址物件---并同時獲取主機名和主機的IP地址
        InetAddress ia = InetAddress.getByName("192.168.1.4");
        //給出發送的目的埠
        int port = 10086;

        //打包資料
        DatagramPacket DP = new DatagramPacket(buf,a,ia,port);

        // 呼叫Socket物件的發送方法發送資料包
        //public void send(DatagramPacket p)throws IOException從此套接字發送資料報包，
        //DatagramPacket 包含的資訊指示：將要發送的資料、其長度、遠程主機的 IP 地址和遠程主機的埠號，
        tt.send(DP);

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

    }
}

UDP接受資料

/*
* UDP協議接收資料：
* A:創建接收端Socket物件
* B:創建一個資料包(接收容器)
* C:呼叫Socket物件的接收方法接收資料
* D:決議資料包，并顯示在控制臺
* E:釋放資源
*/

package Day26;

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

//UDP協議接受資料
/*
 * UDP協議接收資料：
 * A:創建接收端Socket物件
 * B:創建一個資料包(接收容器)
 * C:呼叫Socket物件的接收方法接收資料
 * D:決議資料包，并顯示在控制臺
 * E:釋放資源
 */
public class ReceiveDemo {
    public static void main(String[] args) throws IOException {
        //創建接收端物件---并給出要接受機器的埠
        DatagramSocket DS = new DatagramSocket(10086);

        //創建一個資料包(接受容器)
        //public DatagramPacket(byte[] buf,int length)
        // 構造 DatagramPacket，用來接收長度為 length 的資料包
        //buf - 保存傳入資料報的緩沖區，
        //len - 要讀取的位元組數，
        //指定資料包的大小---用于保存傳入的資料報的緩沖區
        byte [] bt = new byte[1024];
        //獲取包的位元組數長度
        int length = bt.length;
        DatagramPacket DP = new DatagramPacket(bt,length);

        //呼叫Sockt物件的方法來接受資料
        //public void receive(DatagramPacket p)從此套接字接收資料報包
        //p - 要放置傳入資料的 DatagramPacket
        DS.receive(DP);

        //決議資料包并顯示在控制臺上
        // 獲取發送端對方的ip
        // public InetAddress getAddress()
        //某臺機器的 IP 地址，此資料報將要發往該機器或者是從該機器接收到的，
        InetAddress IA = DP.getAddress();
        //public String getHostAddress()回傳 IP 地址字串（以文本表現形式），
        String ip = IA.getHostAddress();

        // public byte[] getData():獲取資料緩沖區
        //用來接識訓發送資料的緩沖
        // public int getLength():獲取資料的實際長度
        //將要發送或接收到的資料的長度，
        byte[] bt1 = DP.getData();
        int get = DP.getLength();
        //public String(byte[] bytes,int offset,int length)---將位元組陣列轉換為字串
        //bytes - 要解碼為字符的 byte
        //offset - 要解碼的第一個 byte 的索引
        //length - 要解碼的 byte 數
        String s = new String(bt1,0,get);
        //輸出查看某個IP地址的機器傳遞來的資料包
        System.out.println(ip+"傳送的資料是："+s);

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

    }
}

/*
* 資料來自于鍵盤錄入
* 鍵盤錄入資料要自己控制錄入結束，
*/

// 封裝鍵盤錄入資料-----鍵盤自己控制錄入資料---輸入規定字符就會結束回圈
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
String line = null;

while ((line = br.readLine()) != null) {

if ("886".equals(line)) {
break;
}

UDP發送端

package cn.itcast_04;

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

/*
 * 資料來自于鍵盤錄入
 * 鍵盤錄入資料要自己控制錄入結束，
 */
public class SendDemo {
    public static void main(String[] args) throws IOException {
        // 創建發送端的Socket物件
        DatagramSocket ds = new DatagramSocket();

        // 封裝鍵盤錄入資料
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        String line = null;
        while ((line = br.readLine()) != null) {
            if ("886".equals(line)) {
                break;
            }

            // 創建資料并打包
            byte[] bys = line.getBytes();
            // DatagramPacket dp = new DatagramPacket(bys, bys.length,
            // InetAddress.getByName("192.168.12.92"), 12345);
            DatagramPacket dp = new DatagramPacket(bys, bys.length,
                    InetAddress.getByName("192.168.12.255"), 12345);

            // 發送資料
            ds.send(dp);
        }

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

UDP接收端---接收端應該一直開著等待接收資料，是不需要關閉

package cn.itcast_04;

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

/*
 * 多次啟動接收端：
 *         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(12345);

        while (true) {
            // 創建一個包裹
            byte[] bys = new byte[1024];
            DatagramPacket dp = new DatagramPacket(bys, bys.length);

            // 接收資料
            ds.receive(dp);

            // 決議資料
            String ip = dp.getAddress().getHostAddress();
            String s = new String(dp.getData(), 0, dp.getLength());
            System.out.println("from " + ip + " data is : " + s);
        }

        // 釋放資源
        // 接收端應該一直開著等待接收資料，是不需要關閉
        // ds.close();
    }
}

多執行緒實作聊天室程式

一：發送端

package cn.itcast_05;

import java.io.BufferedReader;
import java.io.IOException;
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() {
        try {
            // 封裝鍵盤錄入資料
            BufferedReader br = new BufferedReader(new InputStreamReader(
                    System.in));
            String line = null;
            while ((line = br.readLine()) != null) {
                if ("886".equals(line)) {
                    break;
                }

                // 創建資料并打包
                byte[] bys = line.getBytes();
                // DatagramPacket dp = new DatagramPacket(bys, bys.length,
                // InetAddress.getByName("192.168.12.92"), 12345);
                DatagramPacket dp = new DatagramPacket(bys, bys.length,
                        InetAddress.getByName("192.168.12.255"), 12306);

                // 發送資料
                ds.send(dp);
            }

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

}

二：接收端

package cn.itcast_05;

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() {
        try {
            while (true) {
                // 創建一個包裹
                byte[] bys = new byte[1024];
                DatagramPacket dp = new DatagramPacket(bys, bys.length);

                // 接收資料
                ds.receive(dp);

                // 決議資料
                String ip = dp.getAddress().getHostAddress();
                String s = new String(dp.getData(), 0, dp.getLength());
                System.out.println("from " + ip + " data is : " + s);
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}

三：測驗類

package cn.itcast_05;

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

/*
 * 通過多執行緒改進剛才的聊天程式，這樣我就可以實作在一個視窗發送和接收資料了
 */
public class ChatRoom {
    public static void main(String[] args) throws IOException {
        //創建Socket物件---發送和接收物件
        DatagramSocket dsSend = new DatagramSocket();
        DatagramSocket dsReceive = new DatagramSocket(12306);
  
        //創建物件---并使用構造引數傳遞其要發送和接收的物件
        SendThread st = new SendThread(dsSend);
        ReceiveThread rt = new ReceiveThread(dsReceive);

        //創建執行緒物件并給出運行的物件
        Thread t1 = new Thread(st);
        Thread t2 = new Thread(rt);

        //啟動執行緒
        t1.start();
        t2.start();
    }
}

轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/457586.html

標籤：Java

上一篇：Spring Security + JWT 實作單點登錄，還有誰不會？？

下一篇：學習狂神Spring5_課堂筆記（更新中）