serverpublishmanager.java

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

/*
 * Created on Aug 21, 2006
 *
 * To change the template for this generated file go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */
package org.GTADS.server;

import org.GTADS.debug.ServerLogger;
import org.GTADS.helper.WebClient;

/**
 * @author sday
 *
 * To change the template for this generated type comment go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */
public class ServerPublishManager extends Thread {
	private static ServerPublishManager instance = null;
	
	public static ServerPublishManager getInstance(){
		if (instance == null){
			instance = new ServerPublishManager();
		}
		return instance;
	}
	
	public static void clearInstance(){
		if (instance != null){
			instance = null;
		}
	}
	
	public static boolean hasInstance(){
		return instance != null;
	}
	
	ServerPublishManager(){
		ServerLogger.sendConsoleDebugMessage("Starting Web Publishing Service to URL " + 
				ServerConfig.getInstance().getPublishURL() + "...", this.getClass());
		start();
	}
	
	public void run(){
		try {
			while(true){
				String fullyFormedURL = ServerConfig.getInstance().getPublishURL() + "?hostname=" 
				+ ServerConfig.getInstance().getHostName() + "&port=" + ServerConfig.getInstance().getGSIPPort();
				String webContent = WebClient.webGet(fullyFormedURL);
				if (webContent != null){
					ServerLogger.sendConsoleDebugMessage("Successfully registered to web service!", this.getClass());
				}
				else {
					ServerLogger.sendConsoleDebugMessage("Error going to URL " + fullyFormedURL + "!!!", this.getClass());
				}
				ServerLogger.sendConsoleDebugMessage("Sleeping for " + ServerConfig.getInstance().getPublishInterval() + " seconds"
						,this.getClass());
				//...
				Thread.sleep(ServerConfig.getInstance().getPublishInterval() * 1000);
			}
		} catch (InterruptedException ie){
			return;
		}
	}
}