Socket Java Chat - Verbindung zum Server fehlgeschlagen.

[haui95]

Guten Tag,

ich habe gestern damit angefangen einen Java Chat zu porgrammieren. Dafür benutze ich ein Applet und eine HTML Datei. Nun habe ich zwei Probleme. Das erste Problem ist, dass mein Programm keine Verbindung zum Server herstellen kann, und ich auch nicht wirklich weiß, wie ich ein Applet debuggen kann. Das zweite Problem ist, dass wenn ich meine HTML Datei zweimal im Browser aufrufe, sodas ich zwei Registerkarten mit dem gleichen Applet habe (Sender und Empfänger), das Programm eine BindException wirft.

ChatServer.java

import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.logging.Level;
import java.util.logging.Logger;

public class ChatServer implements Runnable {

    static int port = 8888;
    static String server = "127.0.0.1";
    ServerSocket servSock;
    ArrayList<ConnectionThread> connections;
    Thread connect;

    public ChatServer() {
        try {
            servSock = new ServerSocket(port);
        } catch (Exception ex) {
            return;
        }

        connections = new ArrayList<>();
        
        connect = new Thread(this);
        connect.start();
    }

    @Override
    public void run() {
        try {
            while (true) {
                Socket client = servSock.accept();

                ConnectionThread ct = new ConnectionThread(this, client);
                connections.add(ct);
            }
        } catch (Exception ex) {
        }
    }

