StackOverflow2013

Note that there are some explanatory texts on larger screens.

plurals

POCommunication between threads?
text
Body
copied!<p>Got a programm with 2 threads. one thread is writing some stuff into the console.</p> <pre><code>public class Konsole extends Thread { static int id = 0; Client client; public Konsole(Client client) { this.client = client; } public void run() { System.out.println("========= Konsole "+ ++id +" started"); while(true) { try { String line = client.fromServer.readLine(); client.commands.add(line); System.out.println(line); if(line == null) {break;} } catch (IOException e) {} } </code></pre> <p>in the Client class exits a public static stack. But the stack is allways empty, the Konsole isn't able to access the stack. Can someone give me a hint why?</p> <p>Client class</p> <pre><code>import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; import java.net.UnknownHostException; import java.util.Stack; import java.util.StringTokenizer; public class Client extends Thread { // Verbindungsvariablen final String user = "user"; final String pass = "pass"; public String host = "localhost"; int port = 21; // PASV int portNew; String ipNew = ""; public static Stack<String> commands = new Stack<String>(); boolean lastCommand = false; // Sockets Socket serverSocket; Socket pasvSocket; PrintWriter writeCommands; BufferedReader fromServer; PrintWriter writePasvCommands; BufferedReader fromPasvServer; // Baut die Verbindung auf public void connect() throws IOException { try { serverSocket = new Socket(host, port); System.out.println("Baue Verbindung auf ..."); fromServer = new BufferedReader(new InputStreamReader( serverSocket.getInputStream())); writeCommands = new PrintWriter(serverSocket.getOutputStream(), true); } catch (UnknownHostException e) { System.out.println("Host unbekannt!"); e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public void USER() throws IOException { writeCommands.print("USER " + user + "\n"); writeCommands.flush(); } public void PASS() { writeCommands.print("PASS " + pass +"\n"); writeCommands.flush(); } public void NOOP() { writeCommands.print("NOOP\n"); writeCommands.flush(); } public void getStatus() { Thread konsole = new Thread(new Konsole(this)); konsole.start(); } // PASV anschalten public void PASV() throws IOException, InterruptedException { writeCommands.print("PASV\n"); writeCommands.flush(); //getPasvCon(); } public void getPasvCon() throws IOException, InterruptedException { System.out.println("!!!!!!"); // Commands abholen // IP Adresse holen String pasv = commands.lastElement(); String ipAndPort = pasv.substring(pasv.indexOf("(") + 1, pasv.indexOf(")")); StringTokenizer getIp = new StringTokenizer(ipAndPort); // holt die IP String ipNew = ""; // IP für den neuen Socket for (int i = 0; i < 4; i++) { if (i < 3) { ipNew += (getIp.nextToken(",") + "."); } else { ipNew += (getIp.nextToken(",")); } } Integer portTemp1 = new Integer( getIp.nextToken(",")); Integer portTemp2 = new Integer (getIp.nextToken(",")); portNew = (portTemp1 << 8 )+ portTemp2; try { pasvSocket = new Socket(ipNew, portNew); } catch (UnknownHostException e) { System.out.println("Host unbekannt"); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { fromPasvServer = new BufferedReader(new InputStreamReader( pasvSocket.getInputStream())); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { writePasvCommands = new PrintWriter(pasvSocket.getOutputStream(), true); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public void LIST() throws IOException { writeCommands.print("LIST\n"); writeCommands.flush(); } public void run() { try { connect(); // getStatus(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { USER(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } PASS(); try { PASV(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public Client() throws IOException { } public static void main(String[] args) throws IOException, InterruptedException { Client test = new Client(); Thread client = new Thread(test); client.start(); Thread.sleep(300); Thread konsole = new Thread(new Konsole(test)); konsole.start(); Disrupter disrupt = new Disrupter(test); disrupt.start(); } } </code></pre> <p>(static is senseless, isn't it?)</p>

Querying!

Guidance

An individual column

Larger individual text columns get their own page to allow for proper reading.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload