Thread: Stream issue?

So I've been grinding over the summer to make sure I'm ahead of my class when the school year starts, and I recently started dabbing into sockets and datagram servers etc. I haven't fully wrapped my head around it so logic would dictate that I would eventually run into a problem... Here I am...

Ok so I have two classes here; My client singleton that connects to the port and host name I specified and my server singelton that binds to a port. Here they are:


SERVERSINGLETON:

package org.com.eng.server;
 
import javax.swing.*;
import java.net.*;
import java.io.*;
 
public class ServerSingleton implements Runnable {
 
 
 
 
	public ServerSingleton(int port)throws IOException{
		try {
 
		} catch(Exception e){
			System.out.println("Could not listen on the specified port. Might be in use...");
		}
 
		try {
 
			ServerSocket ServSocket = new ServerSocket(port);
			Socket ClntSocket;
			ClntSocket = ServSocket.accept();
 
			PrintWriter out = new PrintWriter(ClntSocket.getOutputStream(), true);
			BufferedReader in = 
			    new BufferedReader(new InputStreamReader(ClntSocket.getInputStream()));
 
			String userIn = in.readLine();
 
			if(userIn != null){
				System.out.println("Recieved Data!");
			}
 
			if(userIn.equalsIgnoreCase("wai")){
				out.println("You are Patrick.");
				System.out.println("Recieved Data!");
			}
 
			while(userIn != null){
				System.out.println("Recieved Data!");
			}
 
 
		} catch (SocketException e){
			e.printStackTrace();
			System.out.println("Something goofed when determining the server socket");
			System.exit(-1);
		}
		try {
 
		} catch (Exception e) {
			e.printStackTrace();
		}
 
	}
 
	public void run(){
		try {
			getServerSingleton();
		} catch (Exception e){
 
		}
	}
 
	/*
	 * @author Patrick Worlds
	 * @return Returns the current ServerSingleton
	 */
	public static synchronized ServerSingleton getServerSingleton() throws IOException{
		if(Server == null)
			Server = new ServerSingleton(4445);
		return Server;
	}
 
	public Object clone() throws CloneNotSupportedException {
		JOptionPane.showMessageDialog(null, "Bad boy! >:( Go sit in corner nao!");	
		throw new CloneNotSupportedException();
	}
 
	private static ServerSingleton Server;
 
}

CLIENTSINGLETON:

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
 
import java.net.Socket;
 
import javax.swing.JOptionPane;
 
 
 
public class ClientSingleton implements Runnable {
 
	private Socket ClntSocket;
 
 
	public ClientSingleton(int port, String hostname)throws IOException{
		try {
 
 
 
			ClntSocket = new Socket(hostname, port);
 
			BufferedReader stdIn = new BufferedReader(
                    new InputStreamReader(System.in));
 
			PrintWriter out = new PrintWriter(ClntSocket.getOutputStream(), true);
			BufferedReader in = 
			    new BufferedReader(new InputStreamReader(ClntSocket.getInputStream()));
 
 
			if(ClntSocket.isConnected() == true){
				System.out.println("Connection established");
			}
			String userIn;
			String serverOut = in.readLine();
 
			userIn = stdIn.readLine();
			while(userIn != null){
				out.println(userIn);
				System.out.println("You: " +userIn);
			}
 
			while(serverOut != null){
				System.out.println("Server: " +serverOut);
 
			}
 
		} catch (Exception e){
			e.printStackTrace();
			System.out.println("Something goofed when determining a connection...");
			System.exit(-1);
		}
 
	}
 
	public void run(){
		try {
			getClientSingleton();
		} catch (Exception e){
 
		}
	}
 
	/*
	 * @author Patrick Worlds
	 * @return Returns the current ClientSingleton
	 */
	public static synchronized ClientSingleton getClientSingleton() throws IOException{
		if(Client == null)
			Client = new ClientSingleton(4445, "127.0.0.1");
		return Client;
	}
 
	public Object clone() throws CloneNotSupportedException {
		JOptionPane.showMessageDialog(null, "1 at a time ;)");	
		throw new CloneNotSupportedException();
	}
 
	private static ClientSingleton Client;
}

Now a problem arose. That being that every time I attempt to input something (namely "wai") it seems that either the server ignores it, or never even receives it. I'd really love if someone could help me out here. >.<


-Thanks

Originally Posted by Norm

Can you post the console from when you execute the program that shows what it does including the println output?

How do you execute the code? There are no main() methods

The console doesn't show anything because it's (Supposed to be) awaiting input from me (the user). As for the main methods:

Server:

package org.com.eng.server;
 
import java.io.IOException;
 
public class Server {
 
	public static Thread ServerThread;
 
	public static void main(String args[]) throws IOException{
		try{
			ServerThread = new Thread(new ServerSingleton(4445));
			ServerThread.start();
		} catch(Exception e) {
			System.out.println("Could not start server");
		}
	}
 
 
}

Client:

package org.com.eng.client;
 
 
 
import org.com.eng.client.ClientSingleton;;
 
public class Client {
 
	public static Thread ClientThread;
 
	public static void main(String args[]){
		try{
			ClientThread = new Thread(new ClientSingleton(4445, "127.0.0.1"));
			ClientThread.start();
		} catch(Exception e){
			System.out.println("Could not start client");
		}
 
	}
 
 
}

Originally Posted by Norm

How do you know when to enter anything if there is no prompt from the program?

Where is the "wai" entered? I'd expect to see that on the console.
Also where is the java command to start the program entered?

Well, this bit here is meant to await input from the user:

BufferedReader stdIn = new BufferedReader(
                    new InputStreamReader(System.in));
 
			PrintWriter out = new PrintWriter(ClntSocket.getOutputStream(), true);
			BufferedReader in = 
			    new BufferedReader(new InputStreamReader(ClntSocket.getInputStream()));
 
 
			if(ClntSocket.isConnected() == true){
				System.out.println("Connection established");
			}
			String userIn;
			String serverOut = in.readLine();
 
			userIn = stdIn.readLine();
			while(userIn != null){
				out.println(userIn);
				System.out.println("You: " +userIn);
			}
 
			while(serverOut != null){
				System.out.println("Server: " +serverOut);
 
			}

And I don't enter until a connection is established. The client checks that here:

			if(ClntSocket.isConnected() == true){
				System.out.println("Connection established");
			}

So yeah, I type "wai" into the console once I see "Connection established" hoping to see a result, but no dice :/.

Originally Posted by Norm

Try debugging the code by adding lots of println statements so you see where the code is executing. If it is hanging someplace, the printlns will show you the last place it executed before it hung.

It be nice to the user if you typed a message asking for input instead of just waiting.

Hmm Good idea! Don't know why I didn't think of that before >.<