    public void broadcast(String message) {
        int i;
        ConnectionThread user;

        for (i = 0; i < connections.size(); i++) {
            user = (ConnectionThread) connections.get(i);
            try {
                user.output.writeUTF(message);
            } catch (Exception ex) {
                Logger.getLogger(ChatServer.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
    }

    public String getActivationMessage() {
        return "Der Server wurde erfolgreich konfiguriert.";
    }

    public static void main(String[] args) {
        new ChatServer();
    }
}

ConnectionThread.java

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;

public class ConnectionThread extends Thread {

    Socket client;
    DataInputStream input;
    DataOutputStream output;
    ChatServer server;

    public ConnectionThread(ChatServer server, Socket client) throws IOException {
        this.server = server;
        this.client = client;

        try {
            input = new DataInputStream(client.getInputStream());
            output = new DataOutputStream(client.getOutputStream());
        } catch (Exception e) {
            try {
                client.close();
            } catch (Exception ex) {
                return;
            }
        }

        this.start();
    }

    @Override
    public void run() {
        String line;

        try {
            while (true) {
                line = input.readUTF();
                if (line != null) {
                    server.broadcast(line);
                }
            }
        } catch (Exception ex) {
        }
    }
}

ChatAppletForm.java

import java.awt.EventQueue;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.lang.reflect.InvocationTargetException;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.swing.JApplet;
import javax.swing.UIManager;

public class ChatAppletForm extends JApplet implements Runnable {

    int port;
    String server;
    Socket socket;
    DataInputStream input;
    DataOutputStream output;
    Thread thread;

    @Override
    public void init() {
        try {
            UIManager.setLookAndFeel(UIManager.getSystemLookAndFeelClassName());
        } catch (ClassNotFoundException | InstantiationException | IllegalAccessException | javax.swing.UnsupportedLookAndFeelException ex) {
            java.util.logging.Logger.getLogger(ChatAppletForm.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        }

        try {
            EventQueue.invokeAndWait(new Runnable() {
                @Override
                public void run() {
                    initComponents();
                    try {
                        printMessage(new ChatServer().getActivationMessage());
                        port = ChatServer.port;
                        server = ChatServer.server;
                    } catch (Exception ex) {
                        printMessage("Fehler beim Konfigurieren des Servers.");
                    }
                }
            });
        } catch (InterruptedException | InvocationTargetException ex) {
        }
    }

    @SuppressWarnings("unchecked")
    
    private void sendBtnActionPerformed(java.awt.event.ActionEvent evt) {
        if (!inputEdit.getText().equals("")) {
            String in = inputEdit.getText();
            try {
                if (output != null) {
                    output.writeUTF(in);
                }
            } catch (Exception ex) {
                Logger.getLogger(ChatAppletForm.class.getName()).log(Level.SEVERE, null, ex);
            }
            inputEdit.setText("");
        }
    }
    // Variables declaration - do not modify
    private javax.swing.JTextField inputEdit;
    private javax.swing.JTextArea outputArea;
    private javax.swing.JPanel panel1;
    private javax.swing.JScrollPane scrollPane1;
    private javax.swing.JButton sendBtn;
    // End of variables declaration

    @Override
    public void start() {
        try {
            socket = new Socket(server, port);
            input = new DataInputStream(socket.getInputStream());
            output = new DataOutputStream(socket.getOutputStream());
            printMessage("Verbindung zum Server hergestellt...");
        } catch (Exception ex) {
            this.showStatus(ex.toString());
            printMessage("Verbindung zum Server fehlgeschlagen.");
            return;
        }

        if (thread == null) {
            thread = new Thread(this);
            thread.setPriority(Thread.MIN_PRIORITY);
            thread.start();
        }
    }

    @Override
    public void stop() {
        try {
            socket.close();
        } catch (Exception ex) {
            this.showStatus(ex.toString());
        }

        if ((thread != null) && thread.isAlive()) {
            thread.interrupt();
            thread = null;
        }
    }

    public void printMessage(String msg) {
        outputArea.append("*** " + msg + " ***\n");
    }

    @Override
    public void run() {
        String line;

        try {
            while (true) {
                line = input.readUTF();
                if (line != null) {
                    outputArea.append(line + '\n');
                }
            }
        } catch (Exception ex) {
            printMessage("Verbindung zum Server abgebrochen.");
        }
    }
}

Vielen Dank im Voraus !

MfG

Hauke

 

[L-ectron-X]

Schau mal in die FAQ, da gibts ein Beispiel zu einem Java-Chat.

 

[haui95]

Ich habe mir das Tutorial schon einmal angeschaut und mein Programm auf Basis von diesem geschrieben, jedoch wundert es mich, dass er keine Verbindung herstellen kann und eine BindException bei zwei geöffneten Registerkarten für Sender und Empfänger wirft.

public ChatServer() {
        try {
            servSock = new ServerSocket(port);  // Hier wird die Exception geworfen, sobald ich die HTML Seite neu lade oder eine weitere Seite im Browser öffne.
        } catch (Exception ex) {
            return;
        }
 
        connections = new ArrayList<>();
        
        connect = new Thread(this);
        connect.start();
    }

 

[Templarthelast]

Hast du die Jar zertifiziert bzw. welcher Fehler tritt genau auf?

 

[Gast2]

} catch (Exception ex) {
    return;
}

Lass dir hier auf jedenfall die Exception ausgeben, da findest du dann mit Sicherheit mehr Informationen dazu was schief gelaufen ist.

 

[jnetdev]

Was bitte hat denn
[java=34]new ChatServer()[/code]
im Client zu suchen ?

Du hast da einiges ziemlich missverstanden.

Der Server läuft unabhängig vom Applet und hat mit diesem überhaupt nichts zu tun. Außerdem darf ein Applet auch gar kein ServerSocket öffnen und sollte daher ohne Signatur eh eine SecurityException auslösen die alleine schon das Laden des Applets verhindert.

Hier ein einfaches, funktionsfähiges Beispiel :

Server.java

import java.io.*;
import java.net.*;
import java.util.*;
public class Server
{
	private ServerSocket serverSocket=null;
	private Vector<ClientRunnable> clients=null;
	private static Server server=null;
	public static void main(String[] args)
	{
		System.out.println("start-up chat-server");
		server=new Server();
		server.startup();
		System.out.println("start-up complete");
	}
	private Server()
	{
		System.out.print("try to create ServerSocket ... ");
		try
		{
			serverSocket=new ServerSocket(12345);
		}
		catch(Exception e)
		{
			System.out.println("failed to create ServerSocket");
			e.printStackTrace();
			System.exit(1);
		}
		System.out.println("ok");
		clients=new Vector<ClientRunnable>();
	}
	private void startup()
	{
		System.out.print("setting up accept-thread ... ");
		Thread thread=new Thread(new Runnable()
		{
			public void run()
			{
				while(true)
				{
					try
					{
						Socket client=serverSocket.accept();
						ClientRunnable clientRunnable=new ClientRunnable(server, client);
						(new Thread(clientRunnable)).start();
						clients.add(clientRunnable);
					}
					catch(Exception e)
					{
						System.out.println("failed to accept client");
						e.printStackTrace();
					}
				}
			}
		});
		System.out.println("ok");
		System.out.println("starting accept-thread");
		thread.start();
	}
	protected void broadcast(String msg)
	{
		for(ClientRunnable client : clients)
		{
			client.send(msg);
		}
	}
	protected void disconnect(ClientRunnable client)
	{
		clients.remove(client);
	}
}

ClientRunnable.java

import java.io.*;
import java.net.*;
class ClientRunnable implements Runnable
{
	private Server server=null;
	private Socket socket=null;
	private BufferedReader in=null;
	private PrintStream out=null;
	protected ClientRunnable(Server server, Socket socket)
	{
		this.server=server;
		this.socket=socket;
	}
	public void run()
	{
		try
		{
			in=new BufferedReader(new InputStreamReader(socket.getInputStream()));
			out=new PrintStream(socket.getOutputStream());
		}
		catch(Exception e)
		{
			System.out.println("cant get client-streams");
			e.printStackTrace();
			return;
		}
		String line="";
		while(true)
		{
			try
			{
				line=in.readLine();
				if(line==null)
				{
					break;
				}
				if(line.equals(""))
				{
					continue;
				}
				if(line.equals("DC"))
				{
					break;
				}
				server.broadcast(line);
			}
			catch(Exception e)
			{
				System.out.println("failed to read message");
				e.printStackTrace();
			}
		}
		try
		{
			in.close();
			out.close();
			socket.close();
		}
		catch(Exception e)
		{
			System.out.println("cant close streams/socket");
			e.printStackTrace();
		}
		server.disconnect(this);
	}
	protected void send(String msg)
	{
		try
		{
			out.println(msg);
		}
		catch(Exception e)
		{
			System.out.println("cant send message");
			e.printStackTrace();
		}
	}
}

ClientApplet.java

import java.io.*;
import java.net.*;
import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
public class ClientApplet extends JApplet
{
	private Socket socket=null;
	private BufferedReader in=null;
	private PrintStream out=null;
	private JTextField jTextField=null;
	private JTextArea jTextArea=null;
	public ClientApplet()
	{
		setLayout(new BorderLayout());
		setBackground(Color.LIGHT_GRAY);
		setForeground(Color.BLACK);
	}
	public void init()
	{
		jTextField=new JTextField();
		jTextField.setBackground(Color.WHITE);
		jTextField.addActionListener(new ActionListener()
		{
			public void actionPerformed(ActionEvent e)
			{
				try
				{
					String msg=jTextField.getText();
					if(!msg.equalsIgnoreCase("DC"))
					{
						out.println(msg);
					}
					jTextField.setText("");
				}
				catch(Exception ex)
				{
					jTextArea.append(ex.toString()+"\n");
				}
			}
		});
		jTextArea=new JTextArea();
		jTextArea.setBackground(Color.WHITE);
		jTextArea.setEditable(false);
		this.add("South", jTextField);
		this.add("Center", jTextArea);
	}
	public void start()
	{
		try
		{
			socket=new Socket(this.getCodeBase().getHost(), 12345);
			in=new BufferedReader(new InputStreamReader(socket.getInputStream()));
			out=new PrintStream(socket.getOutputStream());
		}
		catch(Exception e)
		{
			jTextArea.append(e.toString()+"\n");
			jTextArea.append("cant connect to server");
			return;
		}
		jTextArea.append("connected\n");
		(new Thread(new Runnable()
		{
			public void run()
			{
				String line="";
				while(true)
				{
					try
					{
						line=in.readLine();
						if(line==null)
						{
							break;
						}
						if(line.equals(""))
						{
							continue;
						}
						jTextArea.append(line+"\n");
					}
					catch(Exception e)
					{
						jTextArea.append(e.toString()+"\n");
					}
				}
				jTextArea.append("ERROR");
				try
				{
					in.close();
					out.close();
					socket.close();
				}
				catch(Exception e)
				{
					jTextArea.append(e.toString()+"\n");
				}
				return;
			}
		})).start();
	}
	public void stop()
	{
	}
	public void destroy()
	{
		try
		{
			out.println("DC");
			in.close();
			out.close();
			socket.close();
		}
		catch(Exception e)
		{
			jTextArea.append(e.toString()+"\n");
		}
	}
}

Zwar nicht schön aber lauffähig. Das ganze ist nur eine modifizierte Version hier von : Java-Chat (Warnung : veraltet !)

Um das ganze nun zum laufen zu bekommen packst du die Klassen "ClientRunnable.class", "Server.class" und "Server$1.class" in ein Jar, packst dieses auf den Server und startest es mit "java -jar server.jar" (richtiges Manifest vorrausgesetzt).
Für den Client packst du die Klassen "ClientApplet.class", "ClientApplet$1.class" und "ClientApplet$2.class" auch in ein Jar, packst dieses in dein Webspace und dazu diese HTML-Seite :

<html>
<head>
<title>Java-Chat</title>
</head>
<body>
<applet code="ClientApplet.class" archive="client.jar" height="500" width="500">
</applet>
</body>
</html>

FERTIG

Das ganze setzt natürlich vorraus das du einen Server hast auf dem du auch Commandos ausführen kannst. Auf deinem eigenen Rechner ist das ja kein Problem, aber im Netz reicht da kein Webspace, dafür brauchst du mindestens eine vServer mit SSH-Zugang um den Server dann auch zu starten. Da das aber denke ich mal für dich zur Zeit noch keine Option ist musst du entweder mit deinem eigenen Rechner den Server hosten oder auf andere Techniken zurückgreifen.

Ich hoffe das waren jetzt genug Infos wie man einen Chat in Java schreibt und diesen dann betreibt.