dongxu1875
dongxu1875
2016-12-20 22:13

golang从net.TCPConn读取字节,其中4字节作为消息分隔

已采纳

I am working on SIP over TCP mock service in golang. Incoming SIP messages are separated by ' ' sequence (I do not care about SDP for now). I want to extract message based on that delimiter and send it over to the processing goroutine. Looking through golang standard libraries I see no trivial way of achieving it. There seems to be no one shop stop in io and bufio packages. Currently I see two options of going forward (bufio):

  1. *Reader.ReadBytes function with '/r' set as the delimiter. Further processing is done by using ReadByte function and comparing it sequentially with each byte of the delimiter and unreading them if necessary (which looks quite tedious)

  2. Using Scanner with a custom split function, which does not look too trivial as well.

I wonder whether there are any other better options, functionality seems so common that it is hard to believe that it is not possible to just define delimiter for tcp stream and extract messages from it.

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享
  • 邀请回答

1条回答

  • doumalu9257 doumalu9257 5年前

    You can either choose to buffer the reads up yourself and split on the delimiter, or let a bufio.Scanner do it for you. There's nothing onerous about implementing a scanner.SplitFunc, and it's definitely simpler than the alternative. Using bufio.ScanLines as an example, you could use:

    scanner.Split(func(data []byte, atEOF bool) (advance int, token []byte, err error) {
        delim := []byte{'', '
    ', '', '
    '}
        if atEOF && len(data) == 0 {
            return 0, nil, nil
        }
        if i := bytes.Index(data, delim); i >= 0 {
            return i + len(delim), data[0:i], nil
        }
        if atEOF {
            return len(data), data, nil
        }
        return 0, nil, nil
    }
    
    点赞 评论 复制链接分享

相关推荐