Docs

Hertz 支持 multiRange

输入“/”快速插入

Hertz 支持 multiRange

背景

Hertz support multipart/byteranges

核心思路

multiRange的数据分为三部分

1.
         bodyHeader部分，由 boundary, Content-Type, Content-Range, \r\n  4部分组成​

2.
         body部分，实际需要读取的数据​

3.
         bodyEnd部分，由boundary组成​

--3d6b6a416f9b5​
Content-Type: text/html​
Content-Range: bytes 0-50/1270​
 ​
<!doctype html>​
<html>​
<head>​
    <title>Example Do​
--3d6b6a416f9b5​
Content-Type: text/html​
Content-Range: bytes 100-150/1270​
 ​
eta http-equiv="Content-type" content="text/html; c​
--3d6b6a416f9b5--​

相比singleRange 直接从文件中读取数据，muliRange在读每个range之前，需要构造bodyHeader,读完全部range后，需要构造bodyEnd.​

由于Hertz的ZeroAlloc特性，不像标准库，每次构造一个满足长度的[]byte数组，存储数据。Hertz每次从pool中拿到cap为4096的[]byte数组，读取数据，所以存在三种没有读完的场景, bodyHeader，body, 以及bodyEnd。针对body没有读完场景，更新range角标即可，针对bodyHeader和bodyEnd场景，需要有个数组临时保存上次没有读完的数据。​

考虑到bodyHeader和bodyEnd的数据不会超过4096的byte，在rangeReader结构体中构建cap为4096的[]byte。​

补充

multiRange场景下的ContentLength 需要提前动态计算

实现细节

1.
singlePart 部分与bigFileReader 和 smallFileReader 隔离。只处理非Accept-Range场景​

详见pr

2.
ParseByteRange 和 SetByteRange 支持 multiRange​

ParseByteRange改名为ParseByteRanges，整体改动基于singleRange，支持multiRang，并添加对应的multi 测试​

func ParseByteRanges(byteRange []byte, contentLength int) (startPos, endPos []int, err error) {​
   b := byteRange​
   if !bytes.HasPrefix(b, bytestr.StrBytes) {​
      return startPos, endPos, fmt.Errorf("unsupported range units: %q. Expecting %q", byteRange, bytestr.StrBytes)​
   }​
   b = b[len(bytestr.StrBytes):]​
   if len(b) == 0 || b[0] != '=' {​
      return startPos, endPos, fmt.Errorf("missing byte range in %q", byteRange)​
   }​
   b = b[1:]​
​
   var n, sta, end, v int​
​
   for _, ra := range bytes.Split(b, bytesconv.S2b(",")) {​
      n = bytes.IndexByte(ra, '-')​
      if n < 0 {​
         return startPos, endPos, fmt.Errorf("missing the end position of byte range in %q", byteRange)​
      }​
      if n == 0 {​
         v, err = bytesconv.ParseUint(ra[n+1:])​
         if err != nil {​
            return startPos, endPos, err​
         }​
         sta = contentLength - v​
         if sta < 0 {​
            sta = 0​
         }​
         startPos = append(startPos, sta)​
         endPos = append(endPos, contentLength-1)​
         continue​
      }​
      if sta, err = bytesconv.ParseUint(ra[:n]); err != nil {​
         return startPos, endPos, err​
      }​
      if sta >= contentLength {​
         return startPos, endPos, fmt.Errorf("the start position of byte range cannot exceed %d. byte range %q", contentLength-1, byteRange)​
      }​
      ra = ra[n+1:]​
      if len(ra) == 0 {​
         startPos = append(startPos, sta)​
         endPos = append(endPos, contentLength-1)​
         continue​
      }​
      if end, err = bytesconv.ParseUint(ra); err != nil {​
         return startPos, endPos, err​
      }​
      if end >= contentLength {​
         end = contentLength - 1​
      }​
      if end < sta {​
         return startPos, endPos, fmt.Errorf("the start position of byte range cannot exceed the end position. byte range %q", byteRange)​
      }​
      startPos = append(startPos, sta)​
      endPos = append(endPos, end)​
   }​
   return startPos, endPos, nil​
}​