import com.google.auth.http.HttpTransportFactory; //导入依赖的package包/类
private static GoogleCredentials createApplicationDefaultCredential() throws IOException {
  final MockTokenServerTransport transport = new MockTokenServerTransport();
  transport.addServiceAccount(ServiceAccount.EDITOR.getEmail(), ACCESS_TOKEN);

  // Set the GOOGLE_APPLICATION_CREDENTIALS environment variable for application-default
  // credentials. This requires us to write the credentials to the location specified by the
  // environment variable.
  File credentialsFile = File.createTempFile("google-test-credentials", "json");
  PrintWriter writer = new PrintWriter(Files.newBufferedWriter(credentialsFile.toPath(), UTF_8));
  writer.print(ServiceAccount.EDITOR.asString());
  writer.close();
  Map<String, String> environmentVariables =
      ImmutableMap.<String, String>builder()
          .put("GOOGLE_APPLICATION_CREDENTIALS", credentialsFile.getAbsolutePath())
          .build();
  TestUtils.setEnvironmentVariables(environmentVariables);
  credentialsFile.deleteOnExit();

  return GoogleCredentials.getApplicationDefault(new HttpTransportFactory() {
    @Override
    public HttpTransport create() {
      return transport;
    }
  });
}
 

import com.google.auth.http.HttpTransportFactory; //导入依赖的package包/类
private static GoogleCredentials createRefreshTokenCredential() throws IOException {

    final MockTokenServerTransport transport = new MockTokenServerTransport();
    transport.addClient(CLIENT_ID, CLIENT_SECRET);
    transport.addRefreshToken(REFRESH_TOKEN, ACCESS_TOKEN);

    Map<String, Object> secretJson = new HashMap<>();
    secretJson.put("client_id", CLIENT_ID);
    secretJson.put("client_secret", CLIENT_SECRET);
    secretJson.put("refresh_token", REFRESH_TOKEN);
    secretJson.put("type", "authorized_user");
    InputStream refreshTokenStream =
        new ByteArrayInputStream(JSON_FACTORY.toByteArray(secretJson));

    return UserCredentials.fromStream(refreshTokenStream, new HttpTransportFactory() {
      @Override
      public HttpTransport create() {
        return transport;
      }
    });
  }
 

import com.google.auth.http.HttpTransportFactory; //导入依赖的package包/类
/**
 * Ensures initialization of Google Application Default Credentials. Any test that depends on
 * ADC should consider this as a fixture, and invoke it before hand. Since ADC are initialized
 * once per JVM, this makes sure that all dependent tests get the same ADC instance, and
 * can reliably reason about the tokens minted using it.
 */
public static synchronized GoogleCredentials getApplicationDefaultCredentials()
    throws IOException {
  if (defaultCredentials != null) {
    return defaultCredentials;
  }
  final MockTokenServerTransport transport = new MockTokenServerTransport();
  transport.addServiceAccount(ServiceAccount.EDITOR.getEmail(), TEST_ADC_ACCESS_TOKEN);
  File serviceAccount = new File("src/test/resources/service_accounts", "editor.json");
  Map<String, String> environmentVariables =
      ImmutableMap.<String, String>builder()
          .put("GOOGLE_APPLICATION_CREDENTIALS", serviceAccount.getAbsolutePath())
          .build();
  setEnvironmentVariables(environmentVariables);
  defaultCredentials = GoogleCredentials.getApplicationDefault(new HttpTransportFactory() {
    @Override
    public HttpTransport create() {
      return transport;
    }
  });
  return defaultCredentials;
}
 

import com.google.auth.http.HttpTransportFactory; //导入依赖的package包/类
private static HttpTransportFactory wrap(final HttpTransport transport) {
  checkNotNull(transport, "HttpTransport must not be null");
  return new HttpTransportFactory() {
    @Override
    public HttpTransport create() {
      return transport;
    }
  };
}
 

import com.google.auth.http.HttpTransportFactory; //导入依赖的package包/类
private static GoogleCredentials createCertificateCredential() throws IOException {
  final MockTokenServerTransport transport = new MockTokenServerTransport();
  transport.addServiceAccount(ServiceAccount.EDITOR.getEmail(), ACCESS_TOKEN);
  return ServiceAccountCredentials.fromStream(ServiceAccount.EDITOR.asStream(),
      new HttpTransportFactory() {
        @Override
        public HttpTransport create() {
          return transport;
        }
      });
}
 

