diff --git a/Production/Public/proto/gen-java/TClient.java b/Production/Public/proto/gen-java/TClient.java index 796b69f..c803a8b 100644 --- a/Production/Public/proto/gen-java/TClient.java +++ b/Production/Public/proto/gen-java/TClient.java @@ -3,12 +3,6 @@ import com.chd.proto.CloudHardDiskService; import com.chd.proto.loginResult; -import org.apache.thrift.TException; -import org.apache.thrift.protocol.TBinaryProtocol; -import org.apache.thrift.protocol.TProtocol; -import org.apache.thrift.transport.THttpClient; -import org.apache.thrift.transport.TTransportException; - import org.apache.http.HttpVersion; import org.apache.http.conn.params.ConnManagerParams; import org.apache.http.conn.params.ConnPerRouteBean; @@ -19,10 +13,15 @@ import org.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager; import org.apache.http.params.BasicHttpParams; import org.apache.http.params.HttpConnectionParams; +import org.apache.thrift.TException; +import org.apache.thrift.protocol.TBinaryProtocol; +import org.apache.thrift.protocol.TProtocol; +import org.apache.thrift.transport.THttpClient; +import org.apache.thrift.transport.TTransportException; - - - +import java.util.HashSet; +import java.util.Iterator; +import java.util.Set; public class TClient { @@ -31,7 +30,67 @@ public class TClient { private ThreadSafeClientConnManager tscm; private static CloudHardDiskService.Client tclient; private static TClient instacne=null; + private final String defaulturl="http://211.155.225.74:8888/chdserver.php"; + private Set servletUrl=null; + + class URLBean + { + private String url; + private int available; + public URLBean(String url1) + { + setUrl(url1); + setAvailable(10); + } + + public String getUrl() { + return url; + } + + public void setUrl(String url1) { + this.url = url; + } + + + public int getAvailable() { + return available; + } + + public void setAvailable(int available) { + this.available = available; + } + } + + + private String getServerUrl() + { + Iterator iterator= servletUrl.iterator(); + URLBean item0=null; + String url=null; + int mmax=Integer.MIN_VALUE; + while (iterator.hasNext()) + { + item0=iterator.next(); + if (mmax(); + for(String url:urls) + { + servletUrl.add(new URLBean(url)); + } + } public TClient getinstance() throws TTransportException { @@ -44,29 +103,32 @@ public TClient() throws TTransportException { BasicHttpParams params= new BasicHttpParams(); params.setParameter("http.protocol.version", HttpVersion.HTTP_1_1); params.setParameter("http.protocol.content-charset", "UTF-8"); -// // Disable Expect-Continue params.setParameter("http.protocol.expect-continue", false); -// // Enable staleness check params.setParameter("http.connection.stalecheck", true); HttpConnectionParams.setSoTimeout(params, 10000); // 10 secondes HttpConnectionParams.setConnectionTimeout(params, 10000); // 10 secondes + //Configuration. ConnManagerParams.setMaxTotalConnections(params, 2); ConnPerRouteBean connPerRoute = new ConnPerRouteBean(20); ConnManagerParams.setMaxConnectionsPerRoute(params, connPerRoute); // + // Registry registry=new Registry(); SchemeRegistry schemeRegistry = new SchemeRegistry(); schemeRegistry.register(new Scheme("http", PlainSocketFactory.getSocketFactory(), 8080)); // tscm = new ThreadSafeClientConnManager(params, schemeRegistry); -// - String servletUrl = "http://211.155.225.74:8888/chdserver.php"; -// + + String servletUrl = getServerUrl(); + THttpClient thc= new THttpClient(servletUrl, new DefaultHttpClient(tscm, params)); TProtocol loPFactory = new TBinaryProtocol(thc); tclient = new CloudHardDiskService.Client(loPFactory); } + + + public loginResult loginAuth(String username, String password, int salt) throws TException { String uname = "hzshark"; String pwd = "aerohive";