如何在ExoPlayer中无缝更新过期HLS流URL（HTTP 483）且不中断播放？

核心思路 #

利用ExoPlayer的媒体源动态更新和错误重试机制，结合自定义组件捕获483错误，在获取新URL后替换媒体源，实现无感知续播。

具体实现步骤 #

1. 自定义HttpDataSource捕获483错误 #

继承DefaultHttpDataSource.Factory，在请求拦截时检测483状态码，抛出自定义异常以便后续处理：

class CustomHttpDataSourceFactory(
    userAgent: String,
    private val on483Error: () -> Unit
) : DefaultHttpDataSource.Factory() {

    init {
        setUserAgent(userAgent)
    }

    override fun createDataSource(): HttpDataSource {
        return object : DefaultHttpDataSource(userAgent) {
            override fun open(dataSpec: DataSpec): Long {
                return try {
                    super.open(dataSpec)
                } catch (e: HttpDataSourceException) {
                    if (e.responseCode == 483) {
                        on483Error.invoke()
                        throw Custom483Exception(e)
                    } else {
                        throw e
                    }
                }
            }
        }
    }

    class Custom483Exception(cause: HttpDataSourceException) : HttpDataSourceException(cause)
}

2. 自定义LoadErrorHandlingPolicy处理重试 #

实现LoadErrorHandlingPolicy，针对Custom483Exception触发重试，同时在重试前获取新的HLS URL：

class CustomLoadErrorPolicy(
    private val getNewHlsUrl: suspend () -> String,
    private val updateMediaSource: (String) -> Unit
) : LoadErrorHandlingPolicy {

    override fun getRetryDelayMsFor(error: ExoPlaybackException): Long {
        return if (error.cause is CustomHttpDataSourceFactory.Custom483Exception) {
            0
        } else {
            LoadErrorHandlingPolicy.DEFAULT_RETRY_DELAY_MS
        }
    }

    override fun getMinimumLoadableRetryCount(dataType: Int): Int {
        return if (dataType == C.DATA_TYPE_MEDIA) 3 else super.getMinimumLoadableRetryCount(dataType)
    }

    override suspend fun onLoadError(
        error: ExoPlaybackException,
        errorCount: Int
    ): LoadErrorAction {
        return if (error.cause is CustomHttpDataSourceFactory.Custom483Exception && errorCount <= 3) {
            val newUrl = getNewHlsUrl()
            updateMediaSource(newUrl)
            LoadErrorAction.RETRY
        } else {
            LoadErrorAction.DONT_RETRY
        }
    }
}

3. 初始化播放器并设置动态更新逻辑 #

初始化ExoPlayer时绑定自定义组件，维护播放状态，替换媒体源时无缝恢复播放：

class PlayerManager {
    private var exoPlayer: ExoPlayer? = null
    private var currentPlaybackPosition: Long = 0
    private var currentWindowIndex: Int = 0
    private var isPlaying: Boolean = false

    fun initPlayer(context: Context) {
        val dataSourceFactory = CustomHttpDataSourceFactory(
            Util.getUserAgent(context, "YourAppName")
        ) {}

        val loadErrorPolicy = CustomLoadErrorPolicy(
            getNewHlsUrl = {
                fetchNewHlsUrlFromServer()
            },
            updateMediaSource = { newUrl ->
                exoPlayer?.let { player ->
                    currentPlaybackPosition = player.currentPosition
                    currentWindowIndex = player.currentWindowIndex
                    isPlaying = player.isPlaying

                    val newMediaSource = HlsMediaSource.Factory(dataSourceFactory)
                        .createMediaSource(MediaItem.fromUri(newUrl))

                    player.setMediaSource(newMediaSource, true)
                    player.seekTo(currentWindowIndex, currentPlaybackPosition)
                    if (isPlaying) player.play()
                }
            }
        )

        exoPlayer = ExoPlayer.Builder(context)
            .setMediaSourceFactory(HlsMediaSource.Factory(dataSourceFactory))
            .setLoadErrorHandlingPolicy(loadErrorPolicy)
            .build()
    }

    private suspend fun fetchNewHlsUrlFromServer(): String {
        return "https://your-server.com/new-stream.m3u8"
    }
}

4. 关键注意事项 #

• 保留播放状态：替换媒体源前必须记录当前播放位置、窗口索引和播放状态，替换后立即恢复。
• 重试次数限制：设置合理的重试次数，避免无限循环请求无效URL。
• 新URL时效性：确保获取的新URL有效未过期，建议获取后立即使用。
• 线程安全：所有播放器操作需在主线程或ExoPlayer专用线程执行，避免并发问题。

内容的提问来源于stack exchange，提问作者Mneckoee