chatroomclient.java

java聊天小程序

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


public class ChatRoomClient extends Frame implements Runnable{
	
 //要放置的控件
 Panel panel1,panel2;
 Button button1,button2;
 TextField textField1,textField2;
 Label label1;
 TextArea textArea;
 ScrollPane sPanel;
 
 
 //套接字部分变量
 PrintWriter out;
 BufferedReader in=null;
 Socket sock;
 public final static int DEFAULT_PORT=6666; 
 
 //readThread线程负责从服务器端读取信息
 Thread readThread;
 boolean isTrue=true;
 
 public ChatRoomClient(){
	 try{
		 jbInit();
	 }catch(Exception e){
		 e.printStackTrace();
	 }
 }
 
 public static void main(String[] args){//main method
  ChatRoomClient c=new ChatRoomClient();
  c.show();
 }
 
 private void jbInit(){//should set size,position and Font of every component
  
  button1=new Button("连接");// set Font 
  button2=new Button("发送");
  textField1=new TextField("input Server address here!");
  textField2=new TextField("input Message here and send to server");
  label1=new Label("消息:");
  panel1=new Panel();
  panel2=new Panel();
  sPanel=new ScrollPane();
  textArea=new TextArea();
  
  //panel1  
  //press button1: 连接 to connect the client to server
  button1.addActionListener(new java.awt.event.ActionListener(){
   public void actionPerformed(ActionEvent e){
    button1_actionPerformed(e);
   }
  });
  //textField1:for input the address of server;be registered to KeyListener.
  //press key:Enter to connect the client to server
  textField1.addKeyListener(new textField1_KeyAdapter(this));//java.awt.event.KeyAdapter()
  panel1.add(button1);
  panel1.add(textField1);
  
  //sPanel  ScrollPane
  sPanel.add(textArea);
  
  //panel2
  //press button2: 发送 to send message
  button2.addActionListener(new java.awt.event.ActionListener(){
   public void actionPerformed(ActionEvent e){
    button2_actionPerformed(e);
   }
  });
  //textField2:for input message;be registered to KeyListener.
  //press key:Enter to send message
  textField2.addKeyListener(new textField2_KeyAdapter(this));
  panel2.add(label1);
  panel2.add(textField2);
  panel2.add(button2);
  
  //frame
  this.addWindowListener(new ChatFrame_WindowAdapter(this));//frame is registered to WindowListener
  this.setLayout(new BorderLayout());
  this.setSize(400,300);
  this.add(panel1,BorderLayout.NORTH);
  this.add(sPanel,BorderLayout.CENTER);
  this.add(panel2,BorderLayout.SOUTH);
  //this.show()
    
 }
  
 public void startConnect(){//开始连接
  try{
   sock=new Socket(textField1.getText(),DEFAULT_PORT);
   if(sock!=null){//connection successed
    processMsg("Connect successfully!");
   }
   in=new BufferedReader(new InputStreamReader(sock.getInputStream()));
   out=new PrintWriter(sock.getOutputStream());
  }catch(IOException ex){
   processMsg(ex.toString());
   processMsg("Connect failed!");
  }
  
  readThread=new Thread(this);
  readThread.start(); 
 }
 
 //public void endConnect(){//close IOstream 
 
 public void sendInformation(){
  out.println(textField2.getText());
  out.flush();
  
 }
 
 private void button1_actionPerformed(ActionEvent e){//连接按钮
  startConnect();
 }
 
 /**
  * 
  * @param e
  */
 private void button2_actionPerformed(ActionEvent e){//发送按钮
  sendInformation();
 }
  
 /**
  * 撤销线程
  *
  */
 public void stopRun(){//to stop the running thread
  isTrue=false;
 } 
 
 
  /**
   * 更新聊天窗口的信息
   * @param msg
   */
 public void processMsg(String msg){
  textArea.append(msg);
  textArea.append("\n");
 }
 
 
 //不断地从服务器端读取信息
 public void run(){
  String msg;
  isTrue=true;
  while(isTrue){
   try{
    msg=in.readLine();
    if(msg.equals("Server exit!")){//server exit
     processMsg(msg);
     stopRun();//终止线程
    }else if(msg!=null){
     processMsg(msg);
    }
    //沉睡1000毫秒
    Thread.sleep(1000);    
   }catch(IOException e){
    processMsg(e.toString());
   }catch(InterruptedException ei){
    processMsg(ei.toString());
   }
  }
  //endConnect();
  try{//服务器退出关闭连接和相关的流
   sock.close();
   in.close();
   out.close();
  }catch(IOException ioe){} 
 }
 
 public void exit(){//窗口关闭；如果有连接则关闭连接和相关的流
  try{
   //send "Client exit!" to Server!
   out.println("Client exit!");
   out.flush();
  }catch(Exception exc){}
  
  //endConnect();
  try{
  //close IOstream 
   sock.close();
   in.close();
   out.close();
  }catch(IOException ioe){}
  finally{ 
   System.exit(0);
  }
 }
}

/**
 * 以下为所有的适配器类
 * @author Administrator
 *
 */
//textField1的键击事件适配器
class textField1_KeyAdapter extends java.awt.event.KeyAdapter{
 ChatRoomClient chatFrame;
 
 public textField1_KeyAdapter(ChatRoomClient chatFrame){
  this.chatFrame=chatFrame;
 }
 
 public void keyPressed(KeyEvent e){
  int j=e.getKeyCode();
  if(j==e.VK_ENTER){//输入的是enter，开始连接！
   chatFrame.startConnect();
  }
 }
}

//textField2的键击事件适配器
class textField2_KeyAdapter extends java.awt.event.KeyAdapter{
 ChatRoomClient chatFrame;
 
 public textField2_KeyAdapter(ChatRoomClient chatFrame){
  this.chatFrame=chatFrame;
 }
 
 public void keyPressed(KeyEvent e){//键击Enter键，发送信息！
  int j=e.getKeyCode();
  if(j==e.VK_ENTER){
   chatFrame.sendInformation();
  }
 }
}

//窗口关闭事件适配器
class ChatFrame_WindowAdapter extends java.awt.event.WindowAdapter{
 ChatRoomClient chatFrame;
 public ChatFrame_WindowAdapter(ChatRoomClient chatFrame){
  this.chatFrame=chatFrame;
 }
 public void windowClosing(WindowEvent e){
  chatFrame.exit();
 }
}