Java

Java RSS

Multi Thread Help

Thread Solved

•

Join Date: Jul 2008

Posts: 92

Reputation: bloody_ninja is an unknown quantity at this point

Solved Threads: 1

bloody_ninja bloody_ninja is offline

Offline

Junior Poster in Training

Multi Thread Help

Jul 18th, 2008

 Help with Code Tags 
 java Syntax (Toggle Plain Text) 
package Ninja;
 
 
 
 
import java.io.*;
import java.awt.*;
import java.awt.event.*;
 
import javax.swing.*;
 
import java.net.*;
 
public class NinjaServer implements Runnable {
 
	   public final static int NULL = 0;
	   public final static int DISCONNECTED = 1;
	   public final static int DISCONNECTING = 2;
	   public final static int BEGIN_CONNECT = 3;
	   public final static int CONNECTED = 4;
 
	   public final static String statusMessages[] = {
		      " Can't Connect!!! Don't Try Again!", " Disconnected",
		      " Disconnecting...", " Connecting... Please Wait", " Connected"
		   };
		   public final static NinjaServer NinjaObj = new NinjaServer();
		   public final static String END_CHAT_SESSION =
		      new Character((char)0).toString(); 
 
		   public static String hostIP = "localhost";
		   public static int port = 1337;
		   public static int connectionStatus = DISCONNECTED;
		   public static boolean isHost = true;
		   public static String statusString = statusMessages[connectionStatus];
		   public static StringBuffer toAppend = new StringBuffer("");
		   public static StringBuffer toSend = new StringBuffer("");
 
 
		   // Various GUI components and info
		   public static JFrame mainFrame = null;
		   public static JTextArea chatText = null;
		   public static JTextField chatLine = null;
		   public static JPanel statusBar = null;
		   public static JLabel statusField = null;
		   public static JTextField statusColor = null;
		   public static JTextField ipField = null;
		   public static JTextField portField = null;
		   public static JRadioButton hostOption = null;
		   public static JRadioButton guestOption = null;
		   public static JRadioButton NinjaOption = null;
		   public static JButton helpButton = null;
		   public static JButton connectButton = null;
		   public static JButton disconnectButton = null;
 
		   public static ServerSocket hostServer = null;
		   public static Socket socket = null;
		   public static BufferedReader in = null;
		   public static PrintWriter out = null;
 
