广告

扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 后端开发 > Python >java使用UDP实现点对点通信
  • 590

0
分享到

java使用UDP实现点对点通信

2024-04-02 19:04:59 590人浏览 八月长安

Python 官方文档：入门教程 => 点击学习

摘要

本文实例为大家分享了java使用UDP实现点对点通信的具体代码，供大家参考，具体内容如下 整体的结构思路： Stu和Tea是收发消息的两端； Stu和Tea类都是通过启动两个线程完成

本文实例为大家分享了java使用UDP实现点对点通信的具体代码，供大家参考，具体内容如下

整体的结构思路：

Stu和Tea是收发消息的两端；

Stu和Tea类都是通过启动两个线程完成通信的，这两个线程分别是发消息线程和收消息线程；

Stu类中启动的两个线程分别写在两个类里，Tea也是这样做。

Stu端及其收发消息代码：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;
 
public class Stu {
 
    public static void main(String[] args) throws IOException {
        new Thread(new StuSendThread("127.0.0.1", 8888)).start();
        new Thread(new StuReceiverThread(8889)).start();
    }
}
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
 
 
public class StuReceiverThread implements Runnable{
 
    private int port;
 
    public StuReceiverThread(int port) {
        this.port = port;
    }
    
    @Override
    public void run() {
        // 创建接收方
        DatagramSocket socket;
        try {
            socket = new DatagramSocket(port);
            while(true) {
                // 准备容器
                byte[] buf = new byte[1024];
                DatagramPacket dPacket = new DatagramPacket(buf, buf.length);
                // 阻塞式接受数据
                try {
                    socket.receive(dPacket);
                } catch (IOException e) {
                    e.printStackTrace();
                }
                // 分析数据
                System.out.println(new String(buf));
                if (new String(buf).equals("exit")) {
                    break;
                }
            }
            // 释放资源
            socket.close();
        } catch (SocketException e1) {
            e1.printStackTrace();
        }        
    }    
}
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
 
public class StuSendThread implements Runnable{
 
    private DatagramSocket socket;
    private BufferedReader br;
    String IP;
    int port;
    
    public StuSendThread(String IP, int port) throws SocketException {
        socket = new DatagramSocket();
        br = new BufferedReader(new InputStreamReader(System.in));
        this.IP = IP;
        this.port = port;
    }
    
