package?javaqq;
import?java.io.*;
import?java.net.*;

import?sun.audio.*;
public?class?Catcher?extends?Thread?{
	MulticastSocket?Csocket;
	Socket?CheckSocket;
	Stateframe?sf;
	InetAddress?Cgroup;
	DatagramPacket?packet;
	DatagramSocket?socket;
	String?tag;
	int?i=0k;
	
	BufferedReader?in;
	PrintWriter?out;
	
	UserInfo[]?userinfo;
	
	public?final?static?int?CATCH_PORT=7322;
	public?final?static?int?CHECK_PORT=5001;
	
	public?Catcher（MulticastSocket?csocket?Stateframe?sf?String?tag?UserInfo[]?userinfo）?{
		Csocket?=?csocket;
		this.sf?=?sf;
		this.tag?=?tag;
		this.userinfo?=?userinfo;
		try?{
			Cgroup=InetAddress.getByName（“239.0.0.0“）;
		}?catch?（UnknownHostException?e）?{
			e.printStackTrace（）;
		}
		start（）;
	}
	
	//實現(xiàn)對組播端口的監(jiān)聽，并作出反映
	public?void?run（）{
		try?{
			socket=new?DatagramSocket（）;
			while（true）{
				byte[]?Rdata=new?byte[256];
				packet=new?DatagramPacket（RdataRdata.length）;
				Csocket.receive（packet）;//等待接受數(shù)據(jù)包
				//count記錄了數(shù)據(jù)包的最后一位數(shù)，也就是記錄了用戶名的長度。
				String?count=new?
					String（packet.getData（））.substring（packet.getLength（）-1packet.getLength（））;
				int?num=Integer.parseInt（count）;
				//check為數(shù)據(jù)包的IP地址
				String?check=new?String（packet.getData（））.substring（1+numpacket.getLength（）-1）;
				String?judge=new?String（packet.getData（））.substring（01）;
				String?usertag=new?String?（packet.getData（））.substring（1num+1）;
				//judge為“C”時反送一個含有對方用戶名以及本機的IP的數(shù)據(jù)包到組播組
				if（judge.equals（“C“））{
					i=sf.friList.getItemCount（）;
					processMsg（usertag）;
					userinfo[i]=new?UserInfo（usertagcheck）;
					ring（）;
					Connect（check）;
				}
				if（judge.equals（“D“））{
					while（userinfo[i]!=null）{
						String?l=userinfo[i].getName（）;
						if（l.equals（usertag））{
							k=i;
							while（userinfo[k]!=null）{
								userinfo[k]=userinfo[k+1];
								k++;
							}
							break;
						}
					}
					try?{
						removeMsg（usertag）;
					}?catch?（Exception?n）?{
						try?{
							removeMsg（usertag）;
						}?catch?（Exception?n2）?{}
					}
				}
			}
			
		}?catch?（Exception?e）?{
			e.printStackTrace（）;
		}
	}
	
	//Connect（）方法實現(xiàn)了對對方回應(yīng)本機信息的過程，
	//其中第一以及最后一個為無用信息，在接受方被吸收掉
	
	public?void?Connect（String?check）{
		try?{
			CheckSocket=new?Socket（checkCHECK_PORT）;
			in=new?BufferedReader（new
					InputStreamReader（CheckSocket.getInputStream（）））;
			out=new?PrintWriter（CheckSocket.getOutputStream（））;
			out.println（“--------------------------“）;
			out.flush（）;
			
			out.println（tag）;
			out.flush（）;
			
			out.println（InetAddress.getLocalHost（）.getHostAddress（））;
			out.flush（）;
			
			out.println（“---------------------------“）;
			out.flush（）;
		}??catch?（Exception?e）?{
			try?{
				in.close（）;
				out.close（）;
				CheckSocket.close（）;
			}?catch?（Exception?e1）?{
				e1.printStackTrace（）;
			}
			e.printStackTrace（）;
		}?finally{
			try?{
				in.close（）;
				out.close（）;
				CheckSocket.close（）;
			}?catch?（Exception?e1）?{