RTMP转webrtc直播技术开源了

?

rtmp协议作为直播姐的一大利器，周边生态很成熟，比如OBS这些直播工具，可以很好的满足 络推各种流，但是 页播放，传统一般是采用的swf播放插件，现在webrtc越来越流行，浏览器天然支持让音视频应用变得更加简洁高效，而且实时性也得到了不晓得提升。

万能的开源给了我无穷的力量，没有什么是ctrl c v解决不了的，于是稍做整合就出来了一套效果不错的直播推流软件，开源软件是用来学习技术的，(温馨提示:请勿用于非法用途），show your my code,音频处理

func (h *Handler) OnAudio(timestamp uint32, payload io.Reader) error {	// Convert AAC to opus	var audio flvtag.AudioData	if err := flvtag.DecodeAudioData(payload, &audio); err != nil {		return err	}	data := new(bytes.Buffer)	if _, err := io.Copy(data, audio.Data); err != nil {		return err	}	if data.Len() <= 0 {		log.Println("no audio datas", timestamp, payload)		return fmt.Errorf("no audio datas")	}	// log.Println("rntimestamp->", timestamp, "rnpayload->", payload, "rnaudio data->", data.Bytes())	datas := data.Bytes()	// log.Println("rnaudio data len:", len(datas), "->") // hex.EncodeToString(datas))	if audio.AACPacketType == flvtag.AACPacketTypeSequenceHeader {		log.Println("Created new codec ", hex.EncodeToString(datas))		err := h.initAudio(h.audioClockRate)		if err != nil {			log.Println(err, "error initializing Audio")			return fmt.Errorf("can't initialize codec with %s", err.Error())		}		err = h.audioDecoder.InitRaw(datas)		if err != nil {			log.Println(err, "error initializing stream")			return fmt.Errorf("can't initialize codec with %s", hex.EncodeToString(datas))		}		return nil	}	pcm, err := h.audioDecoder.Decode(datas)	if err != nil {		log.Println("decode error: ", hex.EncodeToString(datas), err)		return fmt.Errorf("decode error")	}	// log.Println("rnpcm len ", len(pcm), " ->") //, pcm)	blockSize := 960	for h.audioBuffer = append(h.audioBuffer, pcm...); len(h.audioBuffer) >= blockSize*4; h.audioBuffer = h.audioBuffer[blockSize*4:] {		pcm16 := make([]int16, blockSize*2)		pcm16len := len(pcm16)		for i := 0; i < pcm16len; i++ {			pcm16[i] = int16(binary.LittleEndian.Uint16(h.audioBuffer[i*2:]))		}		bufferSize := 1024		opusData := make([]byte, bufferSize)		n, err := h.audioEncoder.Encode(pcm16, opusData)		// n, err := h.audioEncoder.ReadEncode(pcm16, opusData)		if err != nil {			return err		}		opusOutput := opusData[:n]		// log.Println(" pcm len:", pcm16len, " data->", " opusData len", n, " data->")		if audioErr := h.audioTrack.WriteSample(media.Sample{			Data:     opusOutput,			Duration: 20 * time.Millisecond,		}); audioErr != nil {			log.Println("WriteSample err", audioErr)		}	}	return nil}

以上代码，就是简单的实现了AAC转opus的关键一环，将无声的世界变得更美妙的，

?取之于开源用之于开源，开源 站地址请私信或留言点个赞！本项目基于技术实践，学习目的，大家严格遵守法律法规，不要将项目用于非法用途。

我也在开发功能更强大得下一版本，增加设备管理，多链路对多peers,强大的订阅发布功能，房间管理，IM等，兴趣是最好的老师，只要有梦想，一定会实现，程序员永远不老！

以下部分功能

obs推流测试

Obs推流工具真心好用

推流至视频会议，多房间多参与者

多路推流至视频会议

优化后的效果还不错

得力于webrtc的实时性，延迟在260ms左右，不过有大佬直接推流rtmp到100多毫秒不知怎么做到的