www.pudn.com > ChatOnline.rar > ChatOnline.java
import java.io.*;
import java.net.*;
import java.awt.*;
import javax.swing.*;
import java.awt.event.*;
//import javax.swing.event.*;
public class ChatOnline extends JFrame
{
/**
*
*/
private static final long serialVersionUID = 1L;
JRadioButton rButton[] = new JRadioButton[2];
JTextField State,cHost,SMSField;
JButton Connect,DisConnect,SendMsg,SendFile;
JTextArea MessageTextArea;
ServerSocket sSocket;
Socket InSocket, cSocket;
BufferedReader bufReader;
PrintWriter pWriter;
String InStr;
int type = JOptionPane.ERROR_MESSAGE;
String title = "Error Message";
String ErrorMsg = "Error";
Container c = new Container();
NetWork_Client Client;
NetWork_Server Server;
public ChatOnline()
{//
super("TCP Communicate");
//Layout
c.setLayout(null);
setSize(500 , 480);
getContentPane().add(c);
MessageTextArea = new JTextArea();
MessageTextArea.setBounds(100 , 130 , 200 , 200);
MessageTextArea.setLineWrap(true);
c.add(MessageTextArea);
//c.add(new JScrollPane(MessageTextArea));
//the exit event
this.addWindowListener(new WindowAdapter()
{
public void windowClosing(WindowEvent ClosingWin)
{
System.exit(0);
}
});
//interphase
String bStr[] = {"Server", "Client"};
ButtonGroup bGroup = new ButtonGroup();
for(int i= 0;i<2;i++)
{
rButton[i] = new JRadioButton(bStr[i]);
rButton[i].setBounds(10+i*80 , 30 , 80 , 20);
bGroup.add(rButton[i]);
c.add(rButton[i]);
}
rButton[0].setSelected(true);
JLabel ConnectState = new JLabel("ConnectState :");
ConnectState.setBounds(200 , 30 , 100 , 20 );
c.add(ConnectState);
State = new JTextField();
State.setBounds(320, 30 , 150 , 20);
c.add(State);
JLabel ConnectHost = new JLabel("ConnectHost IP");
ConnectHost.setBounds(10 , 80 , 100 , 20);
c.add(ConnectHost);
cHost = new JTextField();
cHost.setBounds(100 , 80 , 200 , 20);
c.add(cHost);
Connect = new JButton("Connect");
Connect.setBounds(320 , 80 , 100 , 20);
c.add(Connect);
Connect.addActionListener(new ActionListener()
{//the event of the connect button
public void actionPerformed(ActionEvent e)
{
try
{
if(rButton[0].isSelected() == true)
{//start up the Server Thread
InStr = "";
SMSField.setText("");
Server.start();
}
else
{//start up the Client thread
InStr = "";
SMSField.setText("");
Client.start();
}
}
catch(Exception Ex)
{
return;
}
finally
{
DisConnect.setEnabled(true);
SendMsg.setEnabled(true);
Connect.setEnabled(false);
}
}
});
JLabel ReceInfo = new JLabel("Information ");
ReceInfo.setBounds(10 , 130 , 100 , 20);
c.add(ReceInfo);
DisConnect = new JButton("DisConnect");
DisConnect.setBounds(320 , 130 , 100 , 20);
c.add(DisConnect);
DisConnect.addActionListener(new ActionListener()
{
public void actionPerformed(ActionEvent e)
{//the event of the disconnect button
//close the server or client
try
{
if(rButton[0].isSelected() == true)
{//close the server
InSocket.close();
}
else
{//close the client
cSocket.close();
}
}
catch(Exception Ex)
{
return;
}
finally
{
State.setText("Closed...");
DisConnect.setEnabled(false);
SendMsg.setEnabled(false);
Connect.setEnabled(true);
}
}
});
SMSField = new JTextField();
SMSField.setBounds(100 , 350 , 200 , 20);
SMSField.setToolTipText("Enter your message here");
c.add(SMSField);
// send message
SendMsg = new JButton("Send");
SendMsg.setBounds(320,350 , 100 , 20);
SendMsg.addKeyListener(new KeyListener()
{
public void keyPressed(KeyEvent e)
{
}
public void keyTyped(KeyEvent e)
{
int key = e.getKeyCode();
if(key == 119)
{
try
{
pWriter.write(SMSField.getText());
pWriter.write("\n");
pWriter.flush();
SMSField.setText("");
}
catch(NullPointerException NpEx)
{
return;
}
}
}
public void keyReleased(KeyEvent e)
{
}
});
SendMsg.addActionListener(new ActionListener()
{
public void actionPerformed(ActionEvent e)
{
try
{
pWriter.write(SMSField.getText());
pWriter.write("\n");
pWriter.flush();
if(rButton[0].isSelected() == true)
{
MessageTextArea.setText("(Server) :"+SMSField.getText());
}
else
{
MessageTextArea.setText("(Client) :"+SMSField.getText());
}
SMSField.setText("");
}
catch(NullPointerException NpEx)
{
return;
}
}
});
c.add(SendMsg);
//send file
/*
SendFile = new JButton("Send File");
SendFile.setBounds(320 , 300 , 100,20);
SendFile.addActionListener(new ActionListener()
{
public void actionPerformed(ActionEvent e)
{
JFileChooser FileCh = new JFileChooser();
FileCh.setDialogTitle("Open File");
FileCh.setApproveButtonText("Open");
FileCh.showOpenDialog(c);
File FileName = FileCh.getSelectedFile();
FileReader FRead = null;
FileInputStream Input = null;
try
{
Input = new FileInputStream(FileName);
}
}
});
c.add(SendFile);
*/
JLabel about = new JLabel("Make by cat lee");
about.setBounds(50 , 400 , 100 , 20);
c.add(about);
//set up the server and client thread
Client = new NetWork_Client();
Server = new NetWork_Server();
}
//The Server Thread
class NetWork_Server extends Thread
{
public NetWork_Server()
{
}
public void run()
{
try
{
Connect.setEnabled(true);
State.setText("Waiting for Connect");
cHost.setText(InetAddress.getLocalHost().getHostAddress());
sSocket = new ServerSocket(1984);
InSocket = sSocket.accept();
bufReader = new BufferedReader(new InputStreamReader(InSocket.getInputStream()));
pWriter = new PrintWriter(InSocket.getOutputStream() , true);
while(true)
{
if(sSocket.isBound() == true)
{//makesure is bound
State.setText("Connecting");
DisConnect.setEnabled(true);
Connect.setEnabled(false);
SendMsg.setEnabled(true);
break;
}
}
while(true)
{
InStr = bufReader.readLine();
if(InStr.length() >0 )
{
MessageTextArea.setText("(Client) :");
MessageTextArea.append(InStr);
MessageTextArea.append("\n");
}
}
}
catch(Exception Ex)
{
if(sSocket.isBound() == false)
{
ErrorMsg = "Disconnected";
State.setText("Closed...");
DisConnect.setEnabled(false);
Connect.setEnabled(true);
//InSocket.close();
JOptionPane.showMessageDialog(c , ErrorMsg,title,type);
}
return;
}
}
}
//The Client Thread
class NetWork_Client extends Thread
{
public NetWork_Client()
{
}
public void run()
{
try
{
Connect.setEnabled(false);
State.setText("Waiting for Connect");
cSocket = new Socket();
cSocket.connect(new InetSocketAddress(cHost.getText() , 1984) ,1985 );
bufReader = new BufferedReader(new InputStreamReader(cSocket.getInputStream()));
pWriter = new PrintWriter(cSocket.getOutputStream() , true);
while(true)
{//makesure is connected
if(cSocket.isConnected() == true)
{
State.setText("Connecting");
DisConnect.setEnabled(true);
Connect.setEnabled(false);
SendMsg.setEnabled(true);
break;
}
}
InStr = "";
while(true)
{
InStr = bufReader.readLine();
if(InStr.length() > 0)
{
MessageTextArea.setText("(Server) :");
MessageTextArea.append(InStr);
MessageTextArea.append("\n");
}
}
}
catch(Exception Ex)
{
ErrorMsg = "Disconnected";
JOptionPane.showMessageDialog(c , ErrorMsg,title,type);
return;
}
}
}
public static void main(String args[])
{
ChatOnline nw = new ChatOnline();
nw.setVisible(true);
nw.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
nw.setResizable(false);
}
}