Codebeispiel für einen einfachen UDP-Server-Client

Paket udp;

importiere java.io.IOException;
importiere java.net.DatagramPacket;
importiere java.net.DatagramSocket;
importiere java.net.InetSocketAddress;

/**
 * UDP-Dienstklasse */
öffentliche Klasse UdpServerSocket {
	
	privater Byte[] Puffer = neues Byte[1024];
	privater statischer DatagramSocket ds = null;
	privates DatagramPacket-Paket = null;
	private InetSocketAddress socketAddress = null;
	
	/**
	 * Testmethode */
	öffentliche statische void main(String[] args) wirft Exception {
		Zeichenfolge serverHost = "127.0.0.1";
		int ServerPort = 3344;
		UdpServerSocket udpServerSocket = neuer UdpServerSocket(ServerHost,
				serverPort);
		während (wahr) {
			udpServerSocket.receive();
			udpServerSocket.response("Hallo, hast du gegessen?");
		}		
	}

	/**
	 * Konstruktor, Host und Port binden */
	öffentlicher UdpServerSocket(String host, int port) löst Ausnahme aus {
		socketAddress = neue InetSocketAddress(Host, Port);
		ds = neuer DatagramSocket(Socket-Adresse);
		System.out.println("Server gestartet!");
	}

	/**
	 * Datenpakete empfangen. Diese Methode führt zu einer Blockierung des Threads */
	public final String receive() wirft IOException {
		Paket = neues Datagrammpaket (Puffer, Pufferlänge);
		ds.receive(Paket);
		String-Info = neuer String (Paket.getData(), 0, Paket.getLength());
		System.out.println("Informationen erhalten: " + info);
		Rückgabeinfo;
	}

	/**
	 * Senden Sie das Antwortpaket an den Anforderer */
	öffentliche finale void-Antwort (String-Info) wirft IOException {
		System.out.println("Clientadresse: " + packet.getAddress().getHostAddress()
				+ ",port:" + packet.getPort());
		DatagramPacket dp = neues DatagramPacket(Puffer, Pufferlänge, Paket
				.getAddress(), Paket.getPort());
		dp.setData(info.getBytes());
		ds.send(dp);
	}
}

Paket udp;

importiere java.io.*;
importiere java.net.*;

/**
 * UDP-Client-Programm, das zum Senden von Daten an den Server und zum Empfangen der Antwortinformationen des Servers verwendet wird */
öffentliche Klasse UdpClientSocket {
	privater Byte[] Puffer = neues Byte[1024];

	privater statischer DatagramSocket ds = null;
	
	/**
	 * Testen Sie die Methode des Clients zum Senden von Paketen und Empfangen von Antwortinformationen */
	öffentliche statische void main(String[] args) wirft Exception {
		UdpClientSocket-Client = neuer UdpClientSocket();
		Zeichenfolge serverHost = "127.0.0.1";
		int ServerPort = 3344;
		client.send(serverHost, serverPort, ("Hallo, Liebling!").getBytes());
		byte[] bt = client.empfangen();
		System.out.println("Serverantwortdaten: " + new String(bt));
		// Schließen Sie die Verbindung try {
			ds.schließen();
		} Fang (Ausnahme ex) {
			Beispiel: printStackTrace();
		}
	}

	/**
	 * Konstruktor, UDP-Client erstellen */
	öffentliche UdpClientSocket() wirft Ausnahme {
		ds = neuer DatagramSocket(8899); // Als Client an lokalen Port binden }
	
	/**
	 * Dateninformationen an den angegebenen Server senden */
	öffentliche final void send(finaler String-Host, finaler int-Port,
			letztes byte[] bytes) wirft IOException {
		DatagramPacket dp = neues DatagramPacket (Bytes, Bytes.Länge, InetAddress.getByName (Host), Port);
		ds.send(dp);
	}

	/**
	 * Vom angegebenen Server zurückgesendete Daten empfangen */
	öffentliches letztes Byte[] empfangen()
			wirft Ausnahme {
		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());		
		Daten zurückgeben;
	}
}