Android 使用Rtmp音视频推流

前言

本文介绍的是使用Android摄像头、麦克风采集的音、视频进行编码。然后通过librtmp推送到流媒体服务器上的功能。
我所使用的环境：Android Studio 2.2.3 、NDK13。

流程

这里写图片描述

使用到的Api

  • 音视频采集用到的api有：Camera、AudioRecord
  • 编码用的是系统提供的API:MediaCodec (硬编码)
  • 推送使用的开源库:librtmp。

代码

ManActivity.java

public class MainActivity extends AppCompatActivity implements SurfaceHolder.Callback2 {static final int NAL_SLICE = 1;static final int NAL_SLICE_DPA = 2;static final int NAL_SLICE_DPB = 3;static final int NAL_SLICE_DPC = 4;static final int NAL_SLICE_IDR = 5;static final int NAL_SEI = 6;static final int NAL_SPS = 7;static final int NAL_PPS = 8;static final int NAL_AUD = 9;static final int NAL_FILLER = 12;private static final String TAG = "MainActivity";public static final String url = "rtmp://192.168.155.1:1935/live/test";private Button btnToggle;private SurfaceView mSurfaceView;private SurfaceHolder mSurfaceHolder;private Camera mCamera;private Camera.Size previewSize;private long presentationTimeUs;MediaCodec vencoder;private Thread recordThread;private boolean aLoop;private AudioRecord mAudioRecord;private byte[] aBuffer;private MediaCodec aencoder;private int aSampleRate;private int aChanelCount;private int colorFormat;private MediaCodec.BufferInfo aBufferInfo = new MediaCodec.BufferInfo();private MediaCodec.BufferInfo vBufferInfo = new MediaCodec.BufferInfo();private boolean isPublished;private RtmpPublisher mRtmpPublisher = new RtmpPublisher();@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);initView();}private void initView() {btnToggle = (Button) findViewById(R.id.btn_toggle);mSurfaceView = (SurfaceView) findViewById(R.id.surface_view);mSurfaceHolder = mSurfaceView.getHolder();mSurfaceHolder.addCallback(this);btnToggle.setOnClickListener(new View.OnClickListener() {@Overridepublic void onClick(View v) {switchPublish();}});}private void switchPublish() {if (isPublished) {stop();} else {start();}btnToggle.setText(isPublished ? "停止" : "开始");}private void start() {//初始化mRtmpPublisher.init(url, previewSize.width, previewSize.height, 5);isPublished = true;initAudioDevice();try {vencoder = initVideoEncoder();} catch (IOException e) {e.printStackTrace();throw new RuntimeException("video encoder init fail");}try {aencoder = initAudioEncoder();} catch (IOException e) {e.printStackTrace();throw new RuntimeException("audio encoder init fail");}//开启录音aLoop = true;recordThread = new Thread(fetchAudioRunnable());presentationTimeUs = new Date().getTime() * 1000;mAudioRecord.startRecording();recordThread.start();if (aencoder != null) {aencoder.start();}if (vencoder != null) {vencoder.start();}}private void stop() {isPublished = false;mRtmpPublisher.stop();aLoop = false;if (recordThread != null) {recordThread.interrupt();}mAudioRecord.stop();mAudioRecord.release();vencoder.stop();vencoder.release();aencoder.stop();aencoder.release();}private Runnable fetchAudioRunnable() {return new Runnable() {@Overridepublic void run() {fetchPcmFromDevice();}};}private void fetchPcmFromDevice() {Log.d(TAG, "录音线程开始");while (aLoop && mAudioRecord != null && !Thread.interrupted()) {int size = mAudioRecord.read(aBuffer, 0, aBuffer.length);if (size < 0) {Log.i(TAG, "audio ignore ,no data to read");break;}if (aLoop) {byte[] audio = new byte[size];System.arraycopy(aBuffer, 0, audio, 0, size);onGetPcmFrame(audio);}}}private void initAudioDevice() {int[] sampleRates = {44100, 22050, 16000, 11025};for (int sampleRate :sampleRates) {//编码制式int audioFormat = AudioFormat.ENCODING_PCM_16BIT;// stereo 立体声，int channelConfig = AudioFormat.CHANNEL_CONFIGURATION_STEREO;int buffsize = 2 * AudioRecord.getMinBufferSize(sampleRate, channelConfig, audioFormat);mAudioRecord = new AudioRecord(MediaRecorder.AudioSource.MIC, sampleRate, channelConfig,audioFormat, buffsize);if (mAudioRecord.getState() != AudioRecord.STATE_INITIALIZED) {continue;}aSampleRate = sampleRate;aChanelCount = channelConfig == AudioFormat.CHANNEL_CONFIGURATION_STEREO ? 2 : 1;aBuffer = new byte[Math.min(4096, buffsize)];}}private MediaCodec initAudioEncoder() throws IOException {MediaCodec aencoder = MediaCodec.createEncoderByType(MediaFormat.MIMETYPE_AUDIO_AAC);MediaFormat format = MediaFormat.createAudioFormat(MediaFormat.MIMETYPE_AUDIO_AAC,aSampleRate, aChanelCount);format.setInteger(KEY_MAX_INPUT_SIZE, 0);format.setInteger(KEY_BIT_RATE, 1000 * 30);aencoder.configure(format, null, null, MediaCodec.CONFIGURE_FLAG_ENCODE);return aencoder;}private MediaCodec initVideoEncoder() throws IOException {// 初始化MediaCodecInfo mediaCodecInfo = getMediaCodecInfoByType(MediaFormat.MIMETYPE_VIDEO_AVC);colorFormat = getColorFormat(mediaCodecInfo);MediaCodec vencoder = MediaCodec.createByCodecName(mediaCodecInfo.getName());MediaFormat format = MediaFormat.createVideoFormat(MediaFormat.MIMETYPE_VIDEO_AVC,previewSize.width, previewSize.height);format.setInteger(KEY_MAX_INPUT_SIZE, 0);format.setInteger(KEY_BIT_RATE, 700 * 1000);format.setInteger(KEY_COLOR_FORMAT, colorFormat);format.setInteger(KEY_FRAME_RATE, 20);format.setInteger(KEY_I_FRAME_INTERVAL, 5);vencoder.configure(format, null, null, CONFIGURE_FLAG_ENCODE);return vencoder;}public static MediaCodecInfo getMediaCodecInfoByType(String mimeType) {for (int i = 0; i < MediaCodecList.getCodecCount(); i++) {MediaCodecInfo codecInfo = MediaCodecList.getCodecInfoAt(i);if (!codecInfo.isEncoder()) {continue;}String[] types = codecInfo.getSupportedTypes();for (int j = 0; j < types.length; j++) {if (types[j].equalsIgnoreCase(mimeType)) {return codecInfo;}}}return null;}public static int getColorFormat(MediaCodecInfo mediaCodecInfo) {int matchedForamt = 0;MediaCodecInfo.CodecCapabilities codecCapabilities =mediaCodecInfo.getCapabilitiesForType(MediaFormat.MIMETYPE_VIDEO_AVC);for (int i = 0; i < codecCapabilities.colorFormats.length; i++) {int format = codecCapabilities.colorFormats[i];if (format >= codecCapabilities.COLOR_FormatYUV420Planar &&format <= codecCapabilities.COLOR_FormatYUV420PackedSemiPlanar) {if (format >= matchedForamt) {matchedForamt = format;}}}return matchedForamt;}private void initCamera() {openCamera();setCameraParameters();setCameraDisplayOrientation(this, Camera.CameraInfo.CAMERA_FACING_BACK, mCamera);try {mCamera.setPreviewDisplay(mSurfaceHolder);} catch (IOException e) {e.printStackTrace();}mCamera.setPreviewCallbackWithBuffer(getPreviewCallback());mCamera.addCallbackBuffer(new byte[calculateFrameSize(ImageFormat.NV21)]);mCamera.startPreview();}private int calculateFrameSize(int format) {return previewSize.width * previewSize.height * ImageFormat.getBitsPerPixel(format) / 8;}public static void setCameraDisplayOrientation(Activity activity,int cameraId, android.hardware.Camera camera) {android.hardware.Camera.CameraInfo info =new android.hardware.Camera.CameraInfo();android.hardware.Camera.getCameraInfo(cameraId, info);int rotation = activity.getWindowManager().getDefaultDisplay().getRotation();int degrees = 0;switch (rotation) {case Surface.ROTATION_0:degrees = 0;break;case Surface.ROTATION_90:degrees = 90;break;case Surface.ROTATION_180:degrees = 180;break;case Surface.ROTATION_270:degrees = 270;break;}int result;if (info.facing == Camera.CameraInfo.CAMERA_FACING_FRONT) {result = (info.orientation + degrees) % 360;result = (360 - result) % 360;  // compensate the mirror} else {  // back-facingresult = (info.orientation - degrees + 360) % 360;}camera.setDisplayOrientation(result);}private void setCameraParameters() {Camera.Parameters parameters = mCamera.getParameters();List<Camera.Size> supportedPreviewSizes = parameters.getSupportedPreviewSizes();for (Camera.Size size : supportedPreviewSizes) {if (size.width >= 320 && size.width <= 720) {previewSize = size;Log.d(TAG, String.format("find preview size width=%d,height=%d", previewSize.width,previewSize.height));break;}}int[] destRange = {25 * 1000, 45 * 1000};List<int[]> supportedPreviewFpsRange = parameters.getSupportedPreviewFpsRange();for (int[] range : supportedPreviewFpsRange) {if (range[PREVIEW_FPS_MIN_INDEX] <= 45 * 1000 && range[PREVIEW_FPS_MAX_INDEX] >= 25 * 1000) {destRange = range;Log.d(TAG, String.format("find fps range :%s", Arrays.toString(destRange)));break;}}parameters.setPreviewSize(previewSize.width, previewSize.height);parameters.setPreviewFpsRange(destRange[PREVIEW_FPS_MIN_INDEX],destRange[PREVIEW_FPS_MAX_INDEX]);parameters.setFocusMode(FOCUS_MODE_AUTO);parameters.setPreviewFormat(ImageFormat.NV21);parameters.setRotation(onOrientationChanged(0));mCamera.setParameters(parameters);}public int onOrientationChanged(int orientation) {android.hardware.Camera.CameraInfo info =new android.hardware.Camera.CameraInfo();android.hardware.Camera.getCameraInfo(Camera.CameraInfo.CAMERA_FACING_BACK, info);orientation = (orientation + 45) / 90 * 90;int rotation = 0;if (info.facing == Camera.CameraInfo.CAMERA_FACING_FRONT) {rotation = (info.orientation - orientation + 360) % 360;} else {  // back-facing camerarotation = (info.orientation + orientation) % 360;}return rotation;}private void openCamera() {if (mCamera == null) {try {mCamera = Camera.open();} catch (Exception e) {e.printStackTrace();Toast.makeText(this, "打开摄像头失败", Toast.LENGTH_SHORT).show();try {Thread.sleep(3000);} catch (InterruptedException e1) {e1.printStackTrace();}throw new RuntimeException("打开摄像头失败", e);}}}@Overrideprotected void onResume() {super.onResume();initCamera();}@Overrideprotected void onPause() {super.onPause();if (mCamera != null) {mCamera.setPreviewCallbackWithBuffer(null);mCamera.stopPreview();mCamera.release();mCamera = null;}}@Overridepublic void surfaceRedrawNeeded(SurfaceHolder holder) {}@Overridepublic void surfaceCreated(SurfaceHolder holder) {}@Overridepublic void surfaceChanged(SurfaceHolder holder, int format, int width, int height) {initCamera();}@Overridepublic void surfaceDestroyed(SurfaceHolder holder) {}public Camera.PreviewCallback getPreviewCallback() {return new Camera.PreviewCallback() {byte[] dstByte = new byte[calculateFrameSize(ImageFormat.NV21)];@Overridepublic void onPreviewFrame(byte[] data, Camera camera) {if (data != null) {if (isPublished) {// data 是Nv21if (colorFormat == MediaCodecInfo.CodecCapabilities.COLOR_FormatYUV420SemiPlanar) {Yuv420Util.Nv21ToYuv420SP(data, dstByte, previewSize.width, previewSize.height);} else if (colorFormat == MediaCodecInfo.CodecCapabilities.COLOR_FormatYUV420Planar) {Yuv420Util.Nv21ToI420(data, dstByte, previewSize.width, previewSize.height);} else if (colorFormat == MediaCodecInfo.CodecCapabilities.COLOR_FormatYUV420Flexible) {// Yuv420_888} else if (colorFormat == MediaCodecInfo.CodecCapabilities.COLOR_FormatYUV420PackedPlanar) {// Yuv420packedPlannar 和 yuv420sp很像// 区别在于 加入 width = 4的话 y1,y2,y3 ,y4公用 u1v1// 而 yuv420dp 则是 y1y2y5y6 共用 u1v1//http://blog.csdn.net/jumper511/article/details/21719313//这样处理的话颜色核能会有些失真。Yuv420Util.Nv21ToYuv420SP(data, dstByte, previewSize.width, previewSize.height);} else {System.arraycopy(data, 0, dstByte, 0, data.length);}onGetVideoFrame(dstByte);}camera.addCallbackBuffer(data);} else {camera.addCallbackBuffer(new byte[calculateFrameSize(ImageFormat.NV21)]);}}};}private void onGetVideoFrame(byte[] dstByte) {ByteBuffer[] inputBuffers = vencoder.getInputBuffers();ByteBuffer[] outputBuffers = vencoder.getOutputBuffers();int inputBufferId = vencoder.dequeueInputBuffer(-1);if (inputBufferId >= 0) {// fill inputBuffers[inputBufferId] with valid dataByteBuffer bb = inputBuffers[inputBufferId];bb.clear();bb.put(dstByte, 0, dstByte.length);long pts = new Date().getTime() * 1000 - presentationTimeUs;vencoder.queueInputBuffer(inputBufferId, 0, dstByte.length, pts, 0);}for (; ; ) {int outputBufferId = vencoder.dequeueOutputBuffer(vBufferInfo, 0);if (outputBufferId >= 0) {// outputBuffers[outputBufferId] is ready to be processed or rendered.ByteBuffer bb = outputBuffers[outputBufferId];onEncodedAvcFrame(bb, vBufferInfo);vencoder.releaseOutputBuffer(outputBufferId, false);}if (outputBufferId < 0) {break;}}}private void onGetPcmFrame(byte[] data) {ByteBuffer[] inputBuffers = aencoder.getInputBuffers();ByteBuffer[] outputBuffers = aencoder.getOutputBuffers();int inputBufferId = aencoder.dequeueInputBuffer(-1);if (inputBufferId >= 0) {ByteBuffer bb = inputBuffers[inputBufferId];bb.clear();bb.put(data, 0, data.length);long pts = new Date().getTime() * 1000 - presentationTimeUs;aencoder.queueInputBuffer(inputBufferId, 0, data.length, pts, 0);}for (; ; ) {int outputBufferId = aencoder.dequeueOutputBuffer(aBufferInfo, 0);if (outputBufferId >= 0) {// outputBuffers[outputBufferId] is ready to be processed or rendered.ByteBuffer bb = outputBuffers[outputBufferId];onEncodeAacFrame(bb, aBufferInfo);aencoder.releaseOutputBuffer(outputBufferId, false);}if (outputBufferId < 0) {break;}}}private void onEncodedAvcFrame(ByteBuffer bb, MediaCodec.BufferInfo vBufferInfo) {int offset = 4;//判断帧的类型if (bb.get(2) == 0x01) {offset = 3;}int type = bb.get(offset) & 0x1f;if (type == NAL_SPS) {//[0, 0, 0, 1, 103, 66, -64, 13, -38, 5, -126, 90, 1, -31, 16, -115, 64, 0, 0, 0, 1, 104, -50, 6, -30]//打印发现这里将 SPS帧和 PPS帧合在了一起发送// SPS为 [4，len-8]// PPS为后4个字节//so .byte[] pps = new byte[4];byte[] sps = new byte[vBufferInfo.size - 12];bb.getInt();// 抛弃 0,0,0,1bb.get(sps, 0, sps.length);bb.getInt();bb.get(pps, 0, pps.length);Log.d(TAG, "解析得到 sps:" + Arrays.toString(sps) + ",PPS=" + Arrays.toString(pps));mRtmpPublisher.sendSpsAndPps(sps, sps.length, pps, pps.length,vBufferInfo.presentationTimeUs / 1000);} else {byte[] bytes = new byte[vBufferInfo.size];bb.get(bytes);mRtmpPublisher.sendVideoData(bytes, bytes.length,vBufferInfo.presentationTimeUs / 1000);}}private void onEncodeAacFrame(ByteBuffer bb, MediaCodec.BufferInfo aBufferInfo) {// 1.界定符 FF F1// 2.加上界定符的前7个字节是帧描述信息// 3.AudioDecoderSpecificInfo 长度为2个字节如果是44100 改值为0x1210//http://blog.csdn.net/avsuper/article/details/24661533//http://www.tuicool.com/articles/aYvmuaif (aBufferInfo.size == 2) {
//            https://my.oschina.net/zhangxu0512/blog/204070
//            faacEncSetConfiguration(m_hEncoder, pConfiguration);
//            int ret = faacEncGetDecoderSpecificInfo(m_hEncoder, &m_pSpc, &m_nSpc);//            //AAC sequence header
//            int[] mpeg4audio_sample_rates = {
//                    96000, 88200, 64000, 48000, 44100, 32000,
//                    24000, 22050, 16000, 12000, 11025, 8000, 7350
//            };
//
//            int m_keyframe[] = new int[2];
//            //get keyframe info.
//            int index;
//            for (index = 0; index < 16; index++) {
//                if (aSampleRate == mpeg4audio_sample_rates[index]) {
//                    break;
//                }
//            }
//            m_keyframe[0] = 0x02 << 3 | index >> 1;
//            m_keyframe[1] = (index & 0x01) << 7 | aChanelCount << 3;
//
//            Log.d(TAG,"挂件"+Arrays.toString(m_keyframe));// 我打印发现，这里应该已经是吧关键帧计算好了，所以我们直接发送byte[] bytes = new byte[2];bb.get(bytes);mRtmpPublisher.sendAacSpec(bytes,2);}else{byte[] bytes = new byte[aBufferInfo.size];bb.get(bytes);mRtmpPublisher.sendAacData(bytes,bytes.length,aBufferInfo.presentationTimeUs/1000);}}}

MainActivity 中的代码主要是采集视频、音频进行编码。然后调用jni方法进行发送。
在c层。我封装了一个类用来发送音视频数据：

class Rtmp {private:int width;int height;int timeOut;std::string url;long startTime;RTMP *rtmp;public:/*** 初始化*/virtual int init(std::string url, int w, int h, int timeOut);/*** 发送sps、pps 帧*/virtual int sendSpsAndPps(BYTE *sps, int spsLen, BYTE *pps, int ppsLen,long timestamp);/*** 发送视频帧*/virtual int sendVideoData(BYTE *data, int len, long timestamp);/*** 发送音频关键帧*/virtual int sendAacSpec(BYTE *data, int len);/*** 发送音频数据*/virtual int sendAacData(BYTE *data, int len,long timestamp);/*** 释放资源*/virtual int stop() const;virtual ~Rtmp();
};

实现：

//
// Created by Administrator on 1/16/2017.
//#include "Rtmp.h"#include "jni.h"
#include "lang.h"#define RTMP_HEAD_SIZE (sizeof(RTMPPacket)+RTMP_MAX_HEADER_SIZE)
#define NAL_SLICE  1
#define NAL_SLICE_DPA  2
#define NAL_SLICE_DPB  3
#define NAL_SLICE_DPC  4
#define NAL_SLICE_IDR  5
#define NAL_SEI  6
#define NAL_SPS  7
#define NAL_PPS  8
#define NAL_AUD  9
#define NAL_FILLER  12#define STREAM_CHANNEL_METADATA  0x03
#define STREAM_CHANNEL_VIDEO     0x04
#define STREAM_CHANNEL_AUDIO     0x05int Rtmp::init(std::string url, int w, int h, int timeOut) {this->url = url;this->width = w;this->height = h;this->timeOut = timeOut;RTMP_LogSetLevel(RTMP_LOGDEBUG);rtmp = RTMP_Alloc();RTMP_Init(rtmp);rtmp->Link.timeout = timeOut;RTMP_SetupURL(rtmp, (char *) url.c_str());RTMP_EnableWrite(rtmp);if (RTMP_Connect(rtmp, NULL) <= 0) {LOGD("RTMP_Connect error");return -1;}if (RTMP_ConnectStream(rtmp, 0) <= 0) {LOGD("RTMP_ConnectStream error");return -1;}return 0;
}int Rtmp::sendSpsAndPps(BYTE *sps, int spsLen, BYTE *pps, int ppsLen, long timestamp) {int i;RTMPPacket *packet = (RTMPPacket *) malloc(RTMP_HEAD_SIZE + 1024);memset(packet, 0, RTMP_HEAD_SIZE);packet->m_body = (char *) packet + RTMP_HEAD_SIZE;BYTE *body = (BYTE *) packet->m_body;i = 0;body[i++] = 0x17; //1:keyframe 7:AVCbody[i++] = 0x00; // AVC sequence headerbody[i++] = 0x00;body[i++] = 0x00;body[i++] = 0x00; //fill in 0/*AVCDecoderConfigurationRecord*/body[i++] = 0x01;body[i++] = sps[1]; //AVCProfileIndecationbody[i++] = sps[2]; //profile_compatibiltybody[i++] = sps[3]; //AVCLevelIndicationbody[i++] = 0xff;//lengthSizeMinusOne/*SPS*/body[i++] = 0xe1;body[i++] = (spsLen >> 8) & 0xff;body[i++] = spsLen & 0xff;/*sps data*/memcpy(&body[i], sps, spsLen);i += spsLen;/*PPS*/body[i++] = 0x01;/*sps data length*/body[i++] = (ppsLen >> 8) & 0xff;body[i++] = ppsLen & 0xff;memcpy(&body[i], pps, ppsLen);i += ppsLen;packet->m_packetType = RTMP_PACKET_TYPE_VIDEO;packet->m_nBodySize = i;packet->m_nChannel = 0x04;packet->m_nTimeStamp = 0;packet->m_hasAbsTimestamp = 0;packet->m_headerType = RTMP_PACKET_SIZE_MEDIUM;packet->m_nInfoField2 = rtmp->m_stream_id;/*发送*/if (RTMP_IsConnected(rtmp)) {RTMP_SendPacket(rtmp, packet, TRUE);}free(packet);return 0;
}int Rtmp::sendVideoData(BYTE *buf, int len, long timestamp) {int type;/*去掉帧界定符*/if (buf[2] == 0x00) {/*00 00 00 01*/buf += 4;len -= 4;} else if (buf[2] == 0x01) {buf += 3;len - 3;}type = buf[0] & 0x1f;RTMPPacket *packet = (RTMPPacket *) malloc(RTMP_HEAD_SIZE + len + 9);memset(packet, 0, RTMP_HEAD_SIZE);packet->m_body = (char *) packet + RTMP_HEAD_SIZE;packet->m_nBodySize = len + 9;/* send video packet*/BYTE *body = (BYTE *) packet->m_body;memset(body, 0, len + 9);/*key frame*/body[0] = 0x27;if (type == NAL_SLICE_IDR) {body[0] = 0x17; //关键帧}body[1] = 0x01;/*nal unit*/body[2] = 0x00;body[3] = 0x00;body[4] = 0x00;body[5] = (len >> 24) & 0xff;body[6] = (len >> 16) & 0xff;body[7] = (len >> 8) & 0xff;body[8] = (len) & 0xff;/*copy data*/memcpy(&body[9], buf, len);packet->m_hasAbsTimestamp = 0;packet->m_packetType = RTMP_PACKET_TYPE_VIDEO;packet->m_nInfoField2 = rtmp->m_stream_id;packet->m_nChannel = 0x04;packet->m_headerType = RTMP_PACKET_SIZE_LARGE;packet->m_nTimeStamp = timestamp;if (RTMP_IsConnected(rtmp)) {RTMP_SendPacket(rtmp, packet, TRUE);}free(packet);return 0;
}int Rtmp::sendAacSpec(BYTE *data, int spec_len) {RTMPPacket *packet;BYTE *body;int len = spec_len;//spec len 是2packet = (RTMPPacket *) malloc(RTMP_HEAD_SIZE + len + 2);memset(packet, 0, RTMP_HEAD_SIZE);packet->m_body = (char *) packet + RTMP_HEAD_SIZE;body = (BYTE *) packet->m_body;/*AF 00 +AAC RAW data*/body[0] = 0xAF;body[1] = 0x00;memcpy(&body[2], data, len);/*data 是AAC sequeuece header数据*/packet->m_packetType = RTMP_PACKET_TYPE_AUDIO;packet->m_nBodySize = len + 2;packet->m_nChannel = STREAM_CHANNEL_AUDIO;packet->m_nTimeStamp = 0;packet->m_hasAbsTimestamp = 0;packet->m_headerType = RTMP_PACKET_SIZE_LARGE;packet->m_nInfoField2 = rtmp->m_stream_id;if (RTMP_IsConnected(rtmp)) {RTMP_SendPacket(rtmp, packet, TRUE);}free(packet);return 0;
}int Rtmp::sendAacData(BYTE *data, int len, long timeOffset) {
//    data += 5;
//    len += 5;if (len > 0) {RTMPPacket *packet;BYTE *body;packet = (RTMPPacket *) malloc(RTMP_HEAD_SIZE + len + 2);memset(packet, 0, RTMP_HEAD_SIZE);packet->m_body = (char *) packet + RTMP_HEAD_SIZE;body = (BYTE *) packet->m_body;/*AF 00 +AAC Raw data*/body[0] = 0xAF;body[1] = 0x01;memcpy(&body[2], data, len);packet->m_packetType = RTMP_PACKET_TYPE_AUDIO;packet->m_nBodySize = len + 2;packet->m_nChannel = STREAM_CHANNEL_AUDIO;packet->m_nTimeStamp = timeOffset;packet->m_hasAbsTimestamp = 0;packet->m_headerType = RTMP_PACKET_SIZE_LARGE;packet->m_nInfoField2 = rtmp->m_stream_id;if (RTMP_IsConnected(rtmp)) {RTMP_SendPacket(rtmp, packet, TRUE);}LOGD("send packet body[0]=%x,body[1]=%x", body[0], body[1]);free(packet);}return 0;
}int Rtmp::stop() const {RTMP_Close(rtmp);RTMP_Free(rtmp);return 0;
}Rtmp::~Rtmp() { stop(); }

观看

我们如果测试的话，我们首先需要搭建一个流媒体服务器。可以在本地安装一个Adobe Media Server 。然后打开它其中的一个示例。比如我安装在D盘Program File 文件夹下
那么我打开D:\Program Files\Adobe\Adobe Media Server 5\samples\videoPlayer\videoplayer.html
输入推流的地址就可以播放了。当然手机和电脑记得处于同一个局域网。
这里写图片描述

完整代码地址 https://github.com/blueberryCoder/LiveStream

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/66390.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【流媒体】推流与拉流简介

【流媒体】推流与拉流简介

本文目录 一、概念 1.1 推流 1.2 拉流 二、示意图 三、RTMP传输协议 四、流媒体协议与格式 一、概念 话不多说&#xff0c;先了解概念&#xff0c;再看示意图更直观&#xff1a; 1.1 推流 推流&#xff1a;将直播的内容推送至服务器的过程。即指的是把采集阶段封包好的…
阅读更多...
【知识拓展】音视频中的推流与拉流

【知识拓展】音视频中的推流与拉流

本文目录 一、什么是推流&#xff1f; 二、什么是拉流&#xff1f; 一、什么是推流&#xff1f; 先来看张图片&#xff0c;看着图再配上文字容易理解&#xff1a; 推流&#xff0c;指的是把采集阶段封包好的内容传输到服务器的过程。其实就是将现场的视频信号传到网络的过程…
阅读更多...
视频点播RTMP推流直播流媒体服务二次开发集成接口

视频点播RTMP推流直播流媒体服务二次开发集成接口

LiveQing流媒体服务器软件&#xff0c;提供一站式的转码、点播、直播、时移回放服务&#xff0c;极大地简化了开发和集成的工作。 其中&#xff0c;点播功能主要包含&#xff1a;上传、转码、分发。直播功能&#xff0c;主要包含&#xff1a;直播、录像&#xff0c; 直播支持R…
阅读更多...
音视频直播推流和拉流到底是什么意思？

音视频直播推流和拉流到底是什么意思？

为什么直播现场的信息&#xff0c;用户通过手机或者网站就能很快的看到呢&#xff1f;为什么有时候网络不稳定&#xff0c;直播效果会有延迟呢&#xff1f;现场的视频信号又是如何传到网络呢&#xff1f; 这些所有问题的产生&#xff0c;都离不开视频直播中常说的两个词&#…
阅读更多...
视频直播推流攻略（整理的各大平台推流界面）

视频直播推流攻略（整理的各大平台推流界面）

如果我要做一场高端大气的直播活动&#xff0c;需要用高清摄像机拍摄画面&#xff0c;需要接入无人机的高空画面&#xff0c;需要在直播中插入多个镜头&#xff0c;甚至需要把电脑桌面共享到直播画面中...... 该如何将这类现场信号采集并整合起来传输到网络呢&#xff1f; 这个…
阅读更多...
音视频流媒体-推流与拉流简介

音视频流媒体-推流与拉流简介

一、概念 话不多说&#xff0c;先了解概念&#xff0c;再看示意图更直观&#xff1a; 1.1 推流 推流&#xff1a;将直播的内容推送至服务器的过程。即指的是把采集阶段封包好的内容传输到服务器的过程。其实就是将现场的视频信号传到网络的过程。“推流”对网络要求比较高&a…
阅读更多...
Feishu(飞书) 聊天机器人应用（3/3）- DevOps 机器人助手，管理 GitLab Issues，BOT 开源示例程序

Feishu(飞书) 聊天机器人应用（3/3）- DevOps 机器人助手，管理 GitLab Issues，BOT 开源示例程序

目录 DevOps 机器人助手命令示例 配置使用创建机器人设置环境变量GITLAB_URLPRIVATE_TOKENVALID_PROJECTS 修改对话使用帮助本系列文章 在上一篇文章&#xff1a;Feishu(飞书) 聊天机器人应用&#xff08;2/2&#xff09;- 定制对话&#xff0c;实现知识库、信息查询、意图识别…
阅读更多...
什么是飞书机器人？如何定时发送飞书机器人消息？

什么是飞书机器人？如何定时发送飞书机器人消息？

什么是飞书机器人&#xff1f; 机器人是飞书应用的一种能力类型。基于飞书的机器人能力&#xff0c;开发者能够以较低的开发成本&#xff08;只需在服务端开发&#xff09;&#xff0c;实现在飞书单聊或群组中的消息推送和简单互动&#xff0c;完成企业系统数据与飞书的互联互通…
阅读更多...
RPA工具实现飞书群聊自动发送信息，我终于也有了自己的机器人

RPA工具实现飞书群聊自动发送信息，我终于也有了自己的机器人

一&#xff0e;RPA究竟是个啥&#xff1f; 首先&#xff0c;他的全称是&#xff1a;Robotic Process Automation&#xff0c;嫌太长&#xff0c;我们三个单词拆开看看&#xff1a; Robotic&#xff1a;软件机器人&#xff0c;不是物理上能走能动的机器人哦&#xff0c;而是一…
阅读更多...
android面试：面向移动应用开发者的 Android 面试经常提问到的15道面试

android面试：面向移动应用开发者的 Android 面试经常提问到的15道面试

Android 软件开发是为运行 Android 操作系统的设备创建应用程序的过程。可以使用 Android 软件开发工具包使用 Kotlin、Java 和 C 语言编写 Android 应用程序。以下是关于 Android 的编码面试问题列表&#xff0c;可帮助您秋招下一次技术面试做好准备。 &#x1f539; 1. 提一…
阅读更多...
字节跳动资深面试官亲述：面试应该注意哪些问题？

字节跳动资深面试官亲述：面试应该注意哪些问题？

01面试做匹配 面试官的根本目的在于考察你这个人是否与招聘岗位相匹配&#xff0c;衡量能否胜任工作&#xff0c;我们在面试中要做到的就是让面试官相信我们能够与应聘岗位相匹配。 针对一些面试题做了总结&#xff1a; 1.请简单进行一下自我介绍 首先请报出自己的姓名和身…
阅读更多...
字节跳动面试官问我看过哪些源码，然后就没有然后了

字节跳动面试官问我看过哪些源码，然后就没有然后了

最近&#xff0c;我的一位朋友在找工作&#xff0c;已经拿到了美团、快手等公司的Offer&#xff0c;准备选择其中一家入职了。 后来他又接到了字节跳动的电话&#xff0c;通知他去参加三面。从二面到三面之间隔了挺久的&#xff0c;他以为都没戏了&#xff0c;结果就收到了通知…
阅读更多...
今日头条面试

今日头条面试

首先说一下&#xff0c;今日头条的面试主要分为三轮到四轮&#xff0c;如果是旺季面三轮&#xff0c;首先是基础面试&#xff0c;基本面试一般10个题左右&#xff0c;最近面试了一下今日头条的移动Android资深工程师&#xff0c;记录下。 第一面是北京的开发进行视频面试&…
阅读更多...
字节跳动Android高工面试官现身说法，深度解密大厂面试套路，赢在起跑线！

字节跳动Android高工面试官现身说法，深度解密大厂面试套路，赢在起跑线！

前言 面试从来不是要你给出每一个问题的标准答案&#xff0c;而是要你给出这个问题的你的、自己的答案。 一 关于简历 面试首先要提到的就是简历&#xff0c;简历这个东西真的是一个很深奥的事情&#xff0c;为什么深奥&#xff0c;其实是对像和我这样的人深奥&#xff1a;学…
阅读更多...
头条面试官问我看过哪些源码，然后就没有然后了

头条面试官问我看过哪些源码，然后就没有然后了

最近&#xff0c;我的一位朋友在找工作&#xff0c;已经拿到了美团、快手等公司的Offer&#xff0c;准备选择其中一家入职了。 后来他又接到了字节跳动的电话&#xff0c;通知他去参加三面。从二面到三面之间隔了挺久的&#xff0c;他以为都没戏了&#xff0c;结果就收到了通知…
阅读更多...
今日头条面试相关

今日头条面试相关

原文地址&#xff1a; http://cv.qiaobutang.com/post/55e6a1110cf2633c1ba8ce8f 面试经历&#xff1a; 总共四轮&#xff0c;HR约得时间是下午两点半开始面&#xff0c;结果我2点20提前到了&#xff0c;坐在那一直等&#xff0c;等到3点5分才叫我去一个会议室&#xff0c;结果…
阅读更多...
面试今日头条Android开发，结束时我问了面试官是否有女朋友，结果你猜？

面试今日头条Android开发，结束时我问了面试官是否有女朋友，结果你猜？

点击上方“何俊林”&#xff0c;马上关注&#xff0c;每天早上8:50准时推送 真爱&#xff0c;请置顶或星标 本文转载自牛客网&#xff0c;作者&#xff1a;皮蛋瘦肉粥&#xff0c;链接&#xff1a;https://www.nowcoder.com/discuss/85227?type0&order0&pos28&pag…
阅读更多...
剖析今日头条技术面试过程以及应该如何准备？

剖析今日头条技术面试过程以及应该如何准备？

作者&#xff1a;“想去大厂的小菜鸡” https://juejin.im/post/5c14e7f051882562502f077 国庆期间公司的项目很闲&#xff0c;很多人觉得没意思陆续走了&#xff0c;我也考虑到自己的发展&#xff0c;从9月底开始面&#xff0c;面到11月底&#xff0c;三十家公司。我从不打没准…
阅读更多...
腾讯面试Android必问11题，我说的，不信就来看看

腾讯面试Android必问11题，我说的，不信就来看看

众所周知兔子啥都会那么一点&#xff0c;不收藏等着干啥呢 1、是否使用过本地广播&#xff0c;和全局广播有什么差别&#xff1f; 引入本地广播的机制是为了解决安全性的问题&#xff1a; 正在发送的广播不会脱离应用程序&#xff0c;比用担心app的数据泄露&#xff1b;其他的…
阅读更多...
字节跳动面试官问了我源码，然后......

字节跳动面试官问了我源码，然后......

最近&#xff0c;我的一位朋友在找工作&#xff0c;已经拿到了拼多多、快手等公司的Offer&#xff0c;准备选择其中一家入职了。 后来他又接到了字节跳动的电话&#xff0c;通知他去参加三面。从二面到三面之间隔了挺久的&#xff0c;他都以为没戏了&#xff0c;结果却收到了通…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023