io.netty.handler.codec.http.multipart

Class HttpPostRequestDecoder

java.lang.Object

io.netty.handler.codec.http.multipart.HttpPostRequestDecoder

All Implemented Interfaces:

InterfaceHttpPostRequestDecoder

public class HttpPostRequestDecoder
extends Object
implements InterfaceHttpPostRequestDecoder

This decoder will decode Body and can handle POST BODY. You MUST call destroy() after completion to release all resources.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HttpPostRequestDecoder.EndOfDataDecoderException Exception when the body is fully decoded, even if there is still data
static class	HttpPostRequestDecoder.ErrorDataDecoderException Exception when an error occurs while decoding
protected static class	HttpPostRequestDecoder.MultiPartStatus states follow NOTSTARTED PREAMBLE ( (HEADERDELIMITER DISPOSITION (FIELD | FILEUPLOAD))* (HEADERDELIMITER DISPOSITION MIXEDPREAMBLE (MIXEDDELIMITER MIXEDDISPOSITION MIXEDFILEUPLOAD)+ MIXEDCLOSEDELIMITER)* CLOSEDELIMITER)+ EPILOGUE First getStatus is: NOSTARTED Content-type: multipart/form-data, boundary=AaB03x => PREAMBLE in Header --AaB03x => HEADERDELIMITER content-disposition: form-data; name="field1" => DISPOSITION Joe Blow => FIELD --AaB03x => HEADERDELIMITER content-disposition: form-data; name="pics" => DISPOSITION Content-type: multipart/mixed, boundary=BbC04y --BbC04y => MIXEDDELIMITER Content-disposition: attachment; filename="file1.txt" => MIXEDDISPOSITION Content-Type: text/plain ... contents of file1.txt ... => MIXEDFILEUPLOAD --BbC04y => MIXEDDELIMITER Content-disposition: file; filename="file2.gif" => MIXEDDISPOSITION Content-type: image/gif Content-Transfer-Encoding: binary ...contents of file2.gif... => MIXEDFILEUPLOAD --BbC04y-- => MIXEDCLOSEDELIMITER --AaB03x-- => CLOSEDELIMITER Once CLOSEDELIMITER is found, last getStatus is EPILOGUE
static class	HttpPostRequestDecoder.NotEnoughDataDecoderException Exception when try reading data from request in chunked format, and not enough data are available (need more chunks)

Constructor Summary

Constructors

Constructor and Description
HttpPostRequestDecoder(HttpDataFactory factory, HttpRequest request)
HttpPostRequestDecoder(HttpDataFactory factory, HttpRequest request, Charset charset)
HttpPostRequestDecoder(HttpRequest request)

Method Summary

Modifier and Type	Method and Description
void	cleanFiles() Clean all HttpDatas (on Disk) for the current request.
InterfaceHttpData	currentPartialHttpData() Returns the current InterfaceHttpData if currently in decoding status, meaning all data are not yet within, or null if there is no InterfaceHttpData currently in decoding status (either because none yet decoded or none currently partially decoded).
void	destroy() Destroy the InterfaceHttpPostRequestDecoder and release all it resources.
InterfaceHttpData	getBodyHttpData(String name) This getMethod returns the first InterfaceHttpData with the given name from body.
List<InterfaceHttpData>	getBodyHttpDatas() This getMethod returns a List of all HttpDatas from body.
List<InterfaceHttpData>	getBodyHttpDatas(String name) This getMethod returns a List of all HttpDatas with the given name from body.
int	getDiscardThreshold() Return the threshold in bytes after which read data in the buffer should be discarded.
protected static String[]	getMultipartDataBoundary(String contentType) Check from the request ContentType if this request is a Multipart request.
boolean	hasNext() True if at current getStatus, there is an available decoded InterfaceHttpData from the Body.
boolean	isMultipart() True if this request is a Multipart request
static boolean	isMultipart(HttpRequest request) Check if the given request is a multipart request
InterfaceHttpData	next() Returns the next available InterfaceHttpData or null if, at the time it is called, there is no more available InterfaceHttpData.
InterfaceHttpPostRequestDecoder	offer(HttpContent content) Initialized the internals from a new chunk
void	removeHttpDataFromClean(InterfaceHttpData data) Remove the given FileUpload from the list of FileUploads to clean
void	setDiscardThreshold(int discardThreshold) Set the amount of bytes after which read bytes in the buffer should be discarded.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HttpPostRequestDecoder

public HttpPostRequestDecoder(HttpRequest request)

Parameters:

request - the request to decode

Throws:

NullPointerException - for request

HttpPostRequestDecoder.ErrorDataDecoderException - if the default charset was wrong when decoding or other errors

HttpPostRequestDecoder

public HttpPostRequestDecoder(HttpDataFactory factory,
                              HttpRequest request)

Parameters:

factory - the factory used to create InterfaceHttpData

request - the request to decode

Throws:

NullPointerException - for request or factory

HttpPostRequestDecoder.ErrorDataDecoderException - if the default charset was wrong when decoding or other errors

HttpPostRequestDecoder

public HttpPostRequestDecoder(HttpDataFactory factory,
                              HttpRequest request,
                              Charset charset)

Parameters:

factory - the factory used to create InterfaceHttpData

request - the request to decode

charset - the charset to use as default

Throws:

NullPointerException - for request or charset or factory

HttpPostRequestDecoder.ErrorDataDecoderException - if the default charset was wrong when decoding or other errors

Method Detail

isMultipart

public static boolean isMultipart(HttpRequest request)

Check if the given request is a multipart request

Returns:

True if the request is a Multipart request

getMultipartDataBoundary

protected static String[] getMultipartDataBoundary(String contentType)

Check from the request ContentType if this request is a Multipart request.

Returns:

an array of String if multipartDataBoundary exists with the multipartDataBoundary as first element, charset if any as second (missing if not set), else null

isMultipart

public boolean isMultipart()

Description copied from interface: InterfaceHttpPostRequestDecoder

True if this request is a Multipart request

Specified by:

isMultipart in interface InterfaceHttpPostRequestDecoder

Returns:

True if this request is a Multipart request

setDiscardThreshold

public void setDiscardThreshold(int discardThreshold)

Description copied from interface: InterfaceHttpPostRequestDecoder

Set the amount of bytes after which read bytes in the buffer should be discarded. Setting this lower gives lower memory usage but with the overhead of more memory copies. Use 0 to disable it.

Specified by:

setDiscardThreshold in interface InterfaceHttpPostRequestDecoder

getDiscardThreshold

public int getDiscardThreshold()

Description copied from interface: InterfaceHttpPostRequestDecoder

Return the threshold in bytes after which read data in the buffer should be discarded.

Specified by:

getDiscardThreshold in interface InterfaceHttpPostRequestDecoder

getBodyHttpDatas

public List<InterfaceHttpData> getBodyHttpDatas()

Description copied from interface: InterfaceHttpPostRequestDecoder

This getMethod returns a List of all HttpDatas from body.
If chunked, all chunks must have been offered using offer() getMethod. If not, NotEnoughDataDecoderException will be raised.

Specified by:

getBodyHttpDatas in interface InterfaceHttpPostRequestDecoder

Returns:

the list of HttpDatas from Body part for POST getMethod

getBodyHttpDatas

public List<InterfaceHttpData> getBodyHttpDatas(String name)

Description copied from interface: InterfaceHttpPostRequestDecoder

This getMethod returns a List of all HttpDatas with the given name from body.
If chunked, all chunks must have been offered using offer() getMethod. If not, NotEnoughDataDecoderException will be raised.

Specified by:

getBodyHttpDatas in interface InterfaceHttpPostRequestDecoder

Returns:

All Body HttpDatas with the given name (ignore case)

getBodyHttpData

public InterfaceHttpData getBodyHttpData(String name)

Description copied from interface: InterfaceHttpPostRequestDecoder

This getMethod returns the first InterfaceHttpData with the given name from body.
If chunked, all chunks must have been offered using offer() getMethod. If not, NotEnoughDataDecoderException will be raised.

Specified by:

getBodyHttpData in interface InterfaceHttpPostRequestDecoder

Returns:

The first Body InterfaceHttpData with the given name (ignore case)

offer

public InterfaceHttpPostRequestDecoder offer(HttpContent content)

Description copied from interface: InterfaceHttpPostRequestDecoder

Initialized the internals from a new chunk

Specified by:

offer in interface InterfaceHttpPostRequestDecoder

Parameters:

content - the new received chunk

hasNext

public boolean hasNext()

Description copied from interface: InterfaceHttpPostRequestDecoder

True if at current getStatus, there is an available decoded InterfaceHttpData from the Body. This getMethod works for chunked and not chunked request.

Specified by:

hasNext in interface InterfaceHttpPostRequestDecoder

Returns:

True if at current getStatus, there is a decoded InterfaceHttpData

next

public InterfaceHttpData next()

Description copied from interface: InterfaceHttpPostRequestDecoder

Returns the next available InterfaceHttpData or null if, at the time it is called, there is no more available InterfaceHttpData. A subsequent call to offer(httpChunk) could enable more data. Be sure to call ReferenceCounted.release() after you are done with processing to make sure to not leak any resources

Specified by:

next in interface InterfaceHttpPostRequestDecoder

Returns:

the next available InterfaceHttpData or null if none

currentPartialHttpData

public InterfaceHttpData currentPartialHttpData()

Description copied from interface: InterfaceHttpPostRequestDecoder

Returns the current InterfaceHttpData if currently in decoding status, meaning all data are not yet within, or null if there is no InterfaceHttpData currently in decoding status (either because none yet decoded or none currently partially decoded). Full decoded ones are accessible through hasNext() and next() methods.

Specified by:

currentPartialHttpData in interface InterfaceHttpPostRequestDecoder

Returns:

the current InterfaceHttpData if currently in decoding status or null if none.

destroy

public void destroy()

Description copied from interface: InterfaceHttpPostRequestDecoder

Destroy the InterfaceHttpPostRequestDecoder and release all it resources. After this method was called it is not possible to operate on it anymore.

Specified by:

destroy in interface InterfaceHttpPostRequestDecoder

cleanFiles

public void cleanFiles()

Description copied from interface: InterfaceHttpPostRequestDecoder

Clean all HttpDatas (on Disk) for the current request.

Specified by:

cleanFiles in interface InterfaceHttpPostRequestDecoder

removeHttpDataFromClean

public void removeHttpDataFromClean(InterfaceHttpData data)

Description copied from interface: InterfaceHttpPostRequestDecoder

Remove the given FileUpload from the list of FileUploads to clean

Specified by:

removeHttpDataFromClean in interface InterfaceHttpPostRequestDecoder