# ffmpegrtmppusher

**Repository Path**: eming/ffmpegrtmppusher

## Basic Information

- **Project Name**: ffmpegrtmppusher
- **Description**: 基于ffmpeg的直播推流器，超级稳定，经过长时间稳定性测试，超低延时，可用于手机，电视，嵌入式等直播App及设备。
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 2
- **Created**: 2024-03-06
- **Last Updated**: 2025-02-13

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# ffmpegrtmppusher
基于ffmpeg的直播推流器，超级稳定，经过长时间稳定性测试，超低延时，可用于手机，电视，嵌入式等直播App及设备。

开发环境 安卓 android
android studio 3.2 

工程加入如下基础模块：

1、摄像头数据推流，音频数据推流，接口简单，几行代码可实现直播推流，及监控功能。

2、权限请求。

3、内有一套编译好的ffmpeg so 库可供NDK开发使用。

4、集成了Camera2的使用。

5、集成GPU美颜模块，几行代码实现集成gpu，让你的直播都是美美哒。

6、提供了YUV数据的各种转换功能，nv21,nv12,yuv420,yuv420sp等等。

7、还可在此基础上扩展帖图，水印等功能，接口都有接供，几行代码的事儿。

8、还有很多。。。自己下载看吧。



调用代码如下:

package rtmppusher.demo.com.rtmppusher;

import android.app.Activity;
import android.opengl.GLSurfaceView;
import android.os.Bundle;

import com.yanzhenjie.permission.AndPermission;
import com.yanzhenjie.permission.Permission;

import butterknife.BindView;
import jp.co.cyberagent.android.gpuimage.GPUImage;
import jp.co.cyberagent.android.gpuimage.util.Rotation;
import rtmppusher.demo.com.rtmppusher.utils.pusher.AudioSource;
import rtmppusher.demo.com.rtmppusher.utils.pusher.VideoSource;

public class MainActivity extends Activity {
    // Used to load the 'native-lib' library on application startup.
    static {
        System.loadLibrary("native-lib");
    }

    @BindView(R.id.glSurfaceView)
    GLSurfaceView glSurfaceView;

    private AudioSource audioSource;
    private VideoSource videoSource;
    private String videoUrl = "rtmp://192.168.0.105/live/1234";
    private GPUImage gpuImage;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        //GLSurfaceView预览
        glSurfaceView = findViewById(R.id.glSurfaceView);
        //音频封装
        audioSource = new AudioSource();
        audioSource.setRecordCallback(this::onRecordFrame); //回调
        //摄像头封装
        videoSource = new VideoSource();
        videoSource.setPreviewCallback(this::onPreviewFrame); //回调
        //添加gpu美颜
        gpuImage = new GPUImage(this);
        gpuImage.setRotation(Rotation.ROTATION_270, false, true); //镜像
        gpuImage.setGLSurfaceView(glSurfaceView);
        //推流初始化
        init();
        startPush(videoUrl); //开始推

        //权限申请
        AndPermission.with(this)
                .permission(Permission.Group.CAMERA)
                .onGranted(permissions -> {
                    videoSource.openCamera();
                })
                .onDenied(permissions -> {
                })
                .start();
        //权限申请
        AndPermission.with(this)
                .permission(Permission.Group.MICROPHONE)
                .onGranted(permissions -> {
                    audioSource.start();
                })
                .onDenied(permissions -> {
                })
                .start();
    }

    @Override
    public void onBackPressed() {
    }

    public void onResume(){
        super.onResume();
    }

    public void onDestroy(){
        super.onDestroy();
    }

    public void onRecordFrame(Object obj) {
        byte[] data = (byte[])obj;
        //音频推流
        pushAudio(data, data.length, 0);
    }

    public void onPreviewFrame(Object obj) {
        byte[] data = (byte[])obj;
        //gpu美颜色显示
        if (glSurfaceView != null && gpuImage != null) {
            gpuImage.updatePreviewFrame(data, 640, 480);
            gpuImage.requestRender();
        }
        //视频推流
        pushVideo(data, data.length, 0);
    }

    /**
     * A native method that is implemented by the 'native-lib' native library,
     * which is packaged with this application.
     */
    public native String init();
    public native String destroy();
    public native void pushVideo(byte[] data, int len, long timestamp);
    public native void pushAudio(byte[] data, int len, long timestamp);
    public native void startPush(String url);
    public native void stopPush();
}