Socket (Client) dauerhaft aktiv?

[Extremefall]

Hallo,
Ich habe momentan folgende Clientenklasse:

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;
 
public class Client implements ActionListener{
    static Socket clientSocket;
 
    public static void connectToSoccet(InetAddress IP, int port) {
        try {
            Socket clientSocket = new Socket(IP, port);
            PrintWriter printWriter = new PrintWriter(new OutputStreamWriter(
                    clientSocket.getOutputStream()));
            printWriter.println("hhi");
            printWriter.flush();
            printWriter.println("duie");
            printWriter.flush();
           
			clientSocket.close();

        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
           e.printStackTrace();
        }
    }

	@Override
	public void actionPerformed(ActionEvent arg0) {
		// TODO Auto-generated method stub
		
	}
    
}

Nun wird der Client ja nach dem Senden geschlossen. Wie kann ich es schaffen, dass ich den Client einfach aufrecht erhalte und somit nicht schließe? Denn wenn ich clientSocket.close() entferne, dann gibt es den Fehler Connection Reset...

Wie kann ich das Problem lösen? Und wie kann ich mittels ActionListener Daten senden?

 

[andre111]

Wenn es dir nur ums Daten senden geht, dann erzeuge einen eigenen Thread, der in einer Dauerschleife überprüft ob Daten zum Senden vorhanden sind. Falls dies so ist können sie gesendet werden. Die Daten selber könntest du in einer BlockingQueue (z. B. LinkedBlockingQueue) speichern.

 

[Michael...]

Unabhängig vom dem Problem würde ich, das static von Socket und von connectToSocket rausschmeißen. Schließlich soll sich ja das Client Objekt eine Socketverbindung aufbauen und nicht die Klasse.
Ob man dann das Socket tatsächlich als Instanzvariable benötigt hängt von der Umsetzung ab (man sollte den Gültigkeitsbereich von Variablen möglichst klein halten).

Definitiv würde ich den Outstream bzw. den Writer darauf als Instanzvariable definieren, so dass man in der actionPerformed ein println(...) darauf aufrufen kann. Besser wäre es eine send - Methode zu definieren und diese in der actionPerformed aufzurufen, das hält die Möglichkeiten zu senden offen. Ein flush() sollte beim PrintWriter nicht notwendig sein - sofern ich die Funktionsweise des PrintWriters korrekt im Kopf habe.

Falls der Client gleichzeitig auch noch eingehende Nachrichten empfangen soll, muss der Inputstream in einem separaten Thread ausgelesen werden, da das Lesen zunächst einmal blockierend ist.

 

[Extremefall]

Wie kann ich denn jetzt den Clienten dauerhaft am "Leben" lassen, sodass ich jederzeit nachrichten versende? Soll ich einfach einen Thread laufen lassen? Wieso wird bei meinem Versuch dann nichts gesendet bzw. kommt nichts beim Server an?

Wie kann ich denn mit dem ActionListener den Wert in den Thread übertragen? Also wie kann ich etwas über den ActionListener senden?

Mein Code:

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
 
public class Client implements Runnable,ActionListener{
    private PrintWriter printWriter;
    private OutputStreamWriter outputstreamwriter;
    private OutputStream outputstream;
    private Socket clientSocket;
    public void connectToSoccet(InetAddress IP, int port) {
            clientSocket = null;
            try {
				clientSocket = new Socket(IP, port);
				outputstream = clientSocket.getOutputStream();
				outputstreamwriter = new OutputStreamWriter(outputstream);
				printWriter = new PrintWriter(outputstreamwriter);
            printWriter.println("duie");
            printWriter.flush();
            Thread sender = new Thread(this);
            sender.start();
            printWriter.println("tow");
            printWriter.flush();
			clientSocket.close();

				}
            
			catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}      
    }
    public void closeClient(){
		
    }
	@Override
	public void actionPerformed(ActionEvent e) {
if (e.getSource()==GUI.send){
	printWriter.println("du");
}
	}
	@Override
	public void run() {
		System.out.println("do");
        printWriter.println("zweiter");
        printWriter.flush();		
	}
	
    
}

 

[andre111]

Ok, im Nachhinein ist mir aufgefallen, dass der extra Thread wohl gar nicht mal notwendig ist. Genau genommen hast du als Membervariable das Socket, mit dem du eine Verbindung zum Server herstellst. Diese darfst du jedoch nicht sofort wieder per close() schließen. In actionPerformed() kannst du dann Daten versenden indem du den OutputStream des bereits verbundenen Sockets verwendest. Schließen kannst du die Verbindung am Ende wie es dir beliebt (z. B. indem du einen WindowListener am Fenster registrierst, der dies übernimmt sobald du das Fenster schließt).

 

