/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. package org.apache.coyote.http2;import java.io.File;import java.io.IOException;import java.io.OutputStream;import java.io.PrintWriter;import java.nio.ByteBuffer;import java.util.ArrayList;import java.util.List;import jakarta.servlet.AsyncContext;import jakarta.servlet.ServletException;import jakarta.servlet.http.HttpServlet;import jakarta.servlet.http.HttpServletRequest;import jakarta.servlet.http.HttpServletResponse;import org.junit.Assert ;import org.junit.Test;import org.apache.catalina.Context;import org.apache.catalina.Wrapper;import org.apache.catalina.connector.Connector;import org.apache.catalina.startup.Tomcat;import org.apache.tomcat.util.compat.JrePlatform;import org.apache.tomcat.util.http.FastHttpDateFormat;public class TestStreamProcessor extends Http2TestBase {public void testAsyncComplete() throws Exception {// Map the async servlet to /simple so we can re-use the HTTP/2 handling // logic from the super class. "" , null );"simple" , new SimpleServlet());"/simple" , "simple" );"async" , new AsyncComplete());true );"/async" , "async" );byte [] frameHeader = new byte [9];null , 3, "/async" );// Flush before startAsync means body is written in two packets so an // additional frame needs to be read Assert .assertEquals("3-HeadersStart\n" + "3-Header-[:status]-[200]\n" +"3-Header-[content-type]-[text/plain;charset=UTF-8]\n" +"3-Header-[date]-[Wed, 11 Nov 2015 19:18:42 GMT]\n" + "3-HeadersEnd\n" + "3-Body-17\n" + "3-Body-8\n" +"3-EndOfStream\n" , output.getTrace());public void testAsyncDispatch() throws Exception {// Map the async servlet to /simple so we can re-use the HTTP/2 handling // logic from the super class. "" , null );"simple" , new SimpleServlet());"/simple" , "simple" );"async" , new AsyncDispatch());true );"/async" , "async" );byte [] frameHeader = new byte [9];null , 3, "/async" );Assert .assertEquals(getSimpleResponseTrace(3), output.getTrace());public void testPrepareHeaders() throws Exception {new File("test/webapp" );null , "" , appDir.getAbsolutePath());"simple" , new SimpleServlet());"/simple" , "simple" );byte [] frameHeader = new byte [9];new ArrayList<>(3);new Header(":method" , "GET" ));new Header(":scheme" , "http" ));new Header(":path" , "/index.html" ));new Header(":authority" , "localhost:" + getPort()));new Header("if-modified-since" , FastHttpDateFormat.getCurrentDate()));null , headers, 3);new StringBuilder();"3-HeadersStart\n" );"3-Header-[:status]-[304]\n" );// Different line-endings -> different files size -> different weak eTag if (JrePlatform.IS_WINDOWS) {"3-Header-[etag]-[W/\" 957-1447269522000\"]\n" );else {"3-Header-[etag]-[W/\" 934-1447269522000\"]\n" );"3-Header-[date]-[Wed, 11 Nov 2015 19:18:42 GMT]\n" );"3-HeadersEnd\n" );"3-EndOfStream\n" );Assert .assertEquals(expected.toString(), output.getTrace());public void testPrepareHeadersNoContent() throws Exception {new File("test/webapp" );null , "" , appDir.getAbsolutePath());"simple" , new SimpleServlet());"/simple" , "simple" );"noContent" , new NoContentServlet());"/noContent" , "noContent" );byte [] frameHeader = new byte [9];new ArrayList<>(3);new Header(":method" , "GET" ));new Header(":scheme" , "http" ));new Header(":path" , "/noContent" ));new Header(":authority" , "localhost:" + getPort()));null , headers, 3);new StringBuilder();"3-HeadersStart\n" );"3-Header-[:status]-[204]\n" );"3-Header-[date]-[Wed, 11 Nov 2015 19:18:42 GMT]\n" );"3-HeadersEnd\n" );"3-EndOfStream\n" );Assert .assertEquals(expected.toString(), output.getTrace());public void testValidateRequestMethod() throws Exception {new File("test/webapp" );null , "" , appDir.getAbsolutePath());"simple" , new SimpleServlet());"/simple" , "simple" );byte [] frameHeader = new byte [9];new ArrayList<>(4);new Header(":method" , "not,token" ));new Header(":scheme" , "http" ));new Header(":path" , "/index.html" ));new Header(":authority" , "localhost:" + getPort()));null , headers, 3);new StringBuilder();"3-HeadersStart\n" );"3-Header-[:status]-[400]\n" );"3-Header-[date]-[Wed, 11 Nov 2015 19:18:42 GMT]\n" );"3-HeadersEnd\n" );Assert .assertEquals(expected.toString(), output.getTrace());public void testValidateRequestHeaderName() throws Exception {new File("test/webapp" );null , "" , appDir.getAbsolutePath());"simple" , new SimpleServlet());"/simple" , "simple" );byte [] frameHeader = new byte [9];new ArrayList<>(5);new Header(":method" , "GET" ));new Header(":scheme" , "http" ));new Header(":path" , "/index.html" ));new Header(":authority" , "localhost:" + getPort()));new Header("not token" , "value" ));null , headers, 3);new StringBuilder();"3-HeadersStart\n" );"3-Header-[:status]-[400]\n" );"3-Header-[date]-[Wed, 11 Nov 2015 19:18:42 GMT]\n" );"3-HeadersEnd\n" );Assert .assertEquals(expected.toString(), output.getTrace());public void testValidateRequestURI() throws Exception {new File("test/webapp" );null , "" , appDir.getAbsolutePath());"simple" , new SimpleServlet());"/simple" , "simple" );byte [] frameHeader = new byte [9];new ArrayList<>(4);new Header(":method" , "GET" ));new Header(":scheme" , "http" ));new Header(":path" , "/index^html" ));new Header(":authority" , "localhost:" + getPort()));null , headers, 3);new StringBuilder();"3-HeadersStart\n" );"3-Header-[:status]-[400]\n" );"3-Header-[date]-[Wed, 11 Nov 2015 19:18:42 GMT]\n" );"3-HeadersEnd\n" );Assert .assertEquals(expected.toString(), output.getTrace());public void testValidateRequestQueryString() throws Exception {new File("test/webapp" );null , "" , appDir.getAbsolutePath());"simple" , new SimpleServlet());"/simple" , "simple" );byte [] frameHeader = new byte [9];new ArrayList<>(4);new Header(":method" , "GET" ));new Header(":scheme" , "http" ));new Header(":path" , "/index.html?foo=[]" ));new Header(":authority" , "localhost:" + getPort()));null , headers, 3);new StringBuilder();"3-HeadersStart\n" );"3-Header-[:status]-[400]\n" );"3-Header-[date]-[Wed, 11 Nov 2015 19:18:42 GMT]\n" );"3-HeadersEnd\n" );Assert .assertEquals(expected.toString(), output.getTrace());public void testValidateRequestQueryStringRelaxed() throws Exception {new File("test/webapp" );null , "" , appDir.getAbsolutePath());"simple" , new SimpleServlet());"/simple" , "simple" );"relaxedQueryChars" , "[]" );byte [] frameHeader = new byte [9];new ArrayList<>(4);new Header(":method" , "GET" ));new Header(":scheme" , "http" ));new Header(":path" , "/index.html?foo=[]" ));new Header(":authority" , "localhost:" + getPort()));null , headers, 3);new StringBuilder();"3-HeadersStart\n" );"3-Header-[:status]-[200]\n" );// The status code is the most important thing to test Assert .assertTrue(output.getTrace().startsWith(expected.toString()));private static final class AsyncComplete extends HttpServlet {private static final long serialVersionUID = 1L;protected void doGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {"text/plain" );"UTF-8" );"Enter-" );final AsyncContext asyncContext = request.startAsync(request, response);"StartAsync-" );new Runnable() {public void run() {try {"Complete" );catch (Exception e) {private static final class AsyncDispatch extends HttpServlet {private static final long serialVersionUID = 1L;protected void doGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {final AsyncContext asyncContext = request.startAsync(request, response);new Runnable() {public void run() {try {"/simple" );catch (Exception e) {public void testCompression() throws Exception {"" , null );"simple" , new SimpleServlet());"/simple" , "simple" );"compression" , new CompressionServlet());"/compression" , "compression" );// Enable compression Assert .assertTrue(connector.setProperty("compression" , "on" ));byte [] frameHeader = new byte [9];new ArrayList<>(3);new Header(":method" , "GET" ));new Header(":scheme" , "http" ));new Header(":path" , "/compression" ));new Header(":authority" , "localhost:" + getPort()));new Header("accept-encoding" , "gzip" ));null , headers, 3);Assert .assertEquals("3-HeadersStart\n" + "3-Header-[:status]-[200]\n" + "3-Header-[vary]-[accept-encoding]\n" +"3-Header-[content-encoding]-[gzip]\n" + "3-Header-[content-type]-[text/plain;charset=UTF-8]\n" +"3-Header-[date]-[Wed, 11 Nov 2015 19:18:42 GMT]\n" + "3-HeadersEnd\n" + "3-Body-97\n" +"3-EndOfStream\n" , output.getTrace());private static class CompressionServlet extends HttpServlet {private static final long serialVersionUID = 1L;protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {// Generate content type that is compressible "text/plain" );"UTF-8" );// Make ir large enough to trigger compression int count = 64 * 1024;// One bytes per entry for (int i = 0; i < count; i++) {'X' );public void testConnect() throws Exception {new ArrayList<>(4);new Header(":method" , "CONNECT" ));new Header(":scheme" , "http" ));new Header(":authority" , "example.local" ));byte [] headersFrameHeader = new byte [9];null , headers, 3);Assert .assertTrue(trace, trace.contains("3-Header-[:status]-[501]" ));quality 95%
¤ Dauer der Verarbeitung: 0.18 Sekunden
(vorverarbeitet)
¤ *© Formatika GbR, Deutschland
