java socket datagramsocket_Java UDP通信:Java DatagramSocket类和DatagramPacket类

java socket datagramsocket_Java UDP通信:Java DatagramSocket类和DatagramPacket类在TCP/IP协议的传输层除了一个TCP协议之外,还有一个UDP协议。UDP协议是用户数据报协议的简称,也用于网络数据的传输。虽然UDP协议是一种不太可靠的协议,但有时在需要较快地接收数据并且可以忍受较小错误的情况下,UDP就会表现出更大的优势。下面是在Java中使用UDP协议发送数据的步骤。使用DatagramSocket()创建一个数据包套接字。使用Datag…

大家好,又见面了,我是你们的朋友全栈君。

在 TCP/IP 协议的传输层除了一个 TCP 协议之外,还有一个 UDP 协议。UDP 协议是用户数据报协议的简称,也用于网络数据的传输。虽然 UDP 协议是一种不太可靠的协议,但有时在需要较快地接收数据并且可以忍受较小错误的情况下,UDP 就会表现出更大的优势。

下面是在 Java 中使用 UDP 协议发送数据的步骤。

使用 DatagramSocket() 创建一个数据包套接字。

使用 DatagramPacket() 创建要发送的数据包。

使用 DatagramSocket 类的 send() 方法发送数据包。

接收 UDP 数据包的步骤如下:

使用 DatagramSocket 创建数据包套接字,并将其绑定到指定的端口。

使用 DatagramPacket 创建字节数组来接收数据包。

使用 DatagramPacket 类的 receive() 方法接收 UDP 包。

DatagramPacket 类

java.net 包中的 DatagramPacket 类用来表示数据报包,数据报包用来实现无连接包投递服务。每条报文仅根据该包中包含的信息从一台机器路由到另一台机器。从一台机器发送到另一台机器的多个包可能选择不同的路由,也可能按不同的顺序到达。表 1 和表 2 简单介绍了 DatagramPacket 的构造方法和常用方法。

表1 DatagramPacket的构造方法

构造方法

说明

DatagramPacket(byte[] buf,int length)

构造 DatagramPacket,用来接收长度为 length 的数据包。

DatagramPacket(byte[] buf,int offset,

int length)

构造 DatagramPacket,用来接收长度为 length 的包,在缓

冲区中指定了偏移量。

DatagramPacket(byte[] buf,int length,

InetAddress address,int port)

构造 DatagramPacket,用来将长度为 length 的包发送到指

定主机上的指定端口。

DatagramPacket(byte[] buf,int length,

SocketAddress address)

构造数据报包,用来将长度为 length 的包发送到指定主机上

的指定端口。

DatagramPacket(byte[] buf,int offset,

int length,InetAddress address,int port)

构造 DatagramPacket,用来将长度为 length 偏移量为 offset

的包发送到指定主机上的指定端口。

DatagramPacket(byte[] buf,int offset,

int length,SocketAddress address)

构造数据报包,用来将长度为 length、偏移量为 offset 的包发

送到指定主机上的指定端口。

表2 DatagramPacket的常用方法

方法

说明

InetAddress getAddress()

返回某台机器的 IP 地址,此数据报将要发往该机器或者

从该机器接收。

byte[] getData()

返回数据缓冲区。

int getLength()

返回将要发送或者接收的数据的长度。

int getOffset()

返回将要发送或者接收的数据的偏移量。

int getPort()

返回某台远程主机的端口号,此数据报将要发往该主机或

者从该主机接收。

getSocketAddress()

获取要将此包发送或者发出此数据报的远程主机的

SocketAddress(通常为 IP地址+端口号)。

void setAddress(InetAddress addr)

设置要将此数据报发往的目的机器的IP地址。

void setData(byte[] buf)

为此包设置数据缓冲区。

void setData(byte[] buf,int offset,

int length)

为此包设置数据缓冲区。

void setLength(int length)

为此包设置长度。

void setPort(int port)

设置要将此数据报发往的远程主机的端口号。

void setSocketAddress(SocketAddress

address)

设置要将此数据报发往的远程主机的

SocketAddress(通常为 IP地址+端口号)。

DatagramSocket 类

DatagramSocket 类用于表示发送和接收数据报包的套接字。数据报包套接字是包投递服务的发送或接收点。每个在数据报包套接字上发送或接收的包都是单独编址和路由的。从一台机器发送到另一台机器的多个包可能选择不同的路由,也可能按不同的顺序到达。

DatagramSocket 类的常用构造方法如表 3 所示。

表3 DatagramSocket 的构造方法

构造方法

说明

DatagramSocket()

构造数据报包套接字并将其绑定到本地主机上任何可用的端口。

DatagramSocket(int port)

创建数据报包套接字并将其绑定到本地主机上的指定端口。

DatagramSocket(int portJnetAddress addr)

创建数据报包套接字,将其绑定到指定的本地地址。

DatagramSocket(SocketAddress bindaddr)

创建数据报包套接字,将其绑定到指定的本地套接字地址。

DatagramSocket 类的常用方法如表 4 所示。

表4 DatagramSocket 的常用方法

方法

说明

void bind(SocketAddress addr)

将此 DatagramSocket 绑定到特定的地址和端口。

void close()

关闭此数据报包套接字。

void connect(InetAddress address,int port)

将套接字连接到此套接字的远程地址。

void connect(SocketAddress addr)

将此套接子连接到远程套接子地址(IP地址+端口号)。

void disconnect()

断开套接字的连接。

InetAddress getInetAddress()

返回此套接字连接的地址。

InetAddress getLocalAddress()

获取套接字绑定的本地地址。

int getLocalPort()

返回此套接字绑定的本地主机上的端口号。

int getPort()

返回此套接字的端口。

例 1

