import org.apache.hadoop.yarn.server.webproxy.WebAppProxyServer; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
  YarnConfiguration conf = new YarnConfiguration();
  conf.set(YarnConfiguration.PROXY_ADDRESS, proxyAddress);
  webAppProxy = new WebAppProxyServer();
  webAppProxy.init(conf);
}
 

import org.apache.hadoop.yarn.server.webproxy.WebAppProxyServer; //导入依赖的package包/类
@Test
public void testBindAddress() {
  YarnConfiguration conf = new YarnConfiguration();

  InetSocketAddress defaultBindAddress = WebAppProxyServer.getBindAddress(conf);
  Assert.assertEquals("Web Proxy default bind address port is incorrect",
      YarnConfiguration.DEFAULT_PROXY_PORT,
      defaultBindAddress.getPort());
}
 

import org.apache.hadoop.yarn.server.webproxy.WebAppProxyServer; //导入依赖的package包/类
@Test
public void testWebAppProxyInStandAloneMode() throws YarnException,
    InterruptedException, IOException {
  conf.setBoolean(YarnConfiguration.AUTO_FAILOVER_ENABLED, false);
  WebAppProxyServer webAppProxyServer = new WebAppProxyServer();
  try {
    conf.set(YarnConfiguration.PROXY_ADDRESS, "0.0.0.0:9099");
    cluster.init(conf);
    cluster.start();
    getAdminService(0).transitionToActive(req);
    assertFalse("RM never turned active", -1 == cluster.getActiveRMIndex());
    verifyConnections();
    webAppProxyServer.init(conf);

    // Start webAppProxyServer
    Assert.assertEquals(STATE.INITED, webAppProxyServer.getServiceState());
    webAppProxyServer.start();
    Assert.assertEquals(STATE.STARTED, webAppProxyServer.getServiceState());

    // send httpRequest with fakeApplicationId
    // expect to get "Not Found" response and 404 response code
    URL wrongUrl = new URL("http://0.0.0.0:9099/proxy/" + fakeAppId);
    HttpURLConnection proxyConn = (HttpURLConnection) wrongUrl
        .openConnection();

    proxyConn.connect();
    verifyResponse(proxyConn);

    explicitFailover();
    verifyConnections();
    proxyConn.connect();
    verifyResponse(proxyConn);
  } finally {
    webAppProxyServer.stop();
  }
}
 

import org.apache.hadoop.yarn.server.webproxy.WebAppProxyServer; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
  YarnConfiguration conf = new YarnConfiguration();
  conf.set(YarnConfiguration.PROXY_ADDRESS, "0.0.0.0:8888");
  webAppProxy = new WebAppProxyServer();
  webAppProxy.init(conf);
}