server.java

这是我们专业的课程设计

package Sever;

import java.net.Socket;

import org.w3c.dom.Document;

import Commen.AnalyzeXML;
import Commen.NetIO;
import Commen.Send;
import Data.AdministratorCommandData;
import Data.InnerPassengerCommandData;
import Data.OuterPassengerCommandData;
import Data.StateData;
import Event.FinishAnalyseListener;
import Event.ServerEventListener;
import XML.TransXML;

public class Server extends Thread implements FinishAnalyseListener {
	private Socket socket;
	private NetIO IO;
	private boolean isActive = false;// 是否处于活动状态

	private boolean isAdmin = false;
	private ServerEventListener listener;
	private AnalyzeXML analyzer;

	public Server(Socket socket, ServerEventListener listener) {
		this.isActive = true;
		this.socket = socket;
		this.listener = listener;
		analyzer = new AnalyzeXML(this);
		IO = new NetIO(socket);
	}

	public void run() {// 由分析器分析后发回事件
		while (isActive) {
			try {
				if (IO.CanRead()) {
					String docStr = IO.ReadString();
					Document doc = TransXML.StringToXMLDoc(docStr);
					analyzer.Analyze(doc);
				}
			} catch (Exception ex) {
				System.out.println("trace" + ex);
			}
			try {
				Thread.sleep(50);
			}catch (Exception ex){}
		}
		System.out.println("connection stop");
		Close();
	}

	public void HandleCommendVoice(String ip) {
		System.out.println("Server:its client want to start voice " + ip);
		listener.LetAdminToConnect(this, ip);
	}

	public void HandleCommendEndVoice() {
		System.out.println("Server:its client want to end voice ");
		listener.CloseAvoiceConnect(this);
	}

	public void HandleCommendGetFile(String ip) {
		System.out.println("Server:Its client want the file");
		listener.RequireTransferNoteFile(ip);
	}

	public void HandleCommendBeAdmin() {
		isAdmin = true;
		System.out.println("Server:Its client want become Admin");
		listener.SetAdmin(this);
	}

	public void HandleCommendClose() {
		System.out.println("Server:its client want to close");
		listener.CloseThisServer(this);
		Close();
	}

	public void HandleAllData(StateData data) {
	}

	public void HandleInData(InnerPassengerCommandData data) {
		listener.RecieveInData(data);
	}

	public void HandleOutData(OuterPassengerCommandData data) {
		listener.RecieveOutData(data);
	}

	public void HandleAdminData(AdministratorCommandData data) {
		listener.RecieveAdminData(data);
	}

	public void SendCommendVoice(String ip) {// 发出声音请求 并打开一个线程来接管
		System.out.println("Server:send voice commend to its client");
		Send.BeginVoice(ip, IO);
	}

	public void SendCommendEndVoice() {
		System.out.println("Server:send EndVoice commend to its client");
		Send.EndVoice(IO);
	}

	public void SendAllData(StateData data) {
		System.out.println("Server:send AllData Data to its client");
		Send.AllData(IO, data);
	}

	public void EndVoice() {// 貌似没事情

	}

	public void Close() {
		try {
			if (isAdmin) {
				listener.SetAdmin(null);
			}
			IO.Close();
			isActive = false;
			socket.close();
		} catch (Exception ex) {
			System.out.println(ex);
		}
	}

	public boolean IsAdmin() {
		return isAdmin;
	}

	public Socket GetSocket() {
		return socket;
	}

}