欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Java模拟UDP通信示例代码

程序员文章站 2023-09-07 15:26:02
java基础:模拟udp通信1、一次发送,一次接收1.1、发送方// 发送端,不需要连接服务器public class udpclientdemo { public static void main...

java基础:模拟udp通信

1、一次发送,一次接收

1.1、发送方

// 发送端,不需要连接服务器
public class udpclientdemo {
    public static void main(string[] args) throws exception {
        // 1. 发送数据包需要一个socket
        datagramsocket socket = new datagramsocket();
        // 1.2 建立一个包
        string msg = "你好";
        inetaddress localhost = inetaddress.getbyname("localhost");
        system.out.println(localhost);
        int port = 8080;

        /*
		通过udp发送消息,需要通过 包 来发送,--> datagrampacket(),该方法有多种重载形式,以下使用参数列表最多的那个
		参数:
		- 要发送的 消息 的字节数组 
		- 从字节数组的哪个位置开始发送
		- 发送的长度
		- 对方的 ip地址
		- 对方的端口号
         */

        datagrampacket packet = new datagrampacket(msg.getbytes(), 0, msg.getbytes().length, localhost, port);
        // 2. 发送数据包
        socket.send(packet);
        socket.close();
    }
}

1.2、接收方

// 接收端,接收端需要保证存在,否则接收不到,所以需要提前开启
public class udpserverdemo {

    public static void main(string[] args) throws exception {

        // 1. 接收也需要一个socket,并且要开启接收的端口
        datagramsocket socket = new datagramsocket(8080);
        // 需要一个字节数组来接收数据
        byte[] buffer = new byte[1024];
        // 1.2 封装数据包
        datagrampacket packet = new datagrampacket(buffer, 0, buffer.length);
        // 2. 接收数据,阻塞式接收:一直处于监听状态
        socket.receive(packet);
        // 关闭套接字
        socket.close();
        // 输出一下
        system.out.println(packet.getaddress().gethostaddress());
        // trim():为了去除多余的空格
        system.out.println(new string(packet.getdata()).trim());

    }

}

2、多次发送,多次接收

一方多次发送,一方多次接收,加上一个 while(true) {} 死循环,并规定在什么情况下退出即可。

2.1、发送方

public class chatsenderdemo {
    public static void main(string[] args) throws exception {
        // 使用socket来接收
        datagramsocket socket = new datagramsocket();
        while (true) {
            // 准备发送包裹,从键盘接收数据
            bufferedreader reader = new bufferedreader(new inputstreamreader(system.in));
            // 读取一行
            string data = reader.readline();
            byte[] databytes = data.getbytes();
            datagrampacket packet = new datagrampacket(databytes, databytes.length, new inetsocketaddress("127.0.0.1", 6666));
            // 发送
            socket.send(packet);
            // 什么时候退出
            if ("bye".equals(data)) {
                break;
            }
        }
        // 关闭
        socket.close();
    }
}

2.2、接收方

public class chatreceivedemo {

    public static void main(string[] args) throws exception {
        datagramsocket socket = new datagramsocket(6666);
        while (true) {
            // 准备接收数据包裹
            byte[] buffer = new byte[1024];
            // 用来接收数据
            datagrampacket packet = new datagrampacket(buffer, 0, buffer.length);
            // 接收包裹,阻塞时接收
            socket.receive(packet);
            // 接收到的数据
            string receivedata = new string(packet.getdata()).trim();
            // 打印到控制台
            system.out.println(receivedata);
            // 什么时候退出
            if ("bye".equals(receivedata)) {
                break;
            }
        }

        // 关闭
        socket.close();
    }
}

3、模拟双方通信

模拟双方使用udp通信,需要开启两个线程,并对以上代码进行【共性提取】,进一步进行抽象。

由此,双方可以通过指定的端口来互相发送消息。

3.1、发送方的线程

// 开启多线程需要实现 runnable 接口,实现 run()方法
public class talksender implements runnable {
    // 网络套接字,发送需要
    datagramsocket socket = null;
    // 缓冲读取流
    bufferedreader reader = null;
    // 开启哪个端口接收
    private int fromport;
    // 对方的 ip
    private string toip;
    // 对方的端口
    private int toport;
    // 通过构造方法进行初始化
    public talksender(int fromport, string toip, int toport) {
        this.fromport = fromport;
        this.toip = toip;
        this.toport = toport;
        try {
            socket = new datagramsocket(fromport);
        } catch (socketexception e) {
            e.printstacktrace();
        }
    }

    // 重写 run()方法,设置线程任务
    @override
    public void run() {
        while (true) {
            string data = null;
            try {
                // 准备发送包裹,从键盘接收数据
                reader = new bufferedreader(new inputstreamreader(system.in));
                // 读取一行
                data = reader.readline();
                byte[] databytes = data.getbytes();
                datagrampacket packet = new datagrampacket(databytes, databytes.length, new inetsocketaddress(toip, toport));
                socket.send(packet);
            } catch (ioexception e) {
                e.printstacktrace();
            }

            // 什么时候退出
            if ("bye".equals(data)) {
                break;
            }
        }
        // 关闭
        socket.close();
    }
}

3.2、接收方的线程

public class talkreveicer implements runnable {

    datagramsocket socket = null;
    // 从哪个端口接收
    private int formport;
    // 发送方是谁
    private string who;
    public talkreveicer(int formport, string who) {
        this.formport = formport;
        this.who = who;
        try {
            socket = new datagramsocket(formport);
        } catch (socketexception e) {
            e.printstacktrace();
        }

    }

    @override
    public void run() {
        while (true) {
            string receivedata = null;
            try {
                // 准备接收数据包裹
                byte[] buffer = new byte[1024];
                // 接收数据
                datagrampacket packet = new datagrampacket(buffer, 0, buffer.length);
                // 接收数据,阻塞式
                socket.receive(packet);
                // 接收到的数据
                receivedata = new string(packet.getdata());
                system.out.println(who + ":" + receivedata.trim());
            } catch (ioexception e) {
                e.printstacktrace();
            }
            // 什么时候退出
            if ("bye".equals(receivedata)) {
                break;
            }
        }

        // 关闭
        socket.close();
    }
}

3.3、模拟学生

// 学生端
public class talkstudent {
    public static void main(string[] args) {
        // 开启 5555端口,发送到本机的 6666端口
        new thread(new talksender(5555, "localhost", 6666)).start();
        // 规定使用 7777 端口接收老师发送的消息
        new thread(new talkreveicer(7777, "老师")).start();
    }
}

3.4、模拟老师

// 教师端
public class talkteacher {
    public static void main(string[] args) {
        // 开启 8888端口,发送到本机的 7777端口
        new thread(new talksender(8888, "localhost", 7777)).start();
        // 规定使用 6666 端口接收学生发送的消息
        new thread(new talkreveicer(6666, "学生")).start();

    }

}

总结:

使用udp通信,其实主要的步骤分为三步:

1  用 datagramsocket() 来开启端口,通过开启端口聊天。
2  用datagrampacket() 来发送或者接收数据。
3  关闭 datagramsocket,释放资源。

以上就是java模拟udp通信示例代码的详细内容,更多关于java模拟udp通信的资料请关注其它相关文章!