📄 ajp13connectorrequest.java
字号:
/*
* $Header: /home/cvs/jakarta-tomcat/src/share/org/apache/tomcat/service/connector/Attic/Ajp13ConnectorRequest.java,v 1.5.2.8 2001/06/20 20:52:23 marcsaeg Exp $
* $Revision: 1.5.2.8 $
* $Date: 2001/06/20 20:52:23 $
*
* ====================================================================
*
* The Apache Software License, Version 1.1
*
* Copyright (c) 1999 The Apache Software Foundation. All rights
* reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in
* the documentation and/or other materials provided with the
* distribution.
*
* 3. The end-user documentation included with the redistribution, if
* any, must include the following acknowlegement:
* "This product includes software developed by the
* Apache Software Foundation (http://www.apache.org/)."
* Alternately, this acknowlegement may appear in the software itself,
* if and wherever such third-party acknowlegements normally appear.
*
* 4. The names "The Jakarta Project", "Tomcat", and "Apache Software
* Foundation" must not be used to endorse or promote products derived
* from this software without prior written permission. For written
* permission, please contact apache@apache.org.
*
* 5. Products derived from this software may not be called "Apache"
* nor may "Apache" appear in their names without prior written
* permission of the Apache Group.
*
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
* ====================================================================
*
* This software consists of voluntary contributions made by many
* individuals on behalf of the Apache Software Foundation. For more
* information on the Apache Software Foundation, please see
* <http://www.apache.org/>.
*
* [Additional notices, if required by prior licensing conditions]
*
*/
package org.apache.tomcat.service.connector;
import java.io.*;
import java.net.*;
import java.util.*;
import org.apache.tomcat.core.*;
import org.apache.tomcat.util.*;
import javax.servlet.*;
import javax.servlet.http.*;
public class Ajp13ConnectorRequest extends RequestImpl
{
public static final int MAX_READ_SIZE = TcpConnector.MAX_PACKET_SIZE -
TcpConnector.H_SIZE -
2;
public static final byte JK_AJP13_GET_BODY_CHUNK = 6;
public static final byte SC_A_CONTEXT = 1;
public static final byte SC_A_SERVLET_PATH = 2;
public static final byte SC_A_REMOTE_USER = 3;
public static final byte SC_A_AUTH_TYPE = 4;
public static final byte SC_A_QUERY_STRING = 5;
public static final byte SC_A_JVM_ROUTE = 6;
public static final byte SC_A_SSL_CERT = 7;
public static final byte SC_A_SSL_CIPHER = 8;
public static final byte SC_A_SSL_SESSION = 9;
public static final byte SC_A_REQ_ATTRIBUTE = 10;
public static final byte SC_A_ARE_DONE = (byte)0xFF;
public static final String []methodTransArray = {
"OPTIONS",
"GET",
"HEAD",
"POST",
"PUT",
"DELETE",
"TRACE"
};
public static final String []headerTransArray = {
"accept",
"accept-charset",
"accept-encoding",
"accept-language",
"authorization",
"connection",
"content-type",
"content-length",
"cookie",
"cookie2",
"host",
"pragma",
"referer",
"user-agent"
};
MsgConnector con;
byte []bodyBuff = new byte[MAX_READ_SIZE];
int blen;
int pos;
public Ajp13ConnectorRequest()
{
super();
}
protected int decodeRequest(MsgBuffer msg) throws IOException
{
boolean isSSL = false;
byte bsc;
int hCount = 0;
/*
* Read the method and translate it to a String
*/
bsc = msg.getByte();
method = methodTransArray[(int)bsc - 1];
protocol = msg.getString();
requestURI = msg.getString();
remoteAddr = msg.getString();
remoteHost = msg.getString();
serverName = msg.getString();
serverPort = msg.getInt();
bsc = msg.getByte();
if(bsc != 0) {
isSSL = true;
}
hCount = msg.getInt();
for(int i = 0 ; i < hCount ; i++) {
String hName = null;
int isc = msg.peekInt();
int hId = isc & 0x000000FF;
isc &= 0x0000FF00;
if(0x0000A000 == isc) {
msg.getInt();
hName = headerTransArray[hId - 1];
} else {
hName = msg.getString().toLowerCase();
}
String hValue = msg.getString();
headers.putHeader( hName , hValue );
//System.out.println( "Head: " + hName + "=" + hValue);
}
for(bsc = msg.getByte() ;
bsc != SC_A_ARE_DONE ;
bsc = msg.getByte()) {
switch(bsc) {
case SC_A_CONTEXT :
contextPath = msg.getString();
break;
case SC_A_SERVLET_PATH :
System.out.println("SC_A_SERVLET_PATH not in use " + msg.getString());
break;
case SC_A_REMOTE_USER :
remoteUser = msg.getString();
break;
case SC_A_AUTH_TYPE :
authType = msg.getString();
break;
case SC_A_QUERY_STRING :
queryString = msg.getString();
break;
case SC_A_JVM_ROUTE :
jvmRoute = msg.getString();
break;
case SC_A_SSL_CERT :
isSSL = true;
attributes.put("javax.servlet.request.X509Certificate",
msg.getString());
break;
case SC_A_SSL_CIPHER :
isSSL = true;
attributes.put("javax.servlet.request.cipher_suite",
msg.getString());
break;
case SC_A_SSL_SESSION :
isSSL = true;
attributes.put("javax.servlet.request.ssl_session",
msg.getString());
break;
case SC_A_REQ_ATTRIBUTE :
attributes.put(msg.getString(), msg.getString());
break;
default:
return -1;
}
}
if(isSSL) {
setScheme("https");
}
contentLength = headers.getIntHeader("content-length");
contentType = headers.getHeader("content-type");
((BufferedServletInputStream)this.in).setLimit(contentLength);
if(contentLength > 0) {
/* Read present data */
int err = con.receive(msg);
if(err < 0) {
return -1;
}
blen = msg.peekInt();
msg.getBytes(bodyBuff);
}
return 0;
}
public int doRead() throws IOException
{
if(pos >= blen) {
if( ! refillReadBuffer()) {
return -1;
}
}
return bodyBuff[pos++] & 0xFF; // prevent sign extension of byte value
}
public int doRead(byte[] b, int off, int len) throws IOException
{
if(pos >= blen) {
if( ! refillReadBuffer()) {
return -1;
}
}
int toCopy = len;
while(toCopy > 0) {
int bytesRemaining = blen - pos;
if(bytesRemaining < 0)
bytesRemaining = 0;
int c = bytesRemaining < toCopy ? bytesRemaining : toCopy;
System.arraycopy(bodyBuff, pos, b, off, c);
toCopy -= c;
off += c;
pos += c; // In case we exactly consume the buffer
if(toCopy > 0) {
if( ! refillReadBuffer()) { // Resets blen and pos
break;
}
}
}
return len - toCopy;
}
public void recycle()
{
super.recycle();
pos=0;
}
public void setConnector(MsgConnector con)
{
this.con = con;
pos = 0;
this.in = new BufferedServletInputStream(this);
}
public boolean refillReadBuffer() throws IOException
{
MsgBuffer msg = con.getMsgBuffer();
msg.appendByte(JK_AJP13_GET_BODY_CHUNK);
msg.appendInt(MAX_READ_SIZE);
con.send(msg);
int err = con.receive(msg);
if(err < 0) {
throw new IOException();
}
blen = msg.peekInt();
pos = 0;
msg.getBytes(bodyBuff);
return (blen > 0);
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -