Yasea库实现Android RTMP直播推流教程

本教程旨在指导开发者如何在Android应用中直接利用手机摄像头进行RTMP直播推流，无需依赖OBS等桌面软件。我们将重点介绍如何集成并使用高性能的Yasea开源库，实现视频和音频的采集、编码及RTMP协议传输，最终将手机画面实时推送到Nginx RTMP服务器，为移动直播应用提供核心技术支持。

1. 概述与技术背景

随着移动互联网的普及，直接从智能手机进行实时视频直播的需求日益增长。传统的直播方式通常需要通过桌面软件（如OBS Studio）将摄像头信号推送到RTMP服务器。然而，在许多场景下，我们需要直接利用Android手机的内置摄像头进行推流，以实现更便捷、灵活的移动直播体验。

本文将介绍一种高效的解决方案，即利用开源的Yasea库（begeekmyfriend/yasea）在Android应用中实现这一功能。Yasea是一个功能强大的Android RTMP/RTSP推流库，支持H.264视频编码和AAC音频编码，能够轻松集成到Android项目中，实现高质量的直播推流。

在开始之前，请确保您已经搭建了一个可用的RTMP服务器，例如基于Nginx的RTMP模块。如果您尚未搭建，可以参考相关教程（如DigitalOcean提供的Nginx RTMP服务器搭建指南）进行配置。

2. Yasea库的集成

要在您的Android项目中集成Yasea库，您需要将其添加到项目的build.gradle文件中。

2.1 添加依赖

在您的模块级build.gradle（通常是app/build.gradle）文件中，添加以下依赖：

dependencies {
    implementation 'com.github.begeekmyfriend:yasea:1.1.13' // 请检查最新版本
}

请注意，1.1.13可能不是最新版本，建议访问Yasea的GitHub仓库（https://github.com/begeekmyfriend/yasea）查看最新的稳定版本号。

2.2 配置MavenCentral

确保您的项目级build.gradle（通常是根目录下的build.gradle）文件中包含MavenCentral仓库：

allprojects {
    repositories {
        google()
        mavenCentral() // 确保包含此行
        maven { url 'https://jitpack.io' } // 如果Yasea依赖通过JitPack提供，则需要此行
    }
}

3. 所需权限配置

为了使Yasea库能够正常工作，您的Android应用需要获取摄像头、麦克风和网络访问权限。在AndroidManifest.xml文件中添加以下权限：

对于Android 6.0 (API 23) 及以上版本，您还需要在运行时动态请求这些敏感权限。

// 在Activity中请求权限的示例
private static final int REQUEST_PERMISSIONS = 1;
private String[] permissions = {
    Manifest.permission.CAMERA,
    Manifest.permission.RECORD_AUDIO,
    Manifest.permission.INTERNET,
    Manifest.permission.WRITE_EXTERNAL_STORAGE // 如果需要
};

private void checkPermissions() {
    List neededPermissions = new ArrayList<>();
    for (String p : permissions) {
        if (ContextCompat.checkSelfPermission(this, p) != PackageManager.PERMISSION_GRANTED) {
            neededPermissions.add(p);
        }
    }
    if (!neededPermissions.isEmpty()) {
        ActivityCompat.requestPermissions(this, neededPermissions.toArray(new String[0]), REQUEST_PERMISSIONS);
    }
}

@Override
public void onRequestPermissionsResult(int requestCode, @NonNull String[] permissions, @NonNull int[] grantResults) {
    super.onRequestPermissionsResult(requestCode, permissions, grantResults);
    if (requestCode == REQUEST_PERMISSIONS) {
        // 检查所有权限是否都被授予
        boolean allGranted = true;
        for (int result : grantResults) {
            if (result != PackageManager.PERMISSION_GRANTED) {
                allGranted = false;
                break;
            }
        }
        if (allGranted) {
            // 权限已授予，可以初始化推流器
            // initPublisher();
        } else {
            // 权限被拒绝，提示用户或退出应用
            Toast.makeText(this, "Required permissions not granted.", Toast.LENGTH_LONG).show();
            finish();
        }
    }
}

4. 使用Yasea进行推流

Yasea的核心类是SrsPublisher。以下是使用Yasea进行推流的基本步骤和示例代码。

4.1 布局文件

在您的Activity布局文件中添加一个SurfaceView或SurfaceViewRenderer用于显示摄像头预览。

4.2 Activity代码示例

在您的Activity中，初始化SrsPublisher并配置推流参数。

import android.Manifest;
import android.content.pm.PackageManager;
import android.os.Bundle;
import android.widget.Button;
import android.widget.Toast;

import androidx.annotation.NonNull;
import androidx.appcompat.app.AppCompatActivity;
import androidx.core.app.ActivityCompat;
import androidx.core.content.ContextCompat;

import net.ossrs.yasea.SrsCameraView;
import net.ossrs.yasea.SrsPublisher;
import net.ossrs.yasea.rtmp.ConnectCheckerRtmp;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

