Socket Server / Client Anwendung Manipulation von Objekten durch Server

[gamebreiti]

Hallo liebe Comunity,

ich möchte gern ein Kartenspiel über eine Server / Client - Anwendung laufen lassen. Das Grundgerüst läuft soweit.
Der Server nimmt mehrere Clients an und die Clients können bereits Nachrichten ( Objekte ) an den Server schicken und dieser schickt sie an alle verbundenen Clients zurück.
Nun meine Frage: Ist es möglich, ein vom Client eingetroffenes Objekt im Server zu manipulieren und dann weiter zu senden.
Bisher scheint es so zusein, dass die Manipulation erkannt wird und eine Exeption geworfen wird, weil das eingetroffene Objekt nicht dem weitergesendetem Objekt entspricht. Invalid Streamheader!!!! [ingendeine ID]
Mein Nachricht - Objekt implementiert Serializable....

Also ist es mit Client / Server Prinzip , prinzipiell möglich oder sollte man generell einen anderen Weg einschlagen ?

 

[gamebreiti]

Okay, vieleicht war meine Frage zu global.

Ich möchte im Server mehrere Clients aufnehmen. Der Server speichert sodann sie OutputStreams des ankommenden Clients in einer ArrayList. Nun soll er die Größe der ArrayList also (size()) an den Client zurücksenden der gerade der Liste hinzugefügt wurde. Beim 1. Client ist die Größe also 1, beim 2. Client ... 2 usw.....
Der Client speichert dieses int in einer Variable sitzplatz.
Doch jedesmal wenn ich das Object auslese und verändern möchte kommt eine Exeption Invalid Streamheader!!!! [ingendeine ID].

 

[VfL_Freak]

Moin,

ohne den entsprechenden Code können wir nur raten - allerdings tippe ich mal auf falsche Streamverwendung !!

Aber vlt. hilft Dir ja Google weiter ... da kommt ja einiges ....
https://www.google.de/search?q=inva...-8&oe=utf-8&gws_rd=cr&ei=nk23Va22KcLxUpTpkaAC

Gruß Klaus

 

[MisterBu]

Alle Objekte, die Serializable implementieren haben folgende ID:

  public static final long serialVersionUID = 0;

Die muß für das Objekt auf dem Server und auf dem Client gleich sein.

 

[gamebreiti]

Okay hier ein bisschen Code:

Serverseite:

package Programm;

import java.io.IOException;
import java.io_ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;

public class IskaarServer15 {
 
   ServerSocket ss;
   private int sitzplatz;

   //private ObjectInputStream reader;
 
   public static ArrayList <ObjectOutputStream> list_OOS;
   //private boolean goahead;
 
   public static void main(String[] args) {
   
     // eine Instanz der Klasse IskaarServer15 erzeugen
           IskaarServer15 server = new IskaarServer15();
           // Abfrage ob Server gestartet wurde
           if(server.runServer()){
             // warte auf Clients
             server.listenToClients();
           }
           else{
             // tue nix
           }
   }
   public void listenToClients() {
     // Endlos warten auf Clients und verarbeiten
     while(true){
       try {
         // hier wird auf Clients gewartet
         Socket client = ss.accept();
       
         /* neuen ObjectOutputStream erzeugen und den ObjectOutputStream
          * vom eingetroffenen Client darin speichern
          */
       
         ObjectOutputStream oos = new ObjectOutputStream(client.getOutputStream());
 
         // den zwischengespeicherten ObjectOutputStream des Clients der OOSListe hinzufügen
         list_OOS.add(oos);
         sitzplatz = list_OOS.size();
         oos.flush();
         // Ausgabe in der Konsole wievielter Client angemeldet ist
         System.out.println("Spieler " + list_OOS.size() + " wurde dem Spiel hinzugefügt");
         /* Eine neuen Thread für den eingetroffenen Client erzeugen und starten,
          * die Threads werden durch einen Handler verwaltet
          */
         Thread clientThread = new Thread(new ClientHandler(client,sitzplatz));
         clientThread.start();
       
       } catch (IOException e) {
         e.printStackTrace();
       }
     }
   
   }
   public boolean runServer() {
     try{
       ss = new ServerSocket(5555);
       System.out.println("Server wurde gestartet, und läuft auf Port: " + ss.getLocalPort());
       list_OOS = new ArrayList<ObjectOutputStream>();
     
     return true;
     }
     catch(IOException e){
       e.printStackTrace();
       return false;
     }
   }
 

}

Clientseite (Clienthandler):

package Programm;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.Socket;
import java.util.Iterator;


