一个在数据流中解析、提取数据帧的c++类

工作中经常遇到需要在数据流中提取数据帧的任务。这种数据帧一般以某种特定数据序列表示开始（例如0xa5,0x5a)和结束(0xb5, 0x5b)，起始标记间的数据为帧有效数据。为了完成这一任务，包装了一个简易的解析类，在性能要求不高场合使用。

2019-08-02升级：

可以用参数 discardTag 控制在解析数据帧时是否带起始、结束标记数据

解析类代码如下

#ifndef FRAMEPARSER_H
#define FRAMEPARSER_H

#include <vector>
#include <algorithm>
#include <iterator>

template <typename T>
class FrameParser
{
public:
    FrameParser(const std::vector<T> &headTag, const std::vector<T> &tailTag, const bool discardTag=true) 
        : frameHeadTag(headTag), frameTailTag(tailTag), discardFrameTag{ discardTag }
    {}

    bool isDiscardFrameTag() const {
        return discardFrameTag;
    }

    template<class It>
    void append(It f, It l) {
        buffer.insert(buffer.end(), f, l);
    }
    void append(const std::vector<T> &data) {
        buffer.insert(buffer.end(), data.cbegin(), data.cend());
    }

    void parse(std::vector<std::vector<T>>& frames)
    {
        auto it_head{ buffer.cbegin() };
        for (auto it_tail{ std::search(it_head, buffer.cend(), frameTailTag.cbegin(), frameTailTag.cend()) };
            it_tail != buffer.cend(); it_tail = std::search(it_head, buffer.cend(), frameTailTag.cbegin(), frameTailTag.cend()))
        {
            it_head = std::search(it_head, it_tail, frameHeadTag.cbegin(), frameHeadTag.cend());
            if (it_head != it_tail) {
                frames.emplace_back(isDiscardFrameTag() ? it_head + frameHeadTag.size() : it_head
                    , isDiscardFrameTag() ? it_tail : it_tail + frameTailTag.size());
            }
            it_head = std::next(it_tail, frameTailTag.size());
        }

        tempBuffer.insert(tempBuffer.end(), it_head, buffer.cend());
        std::swap(buffer, tempBuffer);
        tempBuffer.clear();
    }

private:
    bool discardFrameTag{ true };
    const std::vector<T> frameHeadTag;
    const std::vector<T> frameTailTag;
    std::vector<T> buffer;
    std::vector<T> tempBuffer;
};

#endif // FRAMEPARSER_H

 

 使用测试代码如下

    FrameParser<std::uint8_t> parser{{ 0xa5, 0x5a }, { 0xb5, 0x5b }};
    std::vector<std::vector<std::uint8_t>> frames;    

    parser.append({
        0x01, 0x02, 0x03, 0xb5, 0x5b
        , 0xa5, 0x5a, 0x04, 0x05, 0x06, 0x07, 0xb5, 0x5b
        , 0xa5, 0x5a, 0x08, 0x09, 0x0a
    });
    parser.parse(frames);

    parser.append({ 0x0b, 0xb5, 0x5b, 0xa5, 0x5a, 0x0c });
    parser.parse(frames);

    parser.append({ 0x0b, 0xb5 });
    parser.parse(frames);