Problem mit Chatprogramm

[Guest]

Hallo, ich habe versucht ein kleines Chatprogramm zu schreiben. Mein Problem ist jedoch, dass die Streams meine gesendeten Nachrichten nicht lesen. Z.b. wenn ich in ChatUI (Z.68) die Nachricht sende sollte sie in Connecter (Z.31) gelesen werden.
(Zum Test des Programms: Erst die Chatserver Klasse starten und dann ChatUI über eine kleine html-seite aufrufen). Ich hoffe ihr könnt mir mit meinem Problem helfen. Danke im voraus!

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

public class Chatserver implements Runnable{
	public static final int PORT = 3535;
	
	Socket client;
	ServerSocket host;
	Thread thread;
	Vector<Connecter> connections;
	
	public Chatserver(){
		try{
			host = new ServerSocket(PORT);
			connections = new Vector<Connecter>();
			thread = new Thread(this);
			thread.start();
		}
		catch(IOException exc){
			System.out.println("error while starting server");
		}
	}
	
	public void run(){
		System.out.println("starting server was successful");
		try{
			while(true){
				System.out.println("waiting for client...");
				client = host.accept();
				Connecter clientCon = new Connecter(client, this);
				connections.add(clientCon);
				System.out.println("new client: "+client.toString());
			}
		}
		catch(IOException exc){
			System.out.println("server error");
		}
	}
	
	public void distributeMessage(String message){
		for(int i=0; i<connections.size(); i++){
			Connecter tempCon = connections.get(i);
			tempCon.transmitMessage(message);
		}
	}
	
	public static void main(String[] args){
		Chatserver chatserver = new Chatserver();
	}
}

import java.net.*;
import java.io.*;
import javax.swing.*;
import java.awt.*;
import java.awt.event.*;

public class Connecter implements Runnable{
	Thread thread;
	Socket client;
	PrintStream dataOut;
	DataInputStream dataIn;
	Chatserver chatserver;
	
	public Connecter(Socket client, Chatserver chatserver){
		try{
			this.client = client;
			dataOut = new PrintStream(client.getOutputStream());
			dataIn = new DataInputStream(client.getInputStream());
			this.chatserver = chatserver;
			thread = new Thread(this);
			thread.start();
		}
		catch(IOException exc){
			System.out.println("error while initializing client");
		}
	}
	
	public void run(){
		try{
			while(true){
				String message = dataIn.readLine();
				chatserver.distributeMessage(message);
			}
		}
		catch(IOException exc){
			System.out.println("error with client");
		}
	}
	
	public void transmitMessage(String message){
		dataOut.println(message);
	}
}

import java.io.*;
import java.net.*;
import java.applet.Applet;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;

public class ChatUI extends JApplet implements ActionListener, Runnable{
	public static final int PORT = 3535;
	
	JTextArea textArea;
	JTextField textField;
	JButton sendButton;
	JPanel textPanel, messagePanel;
	
	Thread thread;
	Socket server;
	DataInputStream dataIn;
	PrintStream dataOut;
	
	public void init(){
		try{
			InetAddress address = InetAddress.getLocalHost();
			server = new Socket(address, PORT);
			dataIn = new DataInputStream(server.getInputStream());
			dataOut = new PrintStream(server.getOutputStream());
			Container cp = getContentPane();
			cp.setLayout(new BoxLayout(cp, BoxLayout.Y_AXIS));
			textArea = new JTextArea(16, 16);
			textArea.setEditable(false);
			textArea.setFont(new Font("Sanserif", Font.PLAIN, 12));
			textField = new JTextField(20);
			sendButton = new JButton("Senden");
			sendButton.addActionListener(this);
			textPanel = new JPanel();
			textPanel.setLayout(new GridLayout(1, 1));
			textPanel.add(new JScrollPane(textArea));
			messagePanel = new JPanel();
			messagePanel.setLayout(new FlowLayout());
			messagePanel.add(textField);
			messagePanel.add(sendButton);
			cp.add(textPanel);
			cp.add(messagePanel);
			thread = new Thread(this);
			thread.start();
		}
		catch(IOException exc){
			System.out.println("failed to build up connection to server");
		}
	}
	
	public void run(){
		textArea.append("*** Connection successful ***");
		try{
			while(true){
				String message = dataIn.readLine();
				textArea.append(message);
			}
		}
		catch(IOException exc){
			System.out.println("error with server");
		}
	}
	
	public void actionPerformed(ActionEvent evt){
		String cmd = evt.getActionCommand();
		if(cmd.equals("Senden")){
				dataOut.print(textField.getText());
				dataOut.flush();
		}
	}
}

 

[Gast]

versuchs mit println()

 

[Guest]

versuchs mit println()

ich glaube du hast nicht im geringsten begriffen worum es mir geht ... ich habe doch oben beschrieben wo mein problem liegt.

 

[Gast]

dataOut.print(textField.getText());

ersetzen mit

dataOut.println(textField.getText());


ich habe dein problem so verstanden, dass du etwas sendest, aber nie etwas bei "Connector" ankommt, oder?

 