编写 UDP 程序,要求客户端程序可以向服务器端发送多条数据,服务器端程序可以接收客户端发送的多条数据并将其信息输出在控制台,主要步骤如下所示。

(1) 创建一个类作为客户端,在 main() 方法定义一个 DatagramSocket 对象和一个 DatagramPacket 对象并初始化为 null。然后再定义一个 InetAddress 对象和一个端口号并分别进行初始化,代码如下所示。

public static void main(String[] args) { DatagramSocket ds=null; DatagramPacket dpSend=null; InetAddress ia=InetAddress.getByName(“127.0.0.1”); int port=3021; }

(2) 使用 DatagramSocket 的 send(DatagramPacket p) 方法向服务器端发送数据报包,使用循环的方式完成 5 次数据的发送,每发送 1 次数据线程休眠 1000 毫秒,数据发送完毕调用 close() 方法,关闭 DatagramSocket 对象,代码如下。

try { ds=new DatagramSocket(); for(int i=0;i<5;i++) { byte[] data=(“我是 UDP 客户端”+i).getBytes(); dpSend=new DatagramPacket(data,data.length,ia,port); ds.send(dpSend); Thread.sleep(1000); } ds.close(); } catch(IOException | InterruptedException e) { // TODO 自动生成的 catch 块 e.printStackTrace(); }

(3) 创建一个类作为服务器端,在 main() 方法中定义一个 DatagramSocket 对象和一个 DatagramPacket 对象并初始化为 null,再定义一个端口号,代码如下所示。

public static void main(String[] args) { DatagramSocket ds=null; DatagramPacket dpReceive=null; int port=3021; }

(4) 如果成功连接到 UDP 服务器则输出“UDP 服务器已启动。。。”。循环接收客户端发送的数据,并将其发送的内容以及IP地址等信息输出到控制台,代码如下所示。

try { ds=new DatagramSocket(port); System.out.println(“UDP服务器已启动。。。”); byte[] b=new byte[1024]; while(ds.isClosed()==false) { dpReceive=new DatagramPacket(b, b.length); try { ds.receive(dpReceive); byte[] Data=dpReceive.getData(); int len=Data.length; System.out.println(“UDP客户端发送的内容是:” + new String(Data, 0, len).trim()); System.out.println(“UDP客户端IP:” + dpReceive.getAddress()); System.out.println(“UDP客户端端口:” + dpReceive.getPort()); } catch(IOException e) { e.printStackTrace(); } } } catch(SocketException e1) { // TODO 自动生成的 catch 块 e1.printStackTrace(); } }

(5) 最后关闭 DatagramSocket 对象。执行服务器端程序,运行结果如下所示。

UDP服务器已启动。。。

(6) 再运行客户端程序,控制台的输出结果如下所示。

UDP客户端发送的内容是:我是UDP客户端0 UDP客户端IP:/127.0.0.1 UDP客户端端口:53472 UDP客户端发送的内容是:我是UDP客户端1 UDP客户端IP:/127.0.0.1 UDP客户端端口:53472 UDP客户端发送的内容是:我是UDP客户端2 UDP客户端IP:/127.0.0.1 UDP客户端端口:53472 UDP客户端发送的内容是:我是UDP客户端3 UDP客户端IP:/127.0.0.1 UDP客户端端口:53472 UDP客户端发送的内容是:我是UDP客户端4 UDP客户端IP:/127.0.0.1 UDP客户端端口:53472

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

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/132505.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • rabbitmq常见面试题「建议收藏」

    rabbitmq常见面试题「建议收藏」1、使用RabbitMQ有什么好处?1.解耦,系统A在代码中直接调用系统B和系统C的代码,如果将来D系统接入,系统A还需要修改代码,过于麻烦!2.异步,将消息写入消息队列,非必要的业务逻辑以异步的方式运行,加快响应速度3.削峰,并发量大的时候,所有的请求直接怼到数据库,造成数据库连接异常2、RabbitMQ中的broker是指什么?cluster又是指什么?bro…

  • 编程怎么入门_损失函数的基本概念和原理

    编程怎么入门_损失函数的基本概念和原理介绍了Socket编程的基本概念,并以UDP编程为例,给出示例。

    2022年10月18日
  • mybatis返回map结果集 key value_java map.entry

    mybatis返回map结果集 key value_java map.entry原文:http://blog.csdn.net/sou_liu/article/details/47755635最近需要用到Mybatis中查询结果集为Map的功能,查了好多资料,最终搞定。其实只需要重写ResultHandler接口,,然后用SqlSession的select方法,将xml里面的映射文件的返回值配置成HashMap就可以了。具体过程如下1、先看看

  • 漏洞挖掘丨敏感信息泄露+IDOR+密码确认绕过=账户劫持

    漏洞挖掘丨敏感信息泄露+IDOR+密码确认绕过=账户劫持获得账户auth_token目标网站是一个工作招聘门户网站,测试保密原因暂且称其为redacted.com。一开始,我登录以应聘者身份去测试CSRF或某些存储型XSS,但没什么发现。接下来,我就想到了越权测试(IDOR),为此,我又创建了另外一个账号,两个账号一起可以测试如注册、登录、忘记密码等功能点的越权可能。创建账号前我开启了流量抓包想看看具体服务端的响应,注册开始时,网站会跳出一个提示,…

  • java中int转long

    java中int转longpackagepid69;publicclassSolution{ publicstaticintmySqrt(intx){ intresult=0; if(x==0||x==1){ returnx; }else{ for(inti=0;i<=x/2;i++){ inta=i*i; //防止溢出,务必注意右边需…

  • SfM问题

    SfM问题StructurefromMotion(SfM)是一个估计相机参数及三维点位置的问题。SfM也就是三维重建

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号