当前位置:

首页 > 编程开发 > Yasea库实现Android RTMP直播推流教程

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

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

本文目录

    使用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直播推流客户端。

    本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系bd@zhengruan.com
    作者最新文章
    编程开发
    相关文章 更多
    GitHub Copilot CLI v1.0.111的用量图与上下文比例应该怎样理解
    GitHub Copilot CLI v1.0.111的用量图与上下文比例应该怎样理解

    理解GitHub Copilot CLI v1.0.111的高级请求百分比、用户提示活动图与实际路由模型窗口,区分显示口径和任务状态。

    n8n 2.47.6、2.47.7、2.48.3 Beta、2.48.4 Beta、3.2.2预发布与1.123.96适用哪些安全修复?
    n8n 2.47.6、2.47.7、2.48.3 Beta、2.48.4 Beta、3.2.2预发布与1.123.96适用哪些安全修复?

    按维护分支、利用权限与节点类型对应四项修复,区分正式补丁、Beta和临时缓解的适用边界。

    GitHub合并故障的已缓解、监控与已解决有什么不同
    GitHub合并故障的已缓解、监控与已解决有什么不同

    GitHub合并故障中的“已缓解并监控”和“已解决”不能互换。前者表示影响已经采取措施缓解,仍在观察稳定性;后者是供应商正式结束这场事故的状态。11月13日的Pull Requests合并超时事件先进入监控,随后于北京时间11月14日02:29标记为已解决。

    llama.cpp v1.0.0的网页聊天分组与Markdown编辑适合哪些场景
    llama.cpp v1.0.0的网页聊天分组与Markdown编辑适合哪些场景

    llama.cpp v1.0.0改善聊天组织、长消息编辑和附件预览;界面变化与底层API迁移、缓存及访问边界需要分别理解。

    Postman 12.36.4 更新后仍报错,怎么判断是哪一层的问题
    Postman 12.36.4 更新后仍报错,怎么判断是哪一层的问题

    Postman 12.36.4 更新后仍有异常时,可按应用、API请求和平台服务区分问题范围,避免把补丁版本当作故障原因。

    n8n 2.47.6、2.48.3 Beta与1.123.96适合哪些部署环境?
    n8n 2.47.6、2.48.3 Beta与1.123.96适合哪些部署环境?

    按正式、预发布和1.x维护渠道对应补丁,再结合Redis、Agent端点和Pinecone索引判断适用范围。

    Codex CLI 0.169.0与0.171.0-alpha.2怎样选择,终端工作区适合哪些任务
    Codex CLI 0.169.0与0.171.0-alpha.2怎样选择,终端工作区适合哪些任务

    Codex CLI 0.169.0提供有明确说明的终端工作区能力;0.171.0-alpha.2为预发布,当前没有功能清单,选用时应分开评估。

    llama.cpp b12345的Hexagon后端支持哪些Q5量化格式?
    llama.cpp b12345的Hexagon后端支持哪些Q5量化格式?

    llama.cpp b12345的预发布构建为Hexagon HTP后端增加Q5_0和Q5_1支持。选择模型时需要核对完整量化名称及实际运行后端,不能只看到“Q5”就视为同一种格式。

    llama.cpp b12344的MCP工具调用在断连或超时后会怎样处理?
    llama.cpp b12344的MCP工具调用在断连或超时后会怎样处理?

    llama.cpp b12344的预发布构建调整了MCP工具调用的取消行为:客户端断连或调用超时时,服务器会向MCP服务发送带请求ID的取消通知。使用服务端工具的Web界面也属于这项变更范围。

    GitHub Actions与Checks同时排队失败时,如何区分平台故障?
    GitHub Actions与Checks同时排队失败时,如何区分平台故障?

    GitHub对11月5日Actions与Checks事件的新增复盘指出:数据库服务在高并发大读请求下耗尽资源,导致部分运行无法排队或执行失败。检查类似问题时,先比对平台事件时间与失败状态,再决定是否重试自己的工作流。

    查看更多
    精品专题 更多
    装机必备
    装机必备

    正软商城装机必备专区,精选办公、浏览器、安全防护、影音播放、压缩解压、设计创作和系统工具等电脑常用正版软件,帮助用户快速完成新电脑软件配置。

    Windows
    Windows

    正软商城Windows软件专区,汇集适用于Windows电脑的办公、设计、安全防护、影音播放、开发工具和系统优化软件,提供软件介绍、系统要求、正版授权及购买下载服务。

    PDF教程
    PDF教程

    正软商城PDF教程频道提供PDF编辑、转换、合并、拆分、压缩及格式处理方法,同时介绍常用PDF软件和工具的使用技巧。

    Mac软件 更多
    讯飞智作 网页版
    讯飞智作 网页版
    Windows/ macOS/ Linux

    讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

    火山引擎 网页版
    火山引擎 网页版
    Windows/ macOS/ Linux

    火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

    Aperty macOS版
    Aperty macOS版
    macOS

    Aperty 是 Skylum 推出的 AI 人像修图软件,支持自然肤质修饰、瑕疵处理、面部与身体调整、预设及批量同步。

    WINDOWS 更多
    讯飞智作 网页版
    讯飞智作 网页版
    Windows/ macOS/ Linux

    讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

    火山引擎 网页版
    火山引擎 网页版
    Windows/ macOS/ Linux

    火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

    PixTV 网页版
    PixTV 网页版
    Windows

    PixTV 是一款在浏览器中使用的 AI 视觉内容创作平台,提供图片、视频、音频、文字生成、AI 分镜、局部重绘、提示词反推和无限画布等工具,适合短剧、漫剧、广告及社交媒体内容制作。