Java中的DatagramPacket与DatagramSocket的初步

Posted jdsjlzx

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Java中的DatagramPacket与DatagramSocket的初步相关的知识,希望对你有一定的参考价值。


1.基本概念:

  a.DatagramPacket与DatagramSocket位于java.net包中

  b.DatagramPacket表示存放数据的数据报,DatagramSocket表示接受或发送数据报的套接字

  c.由这两个类所有构成的网络链接是基于UDP协议,是一种不可靠的协议。

  之所以不可靠是因为发送方不负责数据是否发送成功,接收方收到数据时也不会   向发送方反馈成功消息,容易导致信息的丢失。

  但是这种协议却是快捷的,比如CS(半条命)游戏就是基于UDP协议,否则我们估计   要玩一次游戏后就会把机子砸了,所以我们可以看到游戏有时会失帧。

  2.使用方法:

  要建立基于UDP协议的链接,我们应该先建立套接字<DatagramSocket>(即发送站或接收站),之后通过套接字发送或接受数据<DatagramPacket>。

  我们先了解一下DatagramSocket和DatagramPacket类

  DatagramSocket类:

  构造方法:

  DatagramSocket():

  表示创建一个默认的套接字,并绑定到本地地址和一个随机的端口号

  DatagramSocket(int port):

  与上面不同的是,绑定到特定端口号,其它不变

  DatagramSocket(int port, InetAddress iad):

  表示创建一个套接字,绑定到特定的端口号及指定地址

  DatagramSocket(SocketAddress sad);

  表示创建一个套接字,绑定到特定的套接字地址

  小提示:所谓的本地地址我们可以这样来理解,我们通过“控制面板-本地连接-支持”中可以看到一个IP地址,这就是本地的IP地址,也暂且理解为本地地址。

  基本方法:

  close():

  关闭套接字

  recevie(DatagramPacket dp):

  接受数据报

  send(DatagramPacket dp):

 发送数据报

  这里触及了数据报,下面介绍数据报:

  DatagramPacket类:

  构造方法:(只列出主要的)

  接受类型:

  DatagramPacket(byte[] buf, int length):

  用来接受长度为length的buf数据(即数据存于字节数组buf中)

  发送类型:

  DatagramPacket(byte[] buf, int length, InetAddress address, int port);

  将length长的buf数据发送到指定的地址的端口号处

  DatagramPacket(byte[] buf, int length, SocketAddress address);

   将length长的buf数据发送到指定的套接字地址处

  有上面可知,我们发送数据时构造的数据报应该是发送类型的,而接受数据报时应该是接受类型的    

  开始书写代码

  代码意图:

  1.一个接收方,一个发送方

  2.当接收方收到发送方发送的消息后,打印发送的消息及发送方的地址和端口号,之后向发送反馈一条信息“接受方:我收到了!”

  3.发送方打印出接收方反馈的消息

  详细思路见代码:


​​view plain​​​
​​​copy to clipboard​​​
​​​print​​​
​​​?​​



1. import
2. import
3. import
4.
5. public class
6. public static void
7. try
8. // 创建发送方的套接字,IP默认为本地,端口号随机
9. new
10.
11. // 确定要发送的消息:
12. "你好!接收方!";
13.
14. // 由于数据报的数据是以字符数组传的形式存储的,所以传转数据
15. byte[] buf = mes.getBytes();
16.
17. // 确定发送方的IP地址及端口号,地址为本地机器地址
18. int port = 8888;
19. InetAddress ip = InetAddress.getLocalHost();
20.
21. // 创建发送类型的数据报:
22. new
23. port);
24.
25. // 通过套接字发送数据:
26. sendSocket.send(sendPacket);
27.
28. // 确定接受反馈数据的缓冲存储器,即存储数据的字节数组
29. byte[] getBuf = new byte[1024];
30.
31. // 创建接受类型的数据报
32. new
33.
34. // 通过套接字接受数据
35. sendSocket.receive(getPacket);
36.
37. // 解析反馈的消息,并打印
38. new String(getBuf, 0, getPacket.getLength());
39. "接受方返回的消息:"
40.
41. // 关闭套接字
42. sendSocket.close();
43. catch
44. e.printStackTrace();
45.
46.
47.
48.
49.
50.
51.
52. import
53. import
54. import
55. import
56.
57. public class
58. public static void
59. try
60. // 确定接受方的IP和端口号,IP地址为本地机器地址
61. InetAddress ip = InetAddress.getLocalHost();
62. int port = 8888;
63.
64. // 创建接收方的套接字,并制定端口号和IP地址
65. new
66.
67. // 确定数据报接受的数据的数组大小
68. byte[] buf = new byte[1024];
69.
70. // 创建接受类型的数据报,数据将存储在buf中
71. new
72.
73. // 通过套接字接收数据
74. getSocket.receive(getPacket);
75.
76. // 解析发送方传递的消息,并打印
77. new String(buf, 0, getPacket.getLength());
78. "对方发送的消息:"
79.
80. // 通过数据报得到发送方的IP和端口号,并打印
81. InetAddress sendIP = getPacket.getAddress();
82. int
83. "对方的IP地址是:"
84. "对方的端口号是:"
85.
86. // 通过数据报得到发送方的套接字地址
87. SocketAddress sendAddress = getPacket.getSocketAddress();
88.
89. // 确定要反馈发送方的消息内容,并转换为字节数组
90. "接收方说:我收到了!";
91. byte[] backBuf = feedback.getBytes();
92.
93. // 创建发送类型的数据报
94. new
95. backBuf.length, sendAddress);
96.
97. // 通过套接字发送数据
98. getSocket.send(sendPacket);
99.
100. // 关闭套接字
101. getSocket.close();
102. catch
103. e.printStackTrace();
104.
105.
106.

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class Sender
public static void main(String[] args)
try
// 创建发送方的套接字,IP默认为本地,端口号随机
DatagramSocket sendSocket = new DatagramSocket();

