• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号
登陆 注册

Java JIoEndpoint类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.tomcat.util.net.JIoEndpoint类的典型用法代码示例。如果您正苦于以下问题：Java JIoEndpoint类的具体用法？Java JIoEndpoint怎么用？Java JIoEndpoint使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



JIoEndpoint类属于org.apache.tomcat.util.net包，在下文中一共展示了JIoEndpoint类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: createProcessor

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
@Override
protected Http11Processor createProcessor() {
    Http11Processor processor = new Http11Processor(
            proto.getMaxHttpHeaderSize(), (JIoEndpoint)proto.endpoint,
            proto.getMaxTrailerSize(), proto.getAllowedTrailerHeadersAsSet(),
            proto.getMaxExtensionSize(), proto.getMaxSwallowSize());
    processor.setAdapter(proto.adapter);
    processor.setMaxKeepAliveRequests(proto.getMaxKeepAliveRequests());
    processor.setKeepAliveTimeout(proto.getKeepAliveTimeout());
    processor.setConnectionUploadTimeout(
            proto.getConnectionUploadTimeout());
    processor.setDisableUploadTimeout(proto.getDisableUploadTimeout());
    processor.setCompressionMinSize(proto.getCompressionMinSize());
    processor.setCompression(proto.getCompression());
    processor.setNoCompressionUserAgents(proto.getNoCompressionUserAgents());
    processor.setCompressableMimeTypes(proto.getCompressableMimeTypes());
    processor.setRestrictedUserAgents(proto.getRestrictedUserAgents());
    processor.setSocketBuffer(proto.getSocketBuffer());
    processor.setMaxSavePostSize(proto.getMaxSavePostSize());
    processor.setServer(proto.getServer());
    processor.setDisableKeepAlivePercentage(
            proto.getDisableKeepAlivePercentage());
    processor.setMaxCookieCount(proto.getMaxCookieCount());
    register(processor);
    return processor;
}
开发者ID:liaokailin，项目名称:tomcat7，代码行数:27，代码来源:Http11Protocol.java


示例2: AjpProcessor

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
public AjpProcessor(int packetSize, JIoEndpoint endpoint) {

        this.endpoint = endpoint;

        request = new Request();
        request.setInputBuffer(new SocketInputBuffer());

        response = new Response();
        response.setHook(this);
        response.setOutputBuffer(new SocketOutputBuffer());
        request.setResponse(response);

        requestHeaderMessage = new AjpMessage(packetSize);
        responseHeaderMessage = new AjpMessage(packetSize);
        bodyMessage = new AjpMessage(packetSize);
        
        // Set the get body message buffer
        AjpMessage getBodyMessage = new AjpMessage(16);
        getBodyMessage.reset();
        getBodyMessage.appendByte(Constants.JK_AJP13_GET_BODY_CHUNK);
        getBodyMessage.appendInt(packetSize - Constants.READ_HEAD_LEN);
        getBodyMessage.end();
        getBodyMessageArray = new byte[getBodyMessage.getLen()];
        System.arraycopy(getBodyMessage.getBuffer(), 0, getBodyMessageArray, 
                0, getBodyMessage.getLen());

        // Cause loading of HexUtils
        int foo = HexUtils.DEC[0];

        // Cause loading of HttpMessages
        HttpMessages.getMessage(200);

    }
开发者ID:lamsfoundation，项目名称:lams，代码行数:34，代码来源:AjpProcessor.java


示例3: Http11Processor

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
public Http11Processor(int headerBufferSize, JIoEndpoint endpoint) {

        this.endpoint = endpoint;
        
        request = new Request();
        inputBuffer = new InternalInputBuffer(request, headerBufferSize);
        request.setInputBuffer(inputBuffer);

        response = new Response();
        response.setHook(this);
        outputBuffer = new InternalOutputBuffer(response, headerBufferSize);
        response.setOutputBuffer(outputBuffer);
        request.setResponse(response);

        initializeFilters();

        // Cause loading of HexUtils
        int foo = HexUtils.DEC[0];

        // Cause loading of FastHttpDateFormat
        FastHttpDateFormat.getCurrentDate();

    }
开发者ID:lamsfoundation，项目名称:lams，代码行数:24，代码来源:Http11Processor.java


