gsipsthread.java

来自「是一款国外的网络游戏平台的源码*不是类似浩方那种虚拟局域网技术」· Java 代码 · 共 59 行

/*
 * Created on Jan 9, 2006
 *
 * TODO To change the template for this generated file go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
package org.GTADS.server;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;

/**
 * @author Administrator
 *
 * TODO To change the template for this generated type comment go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
public class GSIPSThread extends Thread{
	private Socket clientSocket;
	public GSIPSThread(Socket clientSocket){
		this.clientSocket = clientSocket;
		start();
	}
	
	public void run() {
		try {
			handleClients();
		} catch (IOException ioe){}
	}
	
	private void handleClients() throws IOException {
		DataOutputStream writeToClient = new DataOutputStream(clientSocket.getOutputStream());
		DataInputStream din = new DataInputStream(clientSocket.getInputStream());
		writeToClient.writeBytes("GSIP Server\n");
		String dataIn = new String();
		do {
			dataIn = din.readLine();
			if (dataIn != null && dataIn.equalsIgnoreCase("query server")){
				writeToClient.writeBytes(getServerInformation());
				clientSocket.close();
			}
		} while (dataIn != null);
	}
	
	private String getServerInformation(){
		String infoString = new String();
		// Grab information such as
		infoString += "server name=" + ServerConfig.getInstance().getServerName();
		infoString += ",server port=" + ServerConfig.getInstance().getServerPort();
		infoString += ",users connected=" + ServerCacheHandler.socketUserCache.size();
		infoString += ",max clients=" + ServerConfig.getInstance().getMaxClients();
		infoString += ",active chatrooms=" + ServerCacheHandler.chatroomNameCache.size();
		
		return infoString;
	}
}