[Guest]

dataOut.print(textField.getText());

ersetzen mit

dataOut.println(textField.getText());


ich habe dein problem so verstanden, dass du etwas sendest, aber nie etwas bei "Connector" ankommt, oder?

das macht keinen unterschied, warum sollte es auch? println heißt doch nur das in die nächste zeile gesprungen wird...

 

[Gast]

warum probierst du es denn nicht einfach aus?

 

[Guest]

warum probierst du es denn nicht einfach aus?

habe ich und es verändert sich nichts.warum sollte es deiner meinung nach funktionieren?

 

[SlaterB]

im Server liest du die Daten mit
> String message = dataIn.readLine();
das heißt es wird solange gewartet, bis der Client einen Zeilenumbruch, ein Enter, Return, \n schickt,
solange das nicht passiert, blockiert readLine()

mit print() schreibst du nur normalen Text, mit println() dagegen auch einen Zeilenumbruch

 

[Guest]

im Server liest du die Daten mit
> String message = dataIn.readLine();
das heißt es wird solange gewartet, bis der Client einen Zeilenumbruch, ein Enter, Return, \n schickt,
solange das nicht passiert, blockiert readLine()

mit print() schreibst du nur normalen Text, mit println() dagegen auch einen Zeilenumbruch

Mh, vielen Dank. Jedoch funktioniert es trotzdem noch nicht... warum wird die Nachricht nicht empfangen

 

[Gast]

dataIn = new DataInputStream(client.getInputStream());

ersetzen mit einem

dataIn = new BufferedReader(new InputStreamReader(client.getInputStream()));

natürlich die Deklaration entsprechend anpassen..

dann sollts mMn gehen..

hab aber auch noch nicht ganz durchgelesen

 

[SlaterB]

bei mir funktionierts auch mit DataInputStream, jedoch nicht als Applet, das mag ich gar nicht testen,
hier ist ein laufendes Test-Programm, starten, beobachten, fertig

import java.io.DataInputStream;
import java.io.IOException;
import java.io.PrintStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Vector;

public class Test {

	public static void main(String[] args) throws Exception {
		new Chatserver();
		new ChatUI().init();
	}
}

class Connecter implements Runnable {
	Thread thread;
	Socket client;
	PrintStream dataOut;
	DataInputStream dataIn;
	Chatserver chatserver;

	public Connecter(Socket client, Chatserver chatserver) {
		try {
			this.client = client;
			dataOut = new PrintStream(client.getOutputStream());
			dataIn = new DataInputStream(client.getInputStream());
			this.chatserver = chatserver;
			thread = new Thread(this);
			thread.start();
		} catch (IOException exc) {
			System.out.println("error while initializing client");
		}
	}

	public void run() {
		try {
			while (true) {
				String message = dataIn.readLine();
				chatserver.distributeMessage(message);
			}
		} catch (IOException exc) {
			System.out.println("error with client");
		}
	}

	public void transmitMessage(String message) {
		dataOut.println(message);
	}
}

class Chatserver implements Runnable {
	public static final int PORT = 3535;

	Socket client;
	ServerSocket host;
	Thread thread;
	Vector<Connecter> connections;

	public Chatserver() {
		try {
			host = new ServerSocket(PORT);
			connections = new Vector<Connecter>();
			thread = new Thread(this);
			thread.start();
		} catch (IOException exc) {
			System.out.println("error while starting server");
		}
	}

	public void run() {
		System.out.println("starting server was successful");
		try {
			while (true) {
				System.out.println("waiting for client...");
				client = host.accept();
				Connecter clientCon = new Connecter(client, this);
				connections.add(clientCon);
				System.out.println("new client: " + client.toString());
			}
		} catch (IOException exc) {
			System.out.println("server error");
		}
	}

	public void distributeMessage(String message) {
		for (int i = 0; i < connections.size(); i++) {
			Connecter tempCon = connections.get(i);
			tempCon.transmitMessage(message);
		}
	}

}

class ChatUI implements Runnable {
	public static final int PORT = 3535;

	Thread thread;
	Socket server;
	DataInputStream dataIn;
	PrintStream dataOut;

	public void init() {
		try {
			System.out.println("a");
			server = new Socket("localhost", PORT);
			System.out.println("b");
			dataIn = new DataInputStream(server.getInputStream());
			dataOut = new PrintStream(server.getOutputStream());

			thread = new Thread(this);
			thread.start();

			new Thread() {

				public void run() {
					for (int i = 0; i < 5; i++) {
						try {
							Thread.sleep(500);
						} catch (InterruptedException e) {
							e.printStackTrace();
						}
						System.out.println("Client: send Ping");
						dataOut.println("Ping");
					}
				}
			}.start();
		} catch (IOException exc) {
			System.out
					.println("Client: failed to build up connection to server");
		}
	}

	public void run() {
		System.out.println("Client: *** Connection successful ***");
		try {
			while (true) {
				String message = dataIn.readLine();
				System.out.println("Client: receive " + message);
			}
		} catch (IOException exc) {
			System.out.println("Client: error with server");
		}
	}

}