Qt实现mjpg streamer

要在Qt中实现mjpg streamer，可以使用Qt的网络模块和多线程技术。

首先，需要创建一个Qt网络服务器，用于接收客户端的请求。在服务器的槽函数中，可以使用Qt的多线程技术创建一个新的线程，用于发送mjpg流数据。在线程中，需要不断地读取摄像头的数据，并将数据转换成mjpg格式的数据流，然后通过网络发送给客户端。

具体的实现步骤如下：

1. 创建一个Qt网络服务器，用于接收客户端的请求；
2. 在服务器的槽函数中启动一个新的线程；
3. 在新线程中，使用OpenCV读取摄像头的数据，并将数据转换成mjpg格式的数据流；
4. 将mjpg数据流通过网络发送给客户端；
5. 循环执行步骤3和4，直到服务器停止。

注意事项：

1. 在多线程中操作摄像头需要加锁，避免多个线程同时访问同一个资源；
2. 不同的浏览器对mjpg流的支持不同，需要测试不同浏览器的兼容性；
3. 需要注意线程的退出条件，避免线程一直运行导致程序崩溃。

参考代码如下：

#include <QtNetwork>
#include <QThread>
#include <opencv2/opencv.hpp>

class MJPGServer : public QTcpServer
{
    Q_OBJECT
public:
    explicit MJPGServer(QObject *parent = nullptr) : QTcpServer(parent)
    {
        listen(QHostAddress::Any, 8080);
        qDebug() << "Server started";
    }

protected:
    void incomingConnection(qintptr socketDescriptor) override
    {
        qDebug() << "New connection: " << socketDescriptor;
        MJPGThread *thread = new MJPGThread(socketDescriptor);
        connect(thread, &MJPGThread::finished, thread, &MJPGThread::deleteLater);
        thread->start();
    }
};

class MJPGThread : public QThread
{
    Q_OBJECT
public:
    explicit MJPGThread(qintptr socketDescriptor, QObject *parent = nullptr) : QThread(parent), socketDescriptor(socketDescriptor)
    {
    }

private:
    qintptr socketDescriptor;

    void run() override
    {
        QTcpSocket socket;
        if (!socket.setSocketDescriptor(socketDescriptor))
        {
            qDebug() << "Error setting socket descriptor";
            return;
        }

        cv::VideoCapture cap(0);
        if (!cap.isOpened())
        {
            qDebug() << "Error opening camera";
            return;
        }

        while (!socket.isWritable())
        {
            msleep(1000);
        }

        socket.write("HTTP/1.0 200 OK\r\n");
        socket.write("Server: MJPGServer\r\n");
        socket.write("Connection: close\r\n");
        socket.write("Max-Age: 0\r\n");
        socket.write("Expires: 0\r\n");
        socket.write("Cache-Control: no-cache, private\r\n");
        socket.write("Pragma: no-cache\r\n");
        socket.write("Content-Type: multipart/x-mixed-replace; boundary=--frame\r\n\r\n");

        cv::Mat frame;
        std::vector<uchar> buffer;
        std::vector<int> params;
        params.push_back(cv::IMWRITE_JPEG_QUALITY);
        params.push_back(80);

        while (socket.state() == QTcpSocket::ConnectedState)
        {
            cap >> frame;
            if (!frame.empty())
            {
                cv::imencode(".jpg", frame, buffer, params);
                socket.write("--frame\r\n");
                socket.write("Content-Type: image/jpeg\r\n");
                socket.write(QString("Content-Length: %1\r\n\r\n").arg(buffer.size()).toUtf8());
                socket.write((const char*)buffer.data(), buffer.size());
                socket.write("\r\n");
            }
        }
    }
};

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);
    MJPGServer server;
    return a.exec();
}

#include "main.moc"

上面的代码使用了Qt的网络模块和多线程技术，实现了一个简单的mjpg streamer服务器。在浏览器中访问 http://localhost:8080 即可查看摄像头的实时画面。