使用c ++进行视频流传输

#include <opencv2/opencv.hpp>

int main() {
    cv::VideoCapture cap(0); // 打开默认摄像头
    if (!cap.isOpened()) {
        std::cerr << "Error opening video stream or file" << std::endl;
        return -1;
    }

    cv::Mat frame;
    while (cap.read(frame)) {
        // 处理每一帧
    }

    cap.release();
    return 0;
}

extern "C" {
#include <libavcodec/avcodec.h>
#include <libavutil/imgutils.h>
#include <libavutil/opt.h>
#include <libswscale/swscale.h>
}

AVCodec* codec = avcodec_find_encoder(AV_CODEC_ID_H264);
AVCodecContext* codecContext = avcodec_alloc_context3(codec);

// 设置编码参数
codecContext->bit_rate = 400000;
codecContext->width = 640;
codecContext->height = 480;
codecContext->time_base = (AVRational){1, 25};
codecContext->framerate = (AVRational){25, 1};
codecContext->gop_size = 10;
codecContext->max_b_frames = 1;
codecContext->pix_fmt = AV_PIX_FMT_YUV420P;

avcodec_open2(codecContext, codec, NULL);

// 编码每一帧
AVFrame* frame = av_frame_alloc();
frame->format = codecContext->pix_fmt;
frame->width = codecContext->width;
frame->height = codecContext->height;

// ... 填充frame数据 ...

AVPacket pkt;
av_init_packet(&pkt);
pkt.data = NULL;
pkt.size = 0;

int ret = avcodec_send_frame(codecContext, frame);
if (ret < 0) {
    // 错误处理
}

ret = avcodec_receive_packet(codecContext, &pkt);
if (ret < 0) {
    // 错误处理
}

// 发送pkt

av_packet_unref(&pkt);
av_frame_free(&frame);
avcodec_close(codecContext);
avcodec_free_context(&codecContext);

#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>

int sock = socket(AF_INET, SOCK_DGRAM, 0);
struct sockaddr_in servaddr;
memset(&servaddr, 0, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_port = htons(8080);
inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr);

sendto(sock, pkt.data, pkt.size, 0, (const struct sockaddr *)&servaddr, sizeof(servaddr));

close(sock);

AVCodec* codec = avcodec_find_decoder(AV_CODEC_ID_H264);
AVCodecContext* codecContext = avcodec_alloc_context3(codec);

// 设置解码参数
codecContext->bit_rate = 400000;
codecContext->width = 640;
codecContext->height = 480;
codecContext->time_base = (AVRational){1, 25};
codecContext->framerate = (AVRational){25, 1};
codecContext::pix_fmt = AV_PIX_FMT_YUV420P;

avcodec_open2(codecContext, codec, NULL);

// 解码每一帧
AVFrame* frame = av_frame_alloc();
frame->format = codecContext->pix_fmt;
frame->width = codecContext->width;
frame->height = codecContext->height;

// 接收pkt并解码
avcodec_send_packet(codecContext, &pkt);
avcodec_receive_frame(codecContext, frame);

// ... 处理解码后的frame数据 ...

av_frame_free(&frame);
avcodec_close(codecContext);
avcodec_free_context(&codecContext);

cv::Mat image(frame->height, frame->width, CV_8UC3);
sws_scale(sws_ctx, (uint8_t const * const *)frame->data, frame->linesize, 0, codecContext->height, image.data, image.step);
cv::imshow("Video", image);
cv::waitKey(30);