    @Override
    public void run() {        
        while(true) {
            // 准备数据
            br = new BufferedReader(new InputStreamReader(System.in));
            String msg;
            try {
                msg = br.readLine();
                byte[] data = msg.getBytes();
                // 封装数据
                DatagramPacket dPacket = new DatagramPacket(data, data.length, InetAddress.getByName(IP), port);
                // 发送数据
                socket.send(dPacket);
                if(msg.equals("exit")) {
                    break;
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
            
        }
        
        // 关闭资源
        try {
            br.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
        
    }
 
}

Tea端及其收发消息代码：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
 
public class TeaSendThread implements Runnable{
    private DatagramSocket socket;
    private BufferedReader br;
    String IP;
    int port;
 
    public TeaSendThread(String IP, int port) throws SocketException {
        socket = new DatagramSocket();
        br = new BufferedReader(new InputStreamReader(System.in));
        this.IP = IP;
        this.port = port;
    }
 
    @Override
    public void run() {
        while (true) {
            // 准备数据
            br = new BufferedReader(new InputStreamReader(System.in));
            String msg;
            try {
                msg = br.readLine();
                byte[] data = msg.getBytes();
                // 封装数据
                DatagramPacket dPacket = new DatagramPacket(data, data.length, InetAddress.getByName(IP), port);
                // 发送数据
                socket.send(dPacket);
                if (msg.equals("exit")) {
                    break;
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
 
        }
 
        // 关闭资源
        try {
            br.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
 
    }
 
}
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
 
public class TeaReceiverTread implements Runnable{
    private int port;
 
    public TeaReceiverTread(int port) {
        this.port = port;
    }
    
    @Override
    public void run() {
        // 创建接收方
        DatagramSocket socket;
        try {
            socket = new DatagramSocket(port);
            while(true) {
                // 准备容器
                byte[] buf = new byte[1024];
                DatagramPacket dPacket = new DatagramPacket(buf, buf.length);
                // 阻塞式接受数据
                try {
                    socket.receive(dPacket);
                } catch (IOException e) {
                    e.printStackTrace();
                }
                // 分析数据
                System.out.println(new String(buf));
                if (new String(buf).equals("exit")) {
                    break;
                }
            }
            // 释放资源
            socket.close();
        } catch (SocketException e1) {
            e1.printStackTrace();
        }        
    }    
}
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
 
public class TeaSendThread implements Runnable{
    private DatagramSocket socket;
    private BufferedReader br;
    String IP;
    int port;
 
    public TeaSendThread(String IP, int port) throws SocketException {
        socket = new DatagramSocket();
        br = new BufferedReader(new InputStreamReader(System.in));
        this.IP = IP;
        this.port = port;
    }
 
    @Override
    public void run() {
        while (true) {
            // 准备数据
            br = new BufferedReader(new InputStreamReader(System.in));
            String msg;
            try {
                msg = br.readLine();
                byte[] data = msg.getBytes();
                // 封装数据
                DatagramPacket dPacket = new DatagramPacket(data, data.length, InetAddress.getByName(IP), port);
                // 发送数据
                socket.send(dPacket);
                if (msg.equals("exit")) {
                    break;
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
 
        }
 
        // 关闭资源
        try {
            br.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
 
    }
 
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持编程网。

您可能感兴趣的文档:
点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: java使用UDP实现点对点通信

本文链接: https://www.lsjlt.com/news/151564.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档
去做题
猜你喜欢
  • java使用UDP实现点对点通信
    本文实例为大家分享了java使用UDP实现点对点通信的具体代码，供大家参考，具体内容如下 整体的结构思路： Stu和Tea是收发消息的两端； Stu和Tea类都是通过启动两个线程完成...
    99+
    2022-11-13
  • java如何使用UDP实现点对点通信
    本文小编为大家详细介绍“java如何使用UDP实现点对点通信”，内容详细，步骤清晰，细节处理妥当，希望这篇“java如何使用UDP实现点对点通信”文章能帮助大家解决疑惑，下面跟着小编的思路慢慢深入，一起来学习新知识吧。整体的结构思路：Stu...
    99+
    2023-07-02
  • TCP点对点和UDP广播怎么实现
    本篇内容主要讲解“TCP点对点和UDP广播怎么实现 ”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“TCP点对点和UDP广播怎么实现 ”吧!　　System：　　System类中提供了大量的静态方...
    99+
    2023-06-02
  • 使用python实现UDP通信方式
    目录python UDP通信对UDP协议的理解Socket简介UDP特点UDP中客户端和服务器端交互 UDP网络通信过程 多线程聊天室服务器端的实现UDP中广播p...
    99+
    2022-11-11
  • Java实现基于UDP协议的网络通信UDP编程
    目录UDP编程通信基本介绍基本流程UDP编程通信 基本介绍 类DatagramSocket和DatagramPacket【数据包/数据报】实现了基于UDP协议网络程序。UDP数据报通...
    99+
    2023-05-17
    Java UDP编程 Java UDP网络编程
  • SpringBoot如何使用WebSocket实现点对点消息
    这篇文章主要介绍“SpringBoot如何使用WebSocket实现点对点消息”的相关知识，小编通过实际案例向大家展示操作过程，操作方法简单快捷，实用性强，希望这篇“SpringBoot如何使用WebSocket实现点对点消息”文章能帮助大...
    99+
    2023-07-06
  • SpringBoot中怎么使用WebSocket实现点对点消息
    本篇内容介绍了“SpringBoot中怎么使用WebSocket实现点对点消息”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！一、添加依赖，配...
    99+
    2023-06-08
  • 怎么在python中利用UDP编程实现通信
    今天就跟大家聊聊有关怎么在python中利用UDP编程实现通信，可能很多人都不太了解，为了让大家更加了解，小编给大家总结了以下内容，希望大家根据这篇文章可以有所收获。python主要应用领域有哪些1、云计算，典型应用OpenStack。2、...
    99+
    2023-06-14
  • C#利用RabbitMQ实现点对点消息传输
    目录消息队列模型RabbitMQ设置RabbitMQ动态库安装RabbitMQ.Client相关知识点示例效果图核心代码消息队列模型 所有 MQ 产品从模型抽象上来说都是一样的过程...
    99+
    2022-11-12
  • 通过Java实现文件断点续传功能
    目录什么是断点续传解决方案效果演示参考代码前端后端什么是断点续传 用户上传大文件,网络差点的需要历时数小时，万一线路中断，不具备断点续传的服务器就只能从头重传，而断点续传就是，允许用...
    99+
    2022-11-13
  • 怎么使用Java实现串口通信
    要使用Java实现串口通信，可以使用Java的RXTX库。以下是一个简单的示例代码： import gnu.io.CommPort;...
    99+
    2023-10-22
    Java
  • 用Java实现24点游戏
    目录一、常见游戏规则二、算法分析三、概要设计四、代码五、测试一、常见游戏规则 从扑克中每次取出4张牌。使用加减乘除，第一个能得出24者为赢。（其中，J代表11，Q代表12，K代表13...
    99+
    2022-11-12
  • C#如何利用RabbitMQ实现点对点消息传输
    这篇文章主要介绍C#如何利用RabbitMQ实现点对点消息传输，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！消息队列模型所有 MQ 产品从模型抽象上来说都是一样的过程：消费者（consumer）订阅某个队列。生产者（...
    99+
    2023-06-15
  • 怎么在HTML5中利用WebSocket实现点对点聊天
    这期内容当中小编将会给大家带来有关怎么在HTML5中利用WebSocket实现点对点聊天，文章内容丰富且以专业的角度为大家分析和叙述，阅读完这篇文章希望大家可以有所收获。首先在系统启动的时候调用InitServlet方法public&nbs...
    99+
    2023-06-09
  • java使用UDP实现多人聊天功能
    使用UDP实现简单聊天功能，供大家参考，具体内容如下 使用UDP实现一个简单的多人聊天功能。该程序使用了多线程，实现了聊天功能。 package 课后作业.E103_10_聊天; ...
    99+
    2022-11-13
  • 怎么通过Java实现文件断点续传功能
    这篇文章主要介绍“怎么通过Java实现文件断点续传功能”的相关知识，小编通过实际案例向大家展示操作过程，操作方法简单快捷，实用性强，希望这篇“怎么通过Java实现文件断点续传功能”文章能帮助大家解决问题。什么是断点续传用户上传大文件,网络差...
    99+
    2023-06-30
  • java如何利用socket通信实现Modbus-RTU通信协议
    小编给大家分享一下java如何利用socket通信实现Modbus-RTU通信协议，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！ModbusModbus是一种串行...
    99+
    2023-06-14
  • 如何使用Java实现简单点餐系统
    小编给大家分享一下如何使用Java实现简单点餐系统，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！程序控制分析：欢迎页循环：do-while2、Scanner 控制...
    99+
    2023-06-29
  • 如何使用Redis实现点赞取消点赞
    这篇文章将为大家详细讲解有关如何使用Redis实现点赞取消点赞，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。代码实现:    private void&n...
    99+
    2023-06-29
  • python使用UDP实现客户端和服务器对话
    目录UDP 客户端UDP 服务端注意事项UDP 客户端 一个使用UDP协议的客户端示例代码，用于实现连续对话。请注意，UDP是无连接协议，因此在实现连续对话时需要特别小心。 以下是...
    99+
    2023-03-23
    python UDP对话 python UDP客户端服务器
软考高级职称资格查询
软考职称历年真题下载
软考职称资料下载
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作