hadoop jetty的应用

yui 发表于 2018-10-30 12:24:14

private HttpServer infoServer = null;　　
...
　　
private void startInfoServer(Configuration conf) throws IOException {
　　
// create a servlet to serve full-file content
　　
InetSocketAddress infoSocAddr = DataNode.getInfoAddr(conf);
　　
String infoHost = infoSocAddr.getHostName();
　　
int tmpInfoPort = infoSocAddr.getPort();
　　
this.infoServer = (secureResources == null)
　　
? new HttpServer("datanode", infoHost, tmpInfoPort, tmpInfoPort == 0,
　　
      conf, new AccessControlList(conf.get(DFS_ADMIN, " ")))
　　
: new HttpServer("datanode", infoHost, tmpInfoPort, tmpInfoPort == 0,
　　
      conf, new AccessControlList(conf.get(DFS_ADMIN, " ")),
　　
      secureResources.getListener());
　　
LOG.info("Opened info server at " + infoHost + ":" + tmpInfoPort);
　　
.....
　　
this.infoServer.addInternalServlet(null, "/streamFile/*", StreamFile.class); //添加datanode专属的servlet
　　
this.infoServer.addInternalServlet(null, "/getFileChecksum/*",
　　
   FileChecksumServlets.GetServlet.class);
　　
this.infoServer.setAttribute("datanode", this);
　　
this.infoServer.setAttribute(JspHelper.CURRENT_CONF, conf);
　　
this.infoServer.addServlet(null, "/blockScannerReport",
　　
                        DataBlockScanner.Servlet.class);
　　
if (WebHdfsFileSystem.isEnabled(conf, LOG)) {
　　
infoServer.addJerseyResourcePackage(DatanodeWebHdfsMethods.class
　　
   .getPackage().getName() + ";" + Param.class.getPackage().getName(),
　　
   WebHdfsFileSystem.PATH_PREFIX + "/*");
　　
}
　　
this.infoServer.start();
　　
}

页: [1]

运维网's Archiver

hadoop jetty的应用