chatarea.java

java网络聊天BS模式

/*
 * Title:        网络应用
 * Description:  b/s模式网络聊天室
 * Copyright:    Copyright (c) 2004  飞鱼工作室
 * Company:      HOHAI
 * @author: lishaofeng,yuanfeng
 * @version: 1.0
 */
import java.awt.*;
import java.net.*;
import java.awt.event.*;
import java.io.*;
import java.util.Hashtable;

public class ChatArea extends Panel implements ActionListener,Runnable
{
  Socket  socket=null;      //和服务器间建立的连接的套接字．                         
  DataInputStream in=null;       //读取服务器信息的输入流．                    
  DataOutputStream out=null;      //向服务器发送信息的输出流．                   
  Thread threadMessage=null;      //读取服务器信息的线程．                   
  TextArea 谈话显示区,私聊显示区=null;
  TextField 送出信息=null;
  Button 确定,刷新谈话区,刷新私聊区;
  Label  提示条=null;
  String name=null;        //聊天者的昵称．                          
  Hashtable listTable;         //存放在线聊天者昵称的散列表．                      
  List  listComponent=null;        //显示在线聊天者昵称的List组件．                  
  Choice privateChatList;          //选择私人聊天者的下拉列表．                   
  int width,height;                //聊天区的宽和高．                   
  public ChatArea(String name,Hashtable listTable,int width,int height)
  {
    setLayout(null); 
    setBackground(Color.orange);
    this.width=width;
    this.height=height;
    setSize(width,height);
    this.listTable=listTable;
    this.name=name;
    threadMessage=new Thread(this); 
    谈话显示区=new TextArea(10,10);
    私聊显示区=new TextArea(10,10);
    确定=new Button("送出信息到:");
    刷新谈话区=new Button("刷新谈话区");
    刷新私聊区=new Button("刷新私聊区");
    提示条=new Label("双击聊天者可私聊",Label.CENTER);
    送出信息=new TextField(50);
    确定.addActionListener(this);
    送出信息.addActionListener(this);
    刷新谈话区.addActionListener(this);
    刷新私聊区.addActionListener(this);
    listComponent=new List();
    listComponent.addActionListener(this);         //双击列表中的聊天者昵称，可选中某聊天者与之私聊。  
    privateChatList=new Choice();
    privateChatList.add("大家(*)");
    privateChatList.select(0);                      //默认情况下，用户输入内容发送给所有聊天者。
   
    add(谈话显示区);
    谈话显示区.setBounds(10,10,(width-120),(height-120)/2); 
    add(私聊显示区);
    私聊显示区.setBounds(10,10+(height-120)/2,(width-120),(height-120)/2);
    add(listComponent);
    listComponent.setBounds(10+(width-120),10,100,(height-160));
    add(提示条);
    提示条.setBounds(10+(width-120),10+(height-160),110,40);
    Panel  pSouth=new Panel();
    pSouth.add(送出信息);
    pSouth.add(确定);
    pSouth.add(privateChatList);
    pSouth.add(刷新谈话区);
    pSouth.add(刷新私聊区); 
    add(pSouth);
    pSouth.setBounds(10,20+(height-120),width-20,60);
  
  }
 public void setName(String s)
  {
    name=s;
  }
 public void setSocketConnection(Socket socket,DataInputStream in,DataOutputStream out)
  {
    this.socket=socket;
    this.in=in;
    this.out=out;
    try             //启动线程,接收服务器信息.
         { 
           threadMessage.start();
         }
    catch(Exception e)
         {
         } 
  }
 public void actionPerformed(ActionEvent e)
  {
   
   if(e.getSource()==确定||e.getSource()==送出信息)
     {  
        String message="";
        String people=privateChatList.getSelectedItem();
        people=people.substring(0,people.indexOf("("));     //获取信息发送对象的昵称.
        message=送出信息.getText();
        if(message.length()>0)
        {             //将聊天内容及对象发送给服务器.
         try {
               if(people.equals("大家"))
                 {
                   out.writeUTF("公共聊天内容:"+name+"说:"+message);
                 }
               else
                 {
                   out.writeUTF("私人聊天内容:"+name+"悄悄地说:"+message+"#"+people);
                 } 
             }
         catch(IOException event)
             {
             }
        }
     }
    else if(e.getSource()==listComponent)
     {
       privateChatList.insert(listComponent.getSelectedItem(),0);
       privateChatList.repaint();
     }
    else if(e.getSource()==刷新谈话区)
     {
       谈话显示区.setText(null);
     }
    else if(e.getSource()==刷新私聊区)
     {
       私聊显示区.setText(null);
     }
  }  
 public void run()                    
  {
     while(true)
        {
           String s=null;
            try
               { 
                 s=in.readUTF();   //等待(阻塞本线程,直到收到信息)服务器信息.            
                 if(s.startsWith("聊天内容:"))   //读取服务器发来的信息.
                    {
                      String content=s.substring(s.indexOf(":")+1);
                      谈话显示区.append("\n"+content);
                    }
                 if(s.startsWith("私人聊天内容:"))   //读取服务器发来的信息.
                    {
                      String content=s.substring(s.indexOf(":")+1);
                      私聊显示区.append("\n"+content);
                    }
                 else if(s.startsWith("聊天者:"))
                    {    //显示新加入的聊天者信息.
                     String people=s.substring(s.indexOf(":")+1,s.indexOf("性别"));
                     String sex=s.substring(s.indexOf("性别")+2);
                     //现将昵称和性别存放在散列表(关键是昵称):
                     listTable.put(people,people+"("+sex+")");    //再将昵称添加到List组件中:
                     
                     listComponent.add((String)listTable.get(people)); 
                     listComponent.repaint();  //刷新List组件,显示新用户昵称.                     
                    } 
                 else if(s.startsWith("用户离线:"))
                    {             //删除已离线的聊天者信息.
                      String awayPeopleName=s.substring(s.indexOf(":")+1);
                      listComponent.remove((String)listTable.get(awayPeopleName));
                      listComponent.repaint();
                      谈话显示区.append("\n"+(String)listTable.get(awayPeopleName)+"离线"); 
                      listTable.remove(awayPeopleName);
                    }
                 Thread.sleep(5); 
               } 
            catch(IOException e)        //服务器关闭套接字连接时，导致IOException。
               {
                  listComponent.removeAll();
                  listComponent.repaint(); 
                  listTable.clear();
                  谈话显示区.setText("和服务器的连接已中断\n必须刷新浏览器才能再次聊天");
                  break;
               }
            catch(InterruptedException e)
               {
               }
        }
  }
}