RTSP 통신문서

cctv와 video, audio등 rtsp을 통해서 양방향 사용되는 프로토콜입니다.
rtsp://admin:xxxx@ip:port/채널이름 형식으로 사용됩니다.

func (w *worker) webrtcVoiceToToCCTVVoice(audioReceiveData *rtp.Packet, timestamp *uint32, seq *uint16) {
	p := rtp.Packet{
		Payload: audioReceiveData.Payload,
		Header: rtp.Header{
			PayloadType:    0,
			Marker:         true,
			Timestamp:      *timestamp,
			SequenceNumber: *seq,
			SSRC:           audioReceiveData.SSRC,
			CSRC:           audioReceiveData.CSRC,
			Version:        audioReceiveData.Version,
		},
	}
 
	*timestamp += uint32(len(audioReceiveData.Payload))
	*seq++
	encodePacket, _ := p.Marshal()
	frame := w.createInterleavedFrame(encodePacket)
	if _, err := w.rtspClient.SendPacket(frame); err != nil {
		log.Errorf("RTSPClient.SendPacket Error", err)
		w.errorChan <- fmt.Sprintf("rtspClient SendPacket %s", err.Error())
		return
	}
}

H.264 비디오 데이터는 NAL (Network Abstraction Layer) 유닛으로 분리되어 전송됩니다. 0x00 0x00 0x00 0x01은 NAL 유닛의 시작을 나타내는 마커입니다.

// cctv 비디오 -> webrtc
func (w *worker) cctvVideoToWebRTCVideo(cctvVideoReceiveData *AvPacket) {
	var packetData []byte
	if cctvVideoReceiveData.packet.IsKeyFrame {
		packetData = append([]byte{0, 0, 0, 1}, bytes.Join([][]byte{cctvVideoReceiveData.codec.SPS(), cctvVideoReceiveData.codec.PPS(), cctvVideoReceiveData.packet.Data[4:]}, []byte{0, 0, 0, 1})...)
	} else {
		packetData = append([]byte{0, 0, 0, 1}, cctvVideoReceiveData.packet.Data[4:]...)
	}
	if w.videoTrack != nil {
 
		if err := w.videoTrack.WriteSample(media.Sample{Data: packetData, Duration: cctvVideoReceiveData.packet.Duration}); err != nil {
			w.errorChan <- fmt.Sprintf("videoTrack WriteSample %s", err.Error())
			log.Errorf("Failed to write sample to video track: %v", err)
		}
	}
}

// rtsp interleaveframe packet 생성 4byte
func (w *worker) createInterleavedFrame(rtpPacket []byte) []byte {
	var buffer bytes.Buffer
 
	channel := byte(4) // RTP 데이터 채널
	header := []byte{0x24, channel} // 0x24 RTSP interleaved 프레임의 시작
 
	lengthBuffer := new(bytes.Buffer)
	length := uint16(len(rtpPacket))
	_ = binary.Write(lengthBuffer, binary.BigEndian, length)
 
	buffer.Write(header)
	buffer.Write(lengthBuffer.Bytes())
	buffer.Write(rtpPacket)
	return buffer.Bytes()
}

SETUP: 스트리밍 세션을 설정하고 미디어 스트림의 전송 방법을 지정합니다.
PLAY: 미디어 스트리밍을 시작합니다.
PAUSE: 미디어 스트리밍을 일시 정지합니다.
TEARDOWN: 스트리밍 세션을 종료합니다.
DESCRIBE: 미디어의 메타데이터를 요청합니다.
OPTIONS: 서버에서 지원하는 명령어와 옵션을 요청합니다.
ANNOUNCE: 서버에 미디어 스트림을 알립니다 (일반적으로 SIP와 함께 사용됨).

"Require": "www.onvif.org/ver20/backchannel",