		   private static JPanel initOptionsPane() {
			      JPanel pane = null;
			      ActionAdapter buttonListener = null;
 
			      JPanel optionsPane = new JPanel(new GridLayout(4, 1));
 
			      pane = new JPanel(new FlowLayout(FlowLayout.RIGHT));
			      pane.add(new JLabel("Computer Name:"));
			      ipField = new JTextField(10); ipField.setText(hostIP);
			      ipField.setEnabled(false);
			      ipField.addFocusListener(new FocusAdapter() {
			            public void focusLost(FocusEvent e) {
			               ipField.selectAll();
			               // Should be editable only when disconnected
			               if (connectionStatus != DISCONNECTED) {
			                  changeStatusNTS(NULL, true);
			               }
			               else {
			                  hostIP = ipField.getText();
			               }
			            }
			         });
 
			      pane.add(ipField);
			      optionsPane.add(pane);
 
			      // Port input
			      pane = new JPanel(new FlowLayout(FlowLayout.RIGHT));
			      pane.add(new JLabel("Port Number:"));
			      portField = new JTextField(10); portField.setEditable(true);
			      portField.setText((new Integer(port)).toString());
			      portField.addFocusListener(new FocusAdapter() {
			            public void focusLost(FocusEvent e) {
			               // should be editable only when disconnected
			               if (connectionStatus != DISCONNECTED) {
			                  changeStatusNTS(NULL, true);
			               }
			               else {
			                  int temp;
			                  try {
			                     temp = Integer.parseInt(portField.getText());
			                     port = temp;
			                  }
 
			                  catch (NumberFormatException nfe) {
			                     portField.setText((new Integer(port)).toString());
			                     mainFrame.repaint();
			                  }
			               }
			            }
			         });
			      pane.add(portField);
			      optionsPane.add(pane);
 
			      buttonListener = new ActionAdapter() {
			            public void actionPerformed(ActionEvent e) {
			               if (connectionStatus != DISCONNECTED) {
			                  changeStatusNTS(NULL, true);
			               }
 
			               else {
			                  isHost = e.getActionCommand().equals("host");
 
			                  // Cannot supply host IP if host option is chosen
			                  if (isHost) {
			                     ipField.setEnabled(false);
			                     ipField.setText("localhost");
			                     hostIP = "localhost";
			                  }
			                  else {
			                     ipField.setEnabled(true);
			                  }
			               }
			            }
			         };
			      ButtonGroup bg = new ButtonGroup();
			      hostOption = new JRadioButton("Host", true);
			      hostOption.setMnemonic(KeyEvent.VK_H);
			      hostOption.setActionCommand("host");
			      hostOption.addActionListener(buttonListener);
			      guestOption = new JRadioButton("Guest", false);
			      guestOption.setMnemonic(KeyEvent.VK_G);
			      guestOption.setActionCommand("guest");
			      guestOption.addActionListener(buttonListener);
 
			      NinjaOption = new JRadioButton ("Ninja", false);
			      NinjaOption.setMnemonic(KeyEvent.VK_N);
			      NinjaOption.setActionCommand("Ninja");
			      NinjaOption.addActionListener(buttonListener);
 
			      bg.add(hostOption);
			      bg.add(guestOption);
			      bg.add(NinjaOption);
			      pane = new JPanel(new GridLayout(1, 2));
			      pane.add(hostOption);
			      pane.add(guestOption);
			      pane.add(NinjaOption);
			      optionsPane.add(pane);
 
			      JPanel buttonPane = new JPanel(new GridLayout(1, 2));
			      buttonListener = new ActionAdapter() {
			            public void actionPerformed(ActionEvent e) {
			               // Request a connection initiation
			               if (e.getActionCommand().equals("connect")) {
			                  changeStatusNTS(BEGIN_CONNECT, true);
			               }
			               // Disconnect
			               else {
			                  changeStatusNTS(DISCONNECTING, true);
			               }
			            }
			         };
			      connectButton = new JButton("Connect");
			      connectButton.setMnemonic(KeyEvent.VK_C);
			      connectButton.setActionCommand("connect");
			      connectButton.addActionListener(buttonListener);
			      connectButton.setEnabled(true);
			      disconnectButton = new JButton("Disconnect");
			      disconnectButton.setMnemonic(KeyEvent.VK_D);
			      disconnectButton.setActionCommand("disconnect");
			      disconnectButton.addActionListener(buttonListener);
			      disconnectButton.setEnabled(false);
			      buttonPane.add(connectButton);
			      buttonPane.add(disconnectButton);
			      optionsPane.add(buttonPane);
 
			      return optionsPane;
			   }
		   // Initialize all the GUI components and display the frame
		   private static void initGUI() {
		      // Set up the status bar
		      statusField = new JLabel();
		      statusField.setText(statusMessages[DISCONNECTED]);
		      statusColor = new JTextField(1);
		      statusColor.setBackground(Color.red);
		      statusColor.setEditable(false);
		      statusBar = new JPanel(new BorderLayout());
		      statusBar.add(statusColor, BorderLayout.EAST);
		      statusBar.add(statusField, BorderLayout.CENTER);
 
		      // Set up the options pane
		      JPanel optionsPane = initOptionsPane();
 
		      // Set up the chat pane
		      JPanel chatPane = new JPanel(new BorderLayout());
		      chatText = new JTextArea(15, 30);
		      chatText.setLineWrap(true);
		      chatText.setEditable(false);
		      chatText.setForeground(Color.green);
		      JScrollPane chatTextPane = new JScrollPane(chatText,
		         JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,
		         JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
		      chatLine = new JTextField();
		      chatLine.setEnabled(false);
		      chatLine.addActionListener(new ActionAdapter() {
		            public void actionPerformed(ActionEvent e) {
		               String s = chatLine.getText();
		               if (!s.equals("")) {
		                  appendToChatBox("OUTGOING: " + s + "\n");
		                  chatLine.selectAll();
 
		                  // Send the string
		                  sendString(s);
		               }
		            }
		         });
		      chatPane.add(chatLine, BorderLayout.SOUTH);
		      chatPane.add(chatTextPane, BorderLayout.CENTER);
		      chatPane.setPreferredSize(new Dimension(200, 200));
 
		      // Set up the main pane
		      JPanel mainPane = new JPanel(new BorderLayout());
		      mainPane.add(statusBar, BorderLayout.SOUTH);
		      mainPane.add(optionsPane, BorderLayout.WEST);
		      mainPane.add(chatPane, BorderLayout.CENTER);
 
		      // Set up the main frame
		      mainFrame = new JFrame("Simple Instant Messenger (SIM)");
		      mainFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		      mainFrame.setContentPane(mainPane);
		      mainFrame.setSize(mainFrame.getPreferredSize());
		      mainFrame.setLocation(1, 1);
		      mainFrame.pack();
		      mainFrame.setVisible(true);
		   }
 
		   /////////////////////////////////////////////////////////////////
 
		   // The thread-safe way to change the GUI components while
		   // changing state
		   private static void changeStatusTS(int newConnectStatus, boolean noError) {
		      // Change state if valid state
		      if (newConnectStatus != NULL) {
		         connectionStatus = newConnectStatus;
		      }
 
		      // If there is no error, display the appropriate status message
		      if (noError) {
		         statusString = statusMessages[connectionStatus];
		      }
		      // Otherwise, display error message
		      else {
		         statusString = statusMessages[NULL];
		      }
 
		      // Call the run() routine (Runnable interface) on the
		      // error-handling and GUI-update thread
		      SwingUtilities.invokeLater(NinjaObj);
		   }
 
		   /////////////////////////////////////////////////////////////////
 
		   // The non-thread-safe way to change the GUI components while
		   // changing state
		   private static void changeStatusNTS(int newConnectStatus, boolean noError) {
		      // Change state if valid state
		      if (newConnectStatus != NULL) {
		         connectionStatus = newConnectStatus;
		      }
 
		      // If there is no error, display the appropriate status message
		      if (noError) {
		         statusString = statusMessages[connectionStatus];
		      }
		      // Otherwise, display error message
		      else {
		         statusString = statusMessages[NULL];
		      }
 
		      // Call the run() routine (Runnable interface) on the
		      // current thread
		      NinjaObj.run();
		   }
 
		   /////////////////////////////////////////////////////////////////
 
		   // Thread-safe way to append to the chat box
		   private static void appendToChatBox(String s) {
		      synchronized (toAppend) {
		         toAppend.append(s);
		      }
		   }
 
		   /////////////////////////////////////////////////////////////////
 
		   // Add text to send-buffer
		   private static void sendString(String s) {
		      synchronized (toSend) {
		         toSend.append(s + "\n");
		      }
		   }
 
		   /////////////////////////////////////////////////////////////////
 
		   // Cleanup for disconnect
		   private static void cleanUp() {
		      try {
		         if (hostServer != null) {
		            hostServer.close();
		            hostServer = null;
		         }
		      }
		      catch (IOException e) { hostServer = null; }
 
		      try {
		         if (socket != null) {
		            socket.close();
		            socket = null;
		         }
		      }
		      catch (IOException e) { socket = null; }
 
		      try {
		         if (in != null) {
		            in.close();
		            in = null;
		         }
		      }
		      catch (IOException e) { in = null; }
 
		      if (out != null) {
		         out.close();
		         out = null;
		      }
		   }
 
		   /////////////////////////////////////////////////////////////////
 
		   // Checks the current state and sets the enables/disables
		   // accordingly
		   public void run() {
		      switch (connectionStatus) {
		      case DISCONNECTED:
		         connectButton.setEnabled(true);
		         disconnectButton.setEnabled(false);
		         ipField.setEnabled(true);
		         portField.setEnabled(true);
		         hostOption.setEnabled(true);
		         guestOption.setEnabled(true);
		         NinjaOption.setEnabled(true);
		         chatLine.setText(""); chatLine.setEnabled(false);
		         statusColor.setBackground(Color.red);
		         break;
 
		      case DISCONNECTING:
		         connectButton.setEnabled(false);
		         disconnectButton.setEnabled(false);
		         ipField.setEnabled(false);
		         portField.setEnabled(false);
		         hostOption.setEnabled(false);
		         guestOption.setEnabled(false);
		         NinjaOption.setEnabled(false);
		         chatLine.setEnabled(false);
		         statusColor.setBackground(Color.yellow);
		         break;
 
		      case CONNECTED:
		         connectButton.setEnabled(false);
		         disconnectButton.setEnabled(true);
		         ipField.setEnabled(false);
		         portField.setEnabled(false);
		         hostOption.setEnabled(false);
		         guestOption.setEnabled(false);
		         NinjaOption.setEnabled(false);
		         chatLine.setEnabled(true);
		         statusColor.setBackground(Color.green);
		         break;
 
		      case BEGIN_CONNECT:
		         connectButton.setEnabled(false);
		         disconnectButton.setEnabled(false);
		         ipField.setEnabled(false);
		         portField.setEnabled(false);
		         hostOption.setEnabled(false);
		         guestOption.setEnabled(false);
		         NinjaOption.setEnabled(false);
		         chatLine.setEnabled(false);
		         chatLine.grabFocus();
		         statusColor.setBackground(Color.yellow);
		         break;
		      }
 
		      // Make sure that the button/text field states are consistent
		      // with the internal states
		      ipField.setText(hostIP);
		      portField.setText((new Integer(port)).toString());
		      hostOption.setSelected(isHost);
		      guestOption.setSelected(!isHost);
		      NinjaOption.setSelected(!isHost);
		      statusField.setText(statusString);
		      chatText.append(toAppend.toString());
		      toAppend.setLength(0);
 
		      mainFrame.repaint();
		   }
 
 
 
		   /////////////////////////////////////////////////////////////////
 
		   // The main procedure
		   public static void main(String args[]) throws IOException {
		      String s;
 
		      initGUI();
 
		      while (true) {
		         try { // Poll every ~10 ms
		            Thread.sleep(10);
		         }
		         catch (InterruptedException e) {}
 
		         switch (connectionStatus) {
		         case BEGIN_CONNECT:
		            try {
		               // Try to set up a server if host
		               if (isHost) {
		                  hostServer = new ServerSocket(port);
		                  socket = hostServer.accept();
 
		                  Thread t = new Thread();
						  t.start();
		               }
 
		               // If guest, try to connect to the server
		               else {
		                  socket = new Socket(hostIP, port);
		               }
 
		               in = new BufferedReader(new 
		                  InputStreamReader(socket.getInputStream()));
		               out = new PrintWriter(socket.getOutputStream(), true);
		               changeStatusTS(CONNECTED, true);
		            }
		            // If error, clean up and output an error message
		            catch (IOException e) {
		               cleanUp();
		               changeStatusTS(DISCONNECTED, false);
		            }
		            break;
 
		         case CONNECTED:
		            try {
		               // Send data
		               if (toSend.length() != 0) {
		                  out.print(toSend); out.flush();
		                  toSend.setLength(0);
		                  changeStatusTS(NULL, true);
		               }
 
		               // Receive data
		               if (in.ready()) {
		                  s = in.readLine();
		                  if ((s != null) &&  (s.length() != 0)) {
		                     // Check if it is the end of a trasmission
		                     if (s.equals(END_CHAT_SESSION)) {
		                        changeStatusTS(DISCONNECTING, true);
		                     }
 
		                     // Otherwise, receive what text
		                     else {
		                        appendToChatBox("INCOMING: " + s + "\n");
		                        changeStatusTS(NULL, true);
		                     }
		                  }
		               }
		            }
		            catch (IOException e) {
		               cleanUp();
		               changeStatusTS(DISCONNECTED, false);
		            }
		            break;
 
		         case DISCONNECTING:
		            // Tell other chatter to disconnect as well
		            out.print(END_CHAT_SESSION); out.flush();
 
		            // Clean up (close all streams/sockets)
		            cleanUp();
		            changeStatusTS(DISCONNECTED, true);
		            break;
 
		         default: break; // do nothing
		         }
		      }
		   }
		}
 
//////////////////////////////////////////////////////////////////		//
 
//		 Action adapter for easy event-listener coding
		class ActionAdapter implements ActionListener {
		   public void actionPerformed(ActionEvent e) {}
		}
 
//////////////////////////////////////////////////////////////////		//
package Ninja;




import java.io.*;
import java.awt.*;
import java.awt.event.*;

import javax.swing.*;

import java.net.*;

public class NinjaServer implements Runnable {
	
