概要

    工控机连接一台工业相机，采集图像，可以确保图像的实时性，但是缺少远程可以实时预览图像的功能。需提供RTSP实时推流服务，工控机有了RTSP推流服务，添加操作工业相机的API，如修改白平衡，曝光时间，增益，可以实现一个虚拟摄像头。

整体架构流程

输入：工业相机视频图像
处理组件：处理工业相机的视频图像，如图像增强，添加水印，并进行H264编码
输出：RTSP推出输出编码数据。

![在这里插入图片描述](https://i-blog.csdnimg.cn/direct/9149491271674213aaf658cd4a332349.png

工业相机输出的图像格式：YUV420P，YUV422P，RGB888，BayRG8。
推荐使用BayRG8，占用的带宽小：wh8*fps。

处理程序：

图像处理线程：如图像增强。
编码:使用ffmpeg的API，对处理后的图像进行H264编码。
推流服务：基于Live555实现的简易的RTSP推流服务，输入为编码后的AVpacket的数据（H264格式）。
推流服务的接口如下：

/**
 * @brief LiveServer 类用于实现一个实时流媒体服务器。
 *        它允许客户端通过网络连接并接收视频/音频数据流。
 *        支持数据推送和会话管理。
 */
class LIVESERVER_EXPORT LiveServer{
public:
    /**
     * @brief 默认构造函数。
     *        初始化 LiveServer 实例，但不启动服务器。
     */
    explicit LiveServer();

    /**
     * @brief 静态初始化方法。
     *        用于在服务器启动前进行一些全局或共享资源的初始化工作，
     *        例如设置内部缓冲区大小等。通常只调用一次。
     * @param buffsize 内部缓冲区的大小，单位通常是字节。
     */
    static void init(int buffsize);

    /**
     * @brief 析构函数。
     *        在 LiveServer 实例销毁时，执行清理工作，例如停止服务器、
     *        释放内部资源等。
     */
    ~LiveServer();

    /**
     * @brief 启动实时流媒体服务器。
     *        服务器将开始监听指定的端口，等待客户端连接。
     *        如果服务器已经在运行，此方法可能无效果或返回错误。
     * @param port 服务器监听的端口号，默认为 8554 (RTSP 默认端口)。
     */
    void startServer(int port = 8554);

    /**
     * @brief 停止实时流媒体服务器。
     *        服务器将停止监听端口，断开所有现有客户端连接，并释放相关资源。
     *        如果服务器未运行，此方法可能无效果。
     */
    void stopServer();

    /**
     * @brief 向指定通道推送 RTP 数据。
     *        此方法用于将编码后的视频/音频数据推送给订阅该通道的客户端。
     *        数据应为 RTP 格式的负载（payload）。
     * @param data 指向 RTP 数据缓冲区的指针。
     * @param len RTP 数据的长度（字节）。
     * @param codeid 编码器ID或媒体类型ID（例如，H.264 ：0，G.711 为另一个ID），
     *               用于标识数据的编码格式。
     * @param channel 要推送数据的目标通道ID。客户端通过订阅该通道来接收数据。
     */
    void pushRtpData(char *data, int len, int codeid, int channel);

    /**
     * @brief 停止指定通道的数据推送。
     *        此方法将停止向特定通道的所有客户端发送数据。
     * @param chan 要停止的通道ID。
     */
    void stopChannel(int chan);

    /**
     * @brief 添加一个新的流媒体会话。
     *        定义一个可供客户端访问的流，并将其绑定到特定的通道。
     *        客户端将通过 streamName 来请求该流。
     * @param streamName 流的名称，例如 "live/stream1"。客户端将使用此名称访问流。
     * @param chan 与此流会话关联的内部通道ID。
     */
    void addSession(const char *streamName, int chan);

private:
    // Pimpl (Pointer to Implementation) 惯用法，用于隐藏内部实现细节。
    // 实际的成员变量和私有逻辑都封装在 LiveServerPriv 类中。
    LiveServerPriv *m_priv;
};