Java模拟UDP通信示例代码

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通信的资料请关注我们其它相关文章!

(0)

相关推荐

  • java 多线程交通信号灯模拟过程详解

    这学期我们java课程的课程设计项目----交通信号灯的线程设计 实验目的:多线程设计,同步机制 题意 设计一个交通信号灯类: 变量:位置.颜色(红.黄.绿).显示时间(秒). 方法:切换信号灯. 创建并启动两个线程(东西向.南北向)同时运行. 实验要求 设计线程. 设计路口信号灯示意图界面. 进一步将每个方向的信号灯分成3种车道灯:左转.直行和右转. 根据车流量进行时间的模糊控制. 在课程设计的开始并没有仔细看老师的要求,只知道是交通信号灯.然后就开始各种找资料,百度,网上大量的关于红绿灯的设

  • java 中模拟UDP传输的发送端和接收端实例详解

    java 中模拟UDP传输的发送端和接收端实例详解 一.创建UDP传输的发送端 1.建立UDP的Socket服务: 2.将要发送的数据封装到数据包中: 3.通过UDP的Socket服务将数据包发送出去: 4.关闭Socket服务. import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; public class

  • Java线程间通信不同步问题原理与模拟实例

    本文实例讲述了Java线程间通信不同步问题原理与模拟.分享给大家供大家参考,具体如下: 一 点睛 下面两种情况可造成线程间不同步: 1 生产者没生产完,消费者就来消费. 2 消费者没消费完,生产者又来生产,覆盖了还没来得及消费的数据. 二 代码 class Producer implements Runnable { private Person person = null; public Producer( Person person ) { this.person = person; } @

  • java模拟TCP通信实现客户端上传文件到服务器端

    java模拟TCP通信实现客户端上传文件到服务器端,供大家参考,具体内容如下 客户端 package com.zr; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; import java.util.Scanner; /* 客户端 */ public class T

  • Java模拟UDP通信示例代码

    Java基础:模拟UDP通信 1.一次发送,一次接收 1.1.发送方 // 发送端,不需要连接服务器 public class UdpClientDemo {     public static void main(String[] args) throws Exception {         // 1. 发送数据包需要一个Socket         DatagramSocket socket = new DatagramSocket();         // 1.2 建立一个包    

  • Node.js dgram模块实现UDP通信示例代码

    1.什么是UDP? 这里简单介绍下,UDP,即用户数据报协议,一种面向无连接的传输层协议,提供不可靠的消息传送服务.UDP协议使用端口号为不同的应用保留其各自的数据传输通道,这一点非常重要.与TCP相比,占用资源更少,传输速度更快. 2.了解UDP单播.广播和组播 单播:向一个单播地址发送UDP数据报时,数据报只能被指定的IP主机接收,同一子网下的其它主机都不会接收该数据报.单播过程(假设子网地址:192.168.10,该子网下有两台主机:192.168.10.2,192.168.10.3,向1

  • Java多线程编程实现socket通信示例代码

    流传于网络上有关Java多线程通信的编程实例有很多,这一篇还算比较不错,代码可用.下面看看具体内容. TCP是Tranfer Control Protocol的 简称,是一种面向连接的保证可靠传输的协议.通过TCP协议传输,得到的是一个顺序的无差错的数据流.发送方和接收方的成对的两个socket之间必须建 立连接,以便在TCP协议的基础上进行通信,当一个socket(通常都是server socket)等待建立连接时,另一个socket可以要求进行连接,一旦这两个socket连接起来,它们就可以

  • Java实现UDP通信过程实例分析【服务器端与客户端】

    本文实例讲述了Java实现UDP通信过程.分享给大家供大家参考,具体如下: TCP是一种面向连接的传输层协议,而UDP是传输层中面向无连接的协议,故传送的数据包不能保证有序和不丢失,实现UDP通信主要用到了两个类:DatagramPacket和DatagramSocket. DatagramSocket 这个类用来表示发送和接收数据包的套接字. //构造方法,创建数据报套接字并将其绑定到本地主机上的指定端口 DatagramSocket socket = new DatagramSocket(0

  • java实现发送邮件的示例代码

    代码 import javax.mail.internet.InternetAddress; import javax.mail.internet.MimeMessage; import javax.mail.internet.MimeUtility; import javax.mail.Session; import javax.mail.MessagingException; import javax.mail.Transport; /** * @author BuNuo */ public

  • Python 通过爬虫实现GitHub网页的模拟登录的示例代码

    1. 实例描述 通过爬虫获取网页的信息时,有时需要登录网页后才可以获取网页中的可用数据,例如获取 GitHub 网页中的注册号码时,就需要先登录账号才能在登录后的页面中看到该信息,如下图所示.那么该如何实现模拟登录的功能呢?本文实现将通过爬虫实现 GitHub 网页的模拟登录. 2. 代码实现 在实现 GitHub 网页的模拟登录时,首先需要查看提交登录请求时都要哪些请求参数,然后获取登录请求的所有参数,再发送登录请求.如果登录成功的情况下获取页面中的注册号码信息即可.具体步骤如下: (1) 点

  • java生成图片验证码的示例代码

    给大家分享一款java生成验证码的源码,可设置随机字符串,去掉了几个容易混淆的字符,还可以设置验证码位数,比如4位,6位.当然也可以根据前台验证码的位置大小,设置验证码图片的大小.下边是源码分享,直接看吧,很简单! 创建servlet类 import java.io.IOException; import javax.servlet.Servlet; import javax.servlet.ServletException; import javax.servlet.http.HttpServ

  • java 格式化时间的示例代码

    package jkcs; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.Date; import org.openqa.selenium.WebDriver; import org.openqa.selenium.firefox.FirefoxDriver; public class jdcs { public static void main(String[] args) th

  • Scrapy实现模拟登录的示例代码

    为什么要模拟登录 有些网站是需要登录之后才能访问的,即便是同一个网站,在用户登录前后页面所展示的内容也可能会大不相同,例如,未登录时访问Github首页将会是以下的注册页面: 然而,登录后访问Github首页将包含如下页面内容: 如果我们要爬取的是一些需要登录之后才能访问的页面数据就需要模拟登录了.通常我们都是利用的 Cookies 来实现模拟登录,在Scrapy中,模拟登陆网站一般有如下两种实现方式:            (1) 请求时携带Cookies            (2) 发送P

随机推荐