Java 类javax.servlet.http.HttpServlet 实例源码

项目：tomcat7 文件：TestExpiresFilter.java

@Test
public void testExcludedResponseStatusCode() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setStatus(HttpServletResponse.SC_NOT_MODIFIED);
            response.addHeader("ETag", "W/\"1934-1269208821000\"");
            response.addDateHeader("Date", System.currentTimeMillis());
        }
    };

    validate(servlet, null, HttpServletResponse.SC_NOT_MODIFIED);
}

项目：tomcat7 文件：TestExpiresFilter.java

@Test
public void testSkipBecauseExpiresIsDefined() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("text/xml; charset=utf-8");
            response.addDateHeader("Expires", System.currentTimeMillis());
            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, null);
}

项目：apache-tomcat-7.0.73-with-comment 文件：TestExpiresFilter.java

@Test
public void testExcludedResponseStatusCode() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setStatus(HttpServletResponse.SC_NOT_MODIFIED);
            response.addHeader("ETag", "W/\"1934-1269208821000\"");
            response.addDateHeader("Date", System.currentTimeMillis());
        }
    };

    validate(servlet, null, HttpServletResponse.SC_NOT_MODIFIED);
}

项目：apache-tomcat-7.0.73-with-comment 文件：TestExpiresFilter.java

@Test
public void testSkipBecauseExpiresIsDefined() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("text/xml; charset=utf-8");
            response.addDateHeader("Expires", System.currentTimeMillis());
            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, null);
}

项目：epay 文件：Expand.java

@Override
public void init(HttpServlet servlet) throws Exception {
    TimeZone.setDefault(TimeZone.getTimeZone("Asia/Shanghai"));
    ServletContext servletContext = servlet.getServletContext();
    String configFileName = servletContext.getInitParameter("configFileName");
    Properties properties = loadConfig(configFileName);
    MybatisManager.init(properties.getProperty("config_dir"), "mybatis-config.xml", new MariadbLog());
    HttpUtil.init("UTF-8", new HttpclientLog());
    ThreadmsgLog threadmsgLog = new ThreadmsgLog();
    AsyncThreadManager.init(100, 10, 3, 0, threadmsgLog);
    AsyncThreadManager.start();
    MsgManager.init(true, threadmsgLog);
    CommonConfig.init(properties);
    HOpCode.init();

    MsgOpCode.init();
    HttpManager.addFilter(new TokenHttpFilter());
    HttpManager.addHttpListener(new AppService());
    HttpManager.addHttpListener(new OrderRecordService());
    HttpManager.addHttpListener(new PayService());
    HttpManager.addHttpListener(new LoginService());
    MsgManager.addMsgListener(new NotifyService(10));
}

项目：hadoop-oss 文件：HttpServer2.java

/**
 * Add an internal servlet in the server, specifying whether or not to
 * protect with Kerberos authentication.
 * Note: This method is to be used for adding servlets that facilitate
 * internal communication and not for user facing functionality. For
 +   * servlets added using this method, filters (except internal Kerberos
 * filters) are not enabled.
 *
 * @param name The name of the servlet (can be passed as null)
 * @param pathSpec The path spec for the servlet
 * @param clazz The servlet class
 * @param requireAuth Require Kerberos authenticate to access servlet
 */
public void addInternalServlet(String name, String pathSpec,
    Class<? extends HttpServlet> clazz, boolean requireAuth) {
  ServletHolder holder = new ServletHolder(clazz);
  if (name != null) {
    holder.setName(name);
  }
  webAppContext.addServlet(holder, pathSpec);

  if(requireAuth && UserGroupInformation.isSecurityEnabled()) {
     LOG.info("Adding Kerberos (SPNEGO) filter to " + name);
     ServletHandler handler = webAppContext.getServletHandler();
     FilterMapping fmap = new FilterMapping();
     fmap.setPathSpec(pathSpec);
     fmap.setFilterName(SPNEGO_FILTER);
     fmap.setDispatches(Handler.ALL);
     handler.addFilterMapping(fmap);
  }
}

项目：startpoint 文件：Expand.java

@Override
public void init(HttpServlet servlet) throws Exception {
    TimeZone.setDefault(TimeZone.getTimeZone("Asia/Shanghai"));
    ServletContext servletContext = servlet.getServletContext();
    String configFileName = servletContext.getInitParameter("configFileName");
    Properties properties = loadConfig(configFileName);
    MybatisManager.init(properties.getProperty("config_dir"), "mybatis-config.xml", new MariadbLog());
    KeyLockManager.init(new UCenterKeyLockType().getkeyLockType(), 120000, 100, new KeylockLog());
    HOpCodeUCenter.init();
    CommonConfigUCenter.init();
    CommonConfigUCenter.UCENTER_URL = properties.getProperty("uCenterUrl");
    HttpManager.addFilter(new TokenHttpFilter());
    HttpManager.addHttpListener(new UserService());
    HttpManager.addHttpListener(new UserGroupService());
    HttpManager.addHttpListener(new TokenService());
}

项目：tomcat7 文件：TestExpiresFilter.java

/**
 * Test that a resource with empty content is also processed
 */
@Test
public void testEmptyContent() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("text/plain");
            // no content is written in the response
        }
    };

    validate(servlet, Integer.valueOf(7 * 60));
}

项目：tomcat7 文件：TestExpiresFilter.java

@Test
public void testSkipBecauseCacheControlMaxAgeIsDefined() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("text/xml; charset=utf-8");
            response.addHeader("Cache-Control", "private, max-age=232");
            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, Integer.valueOf(232));
}

项目：tomcat7 文件：TestExpiresFilter.java

@Test
public void testUseContentTypeExpiresConfiguration() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("text/xml; charset=utf-8");
            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, Integer.valueOf(3 * 60));
}

项目：tomcat7 文件：TestExpiresFilter.java

@Test
public void testUseContentTypeWithoutCharsetExpiresConfiguration()
        throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("text/xml; charset=iso-8859-1");
            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, Integer.valueOf(5 * 60));
}

项目：tomcat7 文件：TestExpiresFilter.java

@Test
public void testUseDefaultConfiguration1() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("image/jpeg");
            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, Integer.valueOf(1 * 60));
}

项目：tomcat7 文件：TestExpiresFilter.java

@Test
public void testUseDefaultConfiguration2() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("image/jpeg");
            response.addHeader("Cache-Control", "private");

            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, Integer.valueOf(1 * 60));
}

项目：tomcat7 文件：TestExpiresFilter.java

@Test
public void testUseMajorTypeExpiresConfiguration() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("text/json; charset=iso-8859-1");
            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, Integer.valueOf(7 * 60));
}

项目：tomcat7 文件：TestMimeHeaders.java

private void setupHeadersTest(Tomcat tomcat) {
    Context ctx = tomcat.addContext("", getTemporaryDirectory()
            .getAbsolutePath());
    Tomcat.addServlet(ctx, "servlet", new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        public void service(ServletRequest req, ServletResponse res)
                throws ServletException, IOException {
            res.setContentType("text/plain; charset=ISO-8859-1");
            res.getWriter().write("OK");
        }
    });
    ctx.addServletMapping("/", "servlet");

    alv = new HeaderCountLogValve();
    tomcat.getHost().getPipeline().addValve(alv);
}

项目：parabuild-ci 文件：WebXMLTest.java

public void testContextParameters() throws Exception {
    WebXMLString wxs = new WebXMLString();
    wxs.addServlet( "/SimpleServlet", SimpleGetServlet.class );
    wxs.addContextParam( "icecream", "vanilla" );
    wxs.addContextParam( "cone", "waffle" );
    wxs.addContextParam( "topping", "" );

    ServletRunner sr = new ServletRunner( toInputStream( wxs.asText() ) );
    ServletUnitClient client = sr.newClient();
    assertEquals( "Context parameter 'icecream'", "vanilla", sr.getContextParameter( "icecream" ) );
    InvocationContext ic = client.newInvocation( "http://localhost/SimpleServlet" );

    javax.servlet.ServletContext sc = ((HttpServlet) ic.getServlet()).getServletContext();
    assertNotNull( "ServletContext should not be null", sc );
    assertEquals( "ServletContext.getInitParameter()", "vanilla", sc.getInitParameter( "icecream" ) );
    assertEquals( "init parameter: cone", "waffle", sc.getInitParameter( "cone" ) );
    assertEquals( "init parameter: topping", "", sc.getInitParameter( "topping" ) );
    assertNull( "ServletContext.getInitParameter() should be null", sc.getInitParameter( "shoesize" ) );

}

项目：apache-tomcat-7.0.73-with-comment 文件：TestExpiresFilter.java

/**
 * Test that a resource with empty content is also processed
 */