	   public final static int NULL = 0;
	   public final static int DISCONNECTED = 1;
	   public final static int DISCONNECTING = 2;
	   public final static int BEGIN_CONNECT = 3;
	   public final static int CONNECTED = 4;

	   public final static String statusMessages[] = {
		      " Can't Connect!!! Don't Try Again!", " Disconnected",
		      " Disconnecting...", " Connecting... Please Wait", " Connected"
		   };
		   public final static NinjaServer NinjaObj = new NinjaServer();
		   public final static String END_CHAT_SESSION =
		      new Character((char)0).toString(); 
		   
		   public static String hostIP = "localhost";
		   public static int port = 1337;
		   public static int connectionStatus = DISCONNECTED;
		   public static boolean isHost = true;
		   public static String statusString = statusMessages[connectionStatus];
		   public static StringBuffer toAppend = new StringBuffer("");
		   public static StringBuffer toSend = new StringBuffer("");
		   
		   
		   // Various GUI components and info
		   public static JFrame mainFrame = null;
		   public static JTextArea chatText = null;
		   public static JTextField chatLine = null;
		   public static JPanel statusBar = null;
		   public static JLabel statusField = null;
		   public static JTextField statusColor = null;
		   public static JTextField ipField = null;
		   public static JTextField portField = null;
		   public static JRadioButton hostOption = null;
		   public static JRadioButton guestOption = null;
		   public static JRadioButton NinjaOption = null;
		   public static JButton helpButton = null;
		   public static JButton connectButton = null;
		   public static JButton disconnectButton = null;
		   
