java - 异步 Servlet 是否允许更高的并发性？

Question

异步Servlets的优势到底是什么？我曾假设这意味着 Web 应用程序容器监听器线程将被“释放”以处理另一个客户端请求，同时 Servlet 执行可能长时间运行的任务。 Tomcat 和 Spring 3.2 的实验不支持这一点。好处是某种内存管理改进吗？

我将 Tomcat 设置为在单个线程上监听。我的 @Controller 调用下游 @Service，后者调用 Thread.sleep(10000)。我每隔一秒钟发出两个请求，第一个请求需要 10 秒才能得到响应，然后又需要 10 秒才能得到第二个响应(所以总共需要 20 秒)。如果我对异步 Servlet 的理解是正确的，我希望在 11 秒内得到两个响应。

Spring 配置:

<mvc:annotation-driven>
    <mvc:async-support task-executor="taskExecutor" default-timeout="20000" />
</mvc:annotation-driven>
<context:component-scan base-package="com.company" />

<task:executor id="taskExecutor" pool-size="5-20" queue-capacity="100"/>

web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://java.sun.com/xml/ns/javaee"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
  version="3.0">
    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>
            classpath:/spring-config/app-context.xml
        </param-value>
    </context-param>
    <listener>
        <listener-class>
            org.springframework.web.context.ContextLoaderListener
        </listener-class>
    </listener>
    <servlet>
        <servlet-name>dispatcher</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet
        </servlet-class>
        <init-param>
            <param-name>contextConfigLocation</param-name>
            <param-value>
                classpath:/spring-config/web-context.xml
            </param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
        <async-supported>true</async-supported>
    </servlet>
    <servlet-mapping>
        <servlet-name>dispatcher</servlet-name>
        <url-pattern>/</url-pattern>
    </servlet-mapping>
</web-app>

Controller

@Controller
public class AsyncController {
    @Autowired
    private BlockingService service;

    @RequestMapping("/test")
    public @ResponseBody Callable<String> test()
    {
        return new Callable<String>() {
            public String call() throws Exception {
                return service.block(System.currentTimeMillis());
            }
        };
    }
}

服务

@Service
public class BlockingService {
    public String block(long timeBefore)
    {
        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "Before: "+timeBefore+"\nTime: "+System.currentTimeMillis();
    }
}

Answer 1

看看this answer .确保在使用 BIO 连接器时设置了 maxConnections，否则默认为 maxThreads

另外请记住，如果您使用的是选项卡式浏览，那么如果 url 相同，它将在客户端对请求进行排队。您可以添加查询字符串参数来对此进行测试。

最好使用两种浏览器进行测试。