import org.apache.hadoop.mapreduce.v2.app.client.MRClientService; //导入依赖的package包/类
@Test
public void testMRWebAppSSLDisabled() throws Exception {
  MRApp app = new MRApp(2, 2, true, this.getClass().getName(), true) {
    @Override
    protected ClientService createClientService(AppContext context) {
      return new MRClientService(context);
    }
  };
  Configuration conf = new Configuration();
  // MR is explicitly disabling SSL, even though setting as HTTPS_ONLY
  conf.set(YarnConfiguration.YARN_HTTP_POLICY_KEY, Policy.HTTPS_ONLY.name());
  Job job = app.submit(conf);

  String hostPort =
      NetUtils.getHostPortString(((MRClientService) app.getClientService())
        .getWebApp().getListenerAddress());
  // http:// should be accessible
  URL httpUrl = new URL("http://" + hostPort);
  HttpURLConnection conn = (HttpURLConnection) httpUrl.openConnection();
  InputStream in = conn.getInputStream();
  ByteArrayOutputStream out = new ByteArrayOutputStream();
  IOUtils.copyBytes(in, out, 1024);
  Assert.assertTrue(out.toString().contains("MapReduce Application"));

  // https:// is not accessible.
  URL httpsUrl = new URL("https://" + hostPort);
  try {
    HttpURLConnection httpsConn =
        (HttpURLConnection) httpsUrl.openConnection();
    httpsConn.getInputStream();
    Assert.fail("https:// is not accessible, expected to fail");
  } catch (Exception e) {
    Assert.assertTrue(e instanceof SSLException);
  }

  app.waitForState(job, JobState.SUCCEEDED);
  app.verifyCompleted();
}
 

import org.apache.hadoop.mapreduce.v2.app.client.MRClientService; //导入依赖的package包/类
@Test
public void testMRWebAppRedirection() throws Exception {

  String[] schemePrefix =
      { WebAppUtils.HTTP_PREFIX, WebAppUtils.HTTPS_PREFIX };
  for (String scheme : schemePrefix) {
    MRApp app = new MRApp(2, 2, true, this.getClass().getName(), true) {
      @Override
      protected ClientService createClientService(AppContext context) {
        return new MRClientService(context);
      }
    };
    Configuration conf = new Configuration();
    conf.set(YarnConfiguration.PROXY_ADDRESS, "9.9.9.9");
    conf.set(YarnConfiguration.YARN_HTTP_POLICY_KEY, scheme
      .equals(WebAppUtils.HTTPS_PREFIX) ? Policy.HTTPS_ONLY.name()
        : Policy.HTTP_ONLY.name());
    webProxyBase = "/proxy/" + app.getAppID();
    conf.set("hadoop.http.filter.initializers",
      TestAMFilterInitializer.class.getName());
    Job job = app.submit(conf);
    String hostPort =
        NetUtils.getHostPortString(((MRClientService) app.getClientService())
          .getWebApp().getListenerAddress());
    URL httpUrl = new URL("http://" + hostPort + "/mapreduce");

    HttpURLConnection conn = (HttpURLConnection) httpUrl.openConnection();
    conn.setInstanceFollowRedirects(false);
    conn.connect();
    String expectedURL =
        scheme + conf.get(YarnConfiguration.PROXY_ADDRESS)
            + ProxyUriUtils.getPath(app.getAppID(), "/mapreduce");
    Assert.assertEquals(expectedURL,
      conn.getHeaderField(HttpHeaders.LOCATION));
    Assert.assertEquals(HttpStatus.SC_MOVED_TEMPORARILY,
      conn.getResponseCode());
    app.waitForState(job, JobState.SUCCEEDED);
    app.verifyCompleted();
  }
}
 

import org.apache.hadoop.mapreduce.v2.app.client.MRClientService; //导入依赖的package包/类
@Override
protected ClientService createClientService(AppContext context) {
  return new MRClientService(context) {
    @Override
    public InetSocketAddress getBindAddress() {
      return NetUtils.createSocketAddr("localhost:9876");
    }

    @Override
    public int getHttpPort() {
      return -1;
    }
  };
}
 

import org.apache.hadoop.mapreduce.v2.app.client.MRClientService; //导入依赖的package包/类
@Override
protected ClientService createClientService(AppContext context) {
  return new MRClientService(context) {
    @Override
    public void serviceStop() throws Exception {
      numStops++;
      clientServiceStopped = numStops;
      super.serviceStop();
    }
  };
}
 

import org.apache.hadoop.mapreduce.v2.app.client.MRClientService; //导入依赖的package包/类
protected ClientService createClientService(AppContext context) {
  return new MRClientService(context);
}
 

import org.apache.hadoop.mapreduce.v2.app.client.MRClientService; //导入依赖的package包/类
@Override
protected ClientService createClientService(AppContext context) {
  clientService = new MRClientService(context);
  return clientService;
}
 

import org.apache.hadoop.mapreduce.v2.app.client.MRClientService; //导入依赖的package包/类
@Inject
public AMWebServices(final App app, final AppContext context) {
  this.appCtx = context;
  this.app = app;
  this.service = new MRClientService(context);
}