JAVA学习之网络编程UDP篇

//
import java.net.*;
public class UdpA {
    public static void main(String[] args) throws Exception {
        // 其中发送数据包时的步骤
        // (1).使用DatagramSocket()方法创建一个套接字
        // (2).使用DatagramPacket(byte[] buf, int length, InetAddress address, int
        // port) 打包要发送的数据
        // (3).使用DatagramSocket类的send(DatagramPacket p) 发送数据包
        DatagramSocket socket = new DatagramSocket();// 这里可以不用绑定端口,由系统自动分配
        byte[] buf = "您好,我是UdpA,很高兴认识你".getBytes();
        // 我们把数据包要发送到是IP和端口分别是本机的Ip和10000端口
        DatagramPacket packetSend = new DatagramPacket(buf, buf.length, InetAddress.getByName("127.0.0.1"), 10000);
        socket.send(packetSend);

        //接收数据
        DatagramPacket packetBack = new DatagramPacket(new byte[1024], 1024);
        socket.receive(packetBack);
        System.out.println("对方发来的信息为:" + (new String(packetBack.getData(), 0, packetBack.getLength())));
        socket.close();
    }
}

//
import java.net.*;

public class UdpB {

    /**
     * UdpB先接收数据,然后回发数据 连接创建的过程中会出现各种异常,记得做异常处理
     * 
     * @param args
     * @throws Exception
     */
    public static void main(String[] args) throws Exception {
        // 接收数据包时的步骤
        // (1).使用DatagramSocket(int port) 方法创建一个套接字,其中port说明这个套接节直接绑定到指定端口上
        // (2).使用DatagramPacket(byte[] buf, int length) 方法创建一个来用接收数据包的数据包
        // (3).使用DatagramPacket类的receive(DatagramPacket p) 方法为数据包接收数据
        DatagramSocket socket = new DatagramSocket(10000);// 绑定UdpB的端口为10000
        System.out.println("UdpB开启了");
        DatagramPacket packetRecevice = new DatagramPacket(new byte[1024], 1024);
        socket.receive(packetRecevice);

        String ip = packetRecevice.getAddress().getHostAddress();// 取得发送方的IP
        int port = packetRecevice.getPort();// 取得发送方的端口
        String data = new String(packetRecevice.getData(), 0, packetRecevice.getLength());// 取得发送过来的数据
        System.out.println("接收到的数据为:" + data + "       其中发送方的IP为:" + ip + " 端口为:" + port);// 打印接收到的数据

        // 然后再发一个信息到对方
        byte[] msg = "Hello,我就是UdpB哦".getBytes();
        // 根据上面取得的对方的IP和端口,我们把信息反馈回去
        DatagramPacket packetBack = new DatagramPacket(msg, msg.length, InetAddress.getByName(ip), port);
        socket.send(packetBack);

        // 最后关闭套接字
        socket.close();
    }

}