import io.undertow.server.DefaultByteBufferPool; //导入依赖的package包/类
@Test
public void test() throws Exception {
	ByteBufferPool byteBufferPool = new DefaultByteBufferPool(true, 2, -1, 4);
	PooledByteBufferOutputStream output = new PooledByteBufferOutputStream(byteBufferPool);

	String hello = "hello, 世界！";
	output.write(hello);
	output.flip();

	PooledByteBuffer[] buffers = output.getPooledByteBuffers();

	try (PooledByteBufferInputStream input = new PooledByteBufferInputStream(buffers);) {
		byte[] bytes = new byte[input.available()];
		input.read(bytes);
		String str = new String(bytes, "UTF-8");

		assertEquals(hello, str);
	}

	output.release();
	output.close();
}
 

import io.undertow.server.DefaultByteBufferPool; //导入依赖的package包/类
protected ConnectionBuilder connectionBuilder() throws XNIOException {
    try {
        this.worker = Xnio.getInstance().createWorker(OptionMap.EMPTY);
        return new ConnectionBuilder(this.worker, new DefaultByteBufferPool(true, 1024), uri);
    } catch (IOException e) {
        throw new XNIOException(e);
    }
}
 

import io.undertow.server.DefaultByteBufferPool; //导入依赖的package包/类
public Undertow13BufferSupport() {
	this.undertowBufferPool = new DefaultByteBufferPool(false, 1024, -1, 2);
	this.httpClientConnectCallbackMethod = ReflectionUtils.findMethod(UndertowClient.class, "connect",
			ClientCallback.class, URI.class, XnioWorker.class, ByteBufferPool.class, OptionMap.class);
	this.httpClientConnectMethod = ReflectionUtils.findMethod(UndertowClient.class, "connect",
			URI.class, XnioWorker.class, ByteBufferPool.class, OptionMap.class);
}
 

import io.undertow.server.DefaultByteBufferPool; //导入依赖的package包/类
private static WebSocketDeploymentInfo webSocketDeploymentInfo(Config cfg) {
    Config wsOptions = cfg.getConfig(KEY_WS_WEB_SOCKET_OPTIONS);
    return new WebSocketDeploymentInfo()
            .setWorker(webSocketWorker(wsOptions))
            .setBuffers(new DefaultByteBufferPool(wsOptions.getBoolean(KEY_WS_USE_DIRECT_BUFFER),
                    wsOptions.getInt(KEY_WS_BUFFER_SIZE)))
            .addEndpoint(ServerLogsWebSocket.class);
}
 

import io.undertow.server.DefaultByteBufferPool; //导入依赖的package包/类
public void initUndertowServer() {


        JbootServerClassloader classloader = new JbootServerClassloader(UnderTowServer.class.getClassLoader());
        classloader.setDefaultAssertionStatus(false);


        deploymentInfo = buildDeploymentInfo(classloader);

        if (webConfig.isWebsocketEnable()) {
            Set<Class> endPointClasses = JbootWebsocketManager.me().getWebsocketEndPoints();
            WebSocketDeploymentInfo webSocketDeploymentInfo = new WebSocketDeploymentInfo();
            webSocketDeploymentInfo.setBuffers(new DefaultByteBufferPool(true, webConfig.getWebsocketBufferPoolSize()));
            for (Class endPointClass : endPointClasses) {
                webSocketDeploymentInfo.addEndpoint(endPointClass);
            }
            deploymentInfo.addServletContextAttribute(WebSocketDeploymentInfo.ATTRIBUTE_NAME, webSocketDeploymentInfo);
        }

        servletContainer = Servlets.newContainer();
        deploymentManager = servletContainer.addDeployment(deploymentInfo);
        deploymentManager.deploy();

        HttpHandler httpHandler = null;
        try {
            /**
             * 启动并初始化servlet和filter
             */
            httpHandler = deploymentManager.start();
        } catch (Throwable ex) {
            ex.printStackTrace();
        }


        pathHandler = Handlers.path(
                Handlers.resource(new ClassPathResourceManager(classloader, "webRoot")));

        pathHandler.addPrefixPath(config.getContextPath(), httpHandler);

        undertow = Undertow.builder()
                .addHttpListener(config.getPort(), config.getHost())
                .setHandler(pathHandler)
                .build();

    }
 

import io.undertow.server.DefaultByteBufferPool; //导入依赖的package包/类
InVMConnection(XnioWorker worker, int port) {
    this.bufferPool = new DefaultByteBufferPool(false, 1024, 0, 0);
    this.worker = worker;
    this.address = new InetSocketAddress(port); // port carried forward from the initial
}
 

import io.undertow.server.DefaultByteBufferPool; //导入依赖的package包/类
@Override
protected void doStart() throws Exception {
    super.doStart();

    pool = new DefaultByteBufferPool(true, 8192);

    worker = Xnio.getInstance().createWorker(options);

    LOG.debug("Created worker: {} with options: {}", worker, options);
}