public class MainActivity extends AppCompatActivity implements ConnectCheckerRtmp {

    private SrsPublisher mPublisher;
    private SrsCameraView mCameraView;
    private Button mPublishButton;
    private String rtmpUrl = "rtmp://your_rtmp_server_ip/live/stream_key"; // 替换为您的RTMP推流地址

    private static final int REQUEST_PERMISSIONS = 1;
    private String[] permissions = {
            Manifest.permission.CAMERA,
            Manifest.permission.RECORD_AUDIO,
            Manifest.permission.INTERNET
            // Manifest.permission.WRITE_EXTERNAL_STORAGE // 如果需要录制到本地
    };

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

        mCameraView = findViewById(R.id.glsurfaceview_camera);
        mPublishButton = findViewById(R.id.publish_button);

        checkPermissions(); // 检查并请求权限
    }

    private void checkPermissions() {
        List neededPermissions = new ArrayList<>();
        for (String p : permissions) {
            if (ContextCompat.checkSelfPermission(this, p) != PackageManager.PERMISSION_GRANTED) {
                neededPermissions.add(p);
            }
        }
        if (!neededPermissions.isEmpty()) {
            ActivityCompat.requestPermissions(this, neededPermissions.toArray(new String[0]), REQUEST_PERMISSIONS);
        } else {
            initPublisher(); // 权限已授予，初始化推流器
        }
    }

    @Override
    public void onRequestPermissionsResult(int requestCode, @NonNull String[] permissions, @NonNull int[] grantResults) {
        super.onRequestPermissionsResult(requestCode, permissions, grantResults);
        if (requestCode == REQUEST_PERMISSIONS) {
            boolean allGranted = true;
            for (int result : grantResults) {
                if (result != PackageManager.PERMISSION_GRANTED) {
                    allGranted = false;
                    break;
                }
            }
            if (allGranted) {
                initPublisher();
            } else {
                Toast.makeText(this, "所需权限未授予，无法进行直播。", Toast.LENGTH_LONG).show();
                finish();
            }
        }
    }

    private void initPublisher() {
        // 1. 创建SrsPublisher实例
        mPublisher = new SrsPublisher(mCameraView);
        mPublisher.setPublishEventHandler(this); // 设置推流事件回调

        // 2. 配置视频参数
        // 视频分辨率 (宽, 高)
        mPublisher.setVideoHDMode(); // 切换到高清模式，也可以手动设置分辨率
        // mPublisher.setVideoParam(1280, 720, 30, 2000 * 1024); // 宽, 高, 帧率, 码率(bps)
        mPublisher.setVideoFrameRate(30); // 帧率
        mPublisher.setVideoBitrate(2000 * 1024); // 视频码率，单位bps

        // 3. 配置音频参数
        mPublisher.setAudioParam(44100, true); // 采样率，是否使用立体声

        // 4. 设置预览视图
        mPublisher.setPreviewResolution(mCameraView.getWidth(), mCameraView.getHeight()); // 预览分辨率，通常与SurfaceView尺寸一致
        mPublisher.setScreenOrientation(90); // 设置屏幕方向，0、90、180、270度

        // 5. 启动摄像头预览
        mPublisher.startCamera();

        // 6. 设置推流按钮点击事件
        mPublishButton.setOnClickListener(v -> {
            if (mPublisher.isPublishing()) {
                mPublisher.stopPublish();
                mPublishButton.setText("开始推流");
            } else {
                mPublisher.startPublish(rtmpUrl);
                mPublishButton.setText("停止推流");
            }
        });
    }

    @Override
    protected void onResume() {
        super.onResume();
        if (mPublisher != null) {
            mPublisher.resumeRecord(); // 恢复录制/推流
            mPublisher.startCamera(); // 恢复摄像头预览
        }
    }

    @Override
    protected void onPause() {
        super.onPause();
        if (mPublisher != null) {
            mPublisher.pauseRecord(); // 暂停录制/推流
            mPublisher.stopCamera(); // 停止摄像头预览
        }
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        if (mPublisher != null) {
            mPublisher.stopPublish(); // 停止推流
            mPublisher.stopCamera(); // 停止摄像头
            mPublisher.release(); // 释放资源
        }
    }

    // 实现ConnectCheckerRtmp接口的回调方法
    @Override
    public void onRtmpConnecting(String msg) {
        Toast.makeText(this, "正在连接RTMP服务器...", Toast.LENGTH_SHORT).show();
    }

    @Override
    public void onRtmpConnected(String msg) {
        Toast.makeText(this, "RTMP服务器连接成功！", Toast.LENGTH_SHORT).show();
    }

    @Override
    public void onRtmpVideoStreaming() {
        // 视频流正在传输
    }

    @Override
    public void onRtmpAudioStreaming() {
        // 音频流正在传输
    }

    @Override
    public void onRtmpStopped() {
        Toast.makeText(this, "RTMP推流已停止。", Toast.LENGTH_SHORT).show();
    }

    @Override
    public void onRtmpDisconnected() {
        Toast.makeText(this, "RTMP服务器已断开连接。", Toast.LENGTH_SHORT).show();
    }

    @Override
    public void onRtmpVideoFpsChanged(double fps) {
        // 视频帧率变化
    }

    @Override
    public void onRtmpVideoBitrateChanged(double bitrate) {
        // 视频码率变化
    }

    @Override
    public void onRtmpAudioBitrateChanged(double bitrate) {
        // 音频码率变化
    }

    @Override
    public void onRtmpSocketException(IOException e) {
        Toast.makeText(this, "RTMP Socket异常: " + e.getMessage(), Toast.LENGTH_LONG).show();
        mPublishButton.setText("开始推流");
    }

    @Override
    public void onRtmpNetworkException(IOException e) {
        Toast.makeText(this, "RTMP 网络异常: " + e.getMessage(), Toast.LENGTH_LONG).show();
        mPublishButton.setText("开始推流");
    }

    @Override
    public void onRtmpDataCacheFull() {
        // 数据缓存已满，可能导致卡顿
    }

    @Override
    public void onRtmpDownloadBandwidthDetect(long bitrate) {
        // 下载带宽检测 (对于推流，此回调可能不常用)
    }

    @Override
    public void onRtmpIllegalArgumentException(IllegalArgumentException e) {
        Toast.makeText(this, "RTMP 参数异常: " + e.getMessage(), Toast.LENGTH_LONG).show();
        mPublishButton.setText("开始推流");
    }

    @Override
    public void onRtmpIllegalStateException(IllegalStateException e) {
        Toast.makeText(this, "RTMP 状态异常: " + e.getMessage(), Toast.LENGTH_LONG).show();
        mPublishButton.setText("开始推流");
    }
}

代码解释：

• SrsPublisher: Yasea库的核心类，负责管理摄像头、麦克风、编码和RTMP推流。
• SrsCameraView: Yasea提供的自定义GLSurfaceView，用于显示摄像头预览。
• setVideoParam / setAudioParam: 配置视频和音频的编码参数，如分辨率、帧率、码率、采样率等。这些参数直接影响直播质量和网络带宽消耗。
• startCamera() / stopCamera(): 控制摄像头预览的启动和停止。
• startPublish(rtmpUrl) / stopPublish(): 控制RTMP推流的启动和停止。rtmpUrl是您的RTMP服务器地址，例如rtmp://your_server_ip/live/stream_key，其中stream_key是您为该直播流设定的唯一标识。
• ConnectCheckerRtmp: 一个接口，用于接收RTMP连接和推流状态的回调，方便您在UI上显示状态或进行错误处理。
• Activity生命周期管理: 在onResume()、onPause()和onDestroy()方法中正确管理SrsPublisher的生命周期，以确保资源正确释放，避免内存泄漏或摄像头占用冲突。

5. 注意事项与最佳实践

• RTMP URL配置: 务必将示例代码中的rtmp://your_rtmp_server_ip/live/stream_key替换为您的实际RTMP推流地址。通常，stream_key是Nginx RTMP配置中application块下的live或自定义应用名，以及您为每个直播流指定的密钥。
• 性能与画质平衡: 视频编码参数（分辨率、帧率、码率）的选择需要根据目标设备性能、网络环境和期望画质进行权衡。高分辨率和高码率会消耗更多CPU资源和网络带宽。
• 错误处理: ConnectCheckerRtmp接口提供了丰富的回调，用于处理连接、网络和编码过程中的各种异常。在实际应用中，应根据这些回调向用户提供友好的提示或尝试重连。
• 前后台切换: 在应用进入后台时，应暂停摄像头和推流，以节省电量和资源；在前台时再恢复。Yasea库提供了pauseRecord()和resumeRecord()方法来处理这种情况。
• 权限管理: Android 6.0+的运行时权限是强制性的。确保您的应用在用户首次启动时或尝试推流前请求并获得了必要的权限。
• 多摄像头支持: Yasea支持前后摄像头的切换。您可以通过mPublisher.switchCamera()方法实现。
• 录制到本地: Yasea也支持将直播内容同时录制到本地文件。可以通过mPublisher.startRecord()和mPublisher.stopRecord()方法实现。
• UI交互: 在实际应用中，您可能需要更复杂的UI来控制推流（如切换摄像头、调整画质、美颜等）。

6. 总结

通过集成Yasea库，Android开发者可以非常便捷地在应用中实现手机摄像头到RTMP服务器的直播推流功能。Yasea提供了一套完整的解决方案，涵盖了视频采集、H.264/AAC编码以及RTMP协议传输，大大简化了移动直播应用的开发难度。遵循本教程的步骤和注意事项，您将能够构建稳定、高效的Android直播推流客户端。