利用QBuffer和QLinkedList做数据块存储队列

　　Qt中QByteArray存储数据很方便，使用QBuffer存储大块数据更方便。QBuffer类包装了QByteArray类对象，实际存储还是使用了QByteArray，但QBuffer实现了QIODevice接口，其拥有丰富的读写接口，使操作更方便。

　　主要需求是，存进去的数据接口函数参数要求是char* dat 和int datalength是形式，取出来的数据接口函数参数也是一样。

　　qt里对基本数据格式都进行了封装，提供了如QChar、QBitArray、QByteArray类，使用起来也是很方便。如网络上接受到数据，都是帧流，处理数据时，需要按字节处理（因为通信协议多按字节定义），如上的缓存接口定义就比较合适。

　　使用QBuffer+QLinkedList做一个缓存队列就非常容易了。

　　下面给出代码：

　　FrameStreamManager.cpp

#include "FrameStreamManager.h"

FrameStreamManager::FrameStreamManager()
{

}

FrameStreamManager::~FrameStreamManager()
{

}

int FrameStreamManager::putFrame(char *in,int length)
{
    int ret;
    QMutexLocker locker(&mutex);

    QBuffer *qbuf = new QBuffer();
    qbuf->open(QBuffer::ReadWrite);
    ret = qbuf->write(in,length);
    qbuf->close();

    list.append(qbuf);

    return ret;
}

int FrameStreamManager::getFrame(char *retbuf,int size)
{
    QMutexLocker locker(&mutex);
    QBuffer *qbuf;
    int ret=0;

    if(list.size() > 0)
    {
        qbuf = list.takeFirst();
        qbuf->open(QBuffer::ReadWrite);
        ret = qbuf->read(retbuf,size);
        qbuf->close();
        delete qbuf;
    }

    return ret;
}

int FrameStreamManager::getFrameSize()
{
    return list.size();
}

　　FrameStreamManager.h

#ifndef FRAMESTREAMMANAGER_H
#define FRAMESTREAMMANAGER_H

#include <QLinkedList>
#include <QBuffer>
#include <QByteArray>
#include <QMutexLocker>
#include <QMutex>

class FrameStreamManager
{
public:
    FrameStreamManager();
    ~FrameStreamManager();

private:
    QLinkedList<QBuffer*> list;
    QMutex mutex;

public:
    int putFrame(char *in,int length);
    int getFrame(char *rebuf,int size);
    int getFrameSize(void);
};


#endif

　　测试文件：

　　mainwindow.cpp

#include "mainwindow.h"
#include <QLabel>
#include <QtDebug>
#include <QBuffer>
#include <QPushButton>

MainWindow::MainWindow(QWidget *parent)
    : QMainWindow(parent)
{
    this->setFixedSize(320,240);
    QLabel *label = new QLabel("hello you are",this);
    label->move(0,0);

    QPushButton *btn1 = new QPushButton("put",this);
    connect(btn1, SIGNAL(clicked()), this, SLOT(btn1Clicked()));
    btn1->move(0,25);

    QPushButton *btn2 = new QPushButton("show",this);
    connect(btn2,SIGNAL(clicked()),this,SLOT(btn2Clicked()));
    btn2->move(0,60);

    QPushButton *btn3 = new QPushButton("get",this);
    connect(btn3,SIGNAL(clicked()),this,SLOT(btn3Clicked()));
    btn3->move(0,95);

    for(int i=0;i<512;i++)
        defaultbuf[i] = 100;

    memset(retbuf,0,512);

    /*//    int BUFSIZE = 2048;

    //    QBuffer qbuf;
    //    qbuf.open(QBuffer::ReadWrite);

    //    char *buf = (char*)malloc(BUFSIZE);
    //    for(int i=0;i<BUFSIZE;i++)
    //    {
    //        buf[i] = 234;
    //    }

    //    int ret = qbuf.write(buf,BUFSIZE);
    //    qbuf.close();
    //    qDebug()<<"ret = "<<ret;

    //    char *retbuf = (char *)malloc(BUFSIZE);
    //    memset(retbuf,0,BUFSIZE);
    //    qbuf.open(QBuffer::ReadWrite);

    //    ret = qbuf.read(retbuf,BUFSIZE);
    //    qDebug()<<"ret = "<<ret;
    //    for(int i=0;i<BUFSIZE;i++)
    //    {
    //        if(retbuf[i] != (char)234)
    //        {
    //            qDebug()<<"Error at "<<i<<" : "<<retbuf[i];
    //        }
    //    }
    //    qbuf.close();

    //    free(buf);
    //    free(retbuf); */
}

MainWindow::~MainWindow()
{

}

void MainWindow::btn1Clicked()
{
    qDebug()<<"
put frame!";

    int len = fsm.putFrame(defaultbuf,512);
    if(len != 512)
        qDebug()<<"put frame buf";
}

void MainWindow::btn2Clicked()
{
    qDebug()<<"
show frame list size!";

    int len = fsm.getFrameSize();
    qDebug()<<"Now Frame Size = "<<len;
}

void MainWindow::btn3Clicked()
{
    qDebug()<<"
get frame and check!";

    int len = fsm.getFrame(retbuf,512);
    if(len != 512)
        qDebug()<<"get frame returns "<<len;
    else
    {
        for(int i=0;i<512;i++)
        {
            if(retbuf[i] != 100)
                qDebug()<<" get data error at "<<i<<" : "<<retbuf[i];
        }
    }

    memset(retbuf,0,512);
}

　　mainwindow.h

#ifndef MAINWINDOW_H
#define MAINWINDOW_H

#include <QMainWindow>
#include "FrameStreamManager.h"

class MainWindow : public QMainWindow
{
    Q_OBJECT

public:
    MainWindow(QWidget *parent = 0);
    ~MainWindow();

private slots:
    void btn1Clicked();
    void btn2Clicked();
    void btn3Clicked();

private:
    FrameStreamManager fsm;

    char defaultbuf[512];
    char retbuf[512];
};

#endif // MAINWINDOW_H

　　

　　QByteArray也是可以完成同样功能，QByteArray有如下函数，QByteArray & QByteArray::append(const char *str,int len) 和char * QByteArray::data()。就是QByteArray会在返回的char* 数据后自动加‘’，但int QByteArray::size()返回来的数是不含''，利用size()函数和data()封装一下就可以达到上面QBuffer达到的效果。

　　而且使用QByteArray有个好处，QByteArray重载了操作符=，所以FrameStreamManager里的list可以这样定义-->QLinkedList<QByteArray> list。从队列中取数据时可以直接写QByteArray tmp = list.takeFirst();而QBuffer没有重载=操作符，QBuffer tmp = list.takeFirst();这样就写就会直接报错。定义队列时就必须改成上面那样，就需要自己管理内存了。同时，使用QBuffer还需要打开和关闭设备。

　　综上，队列中使用QByteArray做存储，封装使用更方便。