[Extremefall]

Hi,
kannst du mir vielleicht sagen, was ich mit dem ActionListener jetzt falsch mache?

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;

import javax.swing.JButton;
import javax.swing.JFrame;
 
public class Client implements Runnable,ActionListener{
    private PrintWriter printWriter;
    private OutputStreamWriter outputstreamwriter;
    private OutputStream outputstream;
    private Socket clientSocket;
    String al_text;
    private JButton send;
    public Client(){
    	JFrame frame = new JFrame();
    	send = new JButton("Senden");
    	send.addActionListener(this);
    	frame.add(send);
    	frame.setVisible(true);
    }
    public void connectToSoccet(InetAddress IP, int port) {
            clientSocket = null;
            try {
				clientSocket = new Socket(IP, port);
				outputstream = clientSocket.getOutputStream();
				outputstreamwriter = new OutputStreamWriter(outputstream);
				printWriter = new PrintWriter(outputstreamwriter);
            printWriter.println("duie");
            printWriter.flush();
            Thread sender = new Thread(this);
            sender.start();
            printWriter.println("tow");
            printWriter.flush();
            
				}
            
			catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}      
    }
    public void closeClient(){
		
    }
	@Override
	public void actionPerformed(ActionEvent e) {
if (e.getSource()==send){
	printWriter.println("Message");
    printWriter.flush();
	System.out.println("sende");
}
	}
	
	public void run() {
		while (true){
		if(clientSocket.isConnected()){
        printWriter.println("HI");
        printWriter.flush();
        }
		try {
			clientSocket.close();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	}

    
}

 

[andre111]

Der ActionListener selber ist soweit richtig, aber in deinem extra Thread (den du nicht mehr benötigst), lässt du das Socket sofort wieder schließen. Dementsprechend können im ActionListener später natürlich auch keine Daten mehr versendet werden.
Den Thread den du startest und die run()-Methode benötigst du nicht.

 

[andre111]

Folgendermaßen sollte es funktionieren (nicht getestet), ich hoffe es ist soweit verständlich.

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
 
import javax.swing.JButton;
import javax.swing.JFrame;
 
public class Client implements ActionListener{
    private PrintWriter printWriter;
    private OutputStreamWriter outputstreamwriter;
    private OutputStream outputstream;
    private Socket clientSocket;
    String al_text;
    private JButton send;
    public Client(){
        JFrame frame = new JFrame();
        send = new JButton("Senden");
        send.addActionListener(this);
        frame.add(send);
        frame.setVisible(true);
    }
    public void connectToSoccet(InetAddress IP, int port) {
            clientSocket = null;
            try {
                clientSocket = new Socket(IP, port);
                outputstream = clientSocket.getOutputStream();
                outputstreamwriter = new OutputStreamWriter(outputstream);
                printWriter = new PrintWriter(outputstreamwriter);
            printWriter.println("duie");
            printWriter.flush();
            printWriter.println("tow");
            printWriter.flush();
            
                }
            
            catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }      
    }
    public void closeClient(){
        
    }
    @Override
    public void actionPerformed(ActionEvent e) {
if (e.getSource()==send){
    printWriter.println("Message");
    printWriter.flush();
    System.out.println("sende");
}
    }
    
    }
 
    
}

 

[Marcinek]

Kann man nach knapp 300 Postings von dir erwarten, dass du deine Probleme im ganzen schilderst?

Ich finde es extrem frustrierend, dass hier so viele Leute ihre Zeit opfern um dir zu helfen du aber kaum fortschritte machst und jeden kleinen Fehler hier postest.

Hier sind btw auch hunderte Postings, die sich mit dem Erstellen eines Chats beschäftigen. Auch ganze PDFs wo alles kleinig genau beschrieben wird. Wieso liest du dir das nicht durch?

---------

Zum Problem: Was passiert den? Nullpointer? Wird die methode "connectToSoccet" auch iwo aufgerufen oder steht sie nur da?

Male dir doch mal auf dem Blatt papier auf was in welcher Reihenfolge passieren soll.

1. Verbindungsaufbau
2. Knopfdrücken
3. Senden

 

[Extremefall]

Vielen Dank für eure Hilfe. Es geht nun. Ich habe die Programmstruktur etwas geändert. Ich habe die Methode connectToSoccet entfernt und als Konstruktor der Klasse Client genutzt. Dann habe ich noch die GUI ausgelagert. Es klappt alles.