Android手机摄像头直推RTMP服务器：无需OBS的移动直播解决方案

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

<uses-permission android:name="android.permission.CAMERA" />
<uses-permission android:name="android.permission.RECORD_AUDIO" />
<uses-permission android:name="android.permission.INTERNET" />
<uses-permission android:name="android.permission.FLASHLIGHT" />
<uses-permission android:name="android.permission.WRITE_EXTERNAL_STORAGE" />

<!-- activity_main.xml -->
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:layout_width="match_parent"
    android:layout_height="match_parent">

    <net.ossrs.yasea.SrsCameraView
        android:id="@+id/glsurfaceview_camera"
        android:layout_width="match_parent"
        android:layout_height="match_parent" />

    <!-- 其他UI元素，如开始/停止按钮 -->
    <Button
        android:id="@+id/publish_button"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:layout_alignParentBottom="true"
        android:layout_centerHorizontal="true"
        android:text="开始推流" />

</RelativeLayout>

import android.Manifest;
import android.content.pm.PackageManager;
import android.os.Bundle;
import android.view.View;
import android.widget.Button;
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.SrsRtmp;

public class MainActivity extends AppCompatActivity implements View.OnClickListener {

    private static final int REQUEST_PERMISSIONS = 1;
    private SrsPublisher mPublisher;
    private Button mPublishButton;
    private SrsCameraView mCameraView;

    @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);
        mPublishButton.setOnClickListener(this);

        // 动态请求权限
        checkPermissions();
    }

    private void checkPermissions() {
        String[] permissions = {
                Manifest.permission.CAMERA,
                Manifest.permission.RECORD_AUDIO,
                Manifest.permission.WRITE_EXTERNAL_STORAGE
        };
        boolean allGranted = true;
        for (String permission : permissions) {
            if (ContextCompat.checkSelfPermission(this, permission) != PackageManager.PERMISSION_GRANTED) {
                allGranted = false;
                break;
            }
        }

        if (!allGranted) {
            ActivityCompat.requestPermissions(this, permissions, 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 {
                // 权限未授予，可以提示用户或禁用相关功能
                // finish();
            }
        }
    }

    private void initPublisher() {
        mPublisher = new SrsPublisher(mCameraView);

        // 设置推流参数
        // 视频分辨率 (宽度, 高度)
        mPublisher.setVideoHDMode(); // 默认为720P，也可以自定义分辨率：mPublisher.setVideoParam(width, height, fps, bitrate);
        // 音频参数 (采样率, 通道数)
        mPublisher.setAudioParam(44100, 1);

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

        // 设置推流状态回调
        mPublisher.setPublishEventHandler(new SrsRtmp.EventHandler() {
            @Override
            public void onRtmpConnecting(String msg) {
                // 连接中
            }

            @Override
            public void onRtmpConnected(String msg) {
                // 已连接
            }

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

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

            @Override
            public void onRtmpStopped(String msg) {
                // 推流停止
            }

            @Override
            public void onRtmpDisconnected(String msg) {
                // 已断开连接
            }

            @Override
            public void onRtmpOutputBufferFull(String msg) {
                // 输出缓冲区已满，可能网络不佳
            }

            @Override
            public void onRtmpNetworkWeak(String msg) {
                // 网络信号弱
            }

            @Override
            public void onRtmpStreamError(String msg) {
                // 推流错误
            }
        });
    }

    @Override
    public void onClick(View v) {
        if (v.getId() == R.id.publish_button) {
            if (mPublisher != null) {
                if (mPublisher.isPublishing()) {
                    mPublisher.stopPublish();
                    mPublishButton.setText("开始推流");
                } else {
                    // 设置RTMP推流地址，包含推流码
                    // 格式：rtmp://[RTMP服务器IP或域名]/[应用名]/[推流码]
                    String rtmpUrl = "rtmp://your_rtmp_server_ip/live/stream_key"; // 替换为你的RTMP服务器地址和推流码
                    mPublisher.startPublish(rtmpUrl);
                    mPublishButton.setText("停止推流");
                }
            }
        }
    }

    @Override
    protected void onResume() {
        super.onResume();
        if (mPublisher != null) {
            mPublisher.resumeRecord(); // 恢复录制（如果之前暂停）
        }
    }

    @Override
    protected void onPause() {
        super.onPause();
        if (mPublisher != null) {
            mPublisher.pauseRecord(); // 暂停录制（如果需要）
        }
    }

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