v=0
o=34020000002000000001 0 0 IN IP4 192.168.1.10
s=Play
c=IN IP4 192.168.1.10
t=0 0
m=video 40052 RTP/AVP 96
a=recvonly
a=rtpmap:96 PS/90000
y=0358902090
f=

// Инкапсулировать список NALU H.264 в формат MPEG-PS
void MakeMPEGPS(unsigned char* h264Data, int h264Length,
    unsigned char* psData)
{
    int totalPES = (h264Length + MAX_PES_LENGTH - 1) / MAX_PES_LENGTH; // Подсчитать общее количество PES-пакетов
    int remainingBytes = h264Length; // Количество байт, оставшихся для обработки

    // заголовок MPEG-PS
    unsigned char mpegPSHeader[] = {0x00, 0x00, 0x01, 0xBA};

    // Разделение и инкапсуляция данных H.264
    for (int i = 0; i < totalPES; i++)
    {
        unsigned char* pbuf = psData;

        int pesLength = (remainingBytes > MAX_PES_LENGTH) ? MAX_PES_LENGTH : remainingBytes; // Длина текущего пакета PES
        remainingBytes -= pesLength; // 更新Количество байт, оставшихся для обработки

        // PES Баотоу
        unsigned char pesHeader[] = {0x00, 0x00, 0x01, 0xE0, 0x00, 0x00, 0x80, 0x00};

        // Установить длину пакета PES
        pesHeader[4] = (pesLength + 8) >> 8; // Старшие 8 бит
        pesHeader[5] = (pesLength + 8) & 0xFF; // Младшие 8 бит

        // выходзаголовок MPEG-PS и текущий PES Баотоу
        memcpy(pbuf, mpegPSHeader, sizeof(mpegPSHeader));
        pbuf += sizeof(mpegPSHeader);

        memcpy(pbuf, pesHeader, sizeof(pesHeader));
        pbuf += sizeof(pesHeader);

        // Вывод данных H.264 текущего пакета PES.
        memcpy(pbuf, h264Data + (i * MAX_PES_LENGTH), pesLength);
        pbuf += pesLength;

        int payload_len = (pbuf - psData);

        // Инкапсулировать пакет RTP и отправить
        MakeAndSendRTP(psData, payload_len);
    }
}

struct RTPHeader
{
    uint8_t version; // Номер версии протокола RTP, фиксированный — 2.
    uint8_t padding: 1; // биты заполнения
    uint8_t extension: 1; // бит расширения
    uint8_t csrcCount: 4; // Счетчик CSRC, указывающий количество идентификаторов CSRC.
    uint8_t marker: 1; // Отметить бит
    uint8_t payloadType: 7; // Тип нагрузки
    uint16_t sequenceNumber; // серийный номер
    uint32_t timestamp; // Временная метка
    uint32_t ssrc; // Идентификатор источника синхронизации
};

void MakeRTPHeader(struct RTPHeader* header, uint16_t sequenceNumber, uint32_t timestamp, uint32_t ssrc, bool isMark)
{
    // Установите номер версии протокола RTP на 2.
    header->version = 2;
    // биты заполнения、бит расширение, счетчик CSRC и другие поля могут быть установлены в соответствии с конкретными потребностями.
    header->padding = 0;
    header->extension = 0;
    header->csrcCount = 0;
    // настраивать Отметить бит равен 0 (при необходимости установите его в 1),Затем измените его там, где вам нужно его установить)
    header->marker = isMark ? 1 : 0;
    // Настройки нагрузки（payload тип), устанавливается в соответствии с конкретными потребностями
    header->payloadType = 96;
    // настраиватьсерийный номери Временная метка
    header->sequenceNumber = htons(sequenceNumber); // Требуется преобразование Endian (сетевой порядок байтов)
    header->timestamp = htonl(timestamp); // Требуется преобразование Endian (сетевой порядок байтов)

    // настраивать Идентификатор источника синхронизации
    header->ssrc = htonl(ssrc); // Требуется преобразование Endian (сетевой порядок байтов)
}

void sendRTPPacket(const uint8_t* mpegPSData, int mpegPSLength, uint16_t sequenceNumber, uint32_t timestamp, uint32_t ssrc)
{
    int offset = 0; // Смещение, используемое для прохождения пакетных данных MPEG-PS.
    int remainingLength = mpegPSLength; // Оставшаяся длина используется для определения необходимости разделения сообщения RTP.
    uint8_t rtpbuf[RTP_PAYLOAD_MAX_SIZE]; // Буфер данных полезной нагрузки RTP
    struct RTPHeader rtpHeader; // Заголовок сообщения RTP

    while (remainingLength > 0)
    {
        // Вычислить текущую длину полезных данных RTP (не превышающую максимальный размер полезных данных RTP)
        bool is_mark = false;
        int data_len = RTP_PAYLOAD_MAX_SIZE;
        if (remainingLength <= RTP_PAYLOAD_MAX_SIZE)
        {
            data_len = remainingLength;
            is_mark = true;
        }

        // заполнять Заголовок сообщения RTP
        MakeRTPHeader(&rtpHeader, sequenceNumber, timestamp, ssrc);

        // копировать заголовок RTP в буфер полезной нагрузки RTP
        memcpy(rtpbuf, &rtpHeader, sizeof(RTPHeader));

        // копировать данные MPEG-PS в буфер полезной нагрузки RTP
        memcpy(rtpbuf + RTP_HEADER_LEN, mpegPSData + offset, data_len);

        // Отправьте полный пакет RTP
        if (udp_channel_)
        {
            udp_channel_->PostSendBuf(rtpbuf, RTP_HEADER_LEN + data_len);
        }

        // Обновление смещения, оставшаяся длина、серийный номер и другая информация
        offset += data_len;
        remainingLength -= data_len;
        sequenceNumber++;
    }
}