JavaでUDP送信をシミュレートする送信側と受信側の例の詳細な説明

この記事は、Java での模擬 UDP 送信の送信側インスタンスと受信側インスタンスの詳細な説明に関する関連情報を主に紹介します。必要な方は、

Java での模擬 UDP 送信の送信側インスタンスと受信側インスタンスの詳細な説明を参照してください。

1. UDP 送信の送信側を作成します

1. UDP ソケット サービスを確立します

2. UDP 経由でデータ パケットを送信します。ソケット サービス

4. ソケット サービスを閉じます。

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

public class UDPSend {

 public static void main(String[] args) throws IOException {

  System.out.println("发送端启动......");

  // 1、创建UDP的Socket，使用DatagramSocket对象
  DatagramSocket ds = new DatagramSocket();

  // 2、将要发送的数据封装到数据包中
  String str = "UDP传输演示：I'm coming!";

  byte[] buf = str.getBytes(); //使用DatagramPacket将数据封装到该对象的包中

  DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.191.1"), 10000);

  // 3、通过UDP的Socket服务将数据包发送出去，使用send方法
  ds.send(dp);

  // 4、关闭Socket服务
  ds.close();
 }
}

2. UDP 送信の受信側を作成します

1. データを受信するため、データ パケットを作成する必要があります。受信したデータ。データを解析するには、データ パケット オブジェクト メソッドを使用すると便利です。

4 . データ パケット メソッドを通じてデータを解析します。

5. ソケット サービスを閉じます。

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class UDPReceive {
 public static void main(String[] args) throws IOException {

  System.out.println("接收端启动......");

  // 1、建立UDP的Socket服务
  DatagramSocket ds = new DatagramSocket(10000);

  // 2、创建数据包
  byte[] buf = new byte[1024];
  DatagramPacket dp = new DatagramPacket(buf, buf.length);

  // 3、使用接收方法将数据存储到数据包中
  ds.receive(dp); // 该方法为阻塞式的方法

  // 4、通过数据包对象的方法解析这些数据，例如：地址、端口、数据内容等
  String ip = dp.getAddress().getHostAddress();
  int port = dp.getPort();
  String text = new String(dp.getData(), 0, dp.getLength());

  System.out.println(ip + ":" + port + ":" + text);

  // 5、关闭Socket服务
  ds.close();
 }
}

3. UDP 送信の送信側と受信側を最適化します

最初の 2 つの部分では、一度に 1 つのメッセージしか送信 (または受信) できず、その後サービスをシャットダウンします。そのため、複数のメッセージを送信したい場合、送信側で送信内容を随時変更する必要があり、サーバーの再起動も必要となり、非常に面倒です。上記の欠点を克服するには、次のように最適化します。

1. 送信側で BufferedReader を作成し、キーボードからコンテンツを入力します。

2. ture) ループ、連続 ループでコンテンツを受信します。

/**
*优化UDP传输的发送端
*/
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class UDPSend {
 public static void main(String[] args) throws IOException {

  System.out.println("发送端启动......");

  // 创建UDP的Socket，使用DatagramSocket对象
  DatagramSocket ds = new DatagramSocket();

  BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
  String line = null;
  while ((line = bufr.readLine()) != null) {
   // 使用DatagramPacket将数据封装到该对象的包中
   byte[] buf = line.getBytes();
   DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.191.1"), 10000);
   // 通过UDP的Socket服务将数据包发送出去，使用send方法
   ds.send(dp);
   // 如果输入信息为over，则结束循环
   if ("over".equals(line))
    break;
  }
  // 关闭Socket服务
  ds.close();
 }
}

/**
*优化UDP传输的接收端
*/
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;

public class UDPReceive {
 public static void main(String[] args) throws IOException {

  System.out.println("接收端启动......");

  // 建立UDP的Socket服务
  DatagramSocket ds = new DatagramSocket(10000);

  while(true) {
   // 创建数据包
   byte[] buf = new byte[1024];
   DatagramPacket dp = new DatagramPacket(buf, buf.length);

   // 使用接收方法将数据存储到数据包中
   ds.receive(dp); // 该方法为阻塞式的方法

   // 通过数据包对象的方法解析这些数据，例如：地址、端口、数据内容等
   String ip = dp.getAddress().getHostAddress();

   int port = dp.getPort();
   String text = new String(dp.getData(), 0, dp.getLength());
   System.out.println(ip + ":" + port + ":" + text);
  }
 }
}

4. チャット ルームを作成します

UDP (ユーザー データグラム プロトコル) の関連プロパティに従って、対話型チャットの機能を実現するための UDP 送信プロトコルに基づいた単純なチャット ルームをさらに作成できます。
れぇぇぇぇぇぇぇ

以上がJavaでUDP送信をシミュレートする送信側と受信側の例の詳細な説明の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。