Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package UDP;
- import java.io.IOException;
- import java.net.DatagramPacket;
- import java.net.DatagramSocket;
- import java.net.InetAddress;
- import java.net.SocketException;
- import java.net.UnknownHostException;
- import java.util.Scanner;
- public class ClientUDP implements Runnable {
- private static InetAddress host;
- private static final int port = 1800;
- private static DatagramSocket datagramSocket;
- private static DatagramPacket inPacket, outPacket;
- private static byte[] buffer;
- private static Scanner userEntry;
- @Override
- public void run() {
- try {
- //On initialise la connexion côté client
- datagramSocket = new DatagramSocket();
- InetAddress adresse = InetAddress.getByName("127.0.0.1");
- userEntry = new Scanner(System.in);
- do {
- System.out.print("Enter message: ");
- String message = userEntry.nextLine();
- byte[] buffer = message.getBytes();
- //On crée notre datagramme
- outPacket = new DatagramPacket(buffer, buffer.length, adresse, port);
- //On lui affecte les données à envoyer
- outPacket.setData(buffer);
- //On envoie au serveur
- datagramSocket.send(outPacket);
- //Et on récupère la réponse du serveur
- byte[] buffer2 = new byte[8196];
- DatagramPacket inPacket = new DatagramPacket(buffer2, buffer2.length, adresse, port);
- datagramSocket.receive(inPacket);
- String response =
- new String(inPacket.getData(),
- 0, inPacket.getLength());
- System.out.println(
- "\nSERVER> "+response);
- }while (true);
- } catch (SocketException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } catch (UnknownHostException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- System.out.println(
- "\n* Closing connection... *");
- datagramSocket.close();
- }
- public static void main(String[] args){
- ClientUDP c1=new ClientUDP();
- Thread cli1=new Thread(c1);
- ClientUDP c2=new ClientUDP();
- Thread cli2=new Thread(c2);
- cli1.start();
- cli2.start();
- // new Thread(new ServerUDP()).start()
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement