使用Android原生开发的电视直播软件
-
-
+
+
## 使用
@@ -26,13 +25,11 @@
- 频道选择：OK键；单击屏幕；
- 设置页面：菜单、帮助键、长按OK键；双击屏幕；
-### 自定义直播源
-
-1. 进入设置页面
-2. 请求网址：`http://<设备IP>:10481`
-3. 按界面提示操作
+### 自定义设置
-不支持多源，只会选择频道的第一个源，其他忽略
+- 访问以下网址：`http://<设备IP>:10481`
+- 支持自定义直播源、节目单等
+- 直播源不支持多源，只会选择频道的第一个源，其他忽略
## 下载
@@ -42,7 +39,7 @@
- 主要解决 [my_tv](https://github.com/yaoxieyoulei/my_tv)（flutter）在低端设备上播放（4k）视频卡顿掉帧
- 仅支持Android5及以上
-- 网络环境必须支持IPV6
+- 网络环境必须支持IPV6（默认直播源）
- 只在自家电视上测过，其他电视稳定性未知
## 功能
@@ -51,8 +48,9 @@
- [x] 数字选台
- [x] 节目单
- [x] 开机自启
-- [ ] 自动更新
-- [ ] 自定义直播源
+- [x] 自动更新
+- [x] 自定义直播源
+- [x] 自定义节目单
- [ ] 性能优化
## 更新日志
diff --git a/app/src/main/java/top/yogiczy/mytv/MainActivity.kt b/app/src/main/java/top/yogiczy/mytv/MainActivity.kt
index 2d2d42a1..3819ee14 100644
--- a/app/src/main/java/top/yogiczy/mytv/MainActivity.kt
+++ b/app/src/main/java/top/yogiczy/mytv/MainActivity.kt
@@ -21,6 +21,7 @@ import top.yogiczy.mytv.ui.App
import top.yogiczy.mytv.ui.theme.MyTVTheme
import top.yogiczy.mytv.ui.utils.HttpServer
import top.yogiczy.mytv.ui.utils.SP
+import kotlin.system.exitProcess
@AndroidEntryPoint
@@ -56,16 +57,14 @@ class MainActivity : ComponentActivity() {
LocalContentColor provides MaterialTheme.colorScheme.onSurface
) {
App(
- onBackPressed = { finishAffinity() }
+ onBackPressed = {
+ finish()
+ exitProcess(0)
+ }
)
}
}
}
}
}
-
- override fun onDestroy() {
- HttpServer.stop()
- super.onDestroy()
- }
}
diff --git a/app/src/main/java/top/yogiczy/mytv/data/repositories/EpgRepositoryImpl.kt b/app/src/main/java/top/yogiczy/mytv/data/repositories/EpgRepositoryImpl.kt
index fe1e1177..57e6bc09 100644
--- a/app/src/main/java/top/yogiczy/mytv/data/repositories/EpgRepositoryImpl.kt
+++ b/app/src/main/java/top/yogiczy/mytv/data/repositories/EpgRepositoryImpl.kt
@@ -14,7 +14,6 @@ import top.yogiczy.mytv.data.entities.Epg
import top.yogiczy.mytv.data.entities.EpgList
import top.yogiczy.mytv.data.entities.EpgProgramme
import top.yogiczy.mytv.data.entities.EpgProgrammeList
-import top.yogiczy.mytv.data.utils.Constants
import top.yogiczy.mytv.ui.utils.SP
import java.io.File
import java.io.StringReader
@@ -33,7 +32,7 @@ class EpgRepositoryImpl(private val context: Context) : EpgRepository {
val xml = getXml()
val hashCode = filteredChannels.hashCode()
- if (SP.epgCacheHash == hashCode) {
+ if (SP.epgCachedHash == hashCode) {
val cache = getCache()
if (cache != null) {
Log.d(TAG, "使用缓存epg")
@@ -43,16 +42,16 @@ class EpgRepositoryImpl(private val context: Context) : EpgRepository {
val epgList = parseFromXml(xml, filteredChannels)
setCache(epgList)
- SP.epgCacheHash = hashCode
+ SP.epgCachedHash = hashCode
return epgList
}
private suspend fun fetchXml(): String = withContext(Dispatchers.IO) {
- Log.d(TAG, "获取远程xml: ${Constants.EPG_XML_URL}")
+ Log.d(TAG, "获取远程xml: ${SP.epgXmlUrl}")
val client = OkHttpClient()
- val request = Request.Builder().url(Constants.EPG_XML_URL).build()
+ val request = Request.Builder().url(SP.epgXmlUrl).build()
try {
return@withContext with(client.newCall(request).execute()) {
@@ -84,23 +83,25 @@ class EpgRepositoryImpl(private val context: Context) : EpgRepository {
private suspend fun getXml(): String {
val dateFormat = SimpleDateFormat("yyyy-MM-dd", Locale.getDefault())
- if (dateFormat.format(System.currentTimeMillis()) == dateFormat.format(SP.epgXmlCacheTime)) {
+ if (dateFormat.format(System.currentTimeMillis()) == dateFormat.format(SP.epgXmlCachedAt)) {
val cache = getCacheXml()
if (cache.isNotBlank()) {
Log.d(TAG, "使用缓存xml")
return cache
}
} else {
- if (Calendar.getInstance().get(Calendar.HOUR_OF_DAY) < 1) {
- Log.d(TAG, "未到1点，不刷新epg")
+ if (Calendar.getInstance()
+ .get(Calendar.HOUR_OF_DAY) < SP.epgRefreshTimeThreshold
+ ) {
+ Log.d(TAG, "未到时间点，不刷新epg")
return ""
}
}
val xml = fetchXml()
setCacheXml(xml)
- SP.epgXmlCacheTime = System.currentTimeMillis()
- SP.epgCacheHash = 0
+ SP.epgXmlCachedAt = System.currentTimeMillis()
+ SP.epgCachedHash = 0
return xml
}
diff --git a/app/src/main/java/top/yogiczy/mytv/data/repositories/IptvRepositoryImpl.kt b/app/src/main/java/top/yogiczy/mytv/data/repositories/IptvRepositoryImpl.kt
index a983c60c..79e76c9a 100644
--- a/app/src/main/java/top/yogiczy/mytv/data/repositories/IptvRepositoryImpl.kt
+++ b/app/src/main/java/top/yogiczy/mytv/data/repositories/IptvRepositoryImpl.kt
@@ -11,7 +11,6 @@ import top.yogiczy.mytv.data.entities.IptvGroup
import top.yogiczy.mytv.data.entities.IptvGroupList
import top.yogiczy.mytv.data.entities.IptvList
import top.yogiczy.mytv.data.models.IptvResponseItem
-import top.yogiczy.mytv.data.utils.Constants
import top.yogiczy.mytv.ui.utils.SP
import java.io.File
import javax.inject.Singleton
@@ -21,7 +20,7 @@ class IptvRepositoryImpl(private val context: Context) : IptvRepository {
override suspend fun getIptvGroups(): IptvGroupList {
val now = System.currentTimeMillis()
- if (now - SP.iptvSourceCacheTime < 24 * 60 * 60 * 1000) {
+ if (now - SP.iptvSourceCachedAt < SP.iptvSourceCacheTime) {
val cache = getCache()
if (cache.isNotBlank()) {
Log.d(TAG, "使用缓存直播源")
@@ -31,22 +30,20 @@ class IptvRepositoryImpl(private val context: Context) : IptvRepository {
val data = fetchSource()
setCache(data)
- SP.iptvSourceCacheTime = now
+ SP.iptvSourceCachedAt = now
return parseSource(data)
}
- private fun getSource() = SP.iptvCustomSource.ifBlank { Constants.IPTV_SOURCE_URL }
-
private fun getSourceType(): SourceType {
- return if (getSource().endsWith(".m3u")) SourceType.M3U else SourceType.TVBOX
+ return if (SP.iptvSourceUrl.endsWith(".m3u")) SourceType.M3U else SourceType.TVBOX
}
private suspend fun fetchSource(): String = withContext(Dispatchers.IO) {
- Log.d(TAG, "获取远程直播源: ${getSource()}")
+ Log.d(TAG, "获取远程直播源: ${SP.iptvSourceUrl}")
val client = OkHttpClient()
- val request = Request.Builder().url(getSource()).build()
+ val request = Request.Builder().url(SP.iptvSourceUrl).build()
try {
return@withContext with(client.newCall(request).execute()) {
diff --git a/app/src/main/java/top/yogiczy/mytv/data/utils/Constants.kt b/app/src/main/java/top/yogiczy/mytv/data/utils/Constants.kt
index 53d94276..97bc8e99 100644
--- a/app/src/main/java/top/yogiczy/mytv/data/utils/Constants.kt
+++ b/app/src/main/java/top/yogiczy/mytv/data/utils/Constants.kt
@@ -10,11 +10,21 @@ object Constants {
const val IPTV_SOURCE_URL =
"https://mirror.ghproxy.com/https://raw.githubusercontent.com/zhumeng11/IPTV/main/IPTV.m3u"
+ /**
+ * IPTV源缓存时间（毫秒）
+ */
+ const val IPTV_SOURCE_CACHE_TIME = 1000 * 60 * 60 * 24L // 24小时
+
/**
* 节目单XML地址
*/
const val EPG_XML_URL = "https://live.fanmingming.com/e.xml"
+ /**
+ * 节目单刷新时间阈值（小时）
+ */
+ const val EPG_REFRESH_TIME_THRESHOLD = 6 // 不到6点不刷新
+
/**
* GitHub最新版本信息
*/
@@ -25,4 +35,14 @@ object Constants {
* GitHub加速代理地址
*/
const val GITHUB_PROXY = "https://mirror.ghproxy.com/"
+
+ /**
+ * HTTP请求重试次数
+ */
+ const val HTTP_RETRY_COUNT = 10L
+
+ /**
+ * HTTP请求重试间隔时间（毫秒）
+ */
+ const val HTTP_RETRY_INTERVAL = 3000L
}
\ No newline at end of file
diff --git a/app/src/main/java/top/yogiczy/mytv/ui/screens/home/HomeScreenViewModel.kt b/app/src/main/java/top/yogiczy/mytv/ui/screens/home/HomeScreenViewModel.kt
index 17f949ab..a8838da0 100644
--- a/app/src/main/java/top/yogiczy/mytv/ui/screens/home/HomeScreenViewModel.kt
+++ b/app/src/main/java/top/yogiczy/mytv/ui/screens/home/HomeScreenViewModel.kt
@@ -19,6 +19,7 @@ import top.yogiczy.mytv.data.entities.EpgProgrammeList
import top.yogiczy.mytv.data.entities.IptvGroupList
import top.yogiczy.mytv.data.repositories.EpgRepository
import top.yogiczy.mytv.data.repositories.IptvRepository
+import top.yogiczy.mytv.ui.utils.SP
import javax.inject.Inject
@HiltViewModel
@@ -31,47 +32,38 @@ class HomeScreeViewModel @Inject constructor(
init {
viewModelScope.launch {
- flow { emit(iptvRepository.getIptvGroups()) }
- .retryWhen { _, attempt ->
- if (attempt >= 10) return@retryWhen false
+ flow { emit(iptvRepository.getIptvGroups()) }.retryWhen { _, attempt ->
+ if (attempt >= SP.httpRetryCount) return@retryWhen false
- uiState.value =
- HomeScreenUiState.Loading("获取远程直播源(${attempt + 1}/10)...")
- delay(3000)
- true
- }
- .catch { uiState.value = HomeScreenUiState.Error(it.message) }
- .map {
- uiState.value = HomeScreenUiState.Ready(iptvGroupList = it)
- it
- }
+ uiState.value =
+ HomeScreenUiState.Loading("获取远程直播源(${attempt + 1}/${SP.httpRetryCount})...")
+ delay(SP.httpRetryInterval)
+ true
+ }.catch { uiState.value = HomeScreenUiState.Error(it.message) }.map {
+ uiState.value = HomeScreenUiState.Ready(iptvGroupList = it)
+ it
+ }
// 开始获取epg
.flatMapLatest { iptvGroupList ->
val channels =
iptvGroupList.flatMap { it.iptvs }.map { iptv -> iptv.channelName }
flow { emit(epgRepository.getEpgs(channels)) }
- }
- .retry(10) { delay(3000); true }
- .catch { emit(EpgList()) }
- .map { epgList ->
+ }.retry(SP.httpRetryCount) { delay(SP.httpRetryInterval); true }
+ .catch { emit(EpgList()) }.map { epgList ->
// 移除过期节目
- epgList.copy(
- value = epgList.map { epg ->
- epg.copy(
- programmes = EpgProgrammeList(
- epg.programmes.filter { programme ->
- System.currentTimeMillis() < programme.endAt
- },
- )
+ epgList.copy(value = epgList.map { epg ->
+ epg.copy(
+ programmes = EpgProgrammeList(
+ epg.programmes.filter { programme ->
+ System.currentTimeMillis() < programme.endAt
+ },
)
- }
- )
- }
- .map { epgList ->
- uiState.value = (uiState.value as HomeScreenUiState.Ready)
- .copy(epgList = epgList)
- }
- .collect()
+ )
+ })
+ }.map { epgList ->
+ uiState.value =
+ (uiState.value as HomeScreenUiState.Ready).copy(epgList = epgList)
+ }.collect()
}
}
}
diff --git a/app/src/main/java/top/yogiczy/mytv/ui/screens/settings/components/SettingsList.kt b/app/src/main/java/top/yogiczy/mytv/ui/screens/settings/components/SettingsList.kt
index 16f89cbc..c660f963 100644
--- a/app/src/main/java/top/yogiczy/mytv/ui/screens/settings/components/SettingsList.kt
+++ b/app/src/main/java/top/yogiczy/mytv/ui/screens/settings/components/SettingsList.kt
@@ -53,26 +53,23 @@ fun SettingsList(
val childPadding = rememberChildPadding()
var appBootLaunch by remember { mutableStateOf(SP.appBootLaunch) }
- var debugShowFps by remember { mutableStateOf(SP.debugShowFps) }
var iptvChannelChangeFlip by remember { mutableStateOf(SP.iptvChannelChangeFlip) }
var iptvSourceSimplify by remember { mutableStateOf(SP.iptvSourceSimplify) }
- val iptvCustomSource by remember { mutableStateOf(SP.iptvCustomSource) }
- var iptvSourceCacheTime by remember { mutableLongStateOf(SP.iptvSourceCacheTime) }
+ var iptvSourceCachedAt by remember { mutableLongStateOf(SP.iptvSourceCachedAt) }
+ val iptvSourceCacheTime by remember { mutableLongStateOf(SP.iptvSourceCacheTime) }
var epgEnable by remember { mutableStateOf(SP.epgEnable) }
- var epgXmlCacheTime by remember { mutableLongStateOf(SP.epgXmlCacheTime) }
- var epgCacheHash by remember { mutableIntStateOf(SP.epgCacheHash) }
+ var epgXmlCachedAt by remember { mutableLongStateOf(SP.epgXmlCachedAt) }
+ var epgCachedHash by remember { mutableIntStateOf(SP.epgCachedHash) }
DisposableEffect(Unit) {
onDispose {
SP.appBootLaunch = appBootLaunch
- SP.debugShowFps = debugShowFps
SP.iptvChannelChangeFlip = iptvChannelChangeFlip
SP.iptvSourceSimplify = iptvSourceSimplify
- SP.iptvCustomSource = iptvCustomSource
- SP.iptvSourceCacheTime = iptvSourceCacheTime
+ SP.iptvSourceCachedAt = iptvSourceCachedAt
SP.epgEnable = epgEnable
- SP.epgXmlCacheTime = epgXmlCacheTime
- SP.epgCacheHash = epgCacheHash
+ SP.epgXmlCachedAt = epgXmlCachedAt
+ SP.epgCachedHash = epgCachedHash
}
}
TvLazyRow(
@@ -141,32 +138,19 @@ fun SettingsList(
}
item {
- val serverUrl = "http://${HttpServer.getLocalIpAddress()}:${HttpServer.SERVER_PORT}"
- var showQrcode by remember { mutableStateOf(false) }
-
- SettingsItem(
- title = "自定义直播源",
- value = if (iptvCustomSource.isNotBlank()) "已启用" else "未启用",
- description = "访问以下网址进行配置：$serverUrl",
- onClick = {
- showQrcode = true
- },
- )
-
- if (showQrcode) {
- SettingsQrcodeDialog(
- onDismissRequest = { showQrcode = false },
- data = serverUrl,
- )
+ fun formatDuration(ms: Long): String {
+ return when (ms) {
+ in 0..<60_000 -> "${ms / 1000}秒"
+ in 60_000..<3_600_000 -> "${ms / 60_000}分钟"
+ else -> "${ms / 3_600_000}小时"
+ }
}
- }
- item {
SettingsItem(
title = "直播源缓存",
- value = "24小时",
- description = if (iptvSourceCacheTime > 0) "已缓存(点击清除缓存)" else "未缓存",
- onClick = { iptvSourceCacheTime = 0 },
+ value = formatDuration(iptvSourceCacheTime),
+ description = if (iptvSourceCachedAt > 0) "已缓存(点击清除缓存)" else "未缓存",
+ onClick = { iptvSourceCachedAt = 0 },
)
}
@@ -183,21 +167,33 @@ fun SettingsList(
SettingsItem(
title = "节目单缓存",
value = "当天",
- description = if (epgXmlCacheTime > 0) "已缓存(点击清除缓存)" else "未缓存",
+ description = if (epgXmlCachedAt > 0) "已缓存(点击清除缓存)" else "未缓存",
onClick = {
- epgXmlCacheTime = 0
- epgCacheHash = 0
+ epgXmlCachedAt = 0
+ epgCachedHash = 0
},
)
}
item {
+ val serverUrl = "http://${HttpServer.getLocalIpAddress()}:${HttpServer.SERVER_PORT}"
+ var showQrcode by remember { mutableStateOf(false) }
+
SettingsItem(
- title = "显示FPS",
- value = if (debugShowFps) "启用" else "禁用",
- description = "显示当前帧率",
- onClick = { debugShowFps = !debugShowFps },
+ title = "更多设置",
+ value = "",
+ description = "访问以下网址进行配置：$serverUrl",
+ onClick = {
+ showQrcode = true
+ },
)
+
+ if (showQrcode) {
+ SettingsQrcodeDialog(
+ onDismissRequest = { showQrcode = false },
+ data = serverUrl,
+ )
+ }
}
// item {
diff --git a/app/src/main/java/top/yogiczy/mytv/ui/utils/HttpServer.kt b/app/src/main/java/top/yogiczy/mytv/ui/utils/HttpServer.kt
index b059bbd7..f22444b5 100644
--- a/app/src/main/java/top/yogiczy/mytv/ui/utils/HttpServer.kt
+++ b/app/src/main/java/top/yogiczy/mytv/ui/utils/HttpServer.kt
@@ -7,8 +7,10 @@ import fi.iki.elonen.NanoHTTPD
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.launch
+import kotlinx.serialization.Serializable
+import kotlinx.serialization.encodeToString
+import kotlinx.serialization.json.Json
import top.yogiczy.mytv.R
-import top.yogiczy.mytv.ui.screens.toast.ToastState
import java.net.Inet4Address
import java.net.NetworkInterface
import java.net.SocketException
@@ -35,10 +37,6 @@ object HttpServer {
}
}
- fun stop() {
- server.stop()
- }
-
fun getLocalIpAddress(): String {
val defaultIp = "0.0.0.0"
@@ -67,27 +65,130 @@ object HttpServer {
start(SOCKET_READ_TIMEOUT, false)
}
+ private fun isPreflightRequest(session: IHTTPSession): Boolean {
+ val headers = session.headers
+ return Method.OPTIONS == session.method && headers.contains("origin") && headers.containsKey(
+ "access-control-request-method"
+ ) && headers.containsKey("access-control-request-headers")
+ }
+
+ private fun responseCORS(session: IHTTPSession): Response {
+ val resp = wrapResponse(session, newFixedLengthResponse(""))
+ val headers = session.headers
+ resp.addHeader("Access-Control-Allow-Methods", "POST,GET,OPTIONS")
+ val requestHeaders = headers["access-control-request-headers"]
+ if (requestHeaders != null) {
+ resp.addHeader("Access-Control-Allow-Headers", requestHeaders)
+ }
+ resp.addHeader("Access-Control-Max-Age", "0")
+ return resp
+ }
+
+ private fun wrapResponse(session: IHTTPSession, resp: Response): Response {
+ val headers = session.headers
+ resp.addHeader("Access-Control-Allow-Credentials", "true")
+ resp.addHeader("Access-Control-Allow-Origin", headers.getOrElse("origin") { "*" })
+ val requestHeaders = headers["access-control-request-headers"]
+ if (requestHeaders != null) {
+ resp.addHeader("Access-Control-Allow-Headers", requestHeaders)
+ }
+ return resp
+ }
+
+ private inline fun