Problem mit InputStream

[assix]

Hallo,

ich habe da seit ein paar Tagen ein Problem mit einem Studienprojekt.
Man soll einen Chat auf UDP-Basis programmieren der genauso sicher wie auf TCP-Basis ist.
Man soll also diverse Absicherungsmechanismen implementieren.

Dazu wurde mir ein Gerüst mit einigen Klassen und Interfaces gegeben.
Das Ding hab ich jetzt zu 80% fertig komme jetzt aber einfach nicht weiter.
Man hat uns auch eine MOCK gegeben die es ermöglicht Verbindungen auf TCP-Basis zu verwenden um die ChatAnwendung (Server und Client) unabhängig, von der später zu erstellenden UDP-Lösung, zu implementieren.

Das Problem:
Ich starte den Server der erst mal super funktioniert. Dieser wartet nun auf ankommende Verbindungen.
Dann starte ich einen ChatClienten. Dort muss man erst mal seinen usernamen eingeben und dann wird eine Verbindung zum Server aufgebaut. Bei einem Clienten funktioniert das wunderbar.
Sobald ich allerdings einen zweiten Clienten starte hängt sich der auf.
Da es etwas viel Code ist werde ich die relevanten Codeteile posten. Sollte etwas fehlen oder unübersichtlich wirken - bitte bescheid geben.

Auflistung der verwendeten Klassen in der Reihenfolge wo sie verwendet werden:

1. Client
2. ClientCommunicator
3. ChatClientServiceFactoryImpl
4. ChatClientServiceImpl
5. LWTRTServiceMock
6. MockLWTRTConnection

Ablauf mit Code Auszügen. Ich markiere mit einem Pfeil wo die nächste Klasse verwendet wird. Alles was darunter ist wird also gar nicht mehr ausgeführt.

Client

 public class Client{

 public Client() {
    communicator = new ClientCommunicator(this);
    showLoginFrame();
  }

 class LoginListener extends MouseAdapter {
    public void mouseClicked(MouseEvent e) {
      userName = nameField.getText();
     
      communicator.login(userName); <------------------------hier
    
      loginFrame.dispose();
      showChatFrame();
      //Poller thread = new Poller();
      //thread.start();
    }
  }
}

ClientCommunicator:

public class ClientCommunicator implements ChatClientListener{

public ClientCommunicator(Client gui) {
    try { 
    	factory =  new ChatClientServiceFactoryImpl();
    	chatClient = factory.register(50002);
     	this.gui = gui;
    	
    } 
    catch (Exception e) { e.printStackTrace(); }
  } 


  public void login(String name) {
    try {   	
    	
    	
    	chatClient.registerChatSessionListener(this);
		chatClient.create("127.0.0.1", 50000, name); <----------------hier
	} catch (ChatServiceException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	}
  }
}

ChatClientServiceImpl:

public class ChatClientServiceImpl extends BaseServiceImpl implements ChatClientService {
 public void create(String rcvAdd, int port, String name) throws ChatServiceException {
    	
    	if (currentStatus.equals(SessionStatus.NO_SESSION)) {
    		
			try {
				
				connection = LWTRTServiceMock.INSTANCE.connect(listenport,rcvAdd, port); <---------------------hier
				
				chatPdu = new ChatPdu();
				userName = name;
				chatPdu.setName(userName);
				
				chatPdu.setOpId(ChatOpId.createSession_req_PDU);
				connection.send(chatPdu);
				this.startPollerThreadIfNotRunning();
				
				currentStatus = SessionStatus.SESSION_ACTIVE;
				
			} catch (LWTRTException e) {
				
				throw new ChatServiceException(e);

			}
		} else{
			
			throw new ChatServiceException(
					"Keine Sessionaufbau, da bereits eine session vorhanden ist");
			
		}    

}
}

LWTRTServiceMock:

public class LWTRTServiceMock implements LWTRTService{
public LWTRTConnection connect(int localPort, String remoteAddress, int remotePort) throws LWTRTException {
        try {
        	log.debug("Connection from "+localPort+" to RemoteAdress: "+remoteAddress+":"+remotePort);
            return new MockLWTRTConnection(new Socket(remoteAddress, remotePort)); <-----------hier
        } catch (IOException e) {
            throw new LWTRTException(e);
        }

    }
}

MockLWTRTConnection:

public class MockLWTRTConnection implements LWTRTConnection {

 public MockLWTRTConnection(Socket socket) {
        this.socket = socket;
       [COLOR="Red"] retreiveStreamsIfConnected(socket);[/COLOR]
    }


private void retreiveStreamsIfConnected(Socket socket) {
        if (socket.isConnected()) {
            try {

                oout = new ObjectOutputStream(socket.getOutputStream());
            	oin = new ObjectInputStream(socket.getInputStream()); <--------------hier hängt er dann fest
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }

}

Mithilfe der Debugfunktion in Eclipse hab ich heraus gefunden das der bei oin hängen bleibt und wartet.
Das einzige was kurz zu sehen war der Wert ([toString() unavailable - no suspended threads]) der in oin gespeichert war. Sagt mir allerdings nichts.
oout funktioniert einwandfrei. Da wird ein ObjectOutputStream Objekt zugeodnet.

Woran kann das liegen? Wenn nur ein Client auf dem PC betrieben wird gehts einwandfrei. Nur wenn weitere Clienten gestartet werden pasiert das.
Braucht ihr noch weitere Informationen?

Beste Grüße

Assix

 

[sambalmueslie]

öhm .. bekommt jeder deiner clients einen eigenen port ??

könnte es vielleicht sein, dass der zweite Client sich versucht auf den selben port zu verbinden und dies nicht funktioniert, weil der belegt ist ..

nur mal so eine idee

gruß oli

 

[assix]

Hallo,

die Ports spielen momentan keine Rolle. Da die Verbindung momentan auf TCP basiert werden die Ports selbstständig vergeben.
die momentane Portangabe wird erst später relevant wenn ich das auf UDP-Basis mache und ich darauf achten muss das jeder Client einen unterschiedlichen Port haben sollte.

Da es schon spät ist habe ich sicherheitshalber mal unterschiedliche Ports bei den jeweiligen Clienten verwendet. Das Ergebnis war das selbe.

Beste Grüße,

Vangoo

 

[Spin]

Moinsen. Wieso spielen Ports bei eine TCP Verbindung keine Rolle?

Jedes Packet , dass sich den weg durch das Internet kämpft, bekommt eine Adresse und ein Schlupfloch.
Damit meine ich, dass auf einen Host unterschiedliche Server-Anwendungen laufen, die noch dazu von mehreren Clients genutzt werden. Um aber die Server zu unterscheiden , gibt es neben der adresse auch den Port.

Der Port ist eine Ebene höher als das TCP definiert.
Die hängen zusammen.


Nun aber zu deinen Programm. Arbeite mit Threads, denn deine Server klasse hatte probleme damit von mehreren Clienten Daten zu bekommen. Ein Thread ist ein leichtgewichtiger Prozess, mit dem du dann einfach senden und empfangen handhaen kannst.

 

[sambalmueslie]

Hm, kann dein Server überhaupt zwei Verbindungen ???

versuche dich doch mal zweimal mit Telnet auf den Server zu connecten.

Gruß oli