Global Chat Room

Hello mike,

I presume you have a single server to initialize the Chat application and multiple clients representing multiple threads with each thread having a textarea to globally display the text what other user has been typing.

Do you mean that whatever is typed by one user after logging after a couple of minutes should view the contents of the entire conversation held in that room as currently he is able to view the contents of the message typed after he has logged in and that too in the textarea of his own.

What do you mean by one single TextArea sharing in all threads? Does it mean the understanding mentioned above? Pls clarify.

rgds,

Seetesh

seteshhindlea at 2007-7-13 2:00:54 >

this is my code

client :import java.awt.*;

import java.awt.event.*;

import javax.swing.*;

import java.io.*;

import java.net.*;

class SocketClient extends JFrame implements ActionListener {

JLabel text, clicked;

JButton button;

JPanel panel;

JTextField textField;

Socket socket = null;

PrintWriter out = null;

BufferedReader in = null;

SocketClient(){ //Begin Constructor

text = new JLabel("Text to send over socket:");

textField = new JTextField(20);

button = new JButton("Click Me");

button.addActionListener(this);

panel = new JPanel();

panel.setLayout(new BorderLayout());

panel.setBackground(Color.white);

getContentPane().add(panel);

panel.add("North", text);

panel.add("Center", textField);

panel.add("South", button);

} //End Constructor

public void actionPerformed(ActionEvent event){

Object source = event.getSource();

if(source == button){

//Send data over socket

String text = textField.getText();

out.println(text);

textField.setText(new String(""));

//Receive text from server

try{

String line = in.readLine();

textField.setText(line);

//System.out.println("Text received :" + line);

} catch (IOException e){

System.out.println("Read failed");

System.exit(1);

}

}

}

public void openSocket(){

//Create socket connection

try{

socket = new Socket("localhost", 4444);

out = new PrintWriter(socket.getOutputStream(), true);

in = new BufferedReader(new InputStreamReader(socket.getInputStream()));

} catch (UnknownHostException e) {

System.out.println("Unknown host.");

System.exit(1);

} catch (IOException e) {

System.out.println("No I/O");

System.exit(1);

}

}

public static void main(String[] args){

SocketClient frame = new SocketClient();

frame.setTitle("Client Program");

WindowListener l = new WindowAdapter() {

public void windowClosing(WindowEvent e) {

System.exit(0);

}

};

frame.addWindowListener(l);

frame.pack();

frame.setVisible(true);

frame.openSocket();

}

}

server :import java.awt.*;

import java.awt.event.*;

import javax.swing.*;

import java.io.*;

import java.net.*;

class ClientWorker implements Runnable {

private Socket client;

private JTextArea textArea;

ClientWorker(Socket client, JTextArea textArea) {

this.client = client;

this.textArea = textArea;

}

public void run(){

String line;

BufferedReader in = null;

PrintWriter out = null;

try{

in = new BufferedReader(new InputStreamReader(client.getInputStream()));

out = new PrintWriter(client.getOutputStream(), true);

} catch (IOException e) {

System.out.println("in or out failed");

System.exit(-1);

}

while(true){

try{

line = in.readLine();

//Send data back to client

out.println(line);

textArea.append(Thread.currentThread().getName()+": "+line+"\n");

} catch (IOException e) {

System.out.println("Read failed");

System.exit(-1);

}

}

}

}

class SocketThrdServer extends JFrame{

JLabel label = new JLabel("Text received over socket:");

JPanel panel;

JTextArea textArea = new JTextArea();

ServerSocket server = null;

SocketThrdServer(){ //Begin Constructor

panel = new JPanel();

panel.setLayout(new BorderLayout());

panel.setBackground(Color.white);

getContentPane().add(panel);

panel.add("North", label);

panel.add("Center", textArea);

} //End Constructor

public void listenSocket(){

try{

server = new ServerSocket(4444);

} catch (IOException e) {

System.out.println("Could not listen on port 4444");

System.exit(-1);

}

while(true){

ClientWorker w;

try{

w = new ClientWorker(server.accept(), textArea);

Thread t = new Thread(w);

t.start();

} catch (IOException e) {

System.out.println("Accept failed: 4444");

System.exit(-1);

}

}

}

protected void finalize(){

//Objects created in run method are finalized when

//program terminates and thread exits

try{

server.close();

} catch (IOException e) {

System.out.println("Could not close socket");

System.exit(-1);

}

}

public static void main(String[] args){

SocketThrdServer frame = new SocketThrdServer();

frame.setTitle("Server Program");

WindowListener l = new WindowAdapter() {

public void windowClosing(WindowEvent e) {

System.exit(0);

}

};

frame.addWindowListener(l);

frame.pack();

frame.setVisible(true);

frame.listenSocket();

}

}

mike.kevina at 2007-7-13 2:00:54 >

In this case the client just types in some text and clicks on the Button and the Server displays all the messages posted by each user/thread.

I have a similar application code where each user connects to the Chat application and enters the text. All subsequently connect users can send text messages where they all can see the same on their individual textarea rather than storing all the messages from all users on the server's textarea.

Something similar to yahoo conference/chat.

If this is something that you are looking for then give me ur email id, I will post the snippet code across.

Rgds,

Seetesh

seteshhindlea at 2007-7-13 2:00:54 >

I have to browse through my system to dig up the source code else connect to our CVS for the same. Will get back to you on that soon.

Well You could use the Java Decompiler to convert the .class files to .java

www.softpedia.com/progDownload/ DJ-Java-Decompiler-Download-13481.html

Rgds,

Seetesh

seteshhindlea at 2007-7-13 2:00:55 >

hi Mike

Ur problem can be solved using multithreading twice.

One set of threads(client thread) is for the connection that each client makes with the server.

The second set of threads are Writerthreads that wud just do the job of communicating the message to everyone online.

Now..once a client has connected to the server..add this client to an ArrayList whose object/data type must be an output stream. now..code a routine using a for loop that sends the message posted by a client thread and read by the server to all the clients in the arraylist. Everytime..the server gets some input stream from any client thread..it shud invoke one such thread(a writer thread) which uses the above mentioned routine to post the message to every other client.

I think my way of explaining was very confusing but thats all i can tell coz i actually have developed exactly wat u want..but i cant give u the code..coz of security reasons...

Deepak

dipakucha at 2007-7-20 20:44:16 >