org.mortbay.jetty.servlet.Context.addServlet()方法的使用及代码示例

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

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

Context.addServlet介绍

[英]conveniance method to add a servlet.
[中]conveniance方法添加servlet。

代码示例

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

root.addServlet(new ServletHolder(avServlet), "/" + pluginWebPath + "/*");
PluginRegistry.getRegistry().register(
  new ViewerPlugin(pluginName, pluginWebPath, pluginOrder,

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

final ServletHolder indexRedirect =
  new ServletHolder(new IndexRedirectServlet(defaultServletPath));
root.addServlet(indexRedirect, "/");
final ServletHolder index = new ServletHolder(new ProjectServlet());
root.addServlet(index, "/index");
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");
root.addServlet(new ServletHolder(new FlowTriggerServlet()), "/flowtrigger");
root.addServlet(restliHolder, "/restli/*");

代码示例来源: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: voldemort/voldemort

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: 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: stackoverflow.com

static void startJetty() {
  try {
    Server server = new Server();
    Connector con = new SelectChannelConnector();
    con.setPort(80);
    server.addConnector(con);
    Context context = new Context(server, "/", Context.SESSIONS);
    context.addServlet(new ServletHolder(new MyApp()), "/*");
    server.start();
  } catch (Exception ex) {
    System.err.println(ex);
  }
}

代码示例来源: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);
  }
}

代码示例来源:origin: rhuss/jolokia

/**
 * Constructor
 *
 * @param pParent parent for creating proper exceptions
 * @param pConfig configuration of the server
 */
MortbayMuleAgentHttpServer(Agent pParent, MuleAgentConfig pConfig) {
  parent = pParent;
  // Initialise server
  server = getServer(pConfig);
  Context root = getContext(server, pConfig);
  ServletHolder servletHolder = getServletHolder(pConfig);
  root.addServlet(servletHolder, "/*");
}

代码示例来源: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: org.mortbay.jetty/jetty-servlet-tester

/**
 * @param servlet
 * @param pathSpec
 * @return
 * @see org.mortbay.jetty.servlet.Context#addServlet(java.lang.Class, java.lang.String)
 */
public ServletHolder addServlet(Class servlet, String pathSpec)
{
  return _context.addServlet(servlet,pathSpec);
}

代码示例来源:origin: org.mortbay.jetty/jetty-servlet-tester

/**
 * @param className
 * @param pathSpec
 * @return
 * @see org.mortbay.jetty.servlet.Context#addServlet(java.lang.String, java.lang.String)
 */
public ServletHolder addServlet(String className, String pathSpec)
{
  return _context.addServlet(className,pathSpec);
}

代码示例来源:origin: stackoverflow.com

Servlet servlet = new MyServlet();
String mapping = "/foo";

  Server server = new Server(0);
  Context servletContext = new Context(server, contextPath, Context.SESSIONS);
  servletContext.addServlet(new ServletHolder(servlet), mapping);
  server.start();

  URL url = new URL("http", "localhost", server.getConnectors()[0].getLocalPort(), "/foo?bar");

  //get the url...assert what you want

  //finally server.stop();

代码示例来源:origin: org.ctoolkit.test/ctoolkit-test

@Inject
public JettyServer( int portNumber )
{
  server = new Server( portNumber );
  context = new Context( server, "/", Context.SESSIONS );
  context.addFilter( GuiceFilter.class, "/*", 0 );
  context.addServlet( DefaultServlet.class, "/" );
}

代码示例来源:origin: org.apache.hadoop/avro

/** Starts a server on the named port. */
public HttpServer(ResponderServlet servlet, int port) throws IOException {
 this.server = new org.mortbay.jetty.Server(port);
 new Context(server,"/").addServlet(new ServletHolder(servlet), "/*");
 try {
  server.start();
 } catch (Exception e) {
  throw new AvroRuntimeException(e);
 }
}

代码示例来源:origin: org.apache.avro/avro-ipc

/** Constructs a server to run with the given connector. */
public HttpServer(ResponderServlet servlet, Connector connector) throws IOException {
 this.server = new org.mortbay.jetty.Server();
 server.addConnector(connector);
 new Context(server, "/").addServlet(new ServletHolder(servlet), "/*");
}

代码示例来源:origin: org.apache.avro/avro-ipc

public StatsServer(StatsPlugin plugin, int port) throws Exception {
 this.httpServer = new Server(port);
 this.plugin = plugin;
 Context staticContext = new Context(httpServer, "/static");
 staticContext.addServlet(new ServletHolder(new StaticServlet()), "/");
 Context context = new Context(httpServer, "/");
 context.addServlet(new ServletHolder(new StatsServlet(plugin)), "/");
 httpServer.start();
}

代码示例来源:origin: org.apache.cassandra.deps/avro

public StatsServer(StatsPlugin plugin, int port) throws Exception {
 this.httpServer = new Server(port);
 this.plugin = plugin;
 
 Context staticContext = new Context(httpServer, "/static");
 staticContext.addServlet(new ServletHolder(new StaticServlet()), "/");
 
 Context context = new Context(httpServer, "/");
 context.addServlet(new ServletHolder(new StatsServlet(plugin)), "/");
 
 httpServer.start();
}

代码示例来源:origin: com.lmco.shindig/shindig-gadgets

@Override
protected void addServlets() throws Exception {
 ServletHolder servletHolder = new ServletHolder(new EchoServlet());
 context.addServlet(servletHolder, "/*");
}

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

public static Server startCollectorOnPort(Configuration conf, int port, 
  ServletCollector collector) throws Exception {
 Server server = new Server(port);
 
 Context root = new Context(server, "/", Context.SESSIONS);
 root.addServlet(new ServletHolder(collector), "/*");
 root.addServlet(new ServletHolder(new CommitCheckServlet(conf)), "/"+CommitCheckServlet.DEFAULT_PATH);
 server.start();
 server.setStopAtShutdown(false);
 return server;
}

代码示例来源:origin: tcplugins/tcWebHooks

public WebHookTestProxyServer (String host, Integer port) {
  server = new Server(port);
  Context root = new Context(server,"/",Context.SESSIONS);
  root.addServlet(new ServletHolder(new ProxyServerServlet()), "/*");
}

相关文章