@Test
public void testEmptyContent() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("text/plain");
            // no content is written in the response
        }
    };

    validate(servlet, Integer.valueOf(7 * 60));
}

项目：apache-tomcat-7.0.73-with-comment 文件：TestExpiresFilter.java

@Test
public void testSkipBecauseCacheControlMaxAgeIsDefined() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("text/xml; charset=utf-8");
            response.addHeader("Cache-Control", "private, max-age=232");
            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, Integer.valueOf(232));
}

项目：apache-tomcat-7.0.73-with-comment 文件：TestExpiresFilter.java

@Test
public void testUseContentTypeExpiresConfiguration() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("text/xml; charset=utf-8");
            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, Integer.valueOf(3 * 60));
}

项目：apache-tomcat-7.0.73-with-comment 文件：TestExpiresFilter.java

@Test
public void testUseContentTypeWithoutCharsetExpiresConfiguration()
        throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("text/xml; charset=iso-8859-1");
            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, Integer.valueOf(5 * 60));
}

项目：apache-tomcat-7.0.73-with-comment 文件：TestExpiresFilter.java

@Test
public void testUseDefaultConfiguration1() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("image/jpeg");
            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, Integer.valueOf(1 * 60));
}

项目：apache-tomcat-7.0.73-with-comment 文件：TestExpiresFilter.java

@Test
public void testUseDefaultConfiguration2() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("image/jpeg");
            response.addHeader("Cache-Control", "private");

            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, Integer.valueOf(1 * 60));
}

项目：apache-tomcat-7.0.73-with-comment 文件：TestExpiresFilter.java

@Test
public void testUseMajorTypeExpiresConfiguration() throws Exception {
    HttpServlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void service(HttpServletRequest request,
                HttpServletResponse response) throws ServletException,
                IOException {
            response.setContentType("text/json; charset=iso-8859-1");
            response.getWriter().print("Hello world");
        }
    };

    validate(servlet, Integer.valueOf(7 * 60));
}

项目：apache-tomcat-7.0.73-with-comment 文件：TestMimeHeaders.java

private void setupHeadersTest(Tomcat tomcat) {
    Context ctx = tomcat.addContext("", getTemporaryDirectory()
            .getAbsolutePath());
    Tomcat.addServlet(ctx, "servlet", new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        public void service(ServletRequest req, ServletResponse res)
                throws ServletException, IOException {
            res.setContentType("text/plain; charset=ISO-8859-1");
            res.getWriter().write("OK");
        }
    });
    ctx.addServletMapping("/", "servlet");

    alv = new HeaderCountLogValve();
    tomcat.getHost().getPipeline().addValve(alv);
}

项目：hadoop 文件：HttpServer.java

/**
 * Add an internal servlet in the server, specifying whether or not to
 * protect with Kerberos authentication. 
 * Note: This method is to be used for adding servlets that facilitate
 * internal communication and not for user facing functionality. For
 +   * servlets added using this method, filters (except internal Kerberos
 * filters) are not enabled. 
 * 
 * @param name The name of the servlet (can be passed as null)
 * @param pathSpec The path spec for the servlet
 * @param clazz The servlet class
 * @param requireAuth Require Kerberos authenticate to access servlet
 */
public void addInternalServlet(String name, String pathSpec, 
    Class<? extends HttpServlet> clazz, boolean requireAuth) {
  ServletHolder holder = new ServletHolder(clazz);
  if (name != null) {
    holder.setName(name);
  }
  webAppContext.addServlet(holder, pathSpec);

  if(requireAuth && UserGroupInformation.isSecurityEnabled()) {
     LOG.info("Adding Kerberos (SPNEGO) filter to " + name);
     ServletHandler handler = webAppContext.getServletHandler();
     FilterMapping fmap = new FilterMapping();
     fmap.setPathSpec(pathSpec);
     fmap.setFilterName(SPNEGO_FILTER);
     fmap.setDispatches(Handler.ALL);
     handler.addFilterMapping(fmap);
  }
}

项目：hadoop 文件：HttpServer2.java

/**
 * Add an internal servlet in the server, specifying whether or not to
 * protect with Kerberos authentication.
 * Note: This method is to be used for adding servlets that facilitate
 * internal communication and not for user facing functionality. For
 +   * servlets added using this method, filters (except internal Kerberos
 * filters) are not enabled.
 *
 * @param name The name of the servlet (can be passed as null)
 * @param pathSpec The path spec for the servlet
 * @param clazz The servlet class
 * @param requireAuth Require Kerberos authenticate to access servlet
 */