示例4: createProcessor

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
@Override
protected Http11Processor createProcessor() {
	Http11Processor processor = new Http11Processor(proto.getMaxHttpHeaderSize(), (JIoEndpoint) proto.endpoint,
			proto.getMaxTrailerSize(), proto.getAllowedTrailerHeadersAsSet(), proto.getMaxExtensionSize(),
			proto.getMaxSwallowSize());
	processor.setAdapter(proto.adapter);
	processor.setMaxKeepAliveRequests(proto.getMaxKeepAliveRequests());
	processor.setKeepAliveTimeout(proto.getKeepAliveTimeout());
	processor.setConnectionUploadTimeout(proto.getConnectionUploadTimeout());
	processor.setDisableUploadTimeout(proto.getDisableUploadTimeout());
	processor.setCompressionMinSize(proto.getCompressionMinSize());
	processor.setCompression(proto.getCompression());
	processor.setNoCompressionUserAgents(proto.getNoCompressionUserAgents());
	processor.setCompressableMimeTypes(proto.getCompressableMimeTypes());
	processor.setRestrictedUserAgents(proto.getRestrictedUserAgents());
	processor.setSocketBuffer(proto.getSocketBuffer());
	processor.setMaxSavePostSize(proto.getMaxSavePostSize());
	processor.setServer(proto.getServer());
	processor.setDisableKeepAlivePercentage(proto.getDisableKeepAlivePercentage());
	processor.setMaxCookieCount(proto.getMaxCookieCount());
	register(processor);
	return processor;
}
开发者ID:how2j，项目名称:lazycat，代码行数:24，代码来源:Http11Protocol.java


示例5: actionInternal

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
/**
 * Send an action to the connector.
 *
 * @param actionCode Type of the action
 * @param param Action parameter
 */
@Override
protected void actionInternal(ActionCode actionCode, Object param) {

    if (actionCode == ActionCode.ASYNC_COMPLETE) {
        if (asyncStateMachine.asyncComplete()) {
            ((JIoEndpoint)endpoint).processSocketAsync(this.socketWrapper,
                    SocketStatus.OPEN_READ);
        }

    } else if (actionCode == ActionCode.ASYNC_SETTIMEOUT) {
        if (param == null) return;
        long timeout = ((Long)param).longValue();
        // if we are not piggy backing on a worker thread, set the timeout
        socketWrapper.setTimeout(timeout);

    } else if (actionCode == ActionCode.ASYNC_DISPATCH) {
        if (asyncStateMachine.asyncDispatch()) {
            ((JIoEndpoint)endpoint).processSocketAsync(this.socketWrapper,
                    SocketStatus.OPEN_READ);
        }
    }
}
开发者ID:deathspeeder，项目名称:class-guard，代码行数:29，代码来源:AjpProcessor.java


示例6: createProcessor

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
@Override
protected Http11Processor createProcessor() {
    Http11Processor processor = new Http11Processor(
            proto.getMaxHttpHeaderSize(), (JIoEndpoint)proto.endpoint,
            proto.getMaxTrailerSize(),proto.getMaxExtensionSize());
    processor.setAdapter(proto.adapter);
    processor.setMaxKeepAliveRequests(proto.getMaxKeepAliveRequests());
    processor.setKeepAliveTimeout(proto.getKeepAliveTimeout());
    processor.setConnectionUploadTimeout(
            proto.getConnectionUploadTimeout());
    processor.setDisableUploadTimeout(proto.getDisableUploadTimeout());
    processor.setCompressionMinSize(proto.getCompressionMinSize());
    processor.setCompression(proto.getCompression());
    processor.setNoCompressionUserAgents(proto.getNoCompressionUserAgents());
    processor.setCompressableMimeTypes(proto.getCompressableMimeTypes());
    processor.setRestrictedUserAgents(proto.getRestrictedUserAgents());
    processor.setSocketBuffer(proto.getSocketBuffer());
    processor.setMaxSavePostSize(proto.getMaxSavePostSize());
    processor.setServer(proto.getServer());
    processor.setDisableKeepAlivePercentage(
            proto.getDisableKeepAlivePercentage());
    register(processor);
    return processor;
}
开发者ID:deathspeeder，项目名称:class-guard，代码行数:25，代码来源:Http11Protocol.java


示例7: Http11Protocol

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
public Http11Protocol() {
    endpoint = new JIoEndpoint();
    cHandler = new Http11ConnectionHandler(this);
    ((JIoEndpoint) endpoint).setHandler(cHandler);
    setSoLinger(Constants.DEFAULT_CONNECTION_LINGER);
    setSoTimeout(Constants.DEFAULT_CONNECTION_TIMEOUT);
    setTcpNoDelay(Constants.DEFAULT_TCP_NO_DELAY);
}
开发者ID:sdw2330976，项目名称:apache-tomcat-7.0.57，代码行数:9，代码来源:Http11Protocol.java


示例8: createProcessor

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
@Override
protected Http11Processor createProcessor() {
    Http11Processor processor = new Http11Processor(
            proto.getMaxHttpHeaderSize(), (JIoEndpoint)proto.endpoint,
            proto.getMaxTrailerSize(),proto.getMaxExtensionSize(),
            proto.getMaxSwallowSize());
    processor.setAdapter(proto.adapter);
    processor.setMaxKeepAliveRequests(proto.getMaxKeepAliveRequests());
    processor.setKeepAliveTimeout(proto.getKeepAliveTimeout());
    processor.setConnectionUploadTimeout(
            proto.getConnectionUploadTimeout());
    processor.setDisableUploadTimeout(proto.getDisableUploadTimeout());
    processor.setCompressionMinSize(proto.getCompressionMinSize());
    processor.setCompression(proto.getCompression());
    processor.setNoCompressionUserAgents(proto.getNoCompressionUserAgents());
    processor.setCompressableMimeTypes(proto.getCompressableMimeTypes());
    processor.setRestrictedUserAgents(proto.getRestrictedUserAgents());
    processor.setSocketBuffer(proto.getSocketBuffer());
    processor.setMaxSavePostSize(proto.getMaxSavePostSize());
    processor.setServer(proto.getServer());
    processor.setDisableKeepAlivePercentage(
            proto.getDisableKeepAlivePercentage());
    register(processor);
    return processor;
}
开发者ID:sdw2330976，项目名称:apache-tomcat-7.0.57，代码行数:26，代码来源:Http11Protocol.java


示例9: actionInternal

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
/**
 * Send an action to the connector.
 *
 * @param actionCode Type of the action
 * @param param Action parameter
 */
@Override
protected void actionInternal(ActionCode actionCode, Object param) {

    if (actionCode == ActionCode.ASYNC_COMPLETE) {
        if (asyncStateMachine.asyncComplete()) {
            ((JIoEndpoint)endpoint).processSocketAsync(this.socket,
                    SocketStatus.OPEN);
        }
    } else if (actionCode == ActionCode.ASYNC_SETTIMEOUT) {
        if (param == null) return;
        long timeout = ((Long)param).longValue();
        // if we are not piggy backing on a worker thread, set the timeout
        socket.setTimeout(timeout);
    } else if (actionCode == ActionCode.ASYNC_DISPATCH) {
        if (asyncStateMachine.asyncDispatch()) {
            ((JIoEndpoint)endpoint).processSocketAsync(this.socket,
                    SocketStatus.OPEN);
        }
    }
}
开发者ID:WhiteBearSolutions，项目名称:WBSAirback，代码行数:27，代码来源:AjpProcessor.java


示例10: createProcessor

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
@Override
protected Http11Processor createProcessor() {
    Http11Processor processor = new Http11Processor(
            proto.getMaxHttpHeaderSize(), (JIoEndpoint)proto.endpoint,
            proto.getMaxTrailerSize());
    processor.setAdapter(proto.adapter);
    processor.setMaxKeepAliveRequests(proto.getMaxKeepAliveRequests());
    processor.setKeepAliveTimeout(proto.getKeepAliveTimeout());
    processor.setConnectionUploadTimeout(
            proto.getConnectionUploadTimeout());
    processor.setDisableUploadTimeout(proto.getDisableUploadTimeout());
    processor.setCompressionMinSize(proto.getCompressionMinSize());
    processor.setCompression(proto.getCompression());
    processor.setNoCompressionUserAgents(proto.getNoCompressionUserAgents());
    processor.setCompressableMimeTypes(proto.getCompressableMimeTypes());
    processor.setRestrictedUserAgents(proto.getRestrictedUserAgents());
    processor.setSocketBuffer(proto.getSocketBuffer());
    processor.setMaxSavePostSize(proto.getMaxSavePostSize());
    processor.setServer(proto.getServer());
    processor.setDisableKeepAlivePercentage(
            proto.getDisableKeepAlivePercentage());
    register(processor);
    return processor;
}
开发者ID:WhiteBearSolutions，项目名称:WBSAirback，代码行数:25，代码来源:Http11Protocol.java


