Java学习之网络编程（UDP协议实例）

网络编程(java.net)
一、网络要素
　　1、IP地址：InetAddress
　　　　192.168.1.255（192.168.1网段的广播地址）
　　2、端口号
　　　　0--65535
　　　　0-1024
　　3、传输协议
　　　　UDP
　　　　　　将数据及源和目的封装成数据包中，不需要建立连接
　　　　　　数据包大小限制在64K内
　　　　　　因无连接，不可靠协议
　　　　　　不需要建立连接，速度快
　　　　TCP
　　　　　　建立连接，形成传输数据的通道
　　　　　　在连接中进行大数据量传输
　　　　　　通过三次握手完成连接，是可靠协议
　　　　　　必须建立连接，效率稍低

二、UDP协议实例

DatagramSocket：用来发送和接收数据包的套接字

网络通信：发送端

public class UDPSendDemo {

    /**
     * @param args
     * @throws IOException
     */
    public static void main(String[] args) throws IOException {
    /*
     * 创建UDP传输的发送端 思路：
     * 1、建立udp的socket服务
     * 2、将发送的数据封装到数据包中 
     * 3、通过udp的socket服务将数据包发送出去
     * 4、关闭socket服务
     */
    // 1、
    DatagramSocket ds = new DatagramSocket();
    // 2、
    BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
    String line=null;
    while ((line=br.readLine())!=null) {
        byte[] buff = line.getBytes();
        DatagramPacket dp = new DatagramPacket(buff, buff.length, InetAddress.getByName("172.28.188.168"), 10000);
        ds.send(dp);
    }

    ds.close();

    }

}

 二、网络通信：接收端

public class UDPReceDemo {

    /**
     * @param args
     * @throws IOException
     */
    public static void main(String[] args) throws IOException {
    /*
     * 建立UDP接收端的思路
     * 1、建立udp socket服务 
     * 2、创建数据包，用于存储接收到的数据。方便用数据包对象的方法解析这些数据
     * 3、使用socket服务的receive方法将接收的数据存储到数据包中。 
     * 4、通过数据包的方法解析数据包的数据
     * 5、关闭资源
     */
    DatagramSocket ds = new DatagramSocket(10000);
    while (true) {
        byte[] buf = new byte[1024];
        DatagramPacket dp = new DatagramPacket(buf, buf.length);
        // 使用接收方法将数据存储到数据包中
        ds.receive(dp);// 阻塞式

        // 4、通过数据包对象的方法，解析其中的数据，比如地址，端口，数据内容

        String ip = dp.getAddress().getHostAddress();
        int port = dp.getPort();
        String str = new String(dp.getData(), 0, dp.getLength());
        System.out.println(ip + "::" + port + ":::" + str);
//    ds.close();
    }
    }

}

结果：

实例二、多线程

思路：多线程任务：有发送数据任务和接收数据任务，准备两个类分别用于发送和接收

发送类

public class Send implements Runnable {
    private DatagramSocket ds;

    Send(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) {
        byte[] buff = line.getBytes();
        DatagramPacket dp = new DatagramPacket(buff, buff.length, InetAddress.getByName("172.28.188.168"),
            10000);
        ds.send(dp);
        
        if("886".equals(line))
            break;
        }
        ds.close();
    } catch (IOException e) {

        e.printStackTrace();
    }
    }

}

接收类

public class Rece implements Runnable {
    private DatagramSocket ds;

    Rece(DatagramSocket ds) {
    this.ds = ds;
    }

    @Override
    public void run() {
    try {
        while (true) {
        byte[] buf = new byte[1024];
        DatagramPacket dp = new DatagramPacket(buf, buf.length);
        // 使用接收方法将数据存储到数据包中

        ds.receive(dp);// 阻塞式

        // 4、通过数据包对象的方法，解析其中的数据，比如地址，端口，数据内容

        String ip = dp.getAddress().getHostAddress();
//        int port = dp.getPort();
        String str = new String(dp.getData(), 0, dp.getLength());
        System.out.println(ip + "::" + str);
        if("886".equals(str))
            System.out.println(ip + "退出");
        }
    } catch (IOException e) {

        e.printStackTrace();
    }
    }
}

主函数

public class ChatDemo {

    /**
     * @param args
     * @throws IOException 
     */
    public static void main(String[] args) throws IOException {
    DatagramSocket rece=new DatagramSocket(10000);
    DatagramSocket send=new DatagramSocket();
    new Thread(new Rece(rece)).start();
    new Thread(new Send(send)).start();
    }

}

结果：