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

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

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

Context.addFilter介绍

[英]conveniance method to add a filter
[中]使用conveniance方法添加过滤器

代码示例

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

/**
 * @param filterClass
 * @param pathSpec
 * @param dispatches
 * @return
 * @see org.mortbay.jetty.servlet.Context#addFilter(java.lang.Class, java.lang.String, int)
 */
public FilterHolder addFilter(Class filterClass, String pathSpec, int dispatches)
{
  return _context.addFilter(filterClass,pathSpec,dispatches);
}

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

/**
 * @param filterClass
 * @param pathSpec
 * @param dispatches
 * @return
 * @see org.mortbay.jetty.servlet.Context#addFilter(java.lang.String, java.lang.String, int)
 */
public FilterHolder addFilter(String filterClass, String pathSpec, int dispatches)
{
  return _context.addFilter(filterClass,pathSpec,dispatches);
}

代码示例来源：origin: com.netflix.karyon/karyon2-admin

private void applyAdditionalFilters(final Context contextHandler, List<Filter> additionalFilters) {
  if (additionalFilters != null && !additionalFilters.isEmpty()) {
    for(Filter f : additionalFilters) {
      contextHandler.addFilter(new FilterHolder(f), "/*", Handler.DEFAULT);
    }
  }
}

代码示例来源：origin: jetoile/hadoop-unit

/**
 * Add a filter to the container.
 *
 * @param filterPath path for the filter, it should be prefixed with '/", it may contain a wild card at
 * the end.
 * @param filterClass servlet class
 */
public void addFilter(String filterPath, Class filterClass) {
  context.addFilter(new FilterHolder(filterClass), filterPath, 0);
}

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

Server server = new Server(port);
Context root = new Context(server, "/", Context.SESSIONS);
root.addEventListener(new GuiceServletConfig());
root.addFilter(GuiceFilter.class, "/*", 0);

代码示例来源：origin: com.twitter.common/net-http

/**
 * Registers a servlet filter.
 *
 * @param filterClass Filter class to register.
 * @param pathSpec Path spec that the filter should be activated on.
 * @param dispatch Filter dispatch mode.
 */
public synchronized void registerFilter(
  Class<? extends Filter> filterClass,
  String pathSpec,
  Dispatch dispatch) {
 MorePreconditions.checkNotBlank(pathSpec);
 Preconditions.checkNotNull(filterClass);
 context.addFilter(filterClass, pathSpec, dispatch.value);
}

代码示例来源：origin: airbnb/twitter-commons-sample

private void addRestSupport() {
 Context context = httpServer.getRootContext();
 context.addFilter(GuiceFilter.class, "/suggest/*", 0);
 context.addEventListener(servletConfig);
}

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

@Override
protected void configure(Context context) {
  super.configure(context);
  context.addFilter(CompressionFilter.class,"/*", Handler.DEFAULT);
}

代码示例来源：origin: org.dspace.dependencies.solr/dspace-solr-server

private void init( String context, int port )
{
 this.context = context;
 server = new Server( port );    
 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( SolrDispatchFilter.class, "*", Handler.REQUEST );
}

代码示例来源：origin: apache/hadoop-common

protected void start() 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";
 ServerSocket ss = new ServerSocket(0);
 port = ss.getLocalPort();
 ss.close();
 server.getConnectors()[0].setHost(host);
 server.getConnectors()[0].setPort(port);
 server.start();
 System.out.println("Running embedded servlet container at: http://" + host + ":" + port);
}

代码示例来源：origin: hopshadoop/hops

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: hortonworks/registry

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: 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: ch.cern.hadoop/hadoop-common

context.setContextPath("/foo");
jetty.setHandler(context);
context.addFilter(new FilterHolder(PseudoDTAFilter.class), "/*", 0);
context.addServlet(new ServletHolder(UserServlet.class), "/bar");

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

context.setContextPath("/foo");
jetty.setHandler(context);
context.addFilter(new FilterHolder(PseudoDTAFilter.class), "/*", 0);
context.addServlet(new ServletHolder(UserServlet.class), "/bar");

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

@Test
public void testExternalDelegationTokenSecretManager() throws Exception {
 DummyDelegationTokenSecretManager secretMgr
   = new DummyDelegationTokenSecretManager();
 final Server jetty = createJettyServer();
 Context context = new Context();
 context.setContextPath("/foo");
 jetty.setHandler(context);
 context.addFilter(new FilterHolder(AFilter.class), "/*", 0);
 context.addServlet(new ServletHolder(PingServlet.class), "/bar");
 try {
  secretMgr.startThreads();
  context.setAttribute(DelegationTokenAuthenticationFilter.
      DELEGATION_TOKEN_SECRET_MANAGER_ATTR, secretMgr);
  jetty.start();
  URL authURL = new URL(getJettyURL() + "/foo/bar?authenticated=foo");
  DelegationTokenAuthenticatedURL.Token token =
    new DelegationTokenAuthenticatedURL.Token();
  DelegationTokenAuthenticatedURL aUrl =
    new DelegationTokenAuthenticatedURL();
  aUrl.getDelegationToken(authURL, token, FOO_USER);
  Assert.assertNotNull(token.getDelegationToken());
  Assert.assertEquals(new Text("fooKind"),
    token.getDelegationToken().getKind());
 } finally {
  jetty.stop();
  secretMgr.stopThreads();
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Test
public void testExternalDelegationTokenSecretManager() throws Exception {
 DummyDelegationTokenSecretManager secretMgr
   = new DummyDelegationTokenSecretManager();
 final Server jetty = createJettyServer();
 Context context = new Context();
 context.setContextPath("/foo");
 jetty.setHandler(context);
 context.addFilter(new FilterHolder(AFilter.class), "/*", 0);
 context.addServlet(new ServletHolder(PingServlet.class), "/bar");
 try {
  secretMgr.startThreads();
  context.setAttribute(DelegationTokenAuthenticationFilter.
      DELEGATION_TOKEN_SECRET_MANAGER_ATTR, secretMgr);
  jetty.start();
  URL authURL = new URL(getJettyURL() + "/foo/bar?authenticated=foo");
  DelegationTokenAuthenticatedURL.Token token =
    new DelegationTokenAuthenticatedURL.Token();
  DelegationTokenAuthenticatedURL aUrl =
    new DelegationTokenAuthenticatedURL();
  aUrl.getDelegationToken(authURL, token, FOO_USER);
  Assert.assertNotNull(token.getDelegationToken());
  Assert.assertEquals(new Text("fooKind"),
    token.getDelegationToken().getKind());
 } finally {
  jetty.stop();
  secretMgr.stopThreads();
 }
}

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

Context

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com