serverreceivethread.java

它能够进行简单的文字聊天和基本的信息交换。

/*
 * ServerReceiveThread.java
 
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

/**
 *
 * @author codewar1
 */
import java.awt.event.*;
import javax.swing.*;
import javax.swing.event.*;
import java.awt.*;

import java.io.*;
import java.net.*;
public class ServerReceiveThread extends Thread{
    JTextField jMsg;
    JTextArea jShow;
    client user;
  // iu IU;
    public boolean isStop;
    /** Creates a new instance of ServerReceiveThread */
    public ServerReceiveThread(
            JTextField jMsg,
            JTextArea jShow,
            client user
           // iu IU
            )
    {
                this.jMsg = jMsg;
                this.jShow = jShow;
                this.user = user;
             //  this.IU = IU;
                isStop = false;
        
             
    }
    
  public void run()
   {
       while(!isStop && !user.socket.isClosed())
       {
           try
           {
              
              // String type = read();
              // String type = (String)user.input.readObject();
               String type = user.decrypt((String)user.input.readObject());
               //jShow.append(type);
                
               if (type.equalsIgnoreCase("聊天信息"))
               {
                  // String what = (String)user.input.readObject();
                  //String what = read();
                   
                   String what = user.decrypt((String)user.input.readObject());
                  // jShow.append(what);
                   String msg = user.username+":"+what+"\n";
                   jShow.append(msg);
               }
               else if (type.equalsIgnoreCase("下线请求"))
               {
                   String msg = user.username+": log out"+"\n";
                   jShow.append(msg);
                       
                   user.input.close();
                   user.output.close();
                   user.socket.close();
                   user.k = 0;
                   
               }
         }
           catch(Exception e)
           {}
       }
   }
 /*  public String read(){
         String string = null;
         try
         {
         int bytesAvailable = user.input.available();
         if (bytesAvailable > 0)
         {
             byte[] bytes = new byte[bytesAvailable];
             user.input.read(bytes);
             string = new String(bytes);
         }
         }
         catch(Exception e)
           {}
         return string;
            
}*/
    
}