clientchat.java

用java开发的网络聊天室

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package client;

/**
 *
 * @author Administrator
 */
import java.awt.*;
import java.io.*;
import java.net.*;
import java.applet.*;
import java.util.Hashtable;

public class ClientChat extends Applet implements Runnable
{
  Socket  socket=null;
  DataInputStream in=null; 
  DataOutputStream out=null; 
  InputNameTextField 用户提交昵称界面=null;
  ChatArea 用户聊天界面=null;
  Hashtable listTable;                   
  Label 提示条;
  Panel north, center;
  Thread thread;
  public void init() 
   {
    int width=getSize().width;                           
    int height=getSize().height;                          
    listTable=new Hashtable(); 
    setLayout(new BorderLayout()); 
    用户提交昵称界面=new  InputNameTextField(listTable);
    int h=用户提交昵称界面.getSize().height;
    用户聊天界面=new ChatArea("",listTable,width,height-(h+5));
    用户聊天界面.setVisible(false);
    提示条=new Label("正在连接到服务器,请稍等...",Label.CENTER);
    提示条.setForeground(Color.red);
    north=new Panel(new FlowLayout(FlowLayout.LEFT));
    center=new Panel();
    north.add(用户提交昵称界面);
    north.add(提示条);
    center.add(用户聊天界面);
    add(north,BorderLayout.NORTH);
    add(center,BorderLayout.CENTER);
    validate();
   }
 public void start()
   {
     if(socket!=null&&in!=null&&out!=null)
        {  try
              {
                socket.close();
                in.close(); 
                out.close();
                用户聊天界面.setVisible(false);
              
              }
          catch(Exception ee)
              {
              }
        }
     try
        {
         socket = new Socket(this.getCodeBase().getHost(), 6666);
         in=new DataInputStream(socket.getInputStream());
         out=new DataOutputStream(socket.getOutputStream());
        }
     catch (IOException ee)
        { 
          提示条.setText("连接失败");
        }
     if(socket!=null)
        {
         InetAddress address=socket.getInetAddress();
         提示条.setText("连接:"+address+"成功");
         用户提交昵称界面.setSocketConnection(socket,in,out);
         north.validate();
        } 
     if(thread==null)
        {
          thread=new Thread(this);
          thread.start();
        }
   } 
  
 public void stop()
   {
     try 
         {
           socket.close();
           thread=null;
         }
     catch(IOException e)
         {
          this.showStatus(e.toString());
         }
   }
 public void run()
 {  
    while(thread!=null)
        {
           if(用户提交昵称界面.get能否聊天()==true)
             {
                用户聊天界面.setVisible(true);
                用户聊天界面.setName(用户提交昵称界面.getName());
                用户聊天界面.setSocketConnection(socket,in,out);
                提示条.setText("祝聊天愉快!");
                center.validate();
                break;
             }
           try
               {
                 Thread.sleep(100);
               }
           catch(Exception e)
               {
               }
        }
 }  
}