使用Java服务器实现UDP消息的发送和接收(多线程)

目录

  • 简介:
  • 1. 导入必要的库
  • 2. 创建服务器端代码
  • 3. 创建客户端代码
  • 4. 实现多线程处理
  • 5. 测试运行
  • 示例代码:
  • 函数说明
    • 服务器端代码说明:
    • 客户端代码说明:
  • 总结:

简介:

在本篇博客中,我们将介绍如何使用Java服务器来实现UDP消息的发送和接收,并通过多线程的方式来处理并发请求。UDP(User Datagram Protocol)是一种无连接、不可靠的传输协议,适合于实时性要求高的应用场景,如实时游戏、语音通信等。
在这里插入图片描述

步骤:

1. 导入必要的库

首先,我们需要导入Java提供的网络编程库,包括java.netjava.io

2. 创建服务器端代码

在服务器端,我们需要创建一个Socket对象,并绑定到指定的端口。然后,创建一个无限循环,在循环中接收客户端的请求并作出相应的处理。由于UDP是无连接的,所以我们可以通过DatagramSocket类来完成。

3. 创建客户端代码

在客户端,我们同样需要创建一个Socket对象,并指定服务器的IP地址和端口号。然后,通过Socket对象发送和接收UDP数据报。

4. 实现多线程处理

如果希望服务器能够处理多个客户端的请求,我们可以使用多线程来实现并发处理。每当有新的请求到达服务器,就创建一个新的线程来处理该请求。

5. 测试运行

在服务器和客户端代码都完成后,我们可以分别运行它们,并观察控制台输出。确保服务器能够接收到客户端发送的消息,并正确处理。

示例代码:

下面是一个简单的Java代码示例,演示了如何实现UDP消息的发送和接收(多线程):

// 服务器端代码
import java.io.*;
import java.net.*;public class UDPServer {public static void main(String args[]) throws Exception {DatagramSocket serverSocket = new DatagramSocket(9876);byte[] receiveData = new byte[1024];byte[] sendData;while (true) {DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);serverSocket.receive(receivePacket);String sentence = new String(receivePacket.getData());InetAddress IPAddress = receivePacket.getAddress();int port = receivePacket.getPort();String capitalizedSentence = sentence.toUpperCase();sendData = capitalizedSentence.getBytes();DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, port);serverSocket.send(sendPacket);}}
}// 客户端代码
import java.io.*;
import java.net.*;public class UDPClient {public static void main(String args[]) throws Exception {BufferedReader inFromUser = new BufferedReader(new InputStreamReader(System.in));DatagramSocket clientSocket = new DatagramSocket();InetAddress IPAddress = InetAddress.getByName("localhost");byte[] sendData;byte[] receiveData = new byte[1024];String sentence = inFromUser.readLine();sendData = sentence.getBytes();DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, 9876);clientSocket.send(sendPacket);DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);clientSocket.receive(receivePacket);String modifiedSentence = new String(receivePacket.getData());System.out.println("FROM SERVER:" + modifiedSentence);clientSocket.close();}
}

函数说明

当然,下面是更详细的类和函数接口的说明:

服务器端代码说明:

  1. DatagramSocket类:表示用于发送和接收UDP数据报的套接字。它有以下常用方法:

    • DatagramSocket(int port):创建一个绑定到指定端口的DatagramSocket对象。
    • void receive(DatagramPacket p):将接收到的UDP数据报存储在给定的DatagramPacket对象中。
    • void send(DatagramPacket p):发送给定的DatagramPacket对象中的UDP数据报。
  2. DatagramPacket类:表示UDP数据报。它有以下常用方法:

    • DatagramPacket(byte[] buf, int length):创建一个指定长度的DatagramPacket对象,用于接收数据。
    • DatagramPacket(byte[] buf, int length, InetAddress address, int port):创建一个指定长度的DatagramPacket对象,用于发送数据至指定的IP地址和端口号。
    • byte[] getData():返回接收或发送的数据。
    • InetAddress getAddress():返回远程主机的IP地址。
    • int getPort():返回远程主机的端口号。
  3. String类:表示字符串对象。它有以下常用方法:

    • String(byte[] bytes):使用指定的字节数组创建一个新的字符串对象。
    • String(byte[] bytes, int offset, int length):使用指定的字节数组的一部分创建一个新的字符串对象。
    • byte[] getBytes():将字符串转换为字节数组。

客户端代码说明:

  1. BufferedReader类:用于从输入流中读取文本数据的缓冲区。它有以下常用方法:

    • BufferedReader(Reader reader):创建一个新的缓冲读取器。
    • String readLine():读取一行文本并返回。
  2. InputStreamReader类:转换字节流到字符流的桥梁。它有以下常用构造函数:

    • InputStreamReader(InputStream in):创建一个将字节流转换为字符流的输入流读取器。
  3. DatagramSocket类和DatagramPacket类的说明请参考服务器端代码中的解释。