public void addInternalServlet(String name, String pathSpec,
    Class<? extends HttpServlet> clazz, boolean requireAuth) {
  ServletHolder holder = new ServletHolder(clazz);
  if (name != null) {
    holder.setName(name);
  }
  webAppContext.addServlet(holder, pathSpec);

  if(requireAuth && UserGroupInformation.isSecurityEnabled()) {
     LOG.info("Adding Kerberos (SPNEGO) filter to " + name);
     ServletHandler handler = webAppContext.getServletHandler();
     FilterMapping fmap = new FilterMapping();
     fmap.setPathSpec(pathSpec);
     fmap.setFilterName(SPNEGO_FILTER);
     fmap.setDispatches(Handler.ALL);
     handler.addFilterMapping(fmap);
  }
}

项目：simple-session 文件：SimpleSessionFilterTest.java

@Test
public void test_filter_wrapper() throws IOException, ServletException {
    HttpServlet servlet = new HttpServlet() {
        @Override
        public void service(ServletRequest req, ServletResponse res) throws ServletException, IOException {
            assertThat(req).isInstanceOf(SimpleSessionRequest.class);
            super.service(req, res);
        }
    };
    mockFilterChain = new MockFilterChain(servlet, filter);

    filter.doFilter(mockRequest, mockResponse, mockFilterChain);

    assertThat(mockRequest.getAttribute(SimpleSessionFilter.class.getName().concat(".VISITED")))
            .isEqualTo(Boolean.TRUE);
}

项目：reactive-components 文件：TestRs.java

private Server createServer() {
    Server server = new Server();
    SelectChannelConnector connector = new SelectChannelConnector();
    connector.setPort(8384);
    server.addConnector(connector);

    ServletHandler handler = new ServletHandler();
    Servlet servlet = new HttpServlet() {
        private static final long serialVersionUID = 1L;

        @Override
        protected void doGet(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {
            String path = req.getServletPath().substring(1);
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
            }
            resp.getWriter().append(path);
        }

    };
    handler.addServletWithMapping(new ServletHolder(servlet), "/");
    server.setHandler(handler);
    return server;
}

项目：PCloud_Server_v3 文件：BaseServletAction.java

/**
 * 请求委托
 * @param request
 * @param response
 * @param httpServlet
 */
public void entrust(HttpServletRequest request, HttpServletResponse response, HttpServlet httpServlet){
    method = request.getMethod();
    this.request = request;
    response.setCharacterEncoding(encode);

    //设置POST请求的字符编码
    if(method.equals("POST")){
        try {
            request.setCharacterEncoding(encode);
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }
    }

    //设置Content-Type
    response.setHeader("Content-Type", "text/html;charset=" + encode);

    execute(request, response, httpServlet);
}

项目：ditb 文件：HttpServer.java

/**
 * Add an internal servlet in the server, specifying whether or not to
 * protect with Kerberos authentication.
 * Note: This method is to be used for adding servlets that facilitate
 * internal communication and not for user facing functionality. For
 +   * servlets added using this method, filters (except internal Kerberos
 * filters) are not enabled.
 *
 * @param name The name of the servlet (can be passed as null)
 * @param pathSpec The path spec for the servlet
 * @param clazz The servlet class
 * @param requireAuth Require Kerberos authenticate to access servlet
 */
public void addInternalServlet(String name, String pathSpec,
    Class<? extends HttpServlet> clazz, boolean requireAuth) {
  ServletHolder holder = new ServletHolder(clazz);
  if (name != null) {
    holder.setName(name);
  }
  webAppContext.addServlet(holder, pathSpec);

  if(requireAuth && UserGroupInformation.isSecurityEnabled()) {
     LOG.info("Adding Kerberos (SPNEGO) filter to " + name);
     ServletHandler handler = webAppContext.getServletHandler();
     FilterMapping fmap = new FilterMapping();
     fmap.setPathSpec(pathSpec);
     fmap.setFilterName(SPNEGO_FILTER);
     fmap.setDispatches(Handler.ALL);
     handler.addFilterMapping(fmap);
  }
}

项目：aliyun-oss-hadoop-fs 文件：HttpServer2.java