示例11: action

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
/**
 * Send an action to the connector.
 *
 * @param actionCode Type of the action
 * @param param Action parameter
 */
@Override
@SuppressWarnings("incomplete-switch") // Other cases are handled by action()
protected void actionInternal(ActionCode actionCode, Object param) {

    switch (actionCode) {
    case ASYNC_COMPLETE: {
        if (asyncStateMachine.asyncComplete()) {
            ((JIoEndpoint)endpoint).processSocketAsync(this.socketWrapper,
                    SocketStatus.OPEN_READ);
        }
        break;
    }
    case ASYNC_SETTIMEOUT: {
        if (param == null) return;
        long timeout = ((Long)param).longValue();
        // if we are not piggy backing on a worker thread, set the timeout
        socketWrapper.setTimeout(timeout);
        break;
    }
    case ASYNC_DISPATCH: {
        if (asyncStateMachine.asyncDispatch()) {
            ((JIoEndpoint)endpoint).processSocketAsync(this.socketWrapper,
                    SocketStatus.OPEN_READ);
        }
        break;
    }
    }
}
开发者ID:liaokailin，项目名称:tomcat7，代码行数:35，代码来源:AjpProcessor.java


示例12: AjpProtocol

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
public AjpProtocol() {
    endpoint = new JIoEndpoint();
    cHandler = new AjpConnectionHandler(this);
    ((JIoEndpoint) endpoint).setHandler(cHandler);
    setSoLinger(Constants.DEFAULT_CONNECTION_LINGER);
    setSoTimeout(Constants.DEFAULT_CONNECTION_TIMEOUT);
    setTcpNoDelay(Constants.DEFAULT_TCP_NO_DELAY);
}
开发者ID:liaokailin，项目名称:tomcat7，代码行数:9，代码来源:AjpProtocol.java


示例13: createProcessor

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
@Override
protected AjpProcessor createProcessor() {
    AjpProcessor processor = new AjpProcessor(proto.packetSize, (JIoEndpoint)proto.endpoint);
    processor.setAdapter(proto.adapter);
    processor.setAjpFlush(proto.getAjpFlush());
    processor.setTomcatAuthentication(proto.tomcatAuthentication);
    processor.setTomcatAuthorization(proto.getTomcatAuthorization());
    processor.setRequiredSecret(proto.requiredSecret);
    processor.setKeepAliveTimeout(proto.getKeepAliveTimeout());
    processor.setClientCertProvider(proto.getClientCertProvider());
    processor.setMaxCookieCount(proto.getMaxCookieCount());
    register(processor);
    return processor;
}
开发者ID:liaokailin，项目名称:tomcat7，代码行数:15，代码来源:AjpProtocol.java


示例14: Http11Protocol

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
public Http11Protocol() {
    endpoint = new JIoEndpoint();  //构造实例
    cHandler = new Http11ConnectionHandler(this);
    ((JIoEndpoint) endpoint).setHandler(cHandler);
    setSoLinger(Constants.DEFAULT_CONNECTION_LINGER);
    setSoTimeout(Constants.DEFAULT_CONNECTION_TIMEOUT);
    setTcpNoDelay(Constants.DEFAULT_TCP_NO_DELAY);
}
开发者ID:liaokailin，项目名称:tomcat7，代码行数:9，代码来源:Http11Protocol.java


示例15: Http11Protocol

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
public Http11Protocol() {
    endpoint = new JIoEndpoint();
    cHandler = new Http11ConnectionHandler(this);
    ((JIoEndpoint) endpoint).setHandler(cHandler);
    //设置endpoint默认属性
    setSoLinger(Constants.DEFAULT_CONNECTION_LINGER);
    setSoTimeout(Constants.DEFAULT_CONNECTION_TIMEOUT);
    setTcpNoDelay(Constants.DEFAULT_TCP_NO_DELAY);
}
开发者ID:sunmingshuai，项目名称:apache-tomcat-7.0.73-with-comment，代码行数:10，代码来源:Http11Protocol.java