希望这些详细的类和函数接口说明能够帮助您更好地理解和应用UDP消息的发送和接收(多线程)的实现过程。如果您有任何问题,请随时提问。

总结:

在服务器端代码中,我们使用DatagramSocketDatagramPacket类来处理UDP的发送和接收。在客户端代码中,我们使用BufferedReaderInputStreamReader类来读取用户输入,并使用DatagramSocketDatagramPacket类来发送和接收UDP数据报。

通过本篇博客,我们了解了如何使用Java服务器实现UDP消息的发送和接收,并通过多线程的方式处理并发请求。这对于实时性要求高的应用场景非常有用,如游戏开发、语音通信等。希望本文能够帮助您理解和应用UDP网络编程。如有疑问,请随时留言。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/69740.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【Apollo】阿波罗自动驾驶:塑造自动驾驶技术的未来

前言 Apollo (阿波罗)是一个开放的、完整的、安全的平台,将帮助汽车行业及自动驾驶领域的合作伙伴结合车辆和硬件系统,快速搭建一套属于自己的自动驾驶系统。 开放能力、共享资源、加速创新、持续共赢是 Apollo 开放平台的口号。百度把自己所拥有的强大、…

【网络编程·网络层】IP协议

目录 一、IP协议的概念 二、IP协议的报头 1、四位首部长度 2、16位总长度(解包) 3、8位协议(分用) 4、16位首部校验和 5、8位生存时间 6、32位源IP和32位目的IP 7、4位版本/8位服务类型 8、16位标识 9、3位标志 10、1…

excel 下载方法封装

1.首先需要拿到后端返回的URL下载地址 2.写个下载方法 // url 接口返回的下载地址。例如:https://cancer-research.oss-cn-beijing.aliyuncs.com/yuance-platform-permission/校内共享数据导入模板.xlsx // name 文件名称 例如: 校内共享数据导入模板 /…

UML之四种事物

目录 结构事物 行为事物 分组事物: 注释事物 结构事物 1.类(Class) -类是对一组具有相同属性、方法、关系和语义的对象的描述。一个类实现一个或多个接口 2.接口(interface) -接口描述 了一个类或构件的一个服务的操作集。接口仅仅是定义了一组操作的规范&…

Linux知识点 -- 进程信号(二)

Linux知识点 – 进程信号(二) 文章目录 Linux知识点 -- 进程信号(二)一、信号保存1.相关概念2.信号保存的相关接口3.对所有的信号都进行自定义捕捉4.将2号信号block,并打印pending信号集5.将所有信号都block 二、处理信…

C语言 字符指针

1、介绍 概念: 字符指针,就是字符类型的指针,同整型指针,指针指向的元素表示整型一样,字符指针指向的元素表示的是字符。 假设: char ch a;char * pc &ch; pc 就是字符指针变量,字符指…

git命令使用

君子拙于不知己,而信于知己。——司马迁 清屏:clear 查看当前面板的路径:pwd 查看当前面板的文件:ls 创建文件夹:mkdir 文件夹名 创建文件:touch 文件名 删除文件夹:rm -rf 文件夹名 删除文件:r…

磁力线试验+多图

今天要磨制一个钢针工具。磨下来很多的铁屑,灵机一动,何不来试验一下磁铁的磁力线。这可是难得的材料。 下放7颗强力磁铁,可见强力磁铁的磁力线非常集中。 下放直径4CM的喇叭磁铁 强力磁铁U型铁 强力磁铁E型铁氧体磁芯,可见磁力线…

高忆管理:简单的选股方法?好股票为什么不涨?

股票是一种很受欢迎的出资方式,但选股并不是一件简略的事。那么简略的选股办法?好股票为什么不涨?高忆管理也为大家预备了相关内容,以供参考。 简略的选股办法? 1、基本面选股,这种办法是依据公司所处职业…

掌握Python的X篇_30_使用python解析网页HTML

本篇将会介绍beutifulsoup4模块,可以用于网络爬虫、解析HTML和XML,对于没有接触过前端,不了解HTML是如何工作的,需要先解释一下什么事HTML。 1. HTML 网页中的各种布局等的背后都是非常简单的纯文本格式,那种格式称为…

【猿灰灰赠书活动 - 02期】- 【Java从入门到精通2023年7月最新(第7版)】

说明:博文为大家争取福利,与清华大学出版社合作进行送书活动 图书:《Java从入门到精通》 一、好书推荐 图书介绍 Java入门经典,95万Java程序员的入行选择。配备升级版Java开发资源库,在线大咖课在线答疑,学…

ffmepg滤镜

视频按顺时针方向旋转90度 ffplay -vf transpose1 -i juren-30s.mp4 ffplay -f lavfi -i testsrc -vf transpose1 -f lavfi -i testsrc这个滤镜是ffmpeg给用户的一个测试使用的视频 视频水平翻转(左右翻转) -vf hflip 实现慢速播放,声音速度是原始速度的50% ffpla…