Chatprogramm über udp

[peter75]

hi,

habe hier das beispielprogramm für ein chatprogramm für tcp gefunden interessiere mich aber sehr für eine udp verbindung finde leider nur nichts dazu. wer kann mir hilfreiche tips geben?
ist es schwer das vorhande tcp zu udp zu schreiben? kann mir jemand vielleicht dabei helfen?

gruß

peter

 

[Gast]

naja udp is eigentlich noch einfacher, weil man die packete ja einfach nur losschickt und dann hofft, dass sie ankommen.

bei nem chat is das aber eigentlich recht doof

http://www.vorlesungen.uos.de/informatik/vs01/html/skript-47.html

 

[Peter75]

hallo,

habe hier ein programm mit tcp, dass berichte in einer map zwischenspeichert, wenn der andere nicht gerade online ist, aber die gespeicherten nachrichten sofort in reihenfolge(linkedlist) versendete fall er sich anmeldet. hätte einer lust und zeit mir zu helfen und das prog für udp umzuschreiben. sollte meines erachtens nicht so schwierig sein, wenn man es kann. nur für mich ist das alles nicht so verständlich. :-(

import java.net.*;
import java.io.*;

public class Client {

   public Client() {}

   private void startClient() throws Exception {
	   
      Socket socket;
      String naam; 
      String ontvanger = null;
      String tekst = null;
      ObjectOutputStream out;
      BufferedReader strIn = new BufferedReader(new InputStreamReader(System.in));
      Bericht bericht;
      
      socket = new Socket("127.0.0.1", 4444);
      out = new ObjectOutputStream(socket.getOutputStream());
      System.out.println("\n\nClient gestart...\n\n");     
      
      naam = null;     
      while (naam == null || naam.equals("")) {
         System.out.print("Gebruikernaam ingeven: ");
         naam = strIn.readLine();
      }
      out.writeObject(naam);
      out.flush();
     
      new ClientDraad(new ObjectInputStream(socket.getInputStream())).start();           
      
      pause();
      System.out.print("\nOntvangernaam ingeven: ");
      while (!(ontvanger = strIn.readLine()).equals("stop")) { 
    	  if(ontvanger == null || ontvanger.equals("")) {
    		  System.out.print("\nOngeldige invoer! Ontvangernaam nog een keer ingeven: ");
    		  ontvanger = null;
    	  }
    	  else {
    		  while (tekst == null) {
    			  System.out.print("\nTekst aan de ontvanger ingeven: ");
    			  tekst = strIn.readLine();
    		  }
    		  bericht = new Bericht(naam, ontvanger, tekst);        	 
    		  out.writeObject(bericht);
    		  out.flush();
    		  tekst = null;
    		  System.out.print("\nOntvangernaam ingeven: ");
    	  } 
      }
      System.out.println("\n\nClient gestopt...\n\n");
      out.close();
   }

   
   public void pause() {
       try {
           Thread.sleep(100);
       }
       catch(InterruptedException e) {
           System.out.println("Exception occurred: " + e);
       }
   } 
   
   
   public static void main(String[] x) throws Exception {
	   
	   new Client().startClient();   
   }
}

import java.net.*;
import java.util.*;

public class Server {

   private HashMap <String, ServerDraad>clients;  
   private TreeMap <String, Bericht>berichten;
   
   
   public Server() {
      clients = new HashMap<String, ServerDraad>();
      berichten = new TreeMap<String, Bericht>();
   }
   
   
   private void startServerListener() {
      ServerSocket ss ;
      try {
         ss = new ServerSocket(4444);
         System.out.println("Server gestartet...");
         while (true) {
            new ServerDraad(ss.accept(), this, berichten).start();  
         }
      } catch (Exception e) {
        // e.printStackTrace();
      }
   }   
   
   
   public TreeMap geefBerichten(){
	   return berichten;
   }
   
   
   public void voegGebruikerToe(String naam, ServerDraad draad) {
	   clients.put(naam, draad);
   }
   
   
   public void removeClient(String naam) {
	   clients.remove(naam);
   }
   
   
   public String geefGebruikers() {
      String gebruikers = "\n==>Aangemeldde gebruiker: ";
     
      for (String gebruikernaam : clients.keySet()){
    	  if(!gebruikers.equals("\n==>Aangemeldde gebruiker: ")) {
    		  gebruikers += ", ";
    	  }
    	  gebruikers += gebruikernaam;
      }
      return gebruikers;     
   }
   
   
   public void broadcast(String name, String msg) throws Exception {
	   for (ServerDraad client : clients.values()) {
		   client.send(name + msg);  
	   }
   }
   
   
   public void send(String timeStemp, String naam, String ontvanger, String msg) throws Exception {
      if(bestaanOfflineberichtenVoorClient(ontvanger)) {
    	  clients.get(ontvanger).send("\n<" + timeStemp + "> ==>Ingang van " + naam + ": " + msg); 
      }
      else {
    	  clients.get(ontvanger).send("\n<" + timeStemp + "> ==>Ingang van " + naam + ": " + msg + "\n\nOntvangernaam ingeven: ");
      }
   }
   
   
   public boolean isClient(String name) {
      return clients.containsKey(name);
   }
   
   
   public void verstuurOfflineBerichten(String clientNaam) {
	   	
	   for(Bericht bericht : berichten.values()) {
		   if(bericht.getOntvanger().equalsIgnoreCase(clientNaam)) {
			   try {
				   send(bericht.getDatumEnTijd(), bericht.getEigenNaam(), bericht.getOntvanger(), bericht.getTekst());
				   System.out.println("Offlinebericht:<" + bericht.getDatumEnTijd() + "> Gebruiker " + bericht.getEigenNaam() + " schrijft aan " + bericht.getOntvanger() + ": " + bericht.getTekst());
				   berichten.remove(bericht);
			   }
			   catch(Exception e) {}
		   }
	   }
   }
   
   public boolean bestaanOfflineberichtenVoorClient(String naam) {
	   
	   boolean bestaat = false;
	   
	   for(Bericht bericht : berichten.values()) {
		   if(bericht.getOntvanger().equalsIgnoreCase(naam)) {
			   bestaat = true;
		   }
	   }
	   return bestaat;
   }
   
   
   public static void main(String[] x) {   
 
      new Server().startServerListener();
   }
}

import java.io.*;

class ClientDraad extends Thread {
	
   private ObjectInputStream in;
   
   
   public ClientDraad(ObjectInputStream in) {
	   this.in=in;
   }

   public void run() {
	   
	   String string;
	   
	   try {
		   while((string = (String)in.readObject()) != null) {           
			   System.out.println(string);                   
		   }
	   }
	   catch (Exception e) {}
   }
}

import java.net.*;
import java.util.TreeMap;
import java.io.*;

class ServerDraad extends Thread {

   private Socket cs;
   private Server server;
   private TreeMap <String, Bericht>berichten;
   private ObjectOutputStream out;
   private ObjectInputStream in;

   
   public ServerDraad(Socket cs, Server server, TreeMap <String, Bericht>berichten) {
      this.cs=cs;
      this.server=server;
      this.berichten=berichten;
   }

   public void run() {
      
	   String timeStemp;
	   String naam;
	   String ontvanger;
	   String tekst = null;
      
      try {    
         in = new ObjectInputStream(cs.getInputStream());
         out = new ObjectOutputStream(cs.getOutputStream());
         naam = (String)in.readObject();  
         if(!server.isClient(naam)) {
        	 server.voegGebruikerToe(naam, this);         
        	 server.broadcast("", server.geefGebruikers());
        	 System.out.println("+ Gebruiker " + naam + " heeft zich aangemeld!"); 
        	 server.verstuurOfflineBerichten(naam);
         
        	 for (Bericht bericht; (bericht = (Bericht)in.readObject()) != null;) {
        		 timeStemp = bericht.getDatumEnTijd();
        		 ontvanger = bericht.getOntvanger();
        		 tekst = bericht.getTekst();
            
        		 if (server.isClient(ontvanger)) {
        			 server.send(timeStemp, naam, ontvanger, tekst);
        			 System.out.println("<" + timeStemp + "> Gebruiker " + naam + " schrijft aan " + ontvanger + ": " + tekst);
        		 } 
        		 else {
        			 berichten.put(bericht.getDatumEnTijd(), bericht);
        			 this.send("<" + timeStemp + "> Server: Gebruiker " + ontvanger + " is niet online! Bericht opgeslagen!");
        		 }
        	 }
        	 server.removeClient(naam);
        	 System.out.println("- Gebruiker " + naam + " heeft zich afgemeld!");
        	 in.close();
        	 out.close();               
         }
         else {
     	  	System.out.println("Gebruiker " + naam + " afgewezen! Naam al in gebruik!");
     	  	//++Message aan client
     	  	in.close();
     	  	out.close();
         } 
      }
      catch (Exception e) {
        	 e.printStackTrace();
      }
   }

   
   public void send(String msg) throws Exception {
	   out.writeObject(msg);
	   out.flush();
   }
}

import java.io.*;
import java.util.*;
import java.text.*;

public class Bericht implements Serializable {
    
	private String eigenNaam;
	private String ontvanger;
    private String msg;
    private String datumEnTijd;
	
     
    public Bericht(String name, String targetname, String msg) {
       	this.eigenNaam = name;
    	this.ontvanger = targetname;
    	Date now = new Date();
    	SimpleDateFormat sdf = new SimpleDateFormat ("yyyy-MM-dd HH:mm:ss");
    	String dnow = sdf.format(now);
        this.datumEnTijd = dnow;;
    	this.msg = msg;         	
    }
    
      
    public String getOntvanger() {
    	return ontvanger;
    }
    
    public String getTekst() {
        return msg;
    }
  
    public String getEigenNaam() {
    	return eigenNaam;
    }
      
    public String getDatumEnTijd() {
    	return datumEnTijd;
    }
}

gruß

peter

 

[LoN_Nemesis]

Bei UDP gibt es keine "Verbindung", wie gesagt schickst du die Pakete einfach los und hoffst dass sie ankommen.