// 确定要发送的消息:
String mes = "你好!接收方!";

// 由于数据报的数据是以字符数组传的形式存储的,所以传转数据
byte[] buf = mes.getBytes();

// 确定发送方的IP地址及端口号,地址为本地机器地址
int port = 8888;
InetAddress ip = InetAddress.getLocalHost();

// 创建发送类型的数据报:
DatagramPacket sendPacket = new DatagramPacket(buf, buf.length, ip,
port);

// 通过套接字发送数据:
sendSocket.send(sendPacket);

// 确定接受反馈数据的缓冲存储器,即存储数据的字节数组
byte[] getBuf = new byte[1024];

// 创建接受类型的数据报
DatagramPacket getPacket = new DatagramPacket(getBuf, getBuf.length);

// 通过套接字接受数据
sendSocket.receive(getPacket);

// 解析反馈的消息,并打印
String backMes = new String(getBuf, 0, getPacket.getLength());
System.out.println("接受方返回的消息:" + backMes);

// 关闭套接字
sendSocket.close();
catch (Exception e)
e.printStackTrace();







import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketAddress;

public class Receive
public static void main(String[] args)
try
// 确定接受方的IP和端口号,IP地址为本地机器地址
InetAddress ip = InetAddress.getLocalHost();
int port = 8888;

// 创建接收方的套接字,并制定端口号和IP地址
DatagramSocket getSocket = new DatagramSocket(port, ip);

// 确定数据报接受的数据的数组大小
byte[] buf = new byte[1024];

// 创建接受类型的数据报,数据将存储在buf中
DatagramPacket getPacket = new DatagramPacket(buf, buf.length);

// 通过套接字接收数据
getSocket.receive(getPacket);

// 解析发送方传递的消息,并打印
String getMes = new String(buf, 0, getPacket.getLength());
System.out.println("对方发送的消息:" + getMes);

// 通过数据报得到发送方的IP和端口号,并打印
InetAddress sendIP = getPacket.getAddress();
int sendPort = getPacket.getPort();
System.out.println("对方的IP地址是:" + sendIP.getHostAddress());
System.out.println("对方的端口号是:" + sendPort);

// 通过数据报得到发送方的套接字地址
SocketAddress sendAddress = getPacket.getSocketAddress();

// 确定要反馈发送方的消息内容,并转换为字节数组
String feedback = "接收方说:我收到了!";
byte[] backBuf = feedback.getBytes();

// 创建发送类型的数据报
DatagramPacket sendPacket = new DatagramPacket(backBuf,
backBuf.length, sendAddress);

// 通过套接字发送数据
getSocket.send(sendPacket);

// 关闭套接字
getSocket.close();
catch (Exception e)
e.printStackTrace();


测试已通过

  先启动接收方,然后启动发送方即可


1.基本概念:

  a.DatagramPacket与DatagramSocket位于java.net包中

  b.DatagramPacket表示存放数据的数据报,DatagramSocket表示接受或发送数据报的套接字

  c.由这两个类所有构成的网络链接是基于UDP协议,是一种不可靠的协议。

  之所以不可靠是因为发送方不负责数据是否发送成功,接收方收到数据时也不会   向发送方反馈成功消息,容易导致信息的丢失。

  但是这种协议却是快捷的,比如CS(半条命)游戏就是基于UDP协议,否则我们估计   要玩一次游戏后就会把机子砸了,所以我们可以看到游戏有时会失帧。

  2.使用方法:

  要建立基于UDP协议的链接,我们应该先建立套接字<DatagramSocket>(即发送站或接收站),之后通过套接字发送或接受数据<DatagramPacket>。

  我们先了解一下DatagramSocket和DatagramPacket类

  DatagramSocket类:

  构造方法:

  DatagramSocket():

  表示创建一个默认的套接字,并绑定到本地地址和一个随机的端口号

  DatagramSocket(int port):

  与上面不同的是,绑定到特定端口号,其它不变

  DatagramSocket(int port, InetAddress iad):

  表示创建一个套接字,绑定到特定的端口号及指定地址

  DatagramSocket(SocketAddress sad);

  表示创建一个套接字,绑定到特定的套接字地址

  小提示:所谓的本地地址我们可以这样来理解,我们通过“控制面板-本地连接-支持”中可以看到一个IP地址,这就是本地的IP地址,也暂且理解为本地地址。

  基本方法:

  close():

  关闭套接字

  recevie(DatagramPacket dp):

  接受数据报

  send(DatagramPacket dp):

 发送数据报

  这里触及了数据报,下面介绍数据报:

  DatagramPacket类:

  构造方法:(只列出主要的)

  接受类型:

  DatagramPacket(byte[] buf, int length):

  用来接受长度为length的buf数据(即数据存于字节数组buf中)

  发送类型:

  DatagramPacket(byte[] buf, int length, InetAddress address, int port);

  将length长的buf数据发送到指定的地址的端口号处

  DatagramPacket(byte[] buf, int length, SocketAddress address);

   将length长的buf数据发送到指定的套接字地址处

  有上面可知,我们发送数据时构造的数据报应该是发送类型的,而接受数据报时应该是接受类型的    

  开始书写代码

  代码意图:

  1.一个接收方,一个发送方

  2.当接收方收到发送方发送的消息后,打印发送的消息及发送方的地址和端口号,之后向发送反馈一条信息“接受方:我收到了!”

  3.发送方打印出接收方反馈的消息

  详细思路见代码:



​view plain​​​ ​​​copy to clipboard​​​ ​​​print​​​ ​​​?​



    1. import
    2. import
    3. import
    4.
    5. public class
    6. public static void
    7. try
    8. // 创建发送方的套接字,IP默认为本地,端口号随机
    9. new
    10.
    11. // 确定要发送的消息:
    12. "你好!接收方!";
    13.
    14. // 由于数据报的数据是以字符数组传的形式存储的,所以传转数据
    15. byte[] buf = mes.getBytes();
    16.
    17. // 确定发送方的IP地址及端口号,地址为本地机器地址
    18. int port = 8888;
    19. InetAddress ip = InetAddress.getLocalHost();
    20.
    21. // 创建发送类型的数据报:
    22. new
    23. port);
    24.
    25. // 通过套接字发送数据:
    26. sendSocket.send(sendPacket);
    27.
    28. // 确定接受反馈数据的缓冲存储器,即存储数据的字节数组
    29. byte[] getBuf = new byte[1024];
    30.
    31. // 创建接受类型的数据报
    32. new
    33.
    34. // 通过套接字接受数据
    35. sendSocket.receive(getPacket);
    36.
    37. // 解析反馈的消息,并打印
    38. new String(getBuf, 0, getPacket.getLength());
    39. "接受方返回的消息:"
    40.
    41. // 关闭套接字
    42. sendSocket.close();
    43. catch
    44. e.printStackTrace();
    45.
    46.
    47.
    48.
    49.
    50.
    51.
    52. import
    53. import
    54. import
    55. import
    56.
    57. public class
    58. public static void
    59. try
    60. // 确定接受方的IP和端口号,IP地址为本地机器地址
    61. InetAddress ip = InetAddress.getLocalHost();
    62. int port = 8888;
    63.
    64. // 创建接收方的套接字,并制定端口号和IP地址
    65. new
    66.
    67. // 确定数据报接受的数据的数组大小
    68. byte[] buf = new byte[1024];
    69.
    70. // 创建接受类型的数据报,数据将存储在buf中
    71. new
    72.
    73. // 通过套接字接收数据
    74. getSocket.receive(getPacket);
    75.
    76. // 解析发送方传递的消息,并打印
    77. new String(buf, 0, getPacket.getLength());
    78. "对方发送的消息:"
    79.
    80. // 通过数据报得到发送方的IP和端口号,并打印
    81. InetAddress sendIP = getPacket.getAddress();
    82. int
    83. "对方的IP地址是:"
    84. "对方的端口号是:"
    85.
    86. // 通过数据报得到发送方的套接字地址
    87. SocketAddress sendAddress = getPacket.getSocketAddress();
    88.
    89. // 确定要反馈发送方的消息内容,并转换为字节数组
    90. "接收方说:我收到了!";
    91. byte[] backBuf = feedback.getBytes();
    92.
    93. // 创建发送类型的数据报
    94. new
    95. backBuf.length, sendAddress);
    96.
    97. // 通过套接字发送数据
    98. getSocket.send(sendPacket);
    99.
    100. // 关闭套接字
    101. getSocket.close();
    102. catch
    103. e.printStackTrace();
    104.
    105.
    106.

    import java.net.DatagramPacket;
    import java.net.DatagramSocket;
    import java.net.InetAddress;

    public class Sender
    public static void main(String[] args)
    try
    // 创建发送方的套接字,IP默认为本地,端口号随机
    DatagramSocket sendSocket = new DatagramSocket();

    // 确定要发送的消息:
    String mes = "你好!接收方!";

    // 由于数据报的数据是以字符数组传的形式存储的,所以传转数据
    byte[] buf = mes.getBytes();

    // 确定发送方的IP地址及端口号,地址为本地机器地址
    int port = 8888;
    InetAddress ip = InetAddress.getLocalHost();

    // 创建发送类型的数据报:
    DatagramPacket sendPacket = new DatagramPacket(buf, buf.length, ip,
    port);

    // 通过套接字发送数据:
    sendSocket.send(sendPacket);

    // 确定接受反馈数据的缓冲存储器,即存储数据的字节数组
    byte[] getBuf = new byte[1024];

    // 创建接受类型的数据报
    DatagramPacket getPacket = new DatagramPacket(getBuf, getBuf.length);

    // 通过套接字接受数据
    sendSocket.receive(getPacket);

    // 解析反馈的消息,并打印
    String backMes = new String(getBuf, 0, getPacket.getLength());
    System.out.println("接受方返回的消息:" + backMes);

    // 关闭套接字
    sendSocket.close();
    catch (Exception e)
    e.printStackTrace();







    import java.net.DatagramPacket;
    import java.net.DatagramSocket;
    import java.net.InetAddress;
    import java.net.SocketAddress;

    public class Receive
    public static void main(String[] args)
    try
    // 确定接受方的IP和端口号,IP地址为本地机器地址
    InetAddress ip = InetAddress.getLocalHost();
    int port = 8888;

    // 创建接收方的套接字,并制定端口号和IP地址
    DatagramSocket getSocket = new DatagramSocket(port, ip);

    // 确定数据报接受的数据的数组大小
    byte[] buf = new byte[1024];

    // 创建接受类型的数据报,数据将存储在buf中
    DatagramPacket getPacket = new DatagramPacket(buf, buf.length);

    // 通过套接字接收数据
    getSocket.receive(getPacket);

    // 解析发送方传递的消息,并打印
    String getMes = new String(buf, 0, getPacket.getLength());
    System.out.println("对方发送的消息:" + getMes);

    // 通过数据报得到发送方的IP和端口号,并打印
    InetAddress sendIP = getPacket.getAddress();
    int sendPort = getPacket.getPort();
    System.out.println("对方的IP地址是:" + sendIP.getHostAddress());
    System.out.println("对方的端口号是:" + sendPort);

    // 通过数据报得到发送方的套接字地址
    SocketAddress sendAddress = getPacket.getSocketAddress();

    // 确定要反馈发送方的消息内容,并转换为字节数组
    String feedback = "接收方说:我收到了!";
    byte[] backBuf = feedback.getBytes();

    // 创建发送类型的数据报
    DatagramPacket sendPacket = new DatagramPacket(backBuf,
    backBuf.length, sendAddress);

    // 通过套接字发送数据
    getSocket.send(sendPacket);

    // 关闭套接字
    getSocket.close();
    catch (Exception e)
    e.printStackTrace();


    测试已通过

      先启动接收方,然后启动发送方即可

    以上是关于Java中的DatagramPacket与DatagramSocket的初步的主要内容,如果未能解决你的问题,请参考以下文章

    UDP中使用的DatagramPacket

    java实现UDP通信

    将字符串与字符串进行比较(DatagramPacket 中的字节数组)

    需要将字节数组/二进制消息从 UDP DatagramPacket 转换为 java 中的几个字段

    Java,DatagramPacket接收,如何判断本地ip接口

    试着用java实现DNS——DatagramSocket, DatagramPacket, Message