import com.google.auth.http.HttpTransportFactory; //导入依赖的package包/类
/**
 * Creates and returns HttpTransportOptions from the given connection parameters.
 * 
 * @param parameters
 *          the connection parameters
 * @return the HttpTransportOptions
 */
private static HttpTransportOptions getHttpTransportOptions(ConnectionParameters parameters) {
  HttpTransportOptions.Builder httpOptionsBuilder = HttpTransportOptions.newBuilder();
  httpOptionsBuilder.setConnectTimeout(parameters.getConnectionTimeout());
  httpOptionsBuilder.setReadTimeout(parameters.getReadTimeout());

  HttpTransportFactory httpTransportFactory = parameters.getHttpTransportFactory();
  if (httpTransportFactory != null) {
    httpOptionsBuilder.setHttpTransportFactory(httpTransportFactory);
  }
  return httpOptionsBuilder.build();
}
 

import com.google.auth.http.HttpTransportFactory; //导入依赖的package包/类
@VisibleForTesting
HttpTransportFactory getTransportFactory(final HttpClient httpClient)
{
  return () -> new ApacheHttpTransport(httpClient);
}
 

import com.google.auth.http.HttpTransportFactory; //导入依赖的package包/类
public TestApp()  {

    String projectId = ServiceOptions.getDefaultProjectId();
	try {

		//export GRPC_PROXY_EXP=localhost:3128
		HttpHost proxy = new HttpHost("127.0.0.1",3128);
		DefaultHttpClient httpClient = new DefaultHttpClient();
		httpClient.getParams().setParameter(ConnRoutePNames.DEFAULT_PROXY, proxy);
					
		httpClient.addRequestInterceptor(new HttpRequestInterceptor(){            
			@Override
			public void process(org.apache.http.HttpRequest request, HttpContext context) throws HttpException, IOException {
					//if (request.getRequestLine().getMethod().equals("CONNECT"))                 
					//   request.addHeader(new BasicHeader("Proxy-Authorization","Basic dXNlcjE6dXNlcjE="));
				}
			});
		
		mHttpTransport =  new ApacheHttpTransport(httpClient);		

		HttpTransportFactory hf = new HttpTransportFactory(){
			@Override
			public HttpTransport create() {
				return mHttpTransport;
			}
		};            
		
		credential = GoogleCredentials.getApplicationDefault(hf);

		CredentialsProvider credentialsProvider =  new GoogleCredentialsProvider(){
			public List<String> getScopesToApply(){
				return Arrays.asList("https://www.googleapis.com/auth/pubsub");
			   }

			public Credentials getCredentials()  {
				return credential;
			}
		};

		TopicAdminSettings topicAdminSettings =
		     TopicAdminSettings.newBuilder().setCredentialsProvider(credentialsProvider)
				 .build();
				 
		 TopicAdminClient topicAdminClient =
		     TopicAdminClient.create(topicAdminSettings);
		
		//TopicAdminClient topicAdminClient = TopicAdminClient.create();
		ProjectName project = ProjectName.create(projectId);
		for (Topic element : topicAdminClient.listTopics(project).iterateAll()) 
	  		System.out.println(element.getName());
	
	} catch (Exception ex) 
	{
		System.out.println("ERROR " + ex);
	}
  }
 

import com.google.auth.http.HttpTransportFactory; //导入依赖的package包/类
@Override
protected final void configure() {
  requireBinding(HttpTransportFactory.class);
  requireBinding(Key.get(new TypeLiteral<List<String>>() {}, Scopes.class));
}
 

import com.google.auth.http.HttpTransportFactory; //导入依赖的package包/类
@Provides
@Singleton
final Credentials provideCredentials(HttpTransportFactory transport, @Scopes List<String> scopes)
    throws IOException {
  return GoogleCredentials.getApplicationDefault(checkNotNull(transport)).createScoped(scopes);
}
 

import com.google.auth.http.HttpTransportFactory; //导入依赖的package包/类
/**
 * Returns the HttpTransportFactory.
 * 
 * @return the HttpTransportFactory.
 */
public HttpTransportFactory getHttpTransportFactory() {
  return httpTransportFactory;
}
 

import com.google.auth.http.HttpTransportFactory; //导入依赖的package包/类
/**
 * Sets the HttpTransportFactory.
 * 
 * @param httpTransportFactory
 *          the HttpTransportFactory
 */
public void setHttpTransportFactory(HttpTransportFactory httpTransportFactory) {
  this.httpTransportFactory = httpTransportFactory;
}