Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-2780: ByteArrayLengthHeaderSerializer.inclusive

Browse Source 
Resolves https://github.com/spring-projects/spring-integration/issues/2780
This commit is contained in:
Gary Russell
2019-03-04 18:24:41 -05:00
committed by Artem Bilan
parent 20fde27e65
commit 200f3b3c1d
4 changed files with 110 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/reference/asciidoc/ip.adoc
View File

@@ -373,6 +373,7 @@ The following example shows a client connection factory that uses `java.net.Sock
----
====
[[tcp-codecs]]
==== Message Demarcation (Serializers and Deserializers)
TCP is a streaming protocol.
@@ -398,6 +399,8 @@ The default size of the length header is four bytes (an Integer), allowing for m
However, the `length` header can be a single byte (unsigned) for messages up to 255 bytes, or an unsigned short (2 bytes) for messages up to (2^16 - 1) bytes.
If you need any other format for the header, you can subclass `ByteArrayLengthHeaderSerializer` and provide implementations for the `readHeader` and `writeHeader` methods.
The absolute maximum data size is (2^31 - 1) bytes.
Starting with version 5.2, the header value can include the length of the header in addition to the payload.
Set the `inclusive` property to enable that mechanism (it must be set to the same for producers and consumers).
The `ByteArrayRawSerializer`^*^, converts a byte array to a stream of bytes and adds no additional message demarcation data.
With this serializer (and deserializer), the end of a message is indicated by the client closing the socket in an orderly fashion.

4
src/reference/asciidoc/whats-new.adoc
View File

@@ -10,4 +10,8 @@ If you are interested in more details, see the Issue Tracker tickets that were r
[[x5.2-general]]
=== General Changes
[[5.2-tcp]]
==== TCP Changes
The length header used by the `ByteArrayLengthHeaderSerializer` can now include the length of the header in addition to the payload.
See <<tcp-codecs>> for more information.