org.mortbay.jetty.servlet.Context类的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(15.5k)|赞(0)|评价(0)|浏览(239)

本文整理了Java中org.mortbay.jetty.servlet.Context类的一些代码示例，展示了Context类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Context类的具体详情如下：
包路径：org.mortbay.jetty.servlet.Context
类名称：Context

Context介绍

[英]Servlet Context. This conveniance extention to the ContextHandler allows for simple construction of a context with ServletHandler and optionally session and security handlers, et.

new ServletContext("/context",Context.SESSIONS|Context.NO_SECURITY);

This class should have been called ServletContext, but this would have cause confusion with ServletContext.
[中]Servlet上下文。这种对ContextHandler的方便性扩展允许使用ServletHandler和可选的会话和安全处理程序等简单地构造上下文。

new ServletContext("/context",Context.SESSIONS|Context.NO_SECURITY);

这个类应该被称为ServletContext，但这会导致与ServletContext的混淆。

代码示例

代码示例来源：origin: voldemort/voldemort

public static Context getJettyServer(String clusterXml,
                   String storesXml,
                   String storeName,
                   RequestFormatType requestFormat,
                   int port) throws Exception {
  StoreRepository repository = getStores(storeName, clusterXml, storesXml);
  // initialize servlet
  Server server = new Server(port);
  server.setSendServerVersion(false);
  Context context = new Context(server, "/", Context.NO_SESSIONS);
  RequestHandler handler = getSocketRequestHandlerFactory(clusterXml, storesXml, repository).getRequestHandler(requestFormat);
  context.addServlet(new ServletHolder(new StoreServlet(handler)), "/stores");
  server.start();
  return context;
}

代码示例来源：origin: tjake/Solandra

public JettySolandraRunner( String context, int port, String host)
{

 this.context = context;
 server = new Server( port );   
 server.getConnectors()[0].setHost(host);

 server.setStopAtShutdown( true );
 // Initialize the servlets
 Context root = new Context( server, context, Context.SESSIONS );
 
 // for some reason, there must be a servlet for this to get applied
 root.addServlet( Servlet404.class, "/*" );
 dispatchFilter = root.addFilter( SolandraDispatchFilter.class, "*", Handler.REQUEST );
}

代码示例来源：origin: mapsforge/mapsforge

@Before
public final void beforeTest() throws Exception {
  Assert.assertFalse(this.httpRoot.exists());
  Assert.assertTrue(this.httpRoot.mkdirs());
  Context context = new Context(this.server, "/", Context.SESSIONS);
  context.setBaseResource(new FileResource(new URL("file://" + this.httpRoot.getAbsolutePath())));
  context.setContextPath("/");
  context.addServlet(new ServletHolder(new DefaultServlet()), "/*");
  this.server.setHandler(context);
  this.server.start();
}

代码示例来源：origin: voldemort/voldemort

threadPool.setName("VoldemortHttp");
threadPool.setMaxThreads(this.numberOfThreads);
Server httpServer = new Server();
httpServer.setConnectors(new Connector[] { connector });
httpServer.setThreadPool(threadPool);
httpServer.setSendServerVersion(false);
httpServer.setSendDateHeader(false);
Context context = new Context(httpServer, "/", Context.NO_SESSIONS);
context.setAttribute(VoldemortServletContextListener.SERVER_KEY, server);
context.setAttribute(VoldemortServletContextListener.VELOCITY_ENGINE_KEY,
           velocityEngine);
context.addServlet(new ServletHolder(new AdminServlet(server, velocityEngine)),
          "/admin");
context.addServlet(new ServletHolder(new StoreServlet(requestHandler)), "/stores");
context.addServlet(new ServletHolder(new ReadOnlyStoreManagementServlet(server,
                                    velocityEngine)),
          "/read-only/mgmt");
context.addServlet(new ServletHolder(new StatusServlet(server, velocityEngine)),
          "/server-status");
this.context = context;

代码示例来源：origin: azkaban/azkaban

this.props.getString("web.resource.dir", DEFAULT_STATIC_DIR);
logger.info("Setting up web resource dir " + staticDir);
final Context root = new Context(this.server, "/", Context.SESSIONS);
root.setMaxFormContentSize(MAX_FORM_CONTENT_SIZE);
root.setResourceBase(staticDir);
final ServletHolder indexRedirect =
  new ServletHolder(new IndexRedirectServlet(defaultServletPath));
root.addServlet(indexRedirect, "/");
final ServletHolder index = new ServletHolder(new ProjectServlet());
root.addServlet(index, "/index");
final ServletHolder staticServlet = new ServletHolder(new DefaultServlet());
root.addServlet(staticServlet, "/css/*");
root.addServlet(staticServlet, "/js/*");
root.addServlet(staticServlet, "/images/*");
root.addServlet(staticServlet, "/fonts/*");
root.addServlet(staticServlet, "/favicon.ico");
root.addServlet(new ServletHolder(new ProjectManagerServlet()), "/manager");
root.addServlet(new ServletHolder(new ExecutorServlet()), "/executor");
root.addServlet(new ServletHolder(new HistoryServlet()), "/history");
root.addServlet(new ServletHolder(new ScheduleServlet()), "/schedule");
root.addServlet(new ServletHolder(new JMXHttpServlet()), "/jmx");
root.addServlet(new ServletHolder(new TriggerManagerServlet()), "/triggers");
root.addServlet(new ServletHolder(new StatsServlet()), "/stats");
root.addServlet(new ServletHolder(new StatusServlet(this.statusService)), "/status");
root.addServlet(new ServletHolder(new NoteServlet()), "/notes");
root.addServlet(new ServletHolder(new FlowTriggerInstanceServlet()), "/flowtriggerinstance");

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

private void testDelegationTokenAuthenticatedURLWithNoDT(
  Class<? extends Filter> filterClass)  throws Exception {
 final Server jetty = createJettyServer();
 Context context = new Context();
 context.setContextPath("/foo");
 jetty.setHandler(context);
 context.addFilter(new FilterHolder(filterClass), "/*", 0);
 context.addServlet(new ServletHolder(UserServlet.class), "/bar");
  jetty.start();
  final URL url = new URL(getJettyURL() + "/foo/bar");
  jetty.stop();

代码示例来源：origin: io.hops/hadoop-auth

protected void startJetty() throws Exception {
 server = new Server(0);
 context = new Context();
 context.setContextPath("/foo");
 server.setHandler(context);
 context.addFilter(new FilterHolder(TestFilter.class), "/*", 0);
 context.addServlet(new ServletHolder(TestServlet.class), "/bar");
 host = "localhost";
 port = getLocalPort();
 server.getConnectors()[0].setHost(host);
 server.getConnectors()[0].setPort(port);
 server.start();
 System.out.println("Running embedded servlet container at: http://" + host + ":" + port);
}

代码示例来源：origin: org.jvnet.hudson.main/hudson-test-harness

public JavaNetReverseProxy(File cacheFolder) throws Exception {
  this.cacheFolder = cacheFolder;
  cacheFolder.mkdirs();
  server = new Server();
  ContextHandlerCollection contexts = new ContextHandlerCollection();
  server.setHandler(contexts);
  Context root = new Context(contexts, "/", Context.SESSIONS);
  root.addServlet(new ServletHolder(this), "/");
  SocketConnector connector = new SocketConnector();
  server.addConnector(connector);
  server.start();
  localPort = connector.getLocalPort();
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapred-test

private void startHttpServer() throws Exception {
 // Create the webServer
 if (webServer != null) {
  webServer.stop();
  webServer = null;
 }
 webServer = new Server(0);
 Context context = new Context(webServer, contextPath);
 // create servlet handler
 context.addServlet(new ServletHolder(new NotificationServlet()),
           servletPath);
 // Start webServer
 webServer.start();
 port = webServer.getConnectors()[0].getLocalPort();
}

代码示例来源：origin: com.linkedin.azkaban/azkaban

int maxThreads = props.getInt("executor.maxThreads", DEFAULT_THREAD_NUMBER);
server = new Server(portNumber);
QueuedThreadPool httpThreadPool = new QueuedThreadPool(maxThreads);
server.setThreadPool(httpThreadPool);
Context root = new Context(server, "/", Context.SESSIONS);
root.setMaxFormContentSize(MAX_FORM_CONTENT_SIZE);
root.addServlet(new ServletHolder(new ExecutorServlet()), "/executor");
root.addServlet(new ServletHolder(new JMXHttpServlet()), "/jmx");
root.setAttribute(AzkabanServletContextListener.AZKABAN_SERVLET_CONTEXT_KEY, this);
  server.start();

代码示例来源：origin: com.github.sakserv/hadoop-mini-clusters-hbase

ServletHolder sh = new ServletHolder(containerClass);
sh.setInitParameter("com.sun.jersey.config.property.resourceConfigClass", ResourceConfig.class.getCanonicalName());
sh.setInitParameter("com.sun.jersey.config.property.packages", "jetty");
ServletHolder shPojoMap = new ServletHolder(containerClass);
Map<String, String> shInitMap = sh.getInitParameters();
server = new Server();
server.addConnector(connector);
server.setThreadPool(threadPool);
server.setSendServerVersion(false);
server.setStopAtShutdown(true);
Context context = new Context(server, "/", Context.SESSIONS);
context.addServlet(shPojoMap, "/status/cluster");
context.addServlet(sh, "/*");
if (authFilter != null) {
  context.addFilter(authFilter, "/*", 1);

代码示例来源：origin: net.sf.taverna.t2.activities/interaction-activity

server = new Server(Integer.parseInt(port));
server.setStopAtShutdown(true);
final ServletHolder interactionHolder = new ServletHolder();
interactionHolder.setServlet(interactionServlet);
  interactionHolder.setInitParameter("rootpath",
      getInteractionDirectory().getCanonicalPath());
} catch (final IOException e1) {
final Context overallContext = new Context(handlers, "/",
    Context.SESSIONS);
overallContext.setContextPath("/");
server.setHandler(overallContext);
    BasicProvider.class.getName());
overallContext.addServlet(abderaHolder, "/*");
overallContext.addServlet(interactionHolder, "/interaction/*");
  overallContext.addHandler(sh);

代码示例来源：origin: NGDATA/hbase-indexer

private void startHttpServer() throws Exception {
  server = new Server();
  SelectChannelConnector selectChannelConnector = new SelectChannelConnector();
  selectChannelConnector.setPort(11060);
  server.setConnectors(new Connector[]{selectChannelConnector});
  PackagesResourceConfig packagesResourceConfig = new PackagesResourceConfig("com/ngdata/hbaseindexer/rest");
  ServletHolder servletHolder = new ServletHolder(new ServletContainer(packagesResourceConfig));
  servletHolder.setName("HBase-Indexer");
  Context context = new Context(server, "/", Context.NO_SESSIONS);
  context.addServlet(servletHolder, "/*");
  context.setContextPath("/");
  context.setAttribute("indexerModel", indexerModel);
  context.setAttribute("indexerSupervisor", indexerSupervisor);
  server.setHandler(context);
  server.start();
}

代码示例来源：origin: apache/chukwa

jettyConnector.setReuseAddress(true);
jettyServer = new Server(portNum);
jettyServer.setConnectors(new org.mortbay.jetty.Connector[] { jettyConnector });
QueuedThreadPool pool = new QueuedThreadPool();
pool.setMaxThreads(HTTP_SERVER_THREADS);
jettyServer.setThreadPool(pool);
ServletHolder servletHolder = new ServletHolder(ServletContainer.class);
servletHolder.setInitParameter("com.sun.jersey.config.property.resourceConfigClass",
    "com.sun.jersey.api.core.PackagesResourceConfig");
servletHolder.setInitParameter("com.sun.jersey.config.property.packages",
    jaxRsPackages.toString());
Context root = new Context(jettyServer, "/rest/v2", Context.SESSIONS);
root.setAttribute("ChukwaAgent", ChukwaAgent.getAgent());
root.addServlet(servletHolder, "/*");
root.setAllowNullPathInfo(false);

代码示例来源：origin: org.apache.shindig/shindig-gadgets

public void start(int port) throws Exception {
 server = new Server(port);
 context = new Context(server, "/", Context.SESSIONS);
 addServlets();
 server.start();
}

代码示例来源：origin: org.codehaus.xfire/xfire-core

httpServer = new Server();
  sslConector.setPassword(keystorePassword);
  sslConector.setKeyPassword(keyPassword);
  httpServer.addConnector(sslConector);
   httpServer.addConnector(connector);
loger.setRequestLog(null);
Context context = new Context(httpServer,"/",Context.SESSIONS);
context.setEventListeners(null);
context.addHandler(loger);
ServletHolder servlet = new ServletHolder(new XFireServlet());
context.addServlet(servlet, "/*");
  context.setAttribute(XFireServlet.XFIRE_INSTANCE, xfire);

代码示例来源：origin: apache/chukwa

agent.start();
ServletHolder servletHolder = new ServletHolder(ServletContainer.class);
servletHolder.setInitParameter("com.sun.jersey.config.property.resourceConfigClass",
    "com.sun.jersey.api.core.PackagesResourceConfig");
servletHolder.setInitParameter("com.sun.jersey.config.property.packages",
    "org.apache.hadoop.chukwa.datacollection.agent.rest");
servletHolder.setServletHandler(new ServletHandler());
jettyServer = new Server();
Context root = new Context(jettyServer, "/foo/bar", Context.SESSIONS);
root.setAttribute("ChukwaAgent", agent);
root.addServlet(servletHolder, "/*");
jettyServer.start();
jettyServer.setStopAtShutdown(true);
servlet = servletHolder.getServlet();

代码示例来源：origin: com.cloudera.llama/llama

protected synchronized void startHttpServer() {
 if (httpServer != null && httpServer.isRunning()) {
  return;
 httpServer = new Server();
 QueuedThreadPool qtp = new QueuedThreadPool(JETTY_MAX_THREADS);
 qtp.setName("llama-jetty");
 qtp.setDaemon(true);
 httpServer.setThreadPool(qtp);
 String strAddress = getServerConf().getHttpAddress();
 InetSocketAddress address = NetUtils.createSocketAddr(strAddress,
 httpServer.setConnectors(new Connector[]{connector});
 Context context = new Context();
 context.setContextPath("");
 context.setAttribute("hadoop.conf", new Configuration());
 context.addServlet(JMXJsonServlet.class, "/jmx");
 context.addServlet(LlamaServlet.class, "/*");
 context.addServlet(Log4jLoggersServlet.class, "/loggers");
 context.setAttribute(Log4jLoggersServlet.READ_ONLY,
   getServerConf().getLoggerServletReadOnly());
 context.addServlet(LlamaJsonServlet.class, LlamaJsonServlet.BIND_PATH);
 context.setAttribute(LlamaJsonServlet.REST_DATA, restData);
 httpServer.addHandler(context);

代码示例来源：origin: org.kuali.student.core/ks-common-test

server = new Server(Integer.valueOf(System
      .getProperty("ks.test.port")));
  Context context = new Context();
  ServletHandler servletHandler = new ServletHandler();
  ServletHolder servletHolder = new ServletHolder();
  ServletMapping servletMapping = new ServletMapping();
  ContextLoaderListener contextLoaderListener = new ContextLoaderListener();
  servletHolder.setName("Service");
  servletHolder.setServlet(servlet);
  servletHandler.setServlets(new ServletHolder[] { servletHolder });
      .setServletMappings(new ServletMapping[] { servletMapping });
  context.setContextPath("/Service");
  context.setResourceBase("src/test/resources");
  context.setInitParams(initParams);
  context
      .setEventListeners(new EventListener[] { contextLoaderListener });
  context.setServletHandler(servletHandler);
  server.setHandler(context);
  server.start();
} catch (Exception e) {
  throw new RuntimeException(e);

代码示例来源：origin: soabase/exhibitor

public ExhibitorMain(BackupProvider backupProvider, ConfigProvider configProvider, ExhibitorArguments.Builder builder, int httpPort, String listenAddress, SecurityHandler security, SecurityArguments securityArguments) throws Exception
{
  HashUserRealm realm = makeRealm(securityArguments);
  if ( securityArguments.getRemoteAuthSpec() != null )
  {
    addRemoteAuth(builder, securityArguments.getRemoteAuthSpec());
  }
  builder.shutdownProc(makeShutdownProc(this));
  exhibitor = new Exhibitor(configProvider, null, backupProvider, builder.build());
  exhibitor.start();
  DefaultResourceConfig   application = JerseySupport.newApplicationConfig(new UIContext(exhibitor));
  ServletContainer        container = new ServletContainer(application);
  server = new Server();
  SocketConnector http = new SocketConnector();
  http.setHost(listenAddress);
  http.setPort(httpPort);
  server.addConnector(http);
  Context root = new Context(server, "/", Context.SESSIONS);
  root.addFilter(ExhibitorServletFilter.class, "/", Handler.ALL);
  root.addServlet(new ServletHolder(container), "/*");
  if ( security != null )
  {
    root.setSecurityHandler(security);
  }
  else if ( securityArguments.getSecurityFile() != null )
  {
    addSecurityFile(realm, securityArguments.getSecurityFile(), root);
  }
}

内容来源于网络，如有侵权，请联系作者删除！

Context

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com