public class ClientHandler implements Runnable, Konstanten {
    // globale Variablen
    private Socket client;
    private int sitzplatz;
    private Setup s ;
    private ObjectInputStream ois;
   
   
    // hier wird festgelegt was ein Client tun kann**************************
    public ClientHandler(Socket client,int sitzplatz) {
        try {

            this.client = client;
            this.sitzplatz = sitzplatz;
           
            // hier wird alles gespeichert, was vom Client ankommt
            ois = new ObjectInputStream(client.getInputStream());
            sendBack(sitzplatz);
            } catch (IOException e) {
                e.printStackTrace();
            }
    }
    // Endlos - horchen ob was ankommt und an alle Clients zurück senden.
    @Override
    public void run() {
        Object message;
        try {
            message = (Object)client.getInputStream();
            try {
                message = ois.readObject();
            } catch (ClassNotFoundException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
        } catch (IOException e1){
            e1.printStackTrace();
        }
        try{
        while((message = ois.readObject()) != null){
            sendToAllClients(message);
        }
        }
        catch(Exception e){
           
        }
    }
    private void sendToAllClients(Object message) {
        // erzeugt einen Iterator der die Liste der ClientObjectOutputStream durchläuft
        Iterator<ObjectOutputStream> it = IskaarServer15.list_OOS.iterator();
       
        // hier wird die Liste solange durchlaufen bis kein Element enthalten ist
        while(it.hasNext()){
            // einen neuen ObjectOutputStream erzeugen und den ObjectOutputStream vom Client darin speichern
            ObjectOutputStream writer = (ObjectOutputStream)it.next();
            try {
                writer.writeObject(message);
                writer.flush();
                }
             catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    private void sendBack(int sitzplatz){
   
        // hier wird die Liste solange durchlaufen bis kein Element enthalten ist
               
    }
}

Das Objekt welches verschickt wird: (Setup)

package Programm;

import java.io.Serializable;
import java.util.ArrayList;

public class Setup implements Serializable{
   
    /**
     *
     */
    private static final long serialVersionUID = 1L;
   
    private ArrayList<String> deck = new ArrayList<String>();
    private int numbersOfPlayer;
    private int playerPos = 1;
    private String playerName;

    private String deckName = null;
   
    public Setup(int numbersOfPlayer,int playerPos,String deckName, ArrayList<String> deck, String playerName) {
        this.numbersOfPlayer = numbersOfPlayer;
        this.deck = deck;
        this.deckName  = deckName;
        this.playerName = playerName;
        this.playerPos = playerPos;
    }

    public String getPlayerName() {
        return playerName;
    }

    public ArrayList<String> getDeck() {
        return deck;
    }

    public int getNumbersOfPlayer() {
        return numbersOfPlayer;
    }

    public String getDeckName() {
        // TODO Auto-generated method stub
        return deckName ;
    }

    public int getPlayerPos() {
        return playerPos;
    }

    public void setPlayerPos(int playerPos) {
        this.playerPos = playerPos;
    }
   
}

Ich bin mir ziemlich sicher, dass das Objekt im Clienthandler manipuliert werden kann.

Wie macht man soetwas richtig.

Im oberen try / catch vom Clienthandler bekomme ich immer eine Cannot Cast Exeption, wenn ich das Objekt mit ois.readObject() auslese, also sowas hier mache.

    Object message;
        try {
            message = (Object)client.getInputStream();
            try {
                message = ois.readObject();
                Setup s = (Setup)message;
                s.setPlayerPos(sitzplatz);
               
            } catch (ClassNotFoundException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            
        } catch (IOException e1){
            e1.printStackTrace();
        }

 

[fhoffmann]

Folgendes sieht sehr komisch aus:

message = (Object)client.getInputStream();

 

[gamebreiti]

Und wie ist es richtig? Ersatzlos streichen??

Gruß Breiti

 

[VfL_Freak]

Und wie ist es richtig? Ersatzlos streichen??

Kommt drauf an ..... 🙄

 

[gamebreiti]

Okay ... also ich brauche ein message-Object um abzufragen, ob der ObjectinputStream null oder eben ungleich null ist, solange er ungleich null ist soll die message an alle Clients gesendet werden.

Ich habe auch schon versuch auf s != null (das ist das Setup - Objekt) zu überprüfen, aber dann bleibt er in der Schleife hängen.

Wie ist das jetzt? , wird der InputStream nach dem read()-Aufruf auf null gesetzt?? Also quasi reset() automatisch aufgerufen? Sodass der Inputstream wieder frei ist???

Oder hab ich das falsch verstanden?

 

[gamebreiti]

Ich glaube ich befrage nochmal meine Insel zu dieser speziellen Sache.

Aber Danke Schön!!!!! .... Ich habe die o.g. Codezeile im Clienthandler und im Client gelöscht.

Dann die update-Methode für den ersten Kontakt und dann in der Schleife nochmals aufegerufen und
siehe da, es funktioniert und KEINE Exeption mehr. Juhu.......

Handler:

public void run() {
        Object message;
        try {
            try {
              
                message = ois.readObject();
                s = (Setup)message;
                s.setPlayerPos(sitzplatz);
            } catch (ClassNotFoundException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
           
        } catch (IOException e1){
            e1.printStackTrace();
        }
        try{
        while((message = ois.readObject()) != null){
            s = (Setup)message;
            s.setPlayerPos(sitzplatz);
            sendToAllClients(s);
        }
        }

Client :

public void run() {
        // Endlos hören was vom Server ankommt
        Object message;
        try {
            try {
                message = ois.readObject();
                Setup s = (Setup)message;
        System.out.println("Spieler "+ s.getPlayerPos() + " setzt sich an den Tisch.");
      
            } catch (ClassNotFoundException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        } catch (IOException e1){
            e1.printStackTrace();
        }
        try{
            // wenn eine Nachricht vom Server kommt updaten
            while((message = ois.readObject()) != null){          
                update(message);
                }
          
          
        }
        catch(Exception e){
            e.printStackTrace();
        }
        sendToServer(true);
    }
  
}

Lieben Gruß Breiti