serviceproxyloader.java

单点登陆

package net.s3o.core;

import java.util.Iterator;
import java.util.List;
import java.util.Map;

import net.s3o.common.ClientInfoWrapper;
import net.s3o.common.S3OConstant;
import net.s3o.common.S3OLog;
import net.s3o.core.service.IBaseService;
import net.s3o.core.service.ServiceProxyCenter;

public class ServiceProxyLoader extends Thread {
	
	private List serviceProxysList=null;
	private Map serviceProxys=null;
	
	public ServiceProxyLoader(List serviceProxysList,Map serviceProxys) {
		this.serviceProxysList=serviceProxysList;
		this.serviceProxys=serviceProxys;
		start();
	}
	

	 public void run() {
				try {

					if (serviceProxysList!=null && serviceProxys.size()<1){
						Iterator it=serviceProxysList.iterator();
						String serviceName=null;
						IBaseService baseService=null;
						while(it.hasNext()){
							serviceName=(String)it.next();
							baseService=ServiceProxyCenter.createSerivecProxy(S3OCoreModel.serverURL+S3OCoreModel.getServiceRequestPrefix()+"/"+serviceName);
							if (serviceName!=null && baseService!=null ){
								serviceProxys.put(serviceName,baseService);
							}
						}
						
					}else if (serviceProxys!=null){
						Iterator it=serviceProxys.keySet().iterator();
						String serviceName=null;
						String serviceURI=null;
						IBaseService baseService=null;
						while(it.hasNext()){
							serviceName=(String)it.next();
							serviceURI=S3OCoreModel.getServiceRequestPrefix()+"/"+(String)serviceProxys.get(serviceName);
							if (serviceName!=null && serviceURI!=null ){
								baseService=ServiceProxyCenter.createSerivecProxy(S3OCoreModel.serverURL+"/"+serviceURI);
								if (baseService!=null ){
									serviceProxys.put(serviceName,baseService);
								}
							}
						}
					}
					

					callInitService();
					
					return;
				} catch (Exception e) {
					e.printStackTrace();
					return;
				}
	 }
	  
	  
	 public void callInitService(){
			boolean regOK=false;
			if (serviceProxys!=null){
				IBaseService baseService=(IBaseService)serviceProxys.get(S3OConstant.SERVICENAME_OF_REGCLIENT_S);
				if (baseService!=null){
					ClientInfoWrapper clientInfo=new ClientInfoWrapper();
//					getClientServicePrefix
					clientInfo.setClientKey(S3OCoreModel.systemKey);
					clientInfo.setClientId(S3OCoreModel.clientURL);
					clientInfo.setClientURL(S3OCoreModel.clientURL);
					clientInfo.setClientServicePrefix(S3OCoreModel.getServiceRequestPrefix());
					regOK=((Boolean)(baseService.doService(clientInfo.getClientInfoMap()))).booleanValue();
				}
				
			}
			
			
			if (regOK){
				S3OLog.dealMessage("","S3O Client 在S3O认证服务器上成功注册.");
			}else{
				S3OLog.dealMessage("","S3O Client 无法在S3O认证服务器上正确注册!!!");
			}
	 }

	public Map getServiceProxys() {
		return serviceProxys;
	}

	public void setServiceProxys(Map serviceProxys) {
		this.serviceProxys = serviceProxys;
	}

	public List getServiceProxysList() {
		return serviceProxysList;
	}

	public void setServiceProxysList(List serviceProxysList) {
		this.serviceProxysList = serviceProxysList;
	}

}