1. 编程号首页

JAVA UDP 发送和接收数据

编程小号 • • 未分类

JAVA UDP 发送和接收数据javaudp发送接收数据1.发送端代码packagecom.wei.udp;importjava.net.DatagramPacket;importjava.net.DatagramSocket;importjava.net.InetAddress;publicclassClientDemo1{/***发送端*/publicstaticvoidmain(String[]args)throwsException{

JAVA UDP 发送和接收数据

UDP的三种通讯方式

  • 单播: 单机与单机之间的通讯
  • 广播: 当前主机与所在网络中的所有主机通讯
  • 组播: 当前主机与选定的一组主机通讯

一.单播

1.发送单次单条数据

1.发送端代码

package com.wei.udp;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class ClientDemo1 { 
   
    /** * 发送端 */
    public static void main(String[] args) throws Exception { 
   
        System.out.println("=============发送端启动===========");
        // 1.创建发送端对象
        DatagramSocket socket = new DatagramSocket(6666);

        // 2.创建一个数据包对象封装数据
        /** * 参数1:封装要发送的数据 * 参数2:发送数据的大小 * 参数3:服务端的IP地址 * 参数4:服务端的端口 * * InetAddress.getLocalHost() 获取本机IP地址 */
        byte[] buffer = "我是一坨数据!".getBytes();
        DatagramPacket packet = new DatagramPacket(buffer,buffer.length, InetAddress.getLocalHost(),8888);

        // 3.发送数据
        socket.send(packet);

        // 4.关闭管道
        socket.close();
    }
}

2.服务端(接收端)代码

package com.wei.udp;

import java.net.DatagramPacket;
import java.net.DatagramSocket;

/** * 接收端 */
public class ServerDemo2 { 
   
    public static void main(String[] args) throws Exception { 
   
        System.out.println("=============客户端启动===========");

        // 1.创建接受对象
        DatagramSocket socket = new DatagramSocket(8888);

        // 2.创建一个数据包接收数据
        byte [] buffer = new byte[1024];
        DatagramPacket packet = new DatagramPacket(buffer, buffer.length);

        // 3.等待接受数据
        socket.receive(packet);

        // 4.取出数据
        int len = packet.getLength();
        String rs = new String(buffer,0,len);
        System.out.println("收到的数据:" + rs);
        // 获取发送端的ip和端口
        String ip = packet.getSocketAddress().toString();
        System.out.println("发送端的IP地址: " + ip);

        int port = packet.getPort();
        System.out.println("发送端端口为: "+port);

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

3.接收到的数据

=============客户端启动===========
收到的数据: 我是一坨数据!
发送端的IP地址: /192.168.43.83:6666
发送端端口为: 6666

2.多发多收消息

1.服务端代码

package com.wei.udp2;

import java.net.DatagramPacket;
import java.net.DatagramSocket;

/** * 接收端 */
public class ServerDemo2 { 
   
    public static void main(String[] args) throws Exception { 
   
        System.out.println("=============客户端启动===========");

        // 1.创建接受对象
        DatagramSocket socket = new DatagramSocket(8888);

        // 2.创建一个数据包接收数据
        byte [] buffer = new byte[1024];
        DatagramPacket packet = new DatagramPacket(buffer, buffer.length);

        while (true) { 
   

            // 3.等待接受数据
            socket.receive(packet);

            // 4.取出数据
            int len = packet.getLength();
            String rs = new String(buffer,0,len);
            System.out.println("收到来自: "+ packet.getAddress()+ ",对方端口号为: "+ packet.getPort()+"的消息: " + rs);
        }
    }
}

2.客户端代码

package com.wei.udp2;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;

public class ClientDemo1 { 
   
    /** * 发送端 */
    public static void main(String[] args) throws Exception { 
   
        System.out.println("=============发送端启动===========");
        // 1.创建发送端对象
        DatagramSocket socket = new DatagramSocket(6666);
        Scanner sc = new Scanner(System.in);

        while (true) { 
   
            System.out.println("请输入您要发送的消息: ");
            String msg = sc.nextLine();

            if("exit".equals(msg)){ 
   
                System.out.println("退出成功!");
                socket.close();
                break;
            }

            // 2.创建一个数据包对象封装数据
            byte[] buffer = msg.getBytes();
            DatagramPacket packet = new DatagramPacket(buffer,buffer.length, InetAddress.getLocalHost(),8888);

            // 3.发送数据
            socket.send(packet);
        }
    }
}

3.发送及接收到的数据

===发送端启动=
请输入您要发送的消息:
嗨,在吗?
请输入您要发送的消息:
在吗?
请输入您要发送的消息:
怎么不说话?
请输入您要发送的消息:
exit
退出成功!

===客户端启动=
收到来自: /192.168.43.83,对方端口号为: 6666的消息: 嗨,在吗?
收到来自: /192.168.43.83,对方端口号为: 6666的消息: 在吗?
收到来自: /192.168.43.83,对方端口号为: 6666的消息: 怎么不说话?

二.广播消息

  • 发送广播消息需要使用广播地址: 255.255.255.255
  • 发送端的数据包的目的地址是广播地址+指定端口号(255.255.255.255,9999)
  • 本机所在网段的其他主机只要匹配到端口即可接受消息(9999)

1.服务端代码

package com.wei.udp3;

import java.net.DatagramPacket;
import java.net.DatagramSocket;

/** * 服务端 */
public class ServerDemo2 { 
   
    public static void main(String[] args) throws Exception { 
   
        System.out.println("=============客户端启动===========");

        // 1.创建接受对象
        DatagramSocket socket = new DatagramSocket(9999);

        // 2.创建一个数据包接收数据
        byte [] buffer = new byte[1024];
        DatagramPacket packet = new DatagramPacket(buffer, buffer.length);

        while (true) { 
   

            // 3.等待接受数据
            socket.receive(packet);

            // 4.取出数据
            int len = packet.getLength();
            String rs = new String(buffer,0,len);
            System.out.println("收到来自: "+ packet.getAddress()+ ",对方端口号为: "+ packet.getPort()+"的消息: " + rs);
        }

    }
}

2.发送端代码

package com.wei.udp3;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;

public class ClientDemo1 { 
   
    /** * 发送端 */
    public static void main(String[] args) throws Exception { 
   
        System.out.println("=============发送端启动===========");
        // 1.创建发送端对象
        DatagramSocket socket = new DatagramSocket(6666);
        Scanner sc = new Scanner(System.in);

        while (true) { 
   
            System.out.println("请输入您要发送的消息: ");
            String msg = sc.nextLine();

            if("exit".equals(msg)){ 
   
                System.out.println("退出成功!");
                socket.close();
                break;
            }

            // 2.创建一个数据包对象封装数据
            byte[] buffer = msg.getBytes();
            DatagramPacket packet = new DatagramPacket(buffer,buffer.length, InetAddress.getByName("255.255.255.255"),9999);

            // 3.发送数据
            socket.send(packet);
        }
    }
}

3.发送及接收到的数据

===发送端启动=
请输入您要发送的消息:
hello
请输入您要发送的消息:
我是一条广播消息
请输入您要发送的消息:
exit
退出成功!

===客户端启动=
收到来自: /192.168.43.83,对方端口号为: 6666的消息: hello
收到来自: /192.168.43.83,对方端口号为: 6666的消息: 我是一条广播消息

三.组播

  • 使用组播地址: 224.0.0.0~239.255.255.255
  • 发送端的数据包的目的目的地址是组播ip(224.0.1.1,9999)
  • 接收端必须绑定该组播ip(224.0.1.1),端口还要对应发送端的目的端口(9999)

1.服务端代码

package com.wei.udp4;

import java.net.*;

/** * 服务端 */
public class ServerDemo2 { 
   
    public static void main(String[] args) throws Exception { 
   
        System.out.println("=============客户端启动===========");

        // 1.创建接受对象
        MulticastSocket socket = new MulticastSocket(9999);

        // 把当前接受端加入到一个组播组中,绑定对应组播消息的组ip
// socket.joinGroup(InetAddress.getByName("224.0.1.1")); 过时的方法
        socket.joinGroup(new InetSocketAddress(InetAddress.getByName("224.0.1.1"),9999), NetworkInterface.getByInetAddress(InetAddress.getLocalHost()));

        // 2.创建一个数据包接收数据
        byte [] buffer = new byte[1024];
        DatagramPacket packet = new DatagramPacket(buffer, buffer.length);

        while (true) { 
   

            // 3.等待接受数据
            socket.receive(packet);

            // 4.取出数据
            int len = packet.getLength();
            String rs = new String(buffer,0,len);
            System.out.println("收到来自: "+ packet.getAddress()+ ",对方端口号为: "+ packet.getPort()+"的消息: " + rs);
        }

    }
}

2.客户端代码

package com.wei.udp4;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.util.Scanner;

public class ClientDemo1 { 
   
    /** * 发送端 */
    public static void main(String[] args) throws Exception { 
   
        System.out.println("=============发送端启动===========");
        // 1.创建发送端对象
        DatagramSocket socket = new DatagramSocket(6666);
        Scanner sc = new Scanner(System.in);

        while (true) { 
   
            System.out.println("请输入您要发送的消息: ");
            String msg = sc.nextLine();

            if("exit".equals(msg)){ 
   
                System.out.println("退出成功!");
                socket.close();
                break;
            }

            // 2.创建一个数据包对象封装数据
            byte[] buffer = msg.getBytes();
            DatagramPacket packet = new DatagramPacket(buffer,buffer.length, InetAddress.getByName("224.0.1.1"),9999);

            // 3.发送数据
            socket.send(packet);
        }
    }
}

3.发送及接收到的数据

===发送端启动=
请输入您要发送的消息:
hello
请输入您要发送的消息:
我是一条组播消息
请输入您要发送的消息:
exit

===客户端启动=
收到来自: /192.168.43.83,对方端口号为: 6666的消息: hello
收到来自: /192.168.43.83,对方端口号为: 6666的消息: 我是一条组播消息

今天的文章JAVA UDP 发送和接收数据分享到此就结束了，感谢您的阅读，如果确实帮到您，您可以动动手指转发给其他人。

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
如需转载请保留出处：https://bianchenghao.cn/25752.html

赞 (0)
编程小号编程小号
0

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注