Some bug in your code

[yudnkuku]

• In your HttpUtil.parseHttpRequest() method: the variable bodyEndIndex should be bodyStartIndex + httpHeaders.contentLength + 1 rather than bodyStartIndex + httpHeaders.contentLength

• In your Message.writePartialMessageToMessage method: the variable startIndexOfPartialMessage should just be endIndex + 1 rather than message.offset + endIndex. the variable lengthOfPartialMessage should be (message.offset + message.length) - endIndex + 1 rather than (message.offset + message.length) - endIndex

• I got a NPE when invoking the HttpMessageReader.read().The code snippet is shown below:

  Message message = this.messageBuffer.getMessage;    //the return message might be null
  message.metadata = new HttpHeaders();    //the NPE occurs here

  To solve the problem,I add some code in your QueueIntFlip.take() method:

      if(!flipped){
          //add this if 
          if(readPos == capacity) {
              readPos = 0;
          }
          if(readPos < writePos){
              return elements[readPos++];
          } else {
              return -1;
          }
      }

[stepfortune]

• In your HttpUtil.parseHttpRequest() method: the variable bodyEndIndex should be bodyStartIndex + httpHeaders.contentLength + 1 rather than bodyStartIndex + httpHeaders.contentLength
• In your Message.writePartialMessageToMessage method: the variable startIndexOfPartialMessage should just be endIndex + 1 rather than message.offset + endIndex. the variable lengthOfPartialMessage should be (message.offset + message.length) - endIndex + 1 rather than (message.offset + message.length) - endIndex
• I got a NPE when invoking the HttpMessageReader.read().The code snippet is shown below:

Message message = this.messageBuffer.getMessage;    //the return message might be null
message.metadata = new HttpHeaders();    //the NPE occurs here

To solve the problem,I add some code in your QueueIntFlip.take() method:

        if(!flipped){
            //add this if 
            if(readPos == capacity) {
                readPos = 0;
            }
            if(readPos < writePos){
                return elements[readPos++];
            } else {
                return -1;
            }
        }

I think the variable startIndexOfPartialMessage should be endIndex, not bodyStartIndex + httpHeaders.contentLength or endIndex + 1, since the endIndex does point to the next byte of a http message body end(the implementation can be found in the HttpUtil.parseHttpRequest method), Additionally, I dont think the code

            if(!flipped){
              //add this if 
              if(readPos == capacity) {
                  readPos = 0;
              }
              if(readPos < writePos){
                  return elements[readPos++];
              } else {
                  return -1;
              }
          }
``` that you mentioned is right, because if you do that, in the case  ` writePos == capacity readPos == capacity flipped == false` which means the all the MessageBuffer blocks are free, then you call the `take()` function again, the `readPos` will be 0, and the writePos and flipped wont be changed, that cause a repeated reading.