receivethread.java

用java开发的聊天程序源代码 包含客户端文件和服务器文件

import java.io.*;
import javax.swing.*;
import java.net.*;

/**
 *
 * 专用于接收网络传输对象的线程
 * 对对象进行简单的分类
 *
 * @author 戚荣波
 *
 * @version 1.0
 * @since J2SE 1.6
 */
public class ReceiveThread extends Thread
{
	private static int response = 0;//0 Waiting,1 Approve,2 Refuse
	
	/**
	 *向对方进行某要求后，所获得的对方的响应
	 *
	 *@return 对方回答
	 */
	public static int getResponse()
	{
		return response;
	}
	
	/**
	 *重设对方响应
	 *
	 *
	 */
	public static void setResponse(int i)
	{
		response = i;
	}
	
	public void run()
	{
		if(SomethingStored.s == null)return;
		SMessage aMessage;
		while(true)
		{
			try
			{
				aMessage = null;				
				aMessage = (SMessage)(SomethingStored.m_input.readObject());
			}
			catch(SocketException se)
			{
				Connect.mb_disconnect();
				SChattingMenu.mb_disconnect();
				return;
			}
			catch(Exception ioe)
			{
				System.err.println("Exception:"+ioe);
				ioe.printStackTrace();
				continue;
			}
			switch(aMessage.getMessageType())
			{
				case SMessage.MT_MESSAGE:
					aMessage.append(SomethingStored.yourName,SomethingStored.tp_show);
					break;
				case SMessage.MT_NAME:
					SomethingStored.yourName = aMessage.getString();
					break;
				case SMessage.MT_DISCONNECT:
					Connect.mb_disconnect();
					break;
				case SMessage.MT_FILE:
					String s = "是否接收来自"+SomethingStored.destIP+"的大小为"+aMessage.getFileLength()+"B的文件";
					int res = JOptionPane.showConfirmDialog(ShowWindow.app,
						s,"",JOptionPane.CANCEL_OPTION);
					if(res == JOptionPane.OK_OPTION)
					{
						SChattingFrame.writeSMessage(SMessage.MT_AGREE,null,null,null);
						SChattingFrame.showMessage("File is receiving...");
						new FileReceiveThread(aMessage.getString(),aMessage.getFileLength(),SomethingStored.filePort,false).start();
					}		
					else SChattingFrame.writeSMessage(SMessage.MT_REFUSE,null,null,null);
					
					break;
				case SMessage.MT_SHOCK:
					shockListener.mb_shock();
					break;
				case SMessage.MT_PICTURE:
					new FileReceiveThread(aMessage.getString(),aMessage.getFileLength(),SomethingStored.filePort,true).start();
					break;
				case SMessage.MT_AGREE:
					response = 1;
					break;
				case SMessage.MT_REFUSE:
					response = 2;
					break;
					
			}
		}
	}
}