/**
 * Add an internal servlet in the server, specifying whether or not to
 * protect with Kerberos authentication.
 * Note: This method is to be used for adding servlets that facilitate
 * internal communication and not for user facing functionality. For
 +   * servlets added using this method, filters (except internal Kerberos
 * filters) are not enabled.
 *
 * @param name The name of the servlet (can be passed as null)
 * @param pathSpec The path spec for the servlet
 * @param clazz The servlet class
 * @param requireAuth Require Kerberos authenticate to access servlet
 */
public void addInternalServlet(String name, String pathSpec,
    Class<? extends HttpServlet> clazz, boolean requireAuth) {
  ServletHolder holder = new ServletHolder(clazz);
  if (name != null) {
    holder.setName(name);
  }
  webAppContext.addServlet(holder, pathSpec);

  if(requireAuth && UserGroupInformation.isSecurityEnabled()) {
     LOG.info("Adding Kerberos (SPNEGO) filter to " + name);
     ServletHandler handler = webAppContext.getServletHandler();
     FilterMapping fmap = new FilterMapping();
     fmap.setPathSpec(pathSpec);
     fmap.setFilterName(SPNEGO_FILTER);
     fmap.setDispatches(Handler.ALL);
     handler.addFilterMapping(fmap);
  }
}

项目：Mastering-Mesos 文件：ShiroKerberosPermissiveAuthenticationFilterTest.java

