Explication détaillée des exemples d'expéditeur et de récepteur de simulation de transmission UDP en Java

Cet article présente principalement des informations pertinentes sur les exemples détaillés de l'expéditeur et du destinataire de la transmission UDP simulée en Java. Les amis dans le besoin peuvent se référer à

L'expéditeur et le destinataire de la transmission UDP simulée en Java. Explication détaillée de l'instance de réception

1. Créer l'extrémité d'envoi de la transmission UDP

1. Établir le service UDP Socket

2. Encapsulez les données à envoyer dans un paquet de données

3. Envoyez le paquet de données via le service UDP Socket

4. le service Socket.

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. Créez une extrémité de réception pour la transmission UDP

1. Établissez un service UDP Socket. Parce que vous souhaitez recevoir des données, vous devez spécifier un port. nombre ;

2. Créez un paquet de données pour stocker les données reçues et faciliter l'analyse des données à l'aide de la méthode objet de paquet de données

3. La méthode de réception reçoit les données et les stocke dans le paquet de données ;

4. Analysez les données via la méthode du paquet de données

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. Optimiser les extrémités d'envoi et de réception de la transmission UDP

Étant donné que dans les deux premières parties, nous ne pouvons envoyer (ou recevoir) qu'un seul message à une fois, puis fermez le service ! Par conséquent, si nous voulons envoyer plusieurs messages, nous devons constamment modifier le contenu envoyé du côté expéditeur, et nous devons également redémarrer le serveur, ce qui est assez gênant. Afin de surmonter les lacunes ci-dessus, nous pouvons l'optimiser, à savoir :

1 Du côté de l'envoi, créez un BufferedReader et saisissez le contenu à partir du clavier ; 2. Du côté de la réception, ajoutez une boucle while(ture) pour recevoir en continu du contenu en boucle.

4. Créer une salle de discussion

/**
*优化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);
  }
 }
}

Selon les propriétés pertinentes d'UDP (User Datagram Protocol, User Datagram Protocol), nous pouvons en outre créer une salle de discussion Une salle de discussion simple basée sur le protocole de transmission UDP pour réaliser une fonction de discussion interactive.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!