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

news2024/11/18 21:34:06

目录

  • 简介:
  • 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.coloradmin.cn/o/886547.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

Spring的三种异常处理方式

1.SpringMVC 异常的处理流程 异常分为编译时异常和运行时异常,编译时异常我们 try-cache 进行捕获,捕获后自行处理,而运行时异常是不 可预期的,就需要规范编码来避免,在SpringMVC 中,不管是编译异常还是运行…

激活函数总结(十):激活函数补充(Identity、LogSigmoid、Bent Identity)

激活函数总结(十):激活函数补充 1 引言2 激活函数2.1 Identity激活函数2.2 LogSigmoid激活函数2.3 Bent Identity激活函数 3. 总结 1 引言 在前面的文章中已经介绍了介绍了一系列激活函数 (Sigmoid、Tanh、ReLU、Leaky ReLU、PReLU、Swish、…

【校招VIP】测试方案之等价类

考点介绍: 在校招中,等价类也是重要的考查点。等价类划分是一种典型的黑盒测试设计方法,使用该方法主要对测试子项进行测试规格分析,得到用例,而不用对系统内部处理进行深入了解,它也是目前测试设计过程中使…

Python Opencv实践 - 图像金字塔

import cv2 as cv import numpy as np import matplotlib.pyplot as pltimg cv.imread("../SampleImages/pomeranian.png", cv.IMREAD_COLOR) print(img.shape)#图像上采样 #cv.pyrUp(src, dstNone, dstsizeNone, borderTypeNone) #参考资料:https://blo…

大势智慧软硬件技术答疑第九期

1.在使用模方修模大面积水面时,原模型没有瓦片的区域修补不了,软件也没有新增瓦片,怎么解决? 答:规则分块的数据,然后用新版本模方处理,设置好对应的空间框架。 2.重建大师密集匹配-纠正影像失败…

生产订单负数WIP处理方法(未发生费用准备金)

这个月财务在月结的时候反馈生产成本与制造费用不一致相差20多万, 先查看3611 制造相关的成本中心看上去过量与吸收不足均是0,都是ok的。 再查看一下啊 S_ALR_87013127 工单的投入产出平衡检查:订单结算后,实际成本借方实际成本贷…

[GitOps]微服务版本控制:使用ArgoCD 部署Grafana Loki

背景介绍 请回答:你们是如何保证线上部署的服务,从服务版本到参数配置,都是和测试通过的版本是一致的呢? 本文将介绍GitOps的基本原理以及ArgoCD的使用:ArgoCD部署Grafana Loki 到k8s集群。 本文项目地址&#xff1…

File Inclusion

File Inclusion 服务器执行PHP文件时,可以通过文件包含函数加载另一个文件中的PHP代码,并且当PHP来执行,这会为开发者节省大量的时间。这意味着您可以创建供所有网页引用的标准页眉或菜单文件。当页眉需要更新时,您只更新一个包含…

Curson 编辑器

Curson 汉化与vacode一样 Curson 自带chat功能 1、快捷键ctrlk(代码中编辑) 2、快捷键ctrll 右侧打开窗口

最新MPAS跨尺度、可变分辨率模式实践技术应用及典型案例分析

目录 一、MPAS 模式基本信息 二、MPAS 代码获取及结构 三、MPAS 移植、编译及运行实践 四、MPAS 全球均匀网格的运行 五、MPAS 全球非均匀网格的运行 六、MPAS 区域网格的运行 七、MPAS 运行中的配置 八、MPAS结果处理、分析及可视化 九、了解 MPAS代码的结构、主要模…

攻防世界-web-fileclude

1. 题目描述 打开链接,可以看到如下代码: 代码意思很简单,让我们传递两个参数,一个file1,一个file2,如果file2的内容为hello ctf,那么就可以在代码中include file1 2. 思路分析 这道题显然是…

Android Stodio编译JNI项目,Cmake出错:Detecting C compiler ABI info - failed

在使用Android Stodio编译JNI项目时出现Cmake错误,报错如下: Execution failed for task :app:configureCMakeDebug[arm64-v8a]. > [CXX1429] error when building with cmake using C:\Users\Dell\AndroidStudioProjects\MyApplication2\app\src\ma…

BDA初级分析——认识SQL,认识基础语法

一、认识SQL SQL作为实用技能,热度高、应用广泛 在对数据分析人员的调查中SQL长期作为热度排名第-一的编程语言超过Python和R SQL:易学易用,高效强大的语言 SQL:Structured Query Language 结构化查询语言 SQL:易学…

svn 过滤文件

1. 右键点击,依次选择 TortoiseSVN -> Settings 2. 添加需要过滤的后缀/关键词【 *.iml *.idea *.jar *.class 】

周期 角频率 频率 振幅 初相角

周期 角频率 频率 振幅 初相角 当我们谈论傅里叶级数或波形分析时,以下术语经常出现: 周期 T T T: 函数在其图形上重复的时间或空间的长度。周期的倒数是频率。 频率 f f f: 周期的倒数,即一秒内波形重复的次数。单位通常为赫兹&#xff…

Unity引擎使用InteriorCubeMap采样制作假室内效果

Unity引擎制作假室内效果 大家好,我是阿赵。   这次来介绍一种使用CubeMap做假室内效果的方式。这种技术名叫InteriorCubeMap,是UE引擎自带的节点效果。我这里是在Unity引擎里面的实现。 一、效果展示 这个假室内效果,要动态看才能看出效…

Centos上df命令执行无结果卡住没反应记录

记录linux服务器上df命令卡住,解决办法: 报错如下,执行df命令一直卡着,不返回结果,没反应: 想着是之前挂载的其他盘符,由于迁移导致的磁盘卡住,执行如下命令: strace d…

c++实现哈希桶

闭散列的回顾 在前面的学习中我们知道了闭散列的运算规则,当两个数据计算得到的位置发生冲突时,它会自动的往后寻找没有发生冲突的位置,比如说当前数据的内容如下: 当插入的数据为33时计算的位置为3,可是位置3已经被占…

经典人体模型SMPL介绍(一)

SMPL是马普所提出的经典人体模型,目前已成为姿态估计、人体重建等领域必不可少的基础先验。SMPL基于蒙皮和BlendShape实现,从数千个三维人体扫描结果得来,后通过PCA统计学习得来。 论文:SMPL: A Skinned Multi-Person Linear Mode…