@Override
public Module getChildServletModule() {
  return new ServletModule() {
    @Override
    protected void configureServlets() {
      filter(PATH).through(filter);
      serve(PATH).with(new HttpServlet() {
        @Override
        protected void service(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {

          mockServlet.service(req, resp);
          resp.setStatus(HttpServletResponse.SC_OK);
        }
      });
    }
  };
}

项目：Mastering-Mesos 文件：ShiroKerberosAuthenticationFilterTest.java

@Override
public Module getChildServletModule() {
  return new ServletModule() {
    @Override
    protected void configureServlets() {
      filter(PATH).through(filter);
      serve(PATH).with(new HttpServlet() {
        @Override
        protected void service(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {

          getMockServlet().service(req, resp);
          resp.setStatus(HttpServletResponse.SC_OK);
        }
      });
    }
  };
}

项目：scheduled 文件：AbstractRestServer.java

@Override
public void start() {
    try {
        servletContext.setContextPath("/");
        server.setHandler(servletContext);

        // configure servlets
        servlets.keySet().forEach(path -> {
            Class<? extends HttpServlet> servletClazz = servlets.get(path);
            HttpServlet servlet = ReflectionUtils.newInstance(
                    servletClazz, HttpServlet.class, new Object[]{ componentManager });
            LOG.info("Servlet instance created: path=" + path + ", servlet=" + servlet);

            servletContext.addServlet(new ServletHolder(servlet), path);
        });

        server.start();
    } catch (Exception e) {
        Throwables.propagate(e);
    } finally {
        stop();
    }
}

项目：beyondj 文件：MockServletContext.java

/** Sets the servlet that will receive all requests in this servlet context. */
public MockServletContext setServlet(Class<? extends HttpServlet> servletClass,
                       String servletName,
                       Map<String,String> initParams) {
    try {
        MockServletConfig config = new MockServletConfig();
        config.setServletName(servletName);
        config.setServletContext(this);
        if (initParams != null) config.addAllInitParameters(initParams);

        this.servlet = servletClass.newInstance();
        this.servlet.init(config);
        return this;
    }
    catch (Exception e) {
        throw new RuntimeException("Exception registering servlet with name " + servletName, e);
    }
}

项目：openbravo-brazil 文件：AuthenticationManager.java

/**
 * Returns an instance of AuthenticationManager subclass, based on the authentication.class
 * property in Openbravo.properties
 */
public final static AuthenticationManager getAuthenticationManager(HttpServlet s) {
  AuthenticationManager authManager;
  String authClass = OBPropertiesProvider.getInstance().getOpenbravoProperties()
      .getProperty("authentication.class", DEFAULT_AUTH_CLASS);
  if (authClass == null || authClass.equals("")) {
    // If not defined, load default
    authClass = "org.openbravo.authentication.basic.DefaultAuthenticationManager";
  }
  try {
    authManager = (AuthenticationManager) OBClassLoader.getInstance().loadClass(authClass)
        .newInstance();
    authManager.init(s);
  } catch (Exception e) {
    log4j
        .error("Defined authentication manager cannot be loaded. Verify the 'authentication.class' entry in Openbravo.properties");
    authManager = new DefaultAuthenticationManager(s);
    authManager.init(s);
  }
  return authManager;
}

项目：big-c 文件：HttpServer.java

/**
 * Add an internal servlet in the server, specifying whether or not to
 * protect with Kerberos authentication. 
 * Note: This method is to be used for adding servlets that facilitate
 * internal communication and not for user facing functionality. For
 +   * servlets added using this method, filters (except internal Kerberos
 * filters) are not enabled. 
 * 
 * @param name The name of the servlet (can be passed as null)
 * @param pathSpec The path spec for the servlet
 * @param clazz The servlet class
 * @param requireAuth Require Kerberos authenticate to access servlet
 */
public void addInternalServlet(String name, String pathSpec, 
    Class<? extends HttpServlet> clazz, boolean requireAuth) {
  ServletHolder holder = new ServletHolder(clazz);
  if (name != null) {
    holder.setName(name);
  }
  webAppContext.addServlet(holder, pathSpec);

  if(requireAuth && UserGroupInformation.isSecurityEnabled()) {
     LOG.info("Adding Kerberos (SPNEGO) filter to " + name);
     ServletHandler handler = webAppContext.getServletHandler();
     FilterMapping fmap = new FilterMapping();
     fmap.setPathSpec(pathSpec);
     fmap.setFilterName(SPNEGO_FILTER);
     fmap.setDispatches(Handler.ALL);
     handler.addFilterMapping(fmap);
  }
}

项目：big-c 文件：HttpServer2.java

/**
 * Add an internal servlet in the server, specifying whether or not to
 * protect with Kerberos authentication.
 * Note: This method is to be used for adding servlets that facilitate
 * internal communication and not for user facing functionality. For
 +   * servlets added using this method, filters (except internal Kerberos
 * filters) are not enabled.
 *
 * @param name The name of the servlet (can be passed as null)
 * @param pathSpec The path spec for the servlet
 * @param clazz The servlet class
 * @param requireAuth Require Kerberos authenticate to access servlet
 */
public void addInternalServlet(String name, String pathSpec,
    Class<? extends HttpServlet> clazz, boolean requireAuth) {
  ServletHolder holder = new ServletHolder(clazz);
  if (name != null) {
    holder.setName(name);
  }
  webAppContext.addServlet(holder, pathSpec);

  if(requireAuth && UserGroupInformation.isSecurityEnabled()) {
     LOG.info("Adding Kerberos (SPNEGO) filter to " + name);
     ServletHandler handler = webAppContext.getServletHandler();
     FilterMapping fmap = new FilterMapping();
     fmap.setPathSpec(pathSpec);
     fmap.setFilterName(SPNEGO_FILTER);
     fmap.setDispatches(Handler.ALL);
     handler.addFilterMapping(fmap);
  }
}

项目：EventManager-JEE 文件：Events.java

public void apply(HttpServlet servlet, UserAwareRequest req, HttpServletResponse resp, UUID id)
        throws ServletException, IOException {

    Optional<Event> eventOpt = eventService.fetch(id);

    // Should never append but...
    if (!eventOpt.isPresent()) {
        redirect(req, resp, "/", tuple("error", "Événement non trouvé"));
        return;
    }

    Event event = eventOpt.get();

    Optional<Person> userOpt = req.getUser();
    // Logged user
    if (userOpt.isPresent()) {
        eventService.linkRegisteredPerson(event, userOpt.get());
        redirect(req, resp, "/events/" + event.getSlug());
        return;
    }

    redirect(req, resp, "/events/" + id + "/participants/add");

}

项目：EventManager-JEE 文件：Persons.java

public void authentication(HttpServlet servlet, HttpServletRequest req, HttpServletResponse resp)
        throws ServletException, IOException {

    String event = req.getParameter("event");


    String email = req.getParameter("email");
    String password = req.getParameter("password");

    Optional<Person> login = personService.login(email, password);
    if (login.isPresent()) {
        HttpSession session = req.getSession();
        session.setAttribute("user", login.get());
        String last_url = Optional.ofNullable(session.getAttribute("last_url")).orElse("/").toString();
           if(event != null){
               redirect(req, resp, "/events/" + event + "/apply");
               return;
           }

        redirect(req, resp, last_url, tuple("info", "Identification réussie !"));
        return;
    }

    redirect(req, resp, "/login", tuple("error",
            "Impossible de vous identifier, merci de vérifier que les informations renseignées sont correctes."));
}