		   public static ServerSocket hostServer = null;
		   public static Socket socket = null;
		   public static BufferedReader in = null;
		   public static PrintWriter out = null;
		   
		   private static JPanel initOptionsPane() {
			      JPanel pane = null;
			      ActionAdapter buttonListener = null;
			      
			      JPanel optionsPane = new JPanel(new GridLayout(4, 1));
			      
			      pane = new JPanel(new FlowLayout(FlowLayout.RIGHT));
			      pane.add(new JLabel("Computer Name:"));
			      ipField = new JTextField(10); ipField.setText(hostIP);
			      ipField.setEnabled(false);
			      ipField.addFocusListener(new FocusAdapter() {
			            public void focusLost(FocusEvent e) {
			               ipField.selectAll();
			               // Should be editable only when disconnected
			               if (connectionStatus != DISCONNECTED) {
			                  changeStatusNTS(NULL, true);
			               }
			               else {
			                  hostIP = ipField.getText();
			               }
			            }
			         });
			      
			      pane.add(ipField);
			      optionsPane.add(pane);

			      // Port input
			      pane = new JPanel(new FlowLayout(FlowLayout.RIGHT));
			      pane.add(new JLabel("Port Number:"));
			      portField = new JTextField(10); portField.setEditable(true);
			      portField.setText((new Integer(port)).toString());
			      portField.addFocusListener(new FocusAdapter() {
			            public void focusLost(FocusEvent e) {
			               // should be editable only when disconnected
			               if (connectionStatus != DISCONNECTED) {
			                  changeStatusNTS(NULL, true);
			               }
			               else {
			                  int temp;
			                  try {
			                     temp = Integer.parseInt(portField.getText());
			                     port = temp;
			                  }
			                  
			                  catch (NumberFormatException nfe) {
			                     portField.setText((new Integer(port)).toString());
			                     mainFrame.repaint();
			                  }
			               }
			            }
			         });
			      pane.add(portField);
			      optionsPane.add(pane);
			      
			      buttonListener = new ActionAdapter() {
			            public void actionPerformed(ActionEvent e) {
			               if (connectionStatus != DISCONNECTED) {
			                  changeStatusNTS(NULL, true);
			               }
			               
			               else {
			                  isHost = e.getActionCommand().equals("host");

			                  // Cannot supply host IP if host option is chosen
			                  if (isHost) {
			                     ipField.setEnabled(false);
			                     ipField.setText("localhost");
			                     hostIP = "localhost";
			                  }
			                  else {
			                     ipField.setEnabled(true);
			                  }
			               }
			            }
			         };
			      ButtonGroup bg = new ButtonGroup();
			      hostOption = new JRadioButton("Host", true);
			      hostOption.setMnemonic(KeyEvent.VK_H);
			      hostOption.setActionCommand("host");
			      hostOption.addActionListener(buttonListener);
			      guestOption = new JRadioButton("Guest", false);
			      guestOption.setMnemonic(KeyEvent.VK_G);
			      guestOption.setActionCommand("guest");
			      guestOption.addActionListener(buttonListener);
			      
			      NinjaOption = new JRadioButton ("Ninja", false);
			      NinjaOption.setMnemonic(KeyEvent.VK_N);
			      NinjaOption.setActionCommand("Ninja");
			      NinjaOption.addActionListener(buttonListener);
			      
			      bg.add(hostOption);
			      bg.add(guestOption);
			      bg.add(NinjaOption);
			      pane = new JPanel(new GridLayout(1, 2));
			      pane.add(hostOption);
			      pane.add(guestOption);
			      pane.add(NinjaOption);
			      optionsPane.add(pane);
			      
			      JPanel buttonPane = new JPanel(new GridLayout(1, 2));
			      buttonListener = new ActionAdapter() {
			            public void actionPerformed(ActionEvent e) {
			               // Request a connection initiation
			               if (e.getActionCommand().equals("connect")) {
			                  changeStatusNTS(BEGIN_CONNECT, true);
			               }
			               // Disconnect
			               else {
			                  changeStatusNTS(DISCONNECTING, true);
			               }
			            }
			         };
			      connectButton = new JButton("Connect");
			      connectButton.setMnemonic(KeyEvent.VK_C);
			      connectButton.setActionCommand("connect");
			      connectButton.addActionListener(buttonListener);
			      connectButton.setEnabled(true);
			      disconnectButton = new JButton("Disconnect");
			      disconnectButton.setMnemonic(KeyEvent.VK_D);
			      disconnectButton.setActionCommand("disconnect");
			      disconnectButton.addActionListener(buttonListener);
			      disconnectButton.setEnabled(false);
			      buttonPane.add(connectButton);
			      buttonPane.add(disconnectButton);
			      optionsPane.add(buttonPane);

			      return optionsPane;
			   }
		   // Initialize all the GUI components and display the frame
		   private static void initGUI() {
		      // Set up the status bar
		      statusField = new JLabel();
		      statusField.setText(statusMessages[DISCONNECTED]);
		      statusColor = new JTextField(1);
		      statusColor.setBackground(Color.red);
		      statusColor.setEditable(false);
		      statusBar = new JPanel(new BorderLayout());
		      statusBar.add(statusColor, BorderLayout.EAST);
		      statusBar.add(statusField, BorderLayout.CENTER);

		      // Set up the options pane
		      JPanel optionsPane = initOptionsPane();

		      // Set up the chat pane
		      JPanel chatPane = new JPanel(new BorderLayout());
		      chatText = new JTextArea(15, 30);
		      chatText.setLineWrap(true);
		      chatText.setEditable(false);
		      chatText.setForeground(Color.green);
		      JScrollPane chatTextPane = new JScrollPane(chatText,
		         JScrollPane.VERTICAL_SCROLLBAR_ALWAYS,
		         JScrollPane.HORIZONTAL_SCROLLBAR_NEVER);
		      chatLine = new JTextField();
		      chatLine.setEnabled(false);
		      chatLine.addActionListener(new ActionAdapter() {
		            public void actionPerformed(ActionEvent e) {
		               String s = chatLine.getText();
		               if (!s.equals("")) {
		                  appendToChatBox("OUTGOING: " + s + "\n");
		                  chatLine.selectAll();

		                  // Send the string
		                  sendString(s);
		               }
		            }
		         });
		      chatPane.add(chatLine, BorderLayout.SOUTH);
		      chatPane.add(chatTextPane, BorderLayout.CENTER);
		      chatPane.setPreferredSize(new Dimension(200, 200));

		      // Set up the main pane
		      JPanel mainPane = new JPanel(new BorderLayout());
		      mainPane.add(statusBar, BorderLayout.SOUTH);
		      mainPane.add(optionsPane, BorderLayout.WEST);
		      mainPane.add(chatPane, BorderLayout.CENTER);

		      // Set up the main frame
		      mainFrame = new JFrame("Simple Instant Messenger (SIM)");
		      mainFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		      mainFrame.setContentPane(mainPane);
		      mainFrame.setSize(mainFrame.getPreferredSize());
		      mainFrame.setLocation(1, 1);
		      mainFrame.pack();
		      mainFrame.setVisible(true);
		   }

