MultiThreading Chat Program

[Noelf21]

Hi i am creating a java chat application i have a client and a server however the chat application has to host many clients, i was just wondering where do i need to insert the multithreading code and what code do i need to use for this to work in the following code.

Server

public class ChatServer extends javax.swing.JFrame {
private ServerSocket server;
private Socket connection;
int counter = 1;
private ObjectInputStream input;
private ObjectOutputStream output;

/** Creates new form ChatServer */
public ChatServer() {
initComponents();
jTextField1.addActionListener(new ActionListener(){
public void actionPerformed(ActionEvent event){
sendData(event.getActionCommand());
jTextField1.setText("");
}
}
);
// runServer();
}
public void runServer(){
try
{
server = new ServerSocket( 12345, 2 ); // set up ServerSocket
while (true){
try{
waitForConnection();
getStreams();
processConnection();
}//end try
catch (EOFException eofException)
{
displayMessage("\nServer terminated connection");
}
finally
{
closeConnection();
counter++;
}
}
} // end try
catch ( IOException ioException )
{
ioException.printStackTrace();
} // end catch

//jTextArea1.setText( "Server awaiting connections\n" );


}
private void waitForConnection() throws IOException{
displayMessage("Server awaiting connections\n");
connection= server.accept();
displayMessage("Connection" +counter+"received from: " + connection.getInetAddress().getHostName());
}
private void getStreams() throws IOException{
output = new ObjectOutputStream(connection.getOutputStream());
output.flush();
input = new ObjectInputStream(connection.getInputStream());
displayMessage("\nGot I/O streams\n");
}
private void processConnection() throws IOException{
String message = "Connection Successful";
sendData(message);
do
{
try{
message = (String)input.readObject();
displayMessage("\n"+message);
} catch(ClassNotFoundException cnfException){
displayMessage("\nunknown object type");
}


}while (!message.equals("Terminate"));
}
private void closeConnection(){
displayMessage("\nterminating Connection");
try{
output.close();
input.close();
connection.close();
}catch(IOException ioException){
ioException.printStackTrace();
}
}
private void sendData(String message){
try{
output.writeObject("Server: "+message);
output.flush();
displayMessage("\nServer>>>"+message);
}catch(IOException ioException){
jTextArea1.append("\nError writing object");
}
}
private void displayMessage(final String messageToDisplay){
SwingUtilities.invokeLater(new Runnable(){
public void run(){
jTextArea1.append(messageToDisplay);
}
});
}
/** This method is called from within the constructor to
* initialize the form.
* WARNING: Do NOT modify this code. The content of this method is
* always regenerated by the Form Editor.
*/
@SuppressWarnings("unchecked")
// <editor-fold defaultstate="collapsed" desc="Generated Code">


public static void main(String args[]) {
ChatServer s= new ChatServer();
s.setVisible(true);
s.runServer();
/* java.awt.EventQueue.invokeLater(new Runnable() {
public void run() {
// new ChatServer().setVisible(true);


}
});*/
}



// <editor-fold defaultstate="collapsed" desc="Generated Code">
private void initComponents() {

jLabel1 = new javax.swing.JLabel();
jScrollPane1 = new javax.swing.JScrollPane();
jTextArea1 = new javax.swing.JTextArea();
jTextField1 = new javax.swing.JTextField();

setDefaultCloseOperation(javax.swing.WindowConstan ts.EXIT_ON_CLOSE);
setTitle("Server");

jLabel1.setText("Enter Your Message Here:");

jTextArea1.setColumns(20);
jTextArea1.setRows(5);
jScrollPane1.setViewportView(jTextArea1);

jTextField1.setText("jTextField1");

org.jdesktop.layout.GroupLayout layout = new org.jdesktop.layout.GroupLayout(getContentPane());
getContentPane().setLayout(layout);
layout.setHorizontalGroup(
layout.createParallelGroup(org.jdesktop.layout.Gro upLayout.LEADING)
.add(layout.createSequentialGroup()
.add(layout.createParallelGroup(org.jdesktop.layou t.GroupLayout.LEADING)
.add(layout.createSequentialGroup()
.addContainerGap()
.add(jScrollPane1, org.jdesktop.layout.GroupLayout.DEFAULT_SIZE, 380, Short.MAX_VALUE))
.add(layout.createSequentialGroup()
.add(18, 18, 18)
.add(layout.createParallelGroup(org.jdesktop.layou t.GroupLayout.LEADING)
.add(jTextField1, org.jdesktop.layout.GroupLayout.PREFERRED_SIZE, 352, org.jdesktop.layout.GroupLayout.PREFERRED_SIZE)
.add(jLabel1))))
.addContainerGap())
);
layout.setVerticalGroup(
layout.createParallelGroup(org.jdesktop.layout.Gro upLayout.LEADING)
.add(layout.createSequentialGroup()
.addContainerGap()
.add(jLabel1)
.add(18, 18, 18)
.add(jTextField1, org.jdesktop.layout.GroupLayout.PREFERRED_SIZE, 35, org.jdesktop.layout.GroupLayout.PREFERRED_SIZE)
.add(45, 45, 45)
.add(jScrollPane1, org.jdesktop.layout.GroupLayout.DEFAULT_SIZE, 166, Short.MAX_VALUE)
.addContainerGap())
);

pack();
}// </editor-fold>

[Atriamax]

Writing the Server Side of a Socket (The Java™ Tutorials > Custom Networking > All About Sockets) check that out, should have the info you need.

[renamed]

In server you will have a thread that will be waiting for new connections and a several threads... each of them will be responsible for one client.