Prinzipanalyse des UDP-Verbindungsobjekts und Anwendungsbeispiele

Paket udp; 
 
importiere java.net.*; 
 
/** 
 * @Beschreibung UDP-Client-Programm, das zum Senden von Daten an den Server und zum Empfangen der Antwortinformationen des Servers verwendet wird * @author cuisuqiang 
 * @version 1.0 
 * @since <a href="mailto:[email protected]" rel="external nofollow" >[email protected]</a> 
 */ 
öffentliche Klasse UdpClientSocket { 
  /** 
   * Verbindungsobjekt */ 
  privater statischer DatagramSocket ds = null; 
  /** 
   * Adressobjekt */ 
  private statische SocketAddress-Adresse = null; 
   
  /** 
   * Testen Sie die Methode des Clients zum Senden von Paketen und Empfangen von Antwortinformationen*/ 
  öffentliche statische void main(String[] args) wirft Exception { 
    init(); 
    während(wahr){ 
      UdpClientSocket.send(address,"Hallo, Liebling!".getBytes()); 
      UdpClientSocket.receive(); 
      versuchen { 
        Thread.sleep(3 * 1000); 
      } Fang (Ausnahme e) { 
        e.printStackTrace(); 
      } 
    } 
  } 
   
  /** 
   * Initialisiere die Verbindung und Adresse */ 
  öffentliche statische Leere init(){ 
    versuchen { 
      ds = neuer DatagramSocket(8899); // Als Client an lokalen Port binden ds.setSoTimeout(2 * 1000); 
      Adresse = neue InetSocketAddress("127.0.0.1",3344); 
    } Fang (Ausnahme e) { 
      e.printStackTrace(); 
    } 
  } 
   
  /** 
   * Dateninformationen an den angegebenen Server senden */ 
  öffentliche statische void send(SocketAddress Adresse,Byte[] Bytes){ 
    versuchen { 
      DatagramPacket dp = neues DatagramPacket(Bytes, Bytes.Länge, Adresse); 
      ds.send(dp); 
    } Fang (Ausnahme e) { 
      e.printStackTrace(); 
    } 
  } 
 
  /** 
   * Vom angegebenen Server zurückgesendete Daten empfangen*/ 
  öffentliche statische Leere empfangen(){ 
    versuchen { 
      byte[] Puffer = neues Byte[1024]; 
      DatagramPacket dp = neues DatagramPacket(Puffer, Pufferlänge); 
      ds.empfangen(dp);    
      byte[] Daten = neues byte[dp.getLength()]; 
      System.arraycopy(dp.getData(), 0, Daten, 0, dp.getLength());  
      System.out.println("Serverantwortdaten: " + new String(data)); 
    } Fang (Ausnahme e) { 
      e.printStackTrace(); 
    } 
  } 
}

Paket udp;

importiere java.net.DatagramPacket;
importiere java.net.DatagramSocket;
importiere java.net.InetSocketAddress;
importiere java.net.SocketAddress;

/**
 * @Beschreibung der UDP-Dienstklasse * @Autor cuisuqiang
 * @version 1.0
 * @since [email protected]
 */
öffentliche Klasse UdpServerSocket {
	
	privater statischer DatagramSocket ds = null;
	private statische SocketAddress-Adresse = null;
	
	/**
	 * Testmethode */
	öffentliche statische void main(String[] args) wirft Exception {
		init();
		System.out.println("---->Dienst beginnt zu lauschen!<----");
		während (wahr) {
			UdpServerSocket.receive();
			UdpServerSocket.response(address,"Hallo, hast du gegessen?");
		}		
	}
	
	öffentliche statische Leere init(){
		versuchen {
			ds = neuer DatagramSocket(3344);
			ds.setSoTimeout(0);
			Adresse = neue InetSocketAddress("127.0.0.1",8899);
		} Fang (Ausnahme e) {
			e.printStackTrace();
		}
	}

	/**
	 * Datenpakete empfangen. Diese Methode führt zu einer Blockierung des Threads */
	öffentliche statische Leere empfangen() {
		versuchen {
			byte[] Puffer = neues Byte[1024];
			DatagramPacket-Paket = neues DatagramPacket (Puffer, Pufferlänge);
			ds.receive(Paket);
			String-Info = neuer String (Paket.getData(), 0, Paket.getLength());
			System.out.println("Informationen erhalten: " + info);
		} Fang (Ausnahme e) {
			e.printStackTrace();
		}
	}

	/**
	 * Senden Sie das Antwortpaket an den Anforderer */
	öffentliche statische void-Antwort (SocketAddress-Adresse, String-Info) {
		versuchen {
			DatagramPacket dp = neues DatagramPacket(info.getBytes(), info.getBytes().Länge, Adresse);
			dp.setData(info.getBytes());
			ds.send(dp);
		} Fang (Ausnahme e) {
			e.printStackTrace();
		}		
	}
}