#include <Windows.h> #include <mutex> #include <condition_variable> #include <opencv2/opencv.hpp> using namespace std; using namespace cv; string camera_path = "0"; string rtmpUrl = "rtmp://server/live/streamName"; Mat frame; CRITICAL_SECTION mtx; CONDITION_VARIABLE cond; PROCESS_INFORMATION pi; DWORD WINAPI capture_func(LPVOID args) { VideoCapture cap(camera_path); while (true) { cap.read(frame); EnterCriticalSection(&mtx); InitializeConditionVariable(&cond); WakeConditionVariable(&cond); LeaveCriticalSection(&mtx); } } DWORD WINAPI push_func(LPVOID args) { HANDLE pipeRead = NULL, pipeWrite; CreatePipe(&pipeRead, &pipeWrite, NULL, 0); EnterCriticalSection(&mtx); InitializeConditionVariable(&cond); STARTUPINFO si; si.cb = sizeof(si); si.dwFlags = STARTF_USESTDHANDLES; HANDLE tmp = pipeRead; si.hStdInput = tmp; wchar_t cmd[4096]; mbstowcs(cmd, "ffmpeg -f rawvideo -vcodec rawvideo -pix_fmt bgr24 -s 640x480 - \\r 30 - \\i pipe : 0 - \\c : v libx264 -preset ultrafast - \\f flv rtmp ://server/live/streamName ", strlen("ffmpeg -f rawvideo ... ") + 1); CreateProcess(NULL, cmd, NULL, NULL, TRUE, 0, NULL, NULL, &si, &pi); CloseHandle(pipeRead); CloseHandle(si.hStdInput); while (true) { SleepConditionVariableCS(&cond, &mtx, INFINITE); DWORD dwWritten; if (!WriteFile(pipeWrite, frame.data, frame.total() * frame.elemSize(), &dwWritten, NULL)) { cout << "Failed to write to pipe. Error: " << GetLastError() << endl; } } LeaveCriticalSection(&mtx); CloseHandle(pipeWrite); } int main() { InitializeCriticalSection(&mtx); EnterCriticalSection(&mtx); InitializeConditionVariable(&cond); LeaveCriticalSection(&mtx); HANDLE capture_thread = CreateThread(NULL, 0, capture_func, NULL, 0, NULL); HANDLE pipeRead, pipeWrite; CreatePipe(&pipeRead, &pipeWrite, NULL, 0); CloseHandle(pipeRead); CloseHandle(pipeWrite); WaitForSingleObject(pi.hProcess, INFINITE); }

这段代码是一个使用 OpenCV 和 FFmpeg 实现将摄像头捕获的视频推流到服务器的程序。其中，使用了 Windows API 中的线程和进程管理函数，以及互斥锁和条件变量来实现线程之间的同步。其中，capture_func 函数用于循环读取摄像头捕获的帧，push_func 函数用于将捕获的帧推流到服务器。具体实现思路是：在 capture_func 函数中，使用 VideoCapture 类从摄像头中读取帧，然后将帧数据存储在全局变量 frame 中；在 push_func 函数中，使用 CreateProcess 函数创建 FFmpeg 进程，并将帧数据通过匿名管道传递给 FFmpeg 进程；使用互斥锁和条件变量来实现线程之间的同步，当捕获到新的帧时，唤醒 push_func 函数。最后，使用 WaitForSingleObject 函数等待 FFmpeg 进程结束。