		   /////////////////////////////////////////////////////////////////

		   // The thread-safe way to change the GUI components while
		   // changing state
		   private static void changeStatusTS(int newConnectStatus, boolean noError) {
		      // Change state if valid state
		      if (newConnectStatus != NULL) {
		         connectionStatus = newConnectStatus;
		      }

		      // If there is no error, display the appropriate status message
		      if (noError) {
		         statusString = statusMessages[connectionStatus];
		      }
		      // Otherwise, display error message
		      else {
		         statusString = statusMessages[NULL];
		      }

		      // Call the run() routine (Runnable interface) on the
		      // error-handling and GUI-update thread
		      SwingUtilities.invokeLater(NinjaObj);
		   }

		   /////////////////////////////////////////////////////////////////

		   // The non-thread-safe way to change the GUI components while
		   // changing state
		   private static void changeStatusNTS(int newConnectStatus, boolean noError) {
		      // Change state if valid state
		      if (newConnectStatus != NULL) {
		         connectionStatus = newConnectStatus;
		      }

		      // If there is no error, display the appropriate status message
		      if (noError) {
		         statusString = statusMessages[connectionStatus];
		      }
		      // Otherwise, display error message
		      else {
		         statusString = statusMessages[NULL];
		      }

		      // Call the run() routine (Runnable interface) on the
		      // current thread
		      NinjaObj.run();
		   }

		   /////////////////////////////////////////////////////////////////

		   // Thread-safe way to append to the chat box
		   private static void appendToChatBox(String s) {
		      synchronized (toAppend) {
		         toAppend.append(s);
		      }
		   }

		   /////////////////////////////////////////////////////////////////

		   // Add text to send-buffer
		   private static void sendString(String s) {
		      synchronized (toSend) {
		         toSend.append(s + "\n");
		      }
		   }

		   /////////////////////////////////////////////////////////////////

		   // Cleanup for disconnect
		   private static void cleanUp() {
		      try {
		         if (hostServer != null) {
		            hostServer.close();
		            hostServer = null;
		         }
		      }
		      catch (IOException e) { hostServer = null; }

		      try {
		         if (socket != null) {
		            socket.close();
		            socket = null;
		         }
		      }
		      catch (IOException e) { socket = null; }

		      try {
		         if (in != null) {
		            in.close();
		            in = null;
		         }
		      }
		      catch (IOException e) { in = null; }

		      if (out != null) {
		         out.close();
		         out = null;
		      }
		   }

		   /////////////////////////////////////////////////////////////////

		   // Checks the current state and sets the enables/disables
		   // accordingly
		   public void run() {
		      switch (connectionStatus) {
		      case DISCONNECTED:
		         connectButton.setEnabled(true);
		         disconnectButton.setEnabled(false);
		         ipField.setEnabled(true);
		         portField.setEnabled(true);
		         hostOption.setEnabled(true);
		         guestOption.setEnabled(true);
		         NinjaOption.setEnabled(true);
		         chatLine.setText(""); chatLine.setEnabled(false);
		         statusColor.setBackground(Color.red);
		         break;

		      case DISCONNECTING:
		         connectButton.setEnabled(false);
		         disconnectButton.setEnabled(false);
		         ipField.setEnabled(false);
		         portField.setEnabled(false);
		         hostOption.setEnabled(false);
		         guestOption.setEnabled(false);
		         NinjaOption.setEnabled(false);
		         chatLine.setEnabled(false);
		         statusColor.setBackground(Color.yellow);
		         break;

		      case CONNECTED:
		         connectButton.setEnabled(false);
		         disconnectButton.setEnabled(true);
		         ipField.setEnabled(false);
		         portField.setEnabled(false);
		         hostOption.setEnabled(false);
		         guestOption.setEnabled(false);
		         NinjaOption.setEnabled(false);
		         chatLine.setEnabled(true);
		         statusColor.setBackground(Color.green);
		         break;

		      case BEGIN_CONNECT:
		         connectButton.setEnabled(false);
		         disconnectButton.setEnabled(false);
		         ipField.setEnabled(false);
		         portField.setEnabled(false);
		         hostOption.setEnabled(false);
		         guestOption.setEnabled(false);
		         NinjaOption.setEnabled(false);
		         chatLine.setEnabled(false);
		         chatLine.grabFocus();
		         statusColor.setBackground(Color.yellow);
		         break;
		      }

		      // Make sure that the button/text field states are consistent
		      // with the internal states
		      ipField.setText(hostIP);
		      portField.setText((new Integer(port)).toString());
		      hostOption.setSelected(isHost);
		      guestOption.setSelected(!isHost);
		      NinjaOption.setSelected(!isHost);
		      statusField.setText(statusString);
		      chatText.append(toAppend.toString());
		      toAppend.setLength(0);

		      mainFrame.repaint();
		   }
		   
		   

		   /////////////////////////////////////////////////////////////////

		   // The main procedure
		   public static void main(String args[]) throws IOException {
		      String s;

		      initGUI();

		      while (true) {
		         try { // Poll every ~10 ms
		            Thread.sleep(10);
		         }
		         catch (InterruptedException e) {}

		         switch (connectionStatus) {
		         case BEGIN_CONNECT:
		            try {
		               // Try to set up a server if host
		               if (isHost) {
		                  hostServer = new ServerSocket(port);
		                  socket = hostServer.accept();
		                  
		                  Thread t = new Thread();
						  t.start();
		               }

		               // If guest, try to connect to the server
		               else {
		                  socket = new Socket(hostIP, port);
		               }

		               in = new BufferedReader(new 
		                  InputStreamReader(socket.getInputStream()));
		               out = new PrintWriter(socket.getOutputStream(), true);
		               changeStatusTS(CONNECTED, true);
		            }
		            // If error, clean up and output an error message
		            catch (IOException e) {
		               cleanUp();
		               changeStatusTS(DISCONNECTED, false);
		            }
		            break;

		         case CONNECTED:
		            try {
		               // Send data
		               if (toSend.length() != 0) {
		                  out.print(toSend); out.flush();
		                  toSend.setLength(0);
		                  changeStatusTS(NULL, true);
		               }

		               // Receive data
		               if (in.ready()) {
		                  s = in.readLine();
		                  if ((s != null) &&  (s.length() != 0)) {
		                     // Check if it is the end of a trasmission
		                     if (s.equals(END_CHAT_SESSION)) {
		                        changeStatusTS(DISCONNECTING, true);
		                     }

		                     // Otherwise, receive what text
		                     else {
		                        appendToChatBox("INCOMING: " + s + "\n");
		                        changeStatusTS(NULL, true);
		                     }
		                  }
		               }
		            }
		            catch (IOException e) {
		               cleanUp();
		               changeStatusTS(DISCONNECTED, false);
		            }
		            break;

		         case DISCONNECTING:
		            // Tell other chatter to disconnect as well
		            out.print(END_CHAT_SESSION); out.flush();

		            // Clean up (close all streams/sockets)
		            cleanUp();
		            changeStatusTS(DISCONNECTED, true);
		            break;

		         default: break; // do nothing
		         }
		      }
		   }
		}

//////////////////////////////////////////////////////////////////		//

//		 Action adapter for easy event-listener coding
		class ActionAdapter implements ActionListener {
		   public void actionPerformed(ActionEvent e) {}
		}

//////////////////////////////////////////////////////////////////		//

I have two problems with this instant messenger at the current moment.

First : I still can't figure out how to get multiple clients to connect to the host. It says connected, but there is no actual Incoming and Outgoing messages.

Second : When I connect to the server as guest, once connected, it switches over to Ninja

•

Join Date: Jul 2008

Posts: 92

Reputation: bloody_ninja is an unknown quantity at this point

Solved Threads: 1

bloody_ninja bloody_ninja is offline

Offline

Junior Poster in Training

Re: Multi Thread Help

Jul 20th, 2008

^bump

•

Join Date: Jul 2008

Posts: 92

Reputation: bloody_ninja is an unknown quantity at this point

Solved Threads: 1

bloody_ninja bloody_ninja is offline

Offline

Junior Poster in Training

Re: Multi Thread Help

Jul 21st, 2008

Someone please help?

Okay, let me shorten this a little.

My goal is to make a multiclient Instant Messenger program. When executing, there are no errors, but it can only support host / client. I am not sure where to put and exactly what to put to make it a multi user program.

 Help with Code Tags 
 java Syntax (Toggle Plain Text) 
		   public static void main(String args[]) throws IOException {
		      String s;
 
		      initGUI();
 
		      while (true) {
 
		    	 NinjaServer n = null;
		         try { // Poll every ~10 ms
		            Thread.sleep(10);
		         }
		         catch (InterruptedException e) {}
 
		         switch (connectionStatus) {
		         case BEGIN_CONNECT:
		            try {
		               // Try to set up a server if host
		               if (isHost) {
		                  hostServer = new ServerSocket(port);
		                  socket = hostServer.accept();
 
		                  Thread t = new Thread(n);
						  t.start();
 
		               }
 
		               // If guest, try to connect to the server
		               else {
		                  socket = new Socket(hostIP, port);
		               }
 
		               in = new BufferedReader(new 
		                  InputStreamReader(socket.getInputStream()));
		               out = new PrintWriter(socket.getOutputStream(), true);
		               changeStatusTS(CONNECTED, true);
		            }
		            // If error, clean up and output an error message
		            catch (IOException e) {
		               cleanUp();
		               changeStatusTS(DISCONNECTED, false);
		            }
		            break;
 
		         case CONNECTED:
		            try {
		               // Send data
		               if (toSend.length() != 0) {
		                  out.print(toSend); out.flush();
		                  toSend.setLength(0);
		                  changeStatusTS(NULL, true);
		               }
 
		               // Receive data
		               if (in.ready()) {
		                  s = in.readLine();
		                  if ((s != null) &&  (s.length() != 0)) {
		                     // Check if it is the end of a trasmission
		                     if (s.equals(END_CHAT_SESSION)) {
		                        changeStatusTS(DISCONNECTING, true);
		                     }
 
		                     // Otherwise, receive what text
		                     else {
		                        appendToChatBox("INCOMING: " + s + "\n");
		                        changeStatusTS(NULL, true);
		                     }
		                  }
		               }
		            }
		            catch (IOException e) {
		               cleanUp();
		               changeStatusTS(DISCONNECTED, false);
		            }
		            break;
 
		         case DISCONNECTING:
		            // Tell other chatter to disconnect as well
		            out.print(END_CHAT_SESSION); out.flush();
 
		            // Clean up (close all streams/sockets)
		            cleanUp();
		            changeStatusTS(DISCONNECTED, true);
		            break;
 
		         default: break; // do nothing
		         }
		      }
		   }
		}
		   public static void main(String args[]) throws IOException {
		      String s;

		      initGUI();

		      while (true) {
		    	  
		    	 NinjaServer n = null;
		         try { // Poll every ~10 ms
		            Thread.sleep(10);
		         }
		         catch (InterruptedException e) {}

		         switch (connectionStatus) {
		         case BEGIN_CONNECT:
		            try {
		               // Try to set up a server if host
		               if (isHost) {
		                  hostServer = new ServerSocket(port);
		                  socket = hostServer.accept();
		                  
		                  Thread t = new Thread(n);
						  t.start();
						  
		               }

		               // If guest, try to connect to the server
		               else {
		                  socket = new Socket(hostIP, port);
		               }

		               in = new BufferedReader(new 
		                  InputStreamReader(socket.getInputStream()));
		               out = new PrintWriter(socket.getOutputStream(), true);
		               changeStatusTS(CONNECTED, true);
		            }
		            // If error, clean up and output an error message
		            catch (IOException e) {
		               cleanUp();
		               changeStatusTS(DISCONNECTED, false);
		            }
		            break;

		         case CONNECTED:
		            try {
		               // Send data
		               if (toSend.length() != 0) {
		                  out.print(toSend); out.flush();
		                  toSend.setLength(0);
		                  changeStatusTS(NULL, true);
		               }

		               // Receive data
		               if (in.ready()) {
		                  s = in.readLine();
		                  if ((s != null) &&  (s.length() != 0)) {
		                     // Check if it is the end of a trasmission
		                     if (s.equals(END_CHAT_SESSION)) {
		                        changeStatusTS(DISCONNECTING, true);
		                     }

		                     // Otherwise, receive what text
		                     else {
		                        appendToChatBox("INCOMING: " + s + "\n");
		                        changeStatusTS(NULL, true);
		                     }
		                  }
		               }
		            }
		            catch (IOException e) {
		               cleanUp();
		               changeStatusTS(DISCONNECTED, false);
		            }
		            break;

		         case DISCONNECTING:
		            // Tell other chatter to disconnect as well
		            out.print(END_CHAT_SESSION); out.flush();

		            // Clean up (close all streams/sockets)
		            cleanUp();
		            changeStatusTS(DISCONNECTED, true);
		            break;

		         default: break; // do nothing
		         }
		      }
		   }
		}

•

Join Date: Jul 2008

Posts: 92

Reputation: bloody_ninja is an unknown quantity at this point

Solved Threads: 1

bloody_ninja bloody_ninja is offline

Offline

Junior Poster in Training

Re: Multi Thread Help

Jul 22nd, 2008

No one has any input or advice ?

•

Join Date: Dec 2007

Posts: 43

Reputation: sanzilla has a little shameless behaviour in the past

Solved Threads: 3

sanzilla

Offline

Unverified User

Re: Multi Thread Help

Jul 23rd, 2008

•

When executing, there are no errors, but it can only support host / client.

hmm , I have traced your code , this like a Serial port RS-232 communication .

I think you have to connect to the server to enable the multi user chat , like the IRC chat ! I think you have to change the coce

 Help with Code Tags 
 Java Syntax (Toggle Plain Text) 
// Try to set up a server if host
if (isHost) {
         hostServer = new ServerSocket(port);
         socket = hostServer.accept();
         Thread t = new Thread(n);
         t.start();
}
// If guest, try to connect to the server
else {
        socket = new Socket(hostIP, port);
 
}
// Try to set up a server if host
if (isHost) {
         hostServer = new ServerSocket(port);
         socket = hostServer.accept();
         Thread t = new Thread(n);
         t.start();
}
// If guest, try to connect to the server
else {
        socket = new Socket(hostIP, port);

}

something should be change here ....

just put a watch point on the variable socket and see what is the really value on it on the runtime . after executing the above me quoted code .

Last edited by sanzilla; Jul 23rd, 2008 at 3:33 am.

•

Join Date: Dec 2007

Posts: 43

Reputation: sanzilla has a little shameless behaviour in the past

Solved Threads: 3

sanzilla

Offline

Unverified User

Re: Multi Thread Help

Jul 23rd, 2008

hmm , nice chat program that you copied and pasted from ,

public static String hostIP = "localhost";
and localhost means your computer , then you are using the server as your computer
if you are start chat with him . Look at the quoted text in my previous post . If your friend is starting chat with you then his computer is working as a server and your computer just accept that connection .

So if you want's to chat more than 2 users , then you have to make a intermeadiate server and make that server to work as a router to forward your msg to the friend .

•

Join Date: Jul 2008

Posts: 92

Reputation: bloody_ninja is an unknown quantity at this point

Solved Threads: 1

bloody_ninja bloody_ninja is offline

Offline

Junior Poster in Training

Re: Multi Thread Help

Jul 23rd, 2008

I dont get what you are trying to say. I do connect to the server, but that doesn't enable multiple clients.

What is a watch point? Sorry , I just started recently and don't know all the terms yet.

What I don't get is why it won't just allow more clients, because I am starting new threads and everything.

•

Join Date: Jul 2008

Posts: 92

Reputation: bloody_ninja is an unknown quantity at this point

Solved Threads: 1

bloody_ninja bloody_ninja is offline

Offline

Junior Poster in Training

Re: Multi Thread Help

Jul 23rd, 2008

This guy , the only guy that attempted helping, responded 32 minutes ago. Now he is banned.

•

Join Date: Dec 2007

Posts: 43

Reputation: sanzilla has a little shameless behaviour in the past

Solved Threads: 3

sanzilla

Offline

Unverified User

Re: Multi Thread Help

Jul 23rd, 2008

 Help with Code Tags 
 Java Syntax (Toggle Plain Text) 
// Try to set up a server if host
if (isHost) {
         hostServer = new ServerSocket(port);
         socket = hostServer.accept();
         Thread t = new Thread(n);
         t.start();
}
// If guest, try to connect to the server
else {
        socket = new Socket(hostIP, port);
 
}
// Try to set up a server if host
if (isHost) {
         hostServer = new ServerSocket(port);
         socket = hostServer.accept();
         Thread t = new Thread(n);
         t.start();
}
// If guest, try to connect to the server
else {
        socket = new Socket(hostIP, port);

}

Look at this code , think what was happning
in this code , in nutshell let me explain ,

when you wants to start the chat with your friend , your machine localhost is act like a server and your friend is just accepting that incomming connection . and when your friend is starting the chat then his computer was act like a server and you just act like a host .

so you have to change the code to always connects to a dedicated server and that server should be programmed to route and forward messages . then you are post your message to the server , and the server will post it to all the clients currently chatting except you . so change the code to do that .

if you dont know who to use the watch points and breakpoints lean debugging first , that is very useful when you are developing more complex software .
use the netbeans , that will help you to debug with a GUI , otherwise you have to go to the command prompt . so
http://debuggercore.netbeans.org/nonav/sourcesDemo.html
may be help you

•

Join Date: Jul 2008

Posts: 92

Reputation: bloody_ninja is an unknown quantity at this point

Solved Threads: 1

bloody_ninja bloody_ninja is offline

Offline

Junior Poster in Training

Re: Multi Thread Help

#10

Jul 23rd, 2008

I am not even trying to connect to friends yet. I am just trying to runn multiple clients on my own computer and connect them all to myself. Except only one connects.

But what you said defeats my purpose. I also want the server to be able to communicate to clients, not just relay messages.

Otherwise, if multiple people used it, one person would have to run a client and a server on the same computer.

"when you wants to start the chat with your friend , your machine localhost is act like a server and your friend is just accepting that incomming connection ."

I thought that the server accepts the incoming connections.

And I am currently using Eclipse, don't want to change mid project, so there has to be a way.