示例16: Http11Processor

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
public Http11Processor(int headerBufferSize, JIoEndpoint endpoint, int maxTrailerSize,
        Set<String> allowedTrailerHeaders, int maxExtensionSize, int maxSwallowSize) {

    super(endpoint);
    
    inputBuffer = new InternalInputBuffer(request, headerBufferSize);
    request.setInputBuffer(inputBuffer);

    outputBuffer = new InternalOutputBuffer(response, headerBufferSize);
    response.setOutputBuffer(outputBuffer);

    //TODO
    initializeFilters(maxTrailerSize, allowedTrailerHeaders, maxExtensionSize, maxSwallowSize);
}
开发者ID:sunmingshuai，项目名称:apache-tomcat-7.0.73-with-comment，代码行数:15，代码来源:Http11Processor.java


示例17: actionInternal

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
/**
 * Send an action to the connector.
 *
 * @param actionCode
 *            Type of the action
 * @param param
 *            Action parameter
 */
@Override
@SuppressWarnings("incomplete-switch") // Other cases are handled by
										// action()
protected void actionInternal(ActionCode actionCode, Object param) {

	switch (actionCode) {
	case ASYNC_COMPLETE: {
		if (asyncStateMachine.asyncComplete()) {
			((JIoEndpoint) endpoint).processSocketAsync(this.socketWrapper, SocketStatus.OPEN_READ);
		}
		break;
	}
	case ASYNC_SETTIMEOUT: {
		if (param == null)
			return;
		long timeout = ((Long) param).longValue();
		// if we are not piggy backing on a worker thread, set the timeout
		socketWrapper.setTimeout(timeout);
		break;
	}
	case ASYNC_DISPATCH: {
		if (asyncStateMachine.asyncDispatch()) {
			((JIoEndpoint) endpoint).processSocketAsync(this.socketWrapper, SocketStatus.OPEN_READ);
		}
		break;
	}
	}
}
开发者ID:how2j，项目名称:lazycat，代码行数:37，代码来源:AjpProcessor.java


示例18: AjpProtocol

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
public AjpProtocol() {
	endpoint = new JIoEndpoint();
	cHandler = new AjpConnectionHandler(this);
	((JIoEndpoint) endpoint).setHandler(cHandler);
	setSoLinger(Constants.DEFAULT_CONNECTION_LINGER);
	setSoTimeout(Constants.DEFAULT_CONNECTION_TIMEOUT);
	setTcpNoDelay(Constants.DEFAULT_TCP_NO_DELAY);
}
开发者ID:how2j，项目名称:lazycat，代码行数:9，代码来源:AjpProtocol.java


示例19: createProcessor

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
@Override
protected AjpProcessor createProcessor() {
	AjpProcessor processor = new AjpProcessor(proto.packetSize, (JIoEndpoint) proto.endpoint);
	processor.setAdapter(proto.adapter);
	processor.setAjpFlush(proto.getAjpFlush());
	processor.setTomcatAuthentication(proto.tomcatAuthentication);
	processor.setTomcatAuthorization(proto.getTomcatAuthorization());
	processor.setRequiredSecret(proto.requiredSecret);
	processor.setKeepAliveTimeout(proto.getKeepAliveTimeout());
	processor.setClientCertProvider(proto.getClientCertProvider());
	processor.setMaxCookieCount(proto.getMaxCookieCount());
	register(processor);
	return processor;
}
开发者ID:how2j，项目名称:lazycat，代码行数:15，代码来源:AjpProtocol.java


示例20: Http11Protocol

import org.apache.tomcat.util.net.JIoEndpoint; //导入依赖的package包/类
public Http11Protocol() {
	endpoint = new JIoEndpoint();
	cHandler = new Http11ConnectionHandler(this);
	((JIoEndpoint) endpoint).setHandler(cHandler);
	setSoLinger(Constants.DEFAULT_CONNECTION_LINGER);
	setSoTimeout(Constants.DEFAULT_CONNECTION_TIMEOUT);
	setTcpNoDelay(Constants.DEFAULT_TCP_NO_DELAY);
}
开发者ID:how2j，项目名称:lazycat，代码行数:9，代码来源:Http11Protocol.java



注：本文中的org.apache.tomcat.util.net.JIoEndpoint类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java AccountPasswordMustChangeException类代码示例发布时间：2022-05-22
下一篇：
Java EditorMouseListener类代码示例发布时间：2022-05-22
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap