ModNet.vb 86 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839
  1. Imports System.Net.Http.Headers
  2. Imports System.Threading.Tasks
  3. Imports CacheCow.Client
  4. Public Module ModNet
  5. #Region "网络请求"
  6. ''' <summary>
  7. ''' 发送一次网络请求并获取返回内容。
  8. ''' </summary>
  9. Public Function NetRequestByClient(Url As String, Optional Method As HttpMethod = Nothing,
  10. Optional Content As Object = Nothing, Optional ContentType As String = Nothing, Optional Accept As String = "*/*",
  11. Optional Timeout As Integer = 25000, Optional Headers As String(,) = Nothing,
  12. Optional Encoding As Encoding = Nothing, Optional UseBrowserUserAgent As Boolean = False, Optional MakeLog As Boolean = True) As String
  13. If Method Is Nothing Then Method = HttpMethod.Get
  14. If MakeLog Then Log("[Net] 发起网络请求(" & Method.Method & "," & Url & "),最大超时 " & Timeout)
  15. Try
  16. Dim HeaderDictionary = If(Headers, {}).ToDictionary
  17. If ContentType IsNot Nothing Then HeaderDictionary("Content-Type") = ContentType
  18. If Accept IsNot Nothing Then HeaderDictionary("Accept") = Accept
  19. Return If(Encoding, Encoding.UTF8).GetString(SendRequest(Url, Method, Content, HeaderDictionary, Timeout:=Timeout, Encoding:=Encoding, UseBrowserUserAgent:=UseBrowserUserAgent))
  20. Catch ex As ThreadInterruptedException
  21. Throw
  22. Catch ex As ResponsedWebException
  23. If MakeLog Then Log(ex, "网络请求失败,返回内容为:" & vbCrLf & ex.Response, LogLevel.Developer)
  24. Throw
  25. Catch ex As Exception
  26. If MakeLog Then Log(ex, "网络请求失败", LogLevel.Developer)
  27. Throw
  28. End Try
  29. End Function
  30. ''' <summary>
  31. ''' 发送网络请求并获取返回内容。
  32. ''' 会进行至多 45 秒 3 次的尝试,允许最长 30s 的超时。
  33. ''' </summary>
  34. ''' <param name="BackupUrl">如果第一次尝试失败,换用的备用 URL。</param>
  35. Public Function NetRequestByClientRetry(Url As String, Optional Method As HttpMethod = Nothing, Optional BackupUrl As String = Nothing,
  36. Optional Content As Object = Nothing, Optional ContentType As String = Nothing, Optional Accept As String = "*/*",
  37. Optional Headers As String(,) = Nothing,
  38. Optional Encoding As Encoding = Nothing, Optional UseBrowserUserAgent As Boolean = False) As String
  39. Dim RetryCount As Integer = 0
  40. Dim RetryException As Exception = Nothing
  41. Dim StartTime As Long = GetTimeTick()
  42. Try
  43. Retry:
  44. Select Case RetryCount
  45. Case 0 '正常尝试
  46. Return NetRequestByClient(Url, Method, Content, ContentType, Accept, 10000, Headers, Encoding, UseBrowserUserAgent)
  47. Case 1 '慢速重试
  48. Thread.Sleep(500)
  49. Return NetRequestByClient(Url, Method, Content, ContentType, Accept, 30000, Headers, Encoding, UseBrowserUserAgent)
  50. Case Else '快速重试
  51. If GetTimeTick() - StartTime > 5500 Then
  52. '若前两次加载耗费 5 秒以上,才进行重试
  53. Thread.Sleep(500)
  54. Return NetRequestByClient(Url, Method, Content, ContentType, Accept, 4000, Headers, Encoding, UseBrowserUserAgent)
  55. Else
  56. Throw RetryException
  57. End If
  58. End Select
  59. Catch ex As ThreadInterruptedException
  60. Throw
  61. Catch ex As Exception
  62. Select Case RetryCount
  63. Case 0
  64. RetryException = ex
  65. RetryCount += 1
  66. GoTo Retry
  67. Case 1
  68. RetryCount += 1
  69. GoTo Retry
  70. Case Else
  71. Throw
  72. End Select
  73. End Try
  74. End Function
  75. ''' <summary>
  76. ''' 生成数个线程,同时发送网络请求并获取返回内容。
  77. ''' 每个线程开始之前会略有延迟。
  78. ''' </summary>
  79. Public Function NetRequestByClientMultiple(Url As String, Optional Method As HttpMethod = Nothing, Optional ThreadCount As Integer = 3,
  80. Optional Content As Object = Nothing, Optional ContentType As String = Nothing, Optional Accept As String = "*/*",
  81. Optional Headers As String(,) = Nothing, Optional Timeout As Integer = 25000,
  82. Optional Encoding As Encoding = Nothing, Optional UseBrowserUserAgent As Boolean = False) As String
  83. Dim Threads As New List(Of Thread)
  84. Dim RequestResult = Nothing
  85. Dim RequestEx As Exception = Nothing
  86. Dim FailCount As Integer = 0
  87. For i = 1 To ThreadCount
  88. Dim th As New Thread(
  89. Sub()
  90. Try
  91. RequestResult = NetRequestByClient(Url, Method, Content, ContentType, Accept, Timeout, Headers, Encoding, UseBrowserUserAgent)
  92. Catch ex As Exception
  93. FailCount += 1
  94. RequestEx = ex
  95. End Try
  96. End Sub)
  97. th.Start()
  98. Threads.Add(th)
  99. Thread.Sleep(i * 250)
  100. If RequestResult IsNot Nothing Then GoTo RequestFinished
  101. Next
  102. Do While True
  103. If RequestResult IsNot Nothing Then
  104. RequestFinished:
  105. Try
  106. For Each th In Threads
  107. If th.IsAlive Then th.Interrupt()
  108. Next
  109. Catch
  110. End Try
  111. Return RequestResult
  112. ElseIf FailCount = ThreadCount Then
  113. Try
  114. For Each th In Threads
  115. If th.IsAlive Then th.Interrupt()
  116. Next
  117. Catch
  118. End Try
  119. Throw RequestEx
  120. End If
  121. Thread.Sleep(20)
  122. Loop
  123. Return Nothing
  124. End Function
  125. ''' <summary>
  126. ''' 以多线程下载网页文件的方式获取内容。
  127. ''' 不支持缓存协商;若需缓存协商,需要换用 NetRequestByClient。
  128. ''' </summary>
  129. Public Function NetRequestByLoader(Url As String, Optional Timeout As Integer = 45000, Optional IsJson As Boolean = False, Optional UseBrowserUserAgent As Boolean = False) As String
  130. Return NetRequestByLoader({Url}, Timeout, IsJson, UseBrowserUserAgent)
  131. End Function
  132. ''' <summary>
  133. ''' 以多线程下载网页文件的方式获取内容。
  134. ''' 不支持缓存协商;若需缓存协商,需要换用 NetRequestByClient。
  135. ''' </summary>
  136. Public Function NetRequestByLoader(Urls As IEnumerable(Of String), Optional Timeout As Integer = 45000, Optional IsJson As Boolean = False, Optional UseBrowserUserAgent As Boolean = False) As String
  137. Dim Temp As String = RequestTaskTempFolder() & "download.txt"
  138. Dim NewTask As New LoaderDownload("源码获取 " & GetUuid() & "#", New List(Of NetFile) From {New NetFile(Urls, Temp, New FileChecker With {.IsJson = IsJson}, UseBrowserUserAgent)})
  139. Try
  140. NewTask.WaitForExitTime(Timeout, TimeoutMessage:="连接服务器超时(第一下载源:" & Urls.First & ")")
  141. NetRequestByLoader = ReadFile(Temp)
  142. File.Delete(Temp)
  143. Finally
  144. NewTask.Abort()
  145. End Try
  146. End Function
  147. #End Region
  148. #Region "文件下载"
  149. ''' <summary>
  150. ''' 通过网络请求直接下载小文件,若文件已存在将被覆盖。
  151. ''' 不建议用于下载大文件。
  152. ''' </summary>
  153. Public Sub NetDownloadByClient(Url As String, LocalPath As String)
  154. Log($"[Net] 通过网络请求直接下载小文件:{Url} → {LocalPath}")
  155. '初始化文件路径
  156. Try
  157. Directory.CreateDirectory(GetPathFromFullPath(LocalPath))
  158. File.Delete(LocalPath)
  159. Catch ex As Exception
  160. Throw New Exception($"预处理下载文件路径失败({LocalPath})", ex)
  161. End Try
  162. '下载
  163. Try
  164. File.WriteAllBytes(LocalPath, SendRequest(Url, HttpMethod.Get))
  165. Catch ex As Exception
  166. File.Delete(LocalPath)
  167. Throw New WebException($"通过网络请求直接下载小文件失败({LocalPath})", ex)
  168. End Try
  169. End Sub
  170. ''' <summary>
  171. ''' 通过多线程下载引擎下载文件。
  172. ''' </summary>
  173. Public Sub NetDownloadByLoader(Url As String, LocalPath As String, Optional LoaderToSyncProgress As LoaderBase = Nothing, Optional Check As FileChecker = Nothing, Optional UseBrowserUserAgent As Boolean = False)
  174. NetDownloadByLoader({Url}, LocalPath, LoaderToSyncProgress, Check, UseBrowserUserAgent)
  175. End Sub
  176. ''' <summary>
  177. ''' 通过多线程下载引擎下载文件。
  178. ''' </summary>
  179. ''' <param name="Urls">文件的 Url 列表。</param>
  180. ''' <param name="LocalPath">下载的本地地址。</param>
  181. Public Sub NetDownloadByLoader(Urls As IEnumerable(Of String), LocalPath As String, Optional LoaderToSyncProgress As LoaderBase = Nothing, Optional Check As FileChecker = Nothing, Optional UseBrowserUserAgent As Boolean = False)
  182. Dim NewTask As New LoaderDownload($"文件下载 {GetUuid()}#", New List(Of NetFile) From {New NetFile(Urls, LocalPath, Check, UseBrowserUserAgent)})
  183. Try
  184. NewTask.WaitForExit(LoaderToSyncProgress:=LoaderToSyncProgress)
  185. Catch ex As Exception
  186. Throw New WebException($"多线程直接下载文件失败(第一下载源:" & Urls.First() & ")", ex)
  187. Finally
  188. NewTask.Abort()
  189. End Try
  190. End Sub
  191. #End Region
  192. #Region "基础请求引擎"
  193. '基础请求函数
  194. Private Function SendRequest(Url As String, Method As HttpMethod,
  195. Optional Content As Object = Nothing, Optional Headers As Dictionary(Of String, String) = Nothing,
  196. Optional UseBrowserUserAgent As Boolean = False, Optional Timeout As Integer = 25000, Optional Encoding As Encoding = Nothing) As Byte()
  197. If RunInUi() AndAlso Not Url.Contains("//127.") Then Throw New Exception("在 UI 线程执行了网络请求")
  198. Dim Request As HttpRequestMessage = Nothing, CancelToken As CancellationTokenSource = Nothing, Response As HttpResponseMessage = Nothing
  199. Try
  200. Static Client As HttpClient = ClientExtensions.CreateClient(New FileCacheStore.FileStore(PathTemp & "Cache/Http/"), New HttpClientHandler With {
  201. .AutomaticDecompression = DecompressionMethods.Deflate Or DecompressionMethods.GZip Or DecompressionMethods.None,
  202. .UseCookies = False '不设为 False 就不能从 Header 手动传入 Cookies
  203. })
  204. Url = SecretCdnSign(Url)
  205. Request = New HttpRequestMessage(Method, Url)
  206. '写入 Content
  207. If Content IsNot Nothing AndAlso Request.Method <> HttpMethod.Get AndAlso Request.Method <> HttpMethod.Head Then
  208. Dim Bytes As Byte() = If(TypeOf Content Is Byte(), Content, If(Encoding, Encoding.UTF8).GetBytes(Content.ToString))
  209. Request.Content = New ByteArrayContent(Bytes)
  210. Request.Content.Headers.ContentLength = Bytes.Length
  211. End If
  212. '写入 Headers
  213. If Headers IsNot Nothing Then
  214. For Each Header In Headers
  215. If Header.Key.ToLower = "content-type" Then
  216. Request.Content?.Headers.TryAddWithoutValidation(Header.Key, Header.Value)
  217. Else
  218. Request.Headers.Add(Header.Key, Header.Value)
  219. End If
  220. Next
  221. End If
  222. SecretHeadersSign(Url, Request, UseBrowserUserAgent)
  223. '发送请求
  224. CancelToken = New CancellationTokenSource(Timeout)
  225. Response = Client.SendAsync(Request, HttpCompletionOption.ResponseHeadersRead, CancelToken.Token).GetAwaiter().GetResult()
  226. Dim ResponseStream = Response.Content.ReadAsStreamAsync().GetAwaiter().GetResult()
  227. Dim ResponseBytes As Byte()
  228. Using Stream As New MemoryStream
  229. ResponseStream.CopyToAsync(Stream, 81920, CancelToken.Token).GetAwaiter().GetResult()
  230. ResponseBytes = Stream.ToArray()
  231. End Using
  232. '输出
  233. If Response.IsSuccessStatusCode Then
  234. Return ResponseBytes
  235. Else
  236. Throw New ResponsedWebException($"错误码 {Response.StatusCode} ({CInt(Response.StatusCode)}),{Method},{Url}", If(Encoding, Encoding.UTF8).GetString(ResponseBytes))
  237. End If
  238. Catch ex As ThreadInterruptedException
  239. Throw
  240. Catch ex As ResponsedWebException
  241. Throw
  242. Catch ex As TaskCanceledException 'CancellationTokenSource 超时
  243. Throw New WebException($"连接服务器超时,请检查你的网络环境是否良好({Method}, {Url})", WebExceptionStatus.Timeout)
  244. Catch ex As Exception
  245. Throw New Exception($"网络请求出现意外异常({Method}, {Url})", ex)
  246. Finally
  247. Request?.Dispose()
  248. CancelToken?.Dispose()
  249. Response?.Dispose()
  250. End Try
  251. End Function
  252. Public Class ResponsedWebException
  253. Inherits WebException
  254. ''' <summary>
  255. ''' 远程服务器给予的回复。
  256. ''' </summary>
  257. Public Overloads Property Response As String
  258. Public Sub New(Message As String, Response As String)
  259. MyBase.New(Message)
  260. Me.Response = Response
  261. End Sub
  262. End Class
  263. #End Region
  264. #Region "多线程下载引擎"
  265. ''' <summary>
  266. ''' 最大线程数。
  267. ''' </summary>
  268. Public NetTaskThreadLimit As Integer
  269. ''' <summary>
  270. ''' 速度下限。
  271. ''' </summary>
  272. Public NetTaskSpeedLimitLow As Long = 256 * 1024L '256K/s
  273. ''' <summary>
  274. ''' 速度上限。若无限制则为 -1。
  275. ''' </summary>
  276. Public NetTaskSpeedLimitHigh As Long = -1
  277. ''' <summary>
  278. ''' 基于限速,当前可以下载的剩余量。
  279. ''' </summary>
  280. Public NetTaskSpeedLimitLeft As Long = -1
  281. Private ReadOnly NetTaskSpeedLimitLeftLock As New Object
  282. Private NetTaskSpeedLimitLeftLast As Long
  283. ''' <summary>
  284. ''' 正在运行中的线程数。
  285. ''' </summary>
  286. Public NetTaskThreadCount As Integer = 0
  287. Private ReadOnly NetTaskThreadCountLock As New Object
  288. ''' <summary>
  289. ''' 下载源。
  290. ''' </summary>
  291. Public Class NetSource
  292. Public Id As Integer
  293. Public Url As String
  294. Public FailCount As Integer
  295. Public Ex As Exception
  296. ''' <summary>
  297. ''' 若该下载源正在进行强制单线程下载,标记这个唯一的线程。
  298. ''' </summary>
  299. Public SingleThread As NetThread
  300. Public IsFailed As Boolean
  301. Public Overrides Function ToString() As String
  302. Return Url
  303. End Function
  304. End Class
  305. ''' <summary>
  306. ''' 下载进度标示。
  307. ''' </summary>
  308. Public Enum NetState
  309. ''' <summary>
  310. ''' 尚未进行已存在检查。
  311. ''' </summary>
  312. WaitForCheck = -1
  313. ''' <summary>
  314. ''' 尚未开始。
  315. ''' </summary>
  316. WaitForDownload = 0
  317. ''' <summary>
  318. ''' 正在连接,尚未获取文件大小。
  319. ''' </summary>
  320. Connect = 1
  321. ''' <summary>
  322. ''' 已获取文件大小,尚未有有效下载。
  323. ''' </summary>
  324. [Get] = 2
  325. ''' <summary>
  326. ''' 正在下载。
  327. ''' </summary>
  328. Download = 3
  329. ''' <summary>
  330. ''' 正在合并文件。
  331. ''' </summary>
  332. Merge = 4
  333. ''' <summary>
  334. ''' 不进行下载,因为已发现现存的文件。
  335. ''' </summary>
  336. WaitForCopy = 5
  337. ''' <summary>
  338. ''' 已完成。
  339. ''' </summary>
  340. Finish = 6
  341. ''' <summary>
  342. ''' 已失败或中断。
  343. ''' </summary>
  344. [Error] = 7
  345. End Enum
  346. ''' <summary>
  347. ''' 预下载检查行为。
  348. ''' </summary>
  349. Public Enum NetPreDownloadBehaviour
  350. ''' <summary>
  351. ''' 当文件已存在时,显示提示以提醒用户是否继续下载。
  352. ''' </summary>
  353. HintWhileExists
  354. ''' <summary>
  355. ''' 当文件已存在或正在下载时,直接退出下载函数执行,不对用户进行提示。
  356. ''' </summary>
  357. ExitWhileExistsOrDownloading
  358. ''' <summary>
  359. ''' 不进行已存在检查。
  360. ''' </summary>
  361. IgnoreCheck
  362. End Enum
  363. ''' <summary>
  364. ''' 下载线程。
  365. ''' </summary>
  366. Public Class NetThread
  367. Implements IEnumerable(Of NetThread), IEquatable(Of NetThread)
  368. ''' <summary>
  369. ''' 对应的下载任务。
  370. ''' </summary>
  371. Public Task As NetFile
  372. ''' <summary>
  373. ''' 对应的线程。
  374. ''' </summary>
  375. Public Thread As Thread
  376. ''' <summary>
  377. ''' 链表中的下一个线程。
  378. ''' </summary>
  379. Public NextThread As NetThread
  380. Private ReadOnly Iterator Property [Next]() As IEnumerable(Of NetThread)
  381. Get
  382. Dim CurrentChain As NetThread = Me
  383. While CurrentChain IsNot Nothing
  384. Yield CurrentChain
  385. CurrentChain = CurrentChain.NextThread
  386. End While
  387. End Get
  388. End Property
  389. Public Function GetEnumerator() As IEnumerator(Of NetThread) Implements IEnumerable(Of NetThread).GetEnumerator
  390. Return [Next].GetEnumerator()
  391. End Function
  392. Private Function IEnumerable_GetEnumerator() As IEnumerator Implements IEnumerable.GetEnumerator
  393. Return [Next].GetEnumerator()
  394. End Function
  395. ''' <summary>
  396. ''' 分配给任务中每个线程(无论其是否失败)的编号。
  397. ''' </summary>
  398. Public Uuid As Integer
  399. ''' <summary>
  400. ''' 是否为第一个线程。
  401. ''' </summary>
  402. Public ReadOnly Property IsFirstThread As Boolean
  403. Get
  404. Return DownloadStart = 0 AndAlso Task.FileSize = -2
  405. End Get
  406. End Property
  407. ''' <summary>
  408. ''' 该线程的缓存文件。
  409. ''' </summary>
  410. Public Temp As String
  411. ''' <summary>
  412. ''' 线程下载起始位置。
  413. ''' </summary>
  414. Public DownloadStart As Long
  415. ''' <summary>
  416. ''' 线程下载结束位置。
  417. ''' </summary>
  418. Public ReadOnly Property DownloadEnd As Long
  419. Get
  420. SyncLock Task.LockChain
  421. If NextThread Is Nothing Then
  422. If Task.IsUnknownSize Then
  423. Return 1000 * 1000 * 1000 * 1000L '约 1T
  424. Else
  425. Return Task.FileSize - 1
  426. End If
  427. Else
  428. Return NextThread.DownloadStart - 1
  429. End If
  430. End SyncLock
  431. End Get
  432. End Property
  433. ''' <summary>
  434. ''' 线程未下载的文件大小。
  435. ''' </summary>
  436. Public ReadOnly Property DownloadUndone As Long
  437. Get
  438. Return DownloadEnd - (DownloadStart + DownloadDone) + 1
  439. End Get
  440. End Property
  441. ''' <summary>
  442. ''' 线程已下载的文件大小。
  443. ''' </summary>
  444. Public DownloadDone As Long = 0
  445. ''' <summary>
  446. ''' 上次记速时的时间。
  447. ''' </summary>
  448. Private SpeedLastTime As Long = GetTimeTick()
  449. ''' <summary>
  450. ''' 上次记速时的已下载大小。
  451. ''' </summary>
  452. Private SpeedLastDone As Long = 0
  453. ''' <summary>
  454. ''' 当前的下载速度,单位为 Byte / 秒。
  455. ''' </summary>
  456. Public ReadOnly Property Speed As Long
  457. Get
  458. If GetTimeTick() - SpeedLastTime > 200 Then
  459. Dim DeltaTime As Long = GetTimeTick() - SpeedLastTime
  460. _Speed = (DownloadDone - SpeedLastDone) / (DeltaTime / 1000)
  461. SpeedLastDone = DownloadDone
  462. SpeedLastTime += DeltaTime
  463. End If
  464. Return _Speed
  465. End Get
  466. End Property
  467. Private _Speed As Long = 0
  468. ''' <summary>
  469. ''' 线程初始化时的时间。
  470. ''' </summary>
  471. Public InitTime As Long = GetTimeTick()
  472. ''' <summary>
  473. ''' 上次接受到有效数据的时间,-1 表示尚未有有效数据。
  474. ''' </summary>
  475. Public LastReceiveTime As Long = -1
  476. ''' <summary>
  477. ''' 当前线程的状态。
  478. ''' </summary>
  479. Public State As NetState = NetState.WaitForDownload
  480. ''' <summary>
  481. ''' 是否已经结束。
  482. ''' </summary>
  483. Public ReadOnly Property IsEnded As Boolean
  484. Get
  485. Return State = NetState.Finish OrElse State = NetState.Error
  486. End Get
  487. End Property
  488. ''' <summary>
  489. ''' 当前选取的是哪一个 Url。
  490. ''' </summary>
  491. Public Source As NetSource
  492. '允许进行 UUID 比较
  493. Public Overloads Function Equals(other As NetThread) As Boolean Implements IEquatable(Of NetThread).Equals
  494. Return other IsNot Nothing AndAlso Uuid = other.Uuid
  495. End Function
  496. Public Overrides Function Equals(obj As Object) As Boolean
  497. Return Equals(TryCast(obj, NetThread))
  498. End Function
  499. Public Shared Operator =(left As NetThread, right As NetThread) As Boolean
  500. Return EqualityComparer(Of NetThread).Default.Equals(left, right)
  501. End Operator
  502. Public Shared Operator <>(left As NetThread, right As NetThread) As Boolean
  503. Return Not left = right
  504. End Operator
  505. End Class
  506. ''' <summary>
  507. ''' 下载单个文件。
  508. ''' </summary>
  509. Public Class NetFile
  510. #Region "属性"
  511. ''' <summary>
  512. ''' 所属的文件列表任务。
  513. ''' </summary>
  514. Public Tasks As New SafeList(Of LoaderDownload)
  515. ''' <summary>
  516. ''' 所有下载源。
  517. ''' </summary>
  518. Public Sources As SafeList(Of NetSource)
  519. ''' <summary>
  520. ''' 用于在第一个线程出错时切换下载源。
  521. ''' </summary>
  522. Private FirstThreadSource As Integer = 0
  523. ''' <summary>
  524. ''' 所有已经被标记为失败的,但未完整尝试过的,不允许断点续传的下载源。
  525. ''' </summary>
  526. Public SourcesOnce As New SafeList(Of NetSource)
  527. ''' <summary>
  528. ''' 仅当合并失败或首次下载失败时,会将所有下载源重新标记为不允许断点续传的下载源,逐个重新尝试下载。
  529. ''' 这一策略可以兼容多个下载源中的一部分返回错误的文件的情况,以及部分在多线程下载时会抽风的源。
  530. ''' </summary>
  531. Private Retried As Boolean = False
  532. ''' <summary>
  533. ''' 获取从某个源开始,第一个可用的源。
  534. ''' </summary>
  535. Private Function GetSource(Optional Id As Integer = 0) As NetSource
  536. If Id >= Sources.Count OrElse Id < 0 Then Id = 0
  537. SyncLock LockSource
  538. If HasAvailableSource(False) Then
  539. '存在多线程可用源
  540. Dim CurrentSource As NetSource = Sources(Id)
  541. While CurrentSource.IsFailed
  542. Id += 1
  543. If Id >= Sources.Count Then Id = 0
  544. CurrentSource = Sources(Id)
  545. End While
  546. Return CurrentSource
  547. ElseIf SourcesOnce.Any Then
  548. '仅存在单线程可用源
  549. Return SourcesOnce.First
  550. Else
  551. '没有可用源
  552. Return Nothing
  553. End If
  554. End SyncLock
  555. End Function
  556. ''' <summary>
  557. ''' 是否已经没有可用源了。
  558. ''' </summary>
  559. Public Function HasAvailableSource(Optional AllowOnceSource As Boolean = True) As Boolean
  560. SyncLock LockSource
  561. If AllowOnceSource AndAlso SourcesOnce.Any Then Return True
  562. If Sources.Any(Function(s) Not s.IsFailed) Then Return True
  563. End SyncLock
  564. Return False
  565. End Function
  566. ''' <summary>
  567. ''' 存储在本地的带文件名的地址。
  568. ''' </summary>
  569. Public LocalPath As String = Nothing
  570. ''' <summary>
  571. ''' 存储在本地的文件名。
  572. ''' </summary>
  573. Public LocalName As String = Nothing
  574. ''' <summary>
  575. ''' 当前的下载状态。
  576. ''' </summary>
  577. Public State As NetState = NetState.WaitForCheck
  578. ''' <summary>
  579. ''' 导致下载失败的原因。
  580. ''' </summary>
  581. Public Ex As New List(Of Exception)
  582. ''' <summary>
  583. ''' 作为文件组成部分的线程链表。
  584. ''' 如果没有线程,可以为 Nothing。
  585. ''' </summary>
  586. Public Threads As NetThread
  587. ''' <summary>
  588. ''' 文件的总大小。若为 -2 则为未获取,若为 -1 则为无法获取准确大小。
  589. ''' </summary>
  590. Public FileSize As Long = -2
  591. ''' <summary>
  592. ''' 该文件是否无法获取准确大小。
  593. ''' </summary>
  594. Public IsUnknownSize As Boolean = False
  595. ''' <summary>
  596. ''' 该文件是否不需要分割。
  597. ''' </summary>
  598. Public ReadOnly Property IsNoSplit As Boolean
  599. Get
  600. Return IsUnknownSize OrElse FileSize < FilePieceLimit
  601. End Get
  602. End Property
  603. ''' <summary>
  604. ''' 为不需要分割的小文件在内存中提供临时存储。
  605. ''' </summary>
  606. Private Cache As MemoryStream
  607. ''' <summary>
  608. ''' 文件的已下载大小。
  609. ''' </summary>
  610. Public DownloadDone As Long = 0
  611. Private ReadOnly LockDone As New Object
  612. ''' <summary>
  613. ''' 文件的校验规则。
  614. ''' </summary>
  615. Public Check As FileChecker
  616. ''' <summary>
  617. ''' 下载时是否添加浏览器 UA。
  618. ''' </summary>
  619. Public UseBrowserUserAgent As Boolean
  620. ''' <summary>
  621. ''' 上次记速时的时间。
  622. ''' </summary>
  623. Private SpeedLastTime As Long = GetTimeTick()
  624. ''' <summary>
  625. ''' 上次记速时的已下载大小。
  626. ''' </summary>
  627. Private SpeedLastDone As Long = 0
  628. ''' <summary>
  629. ''' 当前的下载速度,单位为 Byte / 秒。
  630. ''' </summary>
  631. Public ReadOnly Property Speed As Long
  632. Get
  633. If GetTimeTick() - SpeedLastTime > 200 Then
  634. Dim DeltaTime As Long = GetTimeTick() - SpeedLastTime
  635. _Speed = (DownloadDone - SpeedLastDone) / (DeltaTime / 1000)
  636. SpeedLastDone = DownloadDone
  637. SpeedLastTime += DeltaTime
  638. End If
  639. Return _Speed
  640. End Get
  641. End Property
  642. Private _Speed As Long = 0
  643. ''' <summary>
  644. ''' 该文件是否由本地文件直接拷贝完成。
  645. ''' </summary>
  646. Public IsCopy As Boolean = False
  647. ''' <summary>
  648. ''' 本文件的显示进度。
  649. ''' </summary>
  650. Public ReadOnly Property Progress As Double
  651. Get
  652. Select Case State
  653. Case NetState.WaitForCheck
  654. Return 0
  655. Case NetState.WaitForCopy
  656. Return 0.2
  657. Case NetState.WaitForDownload
  658. Return 0.01
  659. Case NetState.Connect
  660. Return 0.02
  661. Case NetState.Get
  662. Return 0.04
  663. Case NetState.Download
  664. '正在下载中,对应 5% ~ 98%
  665. Dim OriginalProgress As Double = If(IsUnknownSize, 0.5, DownloadDone / Math.Max(FileSize, 1))
  666. OriginalProgress = 1 - (1 - OriginalProgress) ^ 0.9
  667. Return OriginalProgress * 0.93 + 0.05
  668. Case NetState.Merge
  669. Return 0.99
  670. Case NetState.Finish, NetState.Error
  671. Return 1
  672. Case Else
  673. Throw New ArgumentOutOfRangeException("文件状态未知:" & State)
  674. End Select
  675. End Get
  676. End Property
  677. ''' <summary>
  678. ''' 各个线程建立连接成功的总次数。
  679. ''' </summary>
  680. Private ConnectCount As Integer = 0
  681. ''' <summary>
  682. ''' 各个线程建立连接成功的总时间。
  683. ''' </summary>
  684. Private ConnectTime As Long = 0
  685. ''' <summary>
  686. ''' 各个线程建立连接成功的平均时间,单位为毫秒,-1 代表尚未有成功连接。
  687. ''' </summary>
  688. Private ReadOnly Property ConnectAverage As Integer
  689. Get
  690. SyncLock LockCount
  691. Return If(ConnectCount = 0, -1, ConnectTime / ConnectCount)
  692. End SyncLock
  693. End Get
  694. End Property
  695. Private Const FilePieceLimit As Long = 256 * 1024
  696. Public ReadOnly LockCount As New Object
  697. Public ReadOnly LockState As New Object
  698. Public ReadOnly LockChain As New Object
  699. Public ReadOnly LockSource As New Object
  700. Public ReadOnly Uuid As Integer = GetUuid()
  701. Public Overrides Function Equals(obj As Object) As Boolean
  702. Dim file = TryCast(obj, NetFile)
  703. Return file IsNot Nothing AndAlso Uuid = file.Uuid
  704. End Function
  705. #End Region
  706. ''' <summary>
  707. ''' 新建一个需要下载的文件。
  708. ''' </summary>
  709. ''' <param name="LocalPath">包含文件名的本地地址。</param>
  710. Public Sub New(Urls As IEnumerable(Of String), LocalPath As String, Optional Check As FileChecker = Nothing, Optional UseBrowserUserAgent As Boolean = False)
  711. Dim Sources As New List(Of NetSource)
  712. Dim Count As Integer = 0
  713. Urls = Urls.Distinct.ToArray
  714. For Each Source As String In Urls
  715. Sources.Add(New NetSource With {.FailCount = 0, .Url = SecretCdnSign(Source.Replace(vbCr, "").Replace(vbLf, "").Trim), .Id = Count, .IsFailed = False, .Ex = Nothing})
  716. Count += 1
  717. Next
  718. Me.Sources = Sources
  719. Me.LocalPath = LocalPath
  720. Me.Check = Check
  721. Me.UseBrowserUserAgent = UseBrowserUserAgent
  722. Me.LocalName = GetFileNameFromPath(LocalPath)
  723. End Sub
  724. ''' <summary>
  725. ''' 尝试开始一个新的下载线程。
  726. ''' 如果失败,返回 Nothing。
  727. ''' </summary>
  728. Public Function TryBeginThread() As NetThread
  729. Try
  730. '条件检测
  731. If NetTaskThreadCount >= NetTaskThreadLimit OrElse Not HasAvailableSource() OrElse
  732. (IsNoSplit AndAlso Threads IsNot Nothing AndAlso Threads.State <> NetState.Error) Then Return Nothing
  733. If State >= NetState.Merge OrElse State = NetState.WaitForCheck Then Return Nothing
  734. SyncLock LockState
  735. If State < NetState.Connect Then State = NetState.Connect
  736. End SyncLock
  737. '初始化参数
  738. Dim StartPosition As Long, StartSource As NetSource = Nothing
  739. Dim Th As Thread, ThreadInfo As NetThread
  740. SyncLock LockChain
  741. '获取线程起点与下载源
  742. '不分割
  743. If IsNoSplit Then GoTo StartSingleThreadDownload
  744. '只剩下单线程可用点
  745. If Not HasAvailableSource(False) Then
  746. If SourcesOnce.First.SingleThread IsNot Nothing AndAlso SourcesOnce.First.SingleThread.State <> NetState.Error Then Return Nothing
  747. StartSingleThreadDownload:
  748. Reset()
  749. State = NetState.Get
  750. End If
  751. '首个开始点
  752. If Threads Is Nothing Then
  753. StartPosition = 0
  754. StartSource = GetSource(FirstThreadSource)
  755. FirstThreadSource = StartSource.Id + 1
  756. GoTo StartThread
  757. End If
  758. '寻找失败点
  759. For Each Thread As NetThread In Threads
  760. If Thread.State = NetState.Error AndAlso Thread.DownloadUndone > 0 Then
  761. StartPosition = Thread.DownloadStart + Thread.DownloadDone
  762. StartSource = GetSource(Thread.Source.Id + 1)
  763. GoTo StartThread
  764. End If
  765. Next
  766. '是否禁用多线程,以及规定碎片大小
  767. Dim TargetUrl As String = GetSource().Url
  768. If TargetUrl.Contains("pcl2-server") OrElse TargetUrl.Contains("bmclapi") OrElse TargetUrl.Contains("github.com") OrElse
  769. TargetUrl.Contains("optifine.net") OrElse TargetUrl.Contains("modrinth") Then Return Nothing
  770. '寻找最大碎片
  771. 'FUTURE: 下载引擎重做,计算下载源平均链接时间和线程下载速度,按最高时间节省来开启多线程
  772. Dim FilePieceMax As NetThread = Threads
  773. For Each Thread As NetThread In Threads
  774. If Thread.DownloadUndone > FilePieceMax.DownloadUndone Then FilePieceMax = Thread
  775. Next
  776. If FilePieceMax Is Nothing OrElse FilePieceMax.DownloadUndone < FilePieceLimit Then Return Nothing
  777. StartPosition = FilePieceMax.DownloadEnd - FilePieceMax.DownloadUndone * 0.4
  778. StartSource = GetSource()
  779. '开始线程
  780. StartThread:
  781. If (StartPosition > FileSize AndAlso FileSize >= 0 AndAlso Not IsUnknownSize) OrElse StartPosition < 0 OrElse IsNothing(StartSource) Then Return Nothing
  782. '构建线程
  783. Dim ThreadUuid As Integer = GetUuid()
  784. If Not Tasks.Any() Then Return Nothing '由于中断,已没有可用任务
  785. Th = New Thread(AddressOf Thread) With {.Name = $"下载 {Tasks(0).Uuid}/{Uuid}/{ThreadUuid}#", .Priority = ThreadPriority.BelowNormal}
  786. ThreadInfo = New NetThread With {.Uuid = ThreadUuid, .DownloadStart = StartPosition, .Thread = Th, .Source = StartSource, .Task = Me, .State = NetState.WaitForDownload}
  787. '链表处理
  788. If ThreadInfo.IsFirstThread OrElse Threads Is Nothing Then
  789. Threads = ThreadInfo
  790. Else
  791. Dim CurrentChain As NetThread = Threads
  792. While CurrentChain.DownloadEnd <= StartPosition
  793. CurrentChain = CurrentChain.NextThread
  794. End While
  795. ThreadInfo.NextThread = CurrentChain.NextThread
  796. CurrentChain.NextThread = ThreadInfo
  797. End If
  798. End SyncLock
  799. '开始线程
  800. SyncLock NetTaskThreadCountLock
  801. NetTaskThreadCount += 1
  802. End SyncLock
  803. SyncLock LockSource
  804. If Not HasAvailableSource(False) Then SourcesOnce.First.SingleThread = ThreadInfo
  805. End SyncLock
  806. Th.Start(ThreadInfo)
  807. Return ThreadInfo
  808. Catch ex As Exception
  809. Log(ex, "尝试开始下载线程失败(" & If(LocalName, "Nothing") & ")", LogLevel.Hint)
  810. Return Nothing
  811. End Try
  812. End Function
  813. ''' <summary>
  814. ''' 每个下载线程执行的代码。
  815. ''' </summary>
  816. Private Sub Thread(Th As NetThread)
  817. If ModeDebug OrElse Th.DownloadStart = 0 Then Log($"[Download] {LocalName}:开始,起始点 {Th.DownloadStart},{Th.Source.Url}")
  818. Dim ResultStream As Stream = Nothing
  819. '部分下载源真的特别慢,并且只需要一个请求,例如 Ping 为 20s,如果增长太慢,就会造成类似 2.5s 5s 7.5s 10s 12.5s... 的极大延迟
  820. '延迟过长会导致某些特别慢的链接迟迟不被掐死
  821. Dim Timeout As Integer = Math.Min(Math.Max(ConnectAverage, 6000) * (1 + Th.Source.FailCount), 30000)
  822. Th.State = NetState.Connect
  823. Try
  824. Dim HttpDataCount As Integer = 0
  825. If SourcesOnce.Contains(Th.Source) AndAlso Th <> Th.Source.SingleThread Then GoTo SourceBreak
  826. Dim HttpRequest As New HttpRequestMessage(HttpMethod.Get, Th.Source.Url)
  827. SecretHeadersSign(Th.Source.Url, HttpRequest, UseBrowserUserAgent)
  828. If Not Th.IsFirstThread Then HttpRequest.Headers.Range = New RangeHeaderValue(Th.DownloadStart, Nothing)
  829. Dim ContentLength As Long = 0
  830. Using CancelToken As New CancellationTokenSource(Timeout)
  831. Static Client As New HttpClient(New HttpClientHandler With {
  832. .AutomaticDecompression = DecompressionMethods.Deflate Or DecompressionMethods.GZip Or DecompressionMethods.None
  833. })
  834. Using Response As HttpResponseMessage = Client.SendAsync(HttpRequest, HttpCompletionOption.ResponseHeadersRead, CancelToken.Token).GetAwaiter().GetResult()
  835. If Not Response.IsSuccessStatusCode Then Throw New Exception($"错误码 {Response.StatusCode} ({CInt(Response.StatusCode)}),{Th.Source.Url}") '状态码检查
  836. If State = NetState.Error Then GoTo SourceBreak '快速中断
  837. If ModeDebug AndAlso Response.RequestMessage.RequestUri.ToString <> Th.Source.Url Then Log($"[Download] {LocalName}:重定向至 {Response.RequestMessage.RequestUri}")
  838. '文件大小校验
  839. ContentLength = Response.Content.Headers.ContentLength.GetValueOrDefault(-1)
  840. If ContentLength = -1 Then
  841. If FileSize > 1 Then
  842. If Th.DownloadStart = 0 Then
  843. Log($"[Download] {LocalName}:文件大小未知,但已从其他下载源获取,不作处理")
  844. Else
  845. Log($"[Download] {LocalName}:ContentLength 返回了 -1,无法确定是否支持分段下载,视作不支持")
  846. GoTo NotSupportRange
  847. End If
  848. Else
  849. FileSize = -1 : IsUnknownSize = True
  850. Log($"[Download] {LocalName}:文件大小未知")
  851. End If
  852. ElseIf ContentLength < 0 Then
  853. Throw New Exception("获取片大小失败,结果为 " & ContentLength & "。")
  854. ElseIf Th.IsFirstThread Then
  855. If Check IsNot Nothing Then
  856. If ContentLength < Check.MinSize AndAlso Check.MinSize > 0 Then
  857. Throw New Exception($"文件大小不足,获取结果为 {ContentLength},要求至少为 {Check.MinSize}。")
  858. End If
  859. If ContentLength <> Check.ActualSize AndAlso Check.ActualSize > 0 Then
  860. Throw New Exception($"文件大小不一致,获取结果为 {ContentLength},要求必须为 {Check.ActualSize}。")
  861. End If
  862. End If
  863. FileSize = ContentLength : IsUnknownSize = False
  864. Log($"[Download] {LocalName}:文件大小 {ContentLength}({GetString(ContentLength)})")
  865. '若文件大小大于 50 M,进行剩余磁盘空间校验
  866. If ContentLength > 50 * 1024 * 1024 Then
  867. For Each Drive As DriveInfo In DriveInfo.GetDrives
  868. Dim DriveName As String = Drive.Name.First.ToString
  869. Dim RequiredSpace = If(PathTemp.StartsWithF(DriveName), ContentLength * 1.1, 0) +
  870. If(LocalPath.StartsWithF(DriveName), ContentLength + 5 * 1024 * 1024, 0)
  871. If Drive.TotalFreeSpace < RequiredSpace Then
  872. Throw New Exception(DriveName & " 盘空间不足,无法进行下载。" & vbCrLf & "需要至少 " & GetString(RequiredSpace) & " 空间,但当前仅剩余 " & GetString(Drive.TotalFreeSpace) & "。" &
  873. If(PathTemp.StartsWithF(DriveName), vbCrLf & vbCrLf & "下载时需要与文件同等大小的空间存放缓存,你可以在设置中调整缓存文件夹的位置。", ""))
  874. End If
  875. Next
  876. End If
  877. ElseIf FileSize < 0 Then
  878. Throw New Exception("非首线程运行时,尚未获取文件大小")
  879. ElseIf Th.DownloadStart > 0 AndAlso ContentLength = FileSize Then
  880. NotSupportRange:
  881. SyncLock LockSource
  882. If SourcesOnce.Contains(Th.Source) Then
  883. GoTo SourceBreak
  884. Else
  885. SourcesOnce.Add(Th.Source)
  886. End If
  887. End SyncLock
  888. Throw New WebException($"该下载源不支持分段下载:Range 起始于 {Th.DownloadStart},预期 ContentLength 为 {FileSize - Th.DownloadStart},返回 ContentLength 为 {ContentLength},总文件大小 {FileSize}")
  889. ElseIf Not FileSize - Th.DownloadStart = ContentLength Then
  890. Throw New WebException($"获取到的分段大小不一致:Range 起始于 {Th.DownloadStart},预期 ContentLength 为 {FileSize - Th.DownloadStart},返回 ContentLength 为 {ContentLength},总文件大小 {FileSize}")
  891. End If
  892. 'Log($"[Download] {LocalName} {Info.Uuid}#:通过大小检查,文件大小 {FileSize},起始点 {Info.DownloadStart},ContentLength {ContentLength}")
  893. Th.State = NetState.Get
  894. SyncLock LockState
  895. If State < NetState.Get Then State = NetState.Get
  896. End SyncLock
  897. '创建缓存文件
  898. If IsNoSplit Then
  899. Th.Temp = Nothing
  900. Cache = New MemoryStream
  901. ResultStream = Cache
  902. Else
  903. Th.Temp = $"{PathTemp}Download\{Uuid}_{Th.Uuid}_{RandomInteger(0, 999999)}.tmp"
  904. ResultStream = New FileStream(Th.Temp, FileMode.Create, FileAccess.Write, FileShare.Read)
  905. End If
  906. '开始下载
  907. Using ResponseStream = Response.Content.ReadAsStreamAsync().GetAwaiter().GetResult()
  908. If Setup.Get("SystemDebugDelay") Then Threading.Thread.Sleep(RandomInteger(50, 3000))
  909. Dim ResponseBytes As Byte() = New Byte(16384) {}
  910. HttpDataCount = ResponseStream.ReadAsync(ResponseBytes, 0, 16384, CancelToken.Token).GetAwaiter().GetResult()
  911. While (IsUnknownSize OrElse Th.DownloadUndone > 0) AndAlso '判断是否下载完成
  912. HttpDataCount > 0 AndAlso Not IsProgramEnded AndAlso State < NetState.Merge AndAlso (Not Th.Source.IsFailed OrElse Th.Source.SingleThread = Th)
  913. '限速
  914. While NetTaskSpeedLimitHigh > 0 AndAlso NetTaskSpeedLimitLeft <= 0
  915. Threading.Thread.Sleep(16)
  916. End While
  917. Dim RealDataCount As Integer = If(IsUnknownSize, HttpDataCount, Math.Min(HttpDataCount, Th.DownloadUndone))
  918. SyncLock NetTaskSpeedLimitLeftLock
  919. If NetTaskSpeedLimitHigh > 0 Then NetTaskSpeedLimitLeft -= RealDataCount
  920. End SyncLock
  921. Dim DeltaTime = GetTimeTick() - Th.LastReceiveTime
  922. If DeltaTime > 1000000 Then DeltaTime = 1 '时间刻反转导致出现极大值
  923. If RealDataCount > 0 Then
  924. '有数据
  925. If Th.DownloadDone = 0 Then
  926. '第一次接受到数据
  927. Th.State = NetState.Download
  928. SyncLock LockState
  929. If State < NetState.Download Then State = NetState.Download
  930. End SyncLock
  931. SyncLock LockCount
  932. ConnectCount += 1
  933. ConnectTime += GetTimeTick() - Th.InitTime
  934. End SyncLock
  935. End If
  936. SyncLock LockCount
  937. Th.Source.FailCount = 0
  938. For Each Task In Tasks
  939. Task.FailCount = 0
  940. Next
  941. End SyncLock
  942. NetManager.DownloadDone += RealDataCount
  943. SyncLock LockDone
  944. DownloadDone += RealDataCount
  945. End SyncLock
  946. Th.DownloadDone += RealDataCount
  947. ResultStream.Write(ResponseBytes, 0, RealDataCount)
  948. '检查速度是否过慢
  949. If DeltaTime > 1500 AndAlso DeltaTime > RealDataCount Then '数据包间隔大于 1.5s,且速度小于 1.5K/s
  950. Throw New TimeoutException("由于速度过慢断开链接,下载 " & RealDataCount & " B,消耗 " & DeltaTime & " ms。")
  951. End If
  952. Th.LastReceiveTime = GetTimeTick()
  953. '已完成
  954. If Th.DownloadUndone = 0 AndAlso Not IsUnknownSize Then Exit While
  955. ElseIf Th.LastReceiveTime > 0 AndAlso DeltaTime > Timeout Then
  956. '无数据,且已超时
  957. Throw New TimeoutException("操作超时,无数据。")
  958. End If
  959. HttpDataCount = ResponseStream.Read(ResponseBytes, 0, 16384)
  960. End While
  961. End Using
  962. End Using
  963. End Using
  964. SourceBreak:
  965. If State = NetState.Error OrElse (Th.Source.IsFailed AndAlso Th.Source.SingleThread <> Th) OrElse (Th.DownloadUndone > 0 AndAlso Not IsUnknownSize) Then
  966. '被外部中断
  967. Th.State = NetState.Error
  968. Log($"[Download] {LocalName}:中断")
  969. ElseIf HttpDataCount = 0 AndAlso Th.DownloadUndone > 0 AndAlso Not IsUnknownSize Then
  970. '服务器无返回数据
  971. Throw New Exception($"返回的 ContentLength 过多:ContentLength 为 {ContentLength},但获取到的总数据量仅为 {Th.DownloadDone}(全文件总数据量 {DownloadDone})")
  972. Else
  973. '本线程完成
  974. Th.State = NetState.Finish
  975. If ModeDebug Then Log($"[Download] {LocalName}:完成,已下载 {Th.DownloadDone}({Th.DownloadStart}~{Th.DownloadEnd})")
  976. End If
  977. Catch ex As Exception
  978. Log($"[Download] {LocalName}:出错,{If(TypeOf ex Is TaskCanceledException, $"已超时({Timeout}ms)", GetExceptionDetail(ex))}")
  979. SourceFail(Th, ex, False)
  980. Finally
  981. SyncLock NetTaskThreadCountLock
  982. NetTaskThreadCount -= 1
  983. End SyncLock
  984. '合并
  985. If Not IsNoSplit Then ResultStream?.Dispose()
  986. If ((FileSize >= 0 AndAlso DownloadDone >= FileSize) OrElse (FileSize = -1 AndAlso DownloadDone > 0)) AndAlso State < NetState.Merge Then Merge(Th)
  987. End Try
  988. End Sub
  989. Private Sub SourceFail(Th As NetThread, ex As Exception, IsMergeFailure As Boolean)
  990. '状态变更
  991. SyncLock LockCount
  992. Th.Source.FailCount += 1
  993. For Each Task In Tasks
  994. Task.FailCount += 1
  995. Next
  996. End SyncLock
  997. Th.State = NetState.Error
  998. Th.Source.Ex = ex
  999. '根据情况判断,是否在多线程下禁用下载源(连续错误过多,或不支持断点续传)
  1000. If IsMergeFailure OrElse
  1001. ex.Message.Contains("该下载源不支持") OrElse ex.Message.Contains("未能解析") OrElse ex.Message.Contains("(404)") OrElse
  1002. ex.Message.Contains("(502)") OrElse ex.Message.Contains("无返回数据") OrElse ex.Message.Contains("空间不足") OrElse ex.Message.Contains("获取到的分段大小不一致") OrElse
  1003. (ex.Message.Contains("(403)") AndAlso Not Th.Source.Url.ContainsF("bmclapi")) OrElse 'BMCLAPI 的部分源在高频率请求下会返回 403,所以不应因此禁用下载源
  1004. (Th.Source.FailCount >= MathClamp(NetTaskThreadLimit, 5, 30) AndAlso DownloadDone < 1) OrElse Th.Source.FailCount > NetTaskThreadLimit + 2 Then
  1005. '当一个下载源有多个线程在下载时,只选择其中一个线程进行后续处理
  1006. Dim IsThisFail As Boolean = False
  1007. SyncLock LockSource
  1008. If Not Th.Source.IsFailed OrElse Th.Source.SingleThread = Th Then
  1009. IsThisFail = True
  1010. Th.Source.IsFailed = True
  1011. End If
  1012. End SyncLock
  1013. '……后续处理
  1014. If IsThisFail Then
  1015. Log($"[Download] {LocalName}:下载源被禁用({Th.Source.Id}):{Th.Source.Url}")
  1016. Log(ex, $"{If(SourcesOnce.FirstOrDefault?.SingleThread Is Nothing, "", "单线程")}下载源 {Th.Source.Id} 已被禁用",
  1017. If(ex.Message.Contains("不支持分段下载") OrElse ex.Message.Contains("(404)") OrElse ex.Message.Contains("(416)"), LogLevel.Developer, LogLevel.Debug))
  1018. SyncLock LockSource
  1019. SourcesOnce.Remove(Th.Source)
  1020. End SyncLock
  1021. If ex.Message.Contains("空间不足") Then
  1022. '硬盘空间不足:强制失败
  1023. Fail(ex)
  1024. ElseIf HasAvailableSource() AndAlso Not IsMergeFailure Then
  1025. '当前源失败,但还有下载源:正常地继续执行
  1026. ElseIf Not Retried AndAlso Sources.Count > 1 Then
  1027. '合并失败或首次下载失败,未重试:将所有下载源重新标记为不允许断点续传的下载源,逐个重新尝试下载
  1028. Log($"[Download] {LocalName}:文件下载失败,正在自动重试……", If(ModeDebug, LogLevel.Hint, LogLevel.Debug)) '在调试模式下给出红色提示
  1029. Retried = True
  1030. SyncLock LockSource
  1031. SourcesOnce.Clear()
  1032. For Each Source In Sources
  1033. SourcesOnce.Add(Source)
  1034. Source.IsFailed = True
  1035. Next
  1036. End SyncLock
  1037. Reset()
  1038. SyncLock LockState
  1039. State = NetState.WaitForDownload
  1040. End SyncLock
  1041. ElseIf HasAvailableSource() AndAlso IsMergeFailure Then
  1042. '合并失败且单个源失败:继续下一个源
  1043. Reset()
  1044. SyncLock LockState
  1045. State = NetState.WaitForDownload
  1046. End SyncLock
  1047. Else
  1048. '失败
  1049. Log($"[Download] {LocalName}:已无可用下载源,下载失败")
  1050. Dim ExampleEx As Exception = Nothing
  1051. SyncLock LockSource
  1052. For Each Source As NetSource In Sources
  1053. Log("[Download] 已禁用的下载源:" & Source.Url)
  1054. If Source.Ex IsNot Nothing Then
  1055. ExampleEx = Source.Ex
  1056. Log(Source.Ex, "下载源禁用原因", LogLevel.Developer)
  1057. End If
  1058. Next
  1059. End SyncLock
  1060. Fail(ExampleEx)
  1061. End If
  1062. End If
  1063. End If
  1064. '清理当前已下载的内容
  1065. If FileSize = -2 Then Reset()
  1066. End Sub
  1067. Private Sub Reset()
  1068. FileSize = -2
  1069. Cache?.Dispose() : Cache = Nothing
  1070. SyncLock LockChain
  1071. Threads = Nothing
  1072. End SyncLock
  1073. NetManager.DownloadDone -= DownloadDone
  1074. SyncLock LockDone
  1075. DownloadDone = 0
  1076. End SyncLock
  1077. SpeedLastDone = 0
  1078. End Sub
  1079. '最终收束事件
  1080. ''' <summary>
  1081. ''' 下载完成。合并文件。
  1082. ''' </summary>
  1083. Private Sub Merge(Th As NetThread)
  1084. '状态判断
  1085. SyncLock LockState
  1086. If State < NetState.Merge Then
  1087. State = NetState.Merge
  1088. Else
  1089. Return
  1090. End If
  1091. End SyncLock
  1092. Dim RetryCount As Integer = 0
  1093. Try
  1094. Retry:
  1095. SyncLock LockChain
  1096. '创建文件夹
  1097. If File.Exists(LocalPath) Then File.Delete(LocalPath)
  1098. Directory.CreateDirectory(GetPathFromFullPath(LocalPath))
  1099. '合并文件
  1100. If IsNoSplit Then
  1101. '仅有一个线程,从缓存中输出
  1102. If ModeDebug Then Log($"[Download] {LocalName}:下载结束,从内存输出文件")
  1103. Cache.Position = 0
  1104. WriteFile(LocalPath, Cache)
  1105. ElseIf Threads.DownloadDone = DownloadDone AndAlso Threads.Temp IsNot Nothing Then
  1106. '仅有一个文件,直接复制
  1107. If ModeDebug Then Log($"[Download] {LocalName}:下载结束,仅有一个文件,无需合并")
  1108. CopyFile(Threads.Temp, LocalPath)
  1109. Else
  1110. '有多个线程,合并
  1111. If ModeDebug Then Log($"[Download] {LocalName}:下载结束,开始合并文件")
  1112. Using MergeFile As New FileStream(LocalPath, FileMode.Create)
  1113. Using AddWriter As New BinaryWriter(MergeFile)
  1114. For Each Thread As NetThread In Threads
  1115. If Thread.DownloadDone = 0 OrElse Thread.Temp Is Nothing Then Continue For
  1116. Using fs As New FileStream(Thread.Temp, FileMode.Open, FileAccess.Read, FileShare.Read)
  1117. Using TempReader As New BinaryReader(fs)
  1118. AddWriter.Write(TempReader.ReadBytes(Thread.DownloadDone))
  1119. End Using
  1120. End Using
  1121. Next
  1122. End Using
  1123. End Using
  1124. End If
  1125. '检查文件
  1126. Dim CheckResult As String = Check?.Check(LocalPath)
  1127. If CheckResult Is Nothing AndAlso Not IsUnknownSize AndAlso Check IsNot Nothing Then
  1128. If Check.ActualSize = -1 Then
  1129. CheckResult = (New FileChecker With {.ActualSize = FileSize}).Check(LocalPath) '不修改原始的 Checker,以免污染原始实例
  1130. ElseIf Check.ActualSize <> FileSize Then
  1131. CheckResult = $"文件大小不一致:任务校验要求为 {Check.ActualSize},请求结果为 {FileSize}"
  1132. End If
  1133. End If
  1134. If CheckResult IsNot Nothing Then
  1135. Log($"[Download] {LocalName} 文件校验失败,下载线程细节:")
  1136. For Each T As NetThread In Threads
  1137. Log($"[Download] - {T.Uuid}#,状态 {GetStringFromEnum(T.State)},范围 {T.DownloadStart}~{T.DownloadEnd},已下载 {T.DownloadDone},未下载 {T.DownloadUndone}")
  1138. Next
  1139. Throw New Exception(CheckResult)
  1140. End If
  1141. '后处理
  1142. If Not IsNoSplit Then
  1143. For Each Thread As NetThread In Threads
  1144. If Thread.Temp IsNot Nothing Then File.Delete(Thread.Temp)
  1145. Next
  1146. End If
  1147. Finish()
  1148. End SyncLock
  1149. Catch ex As Exception
  1150. RetryCount += 1
  1151. Log(ex, $"合并文件出错,第 {RetryCount} 次尝试({LocalName})")
  1152. '重新尝试合并
  1153. If RetryCount < 3 Then
  1154. Threading.Thread.Sleep(500 * RetryCount)
  1155. GoTo Retry
  1156. End If
  1157. '失败,禁用当前下载源并重启下载
  1158. If File.Exists(LocalPath) Then File.Delete(LocalPath)
  1159. SourceFail(Th, ex, True)
  1160. Finally
  1161. Cache?.Dispose()
  1162. End Try
  1163. End Sub
  1164. ''' <summary>
  1165. ''' 下载失败。
  1166. ''' </summary>
  1167. Private Sub Fail(Optional RaiseEx As Exception = Nothing)
  1168. SyncLock LockState
  1169. If State >= NetState.Finish Then Return
  1170. If RaiseEx IsNot Nothing Then Ex.Add(RaiseEx)
  1171. '凉凉
  1172. State = NetState.Error
  1173. End SyncLock
  1174. AbortInternal()
  1175. For Each Task In Tasks
  1176. Task.OnFileFail(Me)
  1177. Next
  1178. End Sub
  1179. ''' <summary>
  1180. ''' 下载中断。
  1181. ''' </summary>
  1182. Public Sub Abort(AbortedTask As LoaderDownload)
  1183. '从特定任务中移除,如果它还属于其他任务,则继续下载
  1184. Tasks.Remove(AbortedTask)
  1185. If Tasks.Any Then Return
  1186. '确认中断
  1187. SyncLock LockState
  1188. If State >= NetState.Finish Then Return
  1189. State = NetState.Error
  1190. End SyncLock
  1191. AbortInternal()
  1192. End Sub
  1193. Private Sub AbortInternal()
  1194. On Error Resume Next
  1195. Reset()
  1196. SyncLock NetManager.LockRemain
  1197. NetManager.FileRemain -= 1
  1198. End SyncLock
  1199. Log($"[Download] {LocalName}:已终止,当前状态 {State}")
  1200. End Sub
  1201. '状态改变接口
  1202. ''' <summary>
  1203. ''' 将该文件设置为已下载完成。
  1204. ''' </summary>
  1205. Public Sub Finish(Optional PrintLog As Boolean = True)
  1206. SyncLock LockState
  1207. If State >= NetState.Finish Then Return
  1208. State = NetState.Finish
  1209. End SyncLock
  1210. SyncLock NetManager.LockRemain
  1211. NetManager.FileRemain -= 1
  1212. End SyncLock
  1213. If PrintLog Then Log($"[Download] {LocalName}:已完成")
  1214. For Each Task In Tasks
  1215. Task.OnFileFinish(Me)
  1216. Next
  1217. End Sub
  1218. End Class
  1219. ''' <summary>
  1220. ''' 下载一系列文件的加载器。
  1221. ''' </summary>
  1222. Public Class LoaderDownload
  1223. Inherits LoaderBase
  1224. #Region "属性"
  1225. ''' <summary>
  1226. ''' 需要下载的文件。
  1227. ''' </summary>
  1228. Public Files As SafeList(Of NetFile)
  1229. ''' <summary>
  1230. ''' 剩余未完成的文件数。(用于减轻 FilesLock 的占用)
  1231. ''' </summary>
  1232. Private FileRemain As Integer
  1233. Private ReadOnly FileRemainLock As New Object
  1234. ''' <summary>
  1235. ''' 用于显示的百分比进度。
  1236. ''' </summary>
  1237. Public Overrides Property Progress As Double
  1238. Get
  1239. If State >= LoadState.Finished Then Return 1
  1240. If Not Files.Any() Then Return 0 '必须返回 0,否则在获取列表的时候会错觉已经下载完了
  1241. Return _Progress
  1242. End Get
  1243. Set(value As Double)
  1244. Throw New Exception("文件下载不允许指定进度")
  1245. End Set
  1246. End Property
  1247. Private _Progress As Double = 0
  1248. ''' <summary>
  1249. ''' 任务中的文件的连续失败计数。
  1250. ''' </summary>
  1251. Public Property FailCount As Integer
  1252. Get
  1253. Return _FailCount
  1254. End Get
  1255. Set(value As Integer)
  1256. _FailCount = value
  1257. If State = LoadState.Loading AndAlso value >= Math.Min(10000, Math.Max(FileRemain * 5.5, NetTaskThreadLimit * 5.5 + 3)) Then
  1258. Log("[Download] 由于同加载器中失败次数过多引发强制失败:连续失败了 " & value & " 次", LogLevel.Debug)
  1259. On Error Resume Next
  1260. Dim ExList As New List(Of Exception)
  1261. For Each File In Files
  1262. For Each Source In File.Sources
  1263. If Source.Ex IsNot Nothing Then
  1264. ExList.Add(Source.Ex)
  1265. If ExList.Count > 10 Then GoTo FinishExCatch
  1266. End If
  1267. Next
  1268. Next
  1269. FinishExCatch:
  1270. OnFail(ExList)
  1271. End If
  1272. End Set
  1273. End Property
  1274. Private _FailCount As Integer = 0
  1275. #End Region
  1276. ''' <summary>
  1277. ''' 刷新公开属性。由 NetManager 每 0.1 秒调用一次。
  1278. ''' </summary>
  1279. Public Sub RefreshStat()
  1280. '计算进度
  1281. Dim NewProgress As Double = 0
  1282. Dim TotalProgress As Double = 0
  1283. For Each File In Files
  1284. If File.IsCopy Then
  1285. NewProgress += File.Progress * 0.2
  1286. TotalProgress += 0.2
  1287. Else
  1288. NewProgress += File.Progress
  1289. TotalProgress += 1
  1290. End If
  1291. Next
  1292. If TotalProgress > 0 AndAlso Not Double.IsNaN(TotalProgress) Then NewProgress /= TotalProgress
  1293. '刷新进度
  1294. _Progress = NewProgress
  1295. End Sub
  1296. Public Sub New(Name As String, FileTasks As List(Of NetFile))
  1297. Me.Name = Name
  1298. Files = New SafeList(Of NetFile)(FileTasks)
  1299. End Sub
  1300. Public Overrides Sub Start(Optional Input As Object = Nothing, Optional IsForceRestart As Boolean = False)
  1301. If Input IsNot Nothing Then Files = New SafeList(Of NetFile)(Input)
  1302. '去重
  1303. Dim ResultArray As New SafeList(Of NetFile)
  1304. For i = 0 To Files.Count - 1
  1305. For ii = i + 1 To Files.Count - 1
  1306. If Files(i).LocalPath = Files(ii).LocalPath Then GoTo NextElement
  1307. Next
  1308. ResultArray.Add(Files(i))
  1309. NextElement:
  1310. Next
  1311. Files = ResultArray
  1312. '设置剩余文件数
  1313. SyncLock FileRemainLock
  1314. For Each File In Files
  1315. If File.State <> NetState.Finish Then FileRemain += 1
  1316. Next
  1317. End SyncLock
  1318. State = LoadState.Loading
  1319. '开始执行
  1320. RunInNewThread(
  1321. Sub()
  1322. Try
  1323. '输入检测
  1324. If Not Files.Any() Then
  1325. OnFinish()
  1326. Return
  1327. End If
  1328. For Each File As NetFile In Files
  1329. If File Is Nothing Then Throw New ArgumentException("存在空文件请求!")
  1330. For Each Source As NetSource In File.Sources
  1331. If Not (Source.Url.StartsWithF("https://", True) OrElse Source.Url.StartsWithF("http://", True)) Then
  1332. Source.Ex = New ArgumentException("输入的下载链接不正确!")
  1333. Source.IsFailed = True
  1334. End If
  1335. Next
  1336. If Not File.HasAvailableSource() Then Throw New ArgumentException("输入的下载链接不正确!")
  1337. If Not File.LocalPath.ToLower.Contains(":\") Then Throw New ArgumentException("输入的本地文件地址不正确!")
  1338. If File.LocalPath.EndsWithF("\") Then Throw New ArgumentException("请输入含文件名的完整文件路径!")
  1339. '文件夹检测
  1340. Dim DirPath As String = New FileInfo(File.LocalPath).Directory.FullName
  1341. If Not Directory.Exists(DirPath) Then Directory.CreateDirectory(DirPath)
  1342. Next
  1343. '接入下载管理器
  1344. NetManager.Start(Me)
  1345. '将文件分配给多个线程以进行已存在查找
  1346. Dim Folders As New List(Of String) '可能会用于已存在查找的文件夹列表
  1347. Dim FoldersFinal As New List(Of String) '最终用于查找的列表
  1348. If Not Setup.Get("SystemDebugSkipCopy") Then '在设置中禁用复制
  1349. Folders.Add(Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData) & "\.minecraft\") '总是添加官启文件夹,因为 HMCL 会把所有文件存在这里
  1350. For Each Folder In McFolderList
  1351. Folders.Add(Folder.Path)
  1352. Next
  1353. Folders = Folders.Distinct.ToList
  1354. For Each Folder In Folders
  1355. If Folder <> PathMcFolder AndAlso Directory.Exists(Folder) Then FoldersFinal.Add(Folder)
  1356. Next
  1357. End If
  1358. '最多 5 个线程,最少每个线程分配 10 个文件
  1359. Dim FilesPerThread As Integer = Math.Max(5, Files.Count / 10 + 1)
  1360. Dim FilesInThread As New List(Of NetFile)
  1361. For Each File In Files
  1362. FilesInThread.Add(File)
  1363. If FilesInThread.Count = FilesPerThread Then
  1364. Dim FilesToRun As New List(Of NetFile)
  1365. FilesToRun.AddRange(FilesInThread)
  1366. RunInNewThread(Sub() StartCopy(FilesToRun, FoldersFinal), "下载 文件复制 " & Uuid)
  1367. FilesInThread.Clear()
  1368. End If
  1369. Next
  1370. If FilesInThread.Any Then
  1371. Dim FilesToRun As New List(Of NetFile)
  1372. FilesToRun.AddRange(FilesInThread)
  1373. RunInNewThread(Sub() StartCopy(FilesToRun, FoldersFinal), "下载 文件复制 " & Uuid)
  1374. FilesInThread.Clear()
  1375. End If
  1376. Catch ex As Exception
  1377. OnFail(New List(Of Exception) From {ex})
  1378. End Try
  1379. End Sub, "L/下载 " & Uuid)
  1380. End Sub
  1381. Private Sub StartCopy(Files As List(Of NetFile), FolderList As List(Of String))
  1382. Try
  1383. If ModeDebug Then Log($"[Download] 检查线程分配文件数:{Files.Count},线程名:{Thread.CurrentThread.Name}")
  1384. '试图从已存在的 Minecraft 文件夹中寻找目标文件
  1385. Dim ExistFiles As New List(Of KeyValuePair(Of NetFile, String)) '{NetFile, Target As String}
  1386. For Each File As NetFile In Files
  1387. Dim ExistFilePath As String = Nothing
  1388. '判断是否有已存在的文件
  1389. If File.Check IsNot Nothing AndAlso McFolderList IsNot Nothing AndAlso PathMcFolder IsNot Nothing AndAlso
  1390. File.Check.CanUseExistsFile AndAlso File.LocalPath.StartsWithF(PathMcFolder) Then
  1391. Dim Relative = File.LocalPath.Replace(PathMcFolder, "")
  1392. For Each Folder In FolderList
  1393. Dim Target = Folder & Relative
  1394. If File.Check.Check(Target) Is Nothing Then
  1395. ExistFilePath = Target
  1396. Exit For
  1397. End If
  1398. Next
  1399. End If
  1400. '若存在,则改变状态
  1401. SyncLock LockState
  1402. If ExistFilePath IsNot Nothing Then
  1403. File.State = NetState.WaitForCopy
  1404. File.IsCopy = True
  1405. ExistFiles.Add(New KeyValuePair(Of NetFile, String)(File, ExistFilePath))
  1406. Else
  1407. File.State = NetState.WaitForDownload
  1408. File.IsCopy = False
  1409. End If
  1410. End SyncLock
  1411. Next
  1412. '复制已存在的文件
  1413. For Each FileToken In ExistFiles
  1414. Dim File As NetFile = FileToken.Key
  1415. SyncLock LockState
  1416. If File.State > NetState.WaitForCopy Then Return
  1417. End SyncLock
  1418. Dim LocalPath As String = FileToken.Value
  1419. Dim RetryCount As Integer = 0
  1420. Retry:
  1421. Try
  1422. Log("[Download] 复制已存在的文件(" & LocalPath & ")")
  1423. CopyFile(LocalPath, File.LocalPath)
  1424. File.Finish(False)
  1425. Catch ex As Exception
  1426. RetryCount += 1
  1427. Log(ex, $"复制已存在的文件失败,重试第 {RetryCount} 次({LocalPath} -> {File.LocalPath})")
  1428. If RetryCount < 3 Then
  1429. Thread.Sleep(200)
  1430. GoTo Retry
  1431. End If
  1432. File.State = NetState.WaitForDownload
  1433. File.IsCopy = False
  1434. End Try
  1435. Next
  1436. Catch ex As Exception
  1437. Log(ex, "下载已存在文件查找失败", LogLevel.Feedback)
  1438. End Try
  1439. End Sub
  1440. Public Sub OnFileFinish(File As NetFile)
  1441. '要求全部文件完成
  1442. SyncLock FileRemainLock
  1443. FileRemain -= 1
  1444. If FileRemain > 0 Then Return
  1445. End SyncLock
  1446. OnFinish()
  1447. End Sub
  1448. Public Sub OnFinish()
  1449. RaisePreviewFinish()
  1450. SyncLock LockState
  1451. If State > LoadState.Loading Then Return
  1452. State = LoadState.Finished
  1453. End SyncLock
  1454. End Sub
  1455. Public Sub OnFileFail(File As NetFile)
  1456. '将下载源的错误加入主错误列表
  1457. For Each Source In File.Sources
  1458. If Not IsNothing(Source.Ex) Then File.Ex.Add(Source.Ex)
  1459. Next
  1460. OnFail(File.Ex)
  1461. End Sub
  1462. Public Sub OnFail(ExList As List(Of Exception))
  1463. SyncLock LockState
  1464. If State > LoadState.Loading Then Return
  1465. If ExList Is Nothing OrElse Not ExList.Any() Then ExList = New List(Of Exception) From {New Exception("未知错误!")}
  1466. '寻找有效的错误信息
  1467. Dim UsefulExs = ExList.Where(Function(e) TypeOf e IsNot TaskCanceledException AndAlso TypeOf e IsNot ThreadInterruptedException).ToList
  1468. [Error] = If(UsefulExs.FirstOrDefault, ExList.FirstOrDefault)
  1469. '获取实际失败的文件
  1470. For Each File In Files
  1471. If File.State <> NetState.Error Then Continue For
  1472. [Error] = New Exception("文件下载失败:" & File.LocalPath & vbCrLf &
  1473. "各下载源的错误如下:" & vbCrLf &
  1474. Join(File.Sources.Select(Function(s) $"{If(s.Ex?.Message, "无错误信息。")}({s.Url})"), vbCrLf),
  1475. [Error])
  1476. Exit For
  1477. Next
  1478. '在设置 Error 对象后再更改为失败,避免 WaitForExit 无法捕获错误
  1479. State = LoadState.Failed
  1480. End SyncLock
  1481. '中断所有文件
  1482. For Each TaskFile In Files
  1483. TaskFile.Abort(Me)
  1484. Next
  1485. '在退出同步锁后再进行日志输出
  1486. Dim ErrOutput As New List(Of String)
  1487. For Each Ex As Exception In ExList
  1488. ErrOutput.Add(GetExceptionDetail(Ex))
  1489. Next
  1490. Log("[Download] " & Join(ErrOutput.Distinct.ToArray, vbCrLf))
  1491. End Sub
  1492. Public Overrides Sub Abort()
  1493. SyncLock LockState
  1494. If State >= LoadState.Finished Then Return
  1495. State = LoadState.Aborted
  1496. End SyncLock
  1497. Log("[Download] " & Name & " 已取消!")
  1498. '中断所有文件
  1499. For Each TaskFile In Files
  1500. TaskFile.Abort(Me)
  1501. Next
  1502. End Sub
  1503. End Class
  1504. Public NetManager As New NetManagerClass
  1505. ''' <summary>
  1506. ''' 下载文件管理。
  1507. ''' </summary>
  1508. Public Class NetManagerClass
  1509. #Region "属性"
  1510. ''' <summary>
  1511. ''' 需要下载的文件。为“本地地址 - 文件对象”键值对。
  1512. ''' </summary>
  1513. Public Files As New Dictionary(Of String, NetFile)
  1514. Public ReadOnly LockFiles As New Object
  1515. ''' <summary>
  1516. ''' 当前的所有下载任务。
  1517. ''' </summary>
  1518. Public Tasks As New SafeList(Of LoaderDownload)
  1519. ''' <summary>
  1520. ''' 已下载完成的大小。
  1521. ''' </summary>
  1522. Public Property DownloadDone As Long
  1523. Get
  1524. Return _DownloadDone
  1525. End Get
  1526. Set(value As Long)
  1527. SyncLock LockDone
  1528. _DownloadDone = value
  1529. End SyncLock
  1530. End Set
  1531. End Property
  1532. Private _DownloadDone As Long = 0
  1533. Private ReadOnly LockDone As New Object
  1534. ''' <summary>
  1535. ''' 尚未完成下载的文件数。
  1536. ''' </summary>
  1537. Public FileRemain As Integer = 0
  1538. Public ReadOnly LockRemain As New Object
  1539. ''' <summary>
  1540. ''' 上次记速时的已下载大小。
  1541. ''' </summary>
  1542. Private SpeedLastDone As Long = 0
  1543. ''' <summary>
  1544. ''' 至多最近 30 次下载速度的记录,较新的在前面。
  1545. ''' </summary>
  1546. Private SpeedLast As New List(Of Long)
  1547. '这些属性由 RefreshStat 刷新
  1548. ''' <summary>
  1549. ''' 当前的全局下载速度,单位为 Byte / 秒。
  1550. ''' </summary>
  1551. Public Speed As Long = 0
  1552. Public ReadOnly Uuid As Integer = GetUuid()
  1553. #End Region
  1554. ''' <summary>
  1555. ''' 进度与下载速度由下载管理线程每隔约 0.1 秒刷新一次。
  1556. ''' </summary>
  1557. Private Sub RefreshStat()
  1558. Try
  1559. Dim DeltaTime As Long = GetTimeTick() - RefreshStatLast
  1560. If DeltaTime = 0 Then Return
  1561. RefreshStatLast += DeltaTime
  1562. #Region "刷新整体速度"
  1563. '计算瞬时速度
  1564. Dim ActualSpeed As Double = Math.Max(0, (DownloadDone - SpeedLastDone) / (DeltaTime / 1000))
  1565. SpeedLast.Insert(0, ActualSpeed)
  1566. If SpeedLast.Count >= 31 Then SpeedLast.RemoveAt(30)
  1567. SpeedLastDone = DownloadDone
  1568. '计算用于显示的速度
  1569. Dim SpeedSum As Long = 0, SpeedDiv As Long = 0, Weight = SpeedLast.Count
  1570. For Each SpeedRecord In SpeedLast
  1571. SpeedSum += SpeedRecord * Weight
  1572. SpeedDiv += Weight
  1573. Weight -= 1
  1574. Next
  1575. Speed = If(SpeedDiv > 0, SpeedSum / SpeedDiv, 0)
  1576. '计算新的速度下限
  1577. Dim Limit As Long = 0
  1578. If SpeedLast.Count >= 10 Then Limit = SpeedLast.Take(10).Average * 0.85 '取近 1 秒的平均速度的 85%
  1579. If Limit > NetTaskSpeedLimitLow Then
  1580. NetTaskSpeedLimitLow = Limit
  1581. Log("[Download] " & "速度下限已提升到 " & GetString(Limit))
  1582. End If
  1583. #End Region
  1584. #Region "刷新下载任务属性"
  1585. For Each Task In Tasks
  1586. Task.RefreshStat()
  1587. Next
  1588. #End Region
  1589. Catch ex As Exception
  1590. Log(ex, "刷新下载公开属性失败")
  1591. End Try
  1592. End Sub
  1593. Private RefreshStatLast As Long
  1594. ''' <summary>
  1595. ''' 启动监控线程,用于新增下载线程。
  1596. ''' </summary>
  1597. Private Sub StartManager()
  1598. If IsManagerStarted Then Return
  1599. IsManagerStarted = True
  1600. Dim ThreadStarter =
  1601. Sub(Id As Integer) '0 或 1
  1602. Try
  1603. While True
  1604. Thread.Sleep(20)
  1605. '获取文件列表
  1606. Dim AllFiles As List(Of NetFile)
  1607. SyncLock LockFiles
  1608. If Id = 0 AndAlso FileRemain = 0 AndAlso Files.Any() Then Files.Clear() '若已完成,则清空
  1609. AllFiles = Files.Values.ToList()
  1610. End SyncLock
  1611. Dim WaitingFiles As New List(Of NetFile)
  1612. Dim OngoingFiles As New List(Of NetFile)
  1613. For Each File As NetFile In AllFiles
  1614. If File.Uuid Mod 2 = Id Then Continue For
  1615. If File.State = NetState.WaitForDownload Then
  1616. WaitingFiles.Add(File)
  1617. ElseIf File.State < NetState.Merge Then
  1618. OngoingFiles.Add(File)
  1619. End If
  1620. Next
  1621. '为等待中的文件开始线程
  1622. For Each File As NetFile In WaitingFiles
  1623. If NetTaskThreadCount >= NetTaskThreadLimit Then Continue While '最大线程数检查
  1624. Dim NewThread = File.TryBeginThread()
  1625. If NewThread IsNot Nothing AndAlso NewThread.Source.Url.Contains("bmclapi") Then Thread.Sleep(30) '减少 BMCLAPI 请求频率(目前每分钟限制 4000 次)
  1626. Next
  1627. '为进行中的文件追加线程
  1628. If Speed >= NetTaskSpeedLimitLow Then Continue While '下载速度足够,无需新增
  1629. For Each File As NetFile In OngoingFiles
  1630. If NetTaskThreadCount >= NetTaskThreadLimit Then Continue While '最大线程数检查
  1631. '线程种类计数
  1632. Dim PreparingCount = 0, DownloadingCount = 0
  1633. If File.Threads IsNot Nothing Then
  1634. For Each Thread As NetThread In File.Threads.ToList
  1635. If Thread.State < NetState.Download Then
  1636. PreparingCount += 1
  1637. ElseIf Thread.State = NetState.Download Then
  1638. DownloadingCount += 1
  1639. End If
  1640. Next
  1641. End If
  1642. '新增线程
  1643. If PreparingCount > DownloadingCount Then Continue For '准备中的线程已多于下载中的线程,不再新增
  1644. Dim NewThread = File.TryBeginThread()
  1645. If NewThread IsNot Nothing AndAlso NewThread.Source.Url.Contains("bmclapi") Then Thread.Sleep(30) '减少 BMCLAPI 请求频率(目前每分钟限制 4000 次)
  1646. Next
  1647. End While
  1648. Catch ex As Exception
  1649. Log(ex, $"下载管理启动线程 {Id} 出错", LogLevel.Critical)
  1650. End Try
  1651. End Sub
  1652. RunInNewThread(Sub() ThreadStarter(0), "NetManager ThreadStarter 0")
  1653. RunInNewThread(Sub() ThreadStarter(1), "NetManager ThreadStarter 1")
  1654. RunInNewThread(
  1655. Sub()
  1656. Try
  1657. Dim LastLoopTime As Long
  1658. NetTaskSpeedLimitLeftLast = GetTimeTick()
  1659. While True
  1660. Dim TimeNow = GetTimeTick()
  1661. LastLoopTime = TimeNow
  1662. '增加限速余量
  1663. If NetTaskSpeedLimitHigh > 0 Then NetTaskSpeedLimitLeft = NetTaskSpeedLimitHigh / 1000 * (TimeNow - NetTaskSpeedLimitLeftLast)
  1664. NetTaskSpeedLimitLeftLast = TimeNow
  1665. '刷新公开属性
  1666. RefreshStat()
  1667. '等待直至 80 ms
  1668. Do While GetTimeTick() - LastLoopTime < 80
  1669. Thread.Sleep(10)
  1670. Loop
  1671. End While
  1672. Catch ex As Exception
  1673. Log(ex, "下载管理刷新线程出错", LogLevel.Critical)
  1674. End Try
  1675. End Sub, "NetManager StatRefresher")
  1676. End Sub
  1677. Private IsManagerStarted As Boolean = False
  1678. 'Public FileRemainList As New List(Of String)
  1679. Private IsDownloadCacheCleared As Boolean = False
  1680. ''' <summary>
  1681. ''' 开始一个下载任务。
  1682. ''' </summary>
  1683. Public Sub Start(Task As LoaderDownload)
  1684. StartManager()
  1685. '清理缓存
  1686. If Not IsDownloadCacheCleared Then
  1687. Try
  1688. DeleteDirectory(PathTemp & "Download")
  1689. Catch ex As Exception
  1690. Log(ex, "清理下载缓存失败")
  1691. End Try
  1692. IsDownloadCacheCleared = True
  1693. End If
  1694. Directory.CreateDirectory(PathTemp & "Download")
  1695. '文件处理
  1696. SyncLock LockFiles
  1697. '添加每个文件
  1698. For i = 0 To Task.Files.Count - 1
  1699. Dim File = Task.Files(i)
  1700. If Files.ContainsKey(File.LocalPath) Then
  1701. '已有该文件
  1702. If Files(File.LocalPath).State >= NetState.Finish Then
  1703. '该文件已经下载过一次,且下载完成
  1704. '将已下载的文件替换成当前文件,重新下载
  1705. File.Tasks.Add(Task)
  1706. Files(File.LocalPath) = File
  1707. SyncLock LockRemain
  1708. FileRemain += 1
  1709. End SyncLock
  1710. If ModeDebug Then Log($"[Download] {File.LocalName}:重新加入下载列表")
  1711. Else
  1712. '该文件正在下载中
  1713. '将当前文件替换成下载中的文件,即两个任务指向同一个文件
  1714. File = Files(File.LocalPath)
  1715. File.Tasks.Add(Task)
  1716. End If
  1717. Else
  1718. '没有该文件
  1719. File.Tasks.Add(Task)
  1720. Files.Add(File.LocalPath, File)
  1721. SyncLock LockRemain
  1722. FileRemain += 1
  1723. End SyncLock
  1724. If ModeDebug Then Log($"[Download] {File.LocalName}:已加入下载列表")
  1725. End If
  1726. Task.Files(i) = File '回设
  1727. Next
  1728. End SyncLock
  1729. Tasks.Add(Task)
  1730. End Sub
  1731. End Class
  1732. ''' <summary>
  1733. ''' 是否有正在进行中、需要在下载管理页面显示的下载任务?
  1734. ''' </summary>
  1735. Public Function HasDownloadingTask(Optional IgnoreCustomDownload As Boolean = False) As Boolean
  1736. For Each Task In LoaderTaskbar.ToList()
  1737. If (Task.Show AndAlso Task.State = LoadState.Loading) AndAlso
  1738. (Not IgnoreCustomDownload OrElse Not Task.Name.ToString.Contains("自定义下载")) Then
  1739. Return True
  1740. End If
  1741. Next
  1742. Return False
  1743. End Function
  1744. #End Region
  1745. ''' <summary>
  1746. ''' 测试 Ping。失败则返回 -1。
  1747. ''' </summary>
  1748. Public Function Ping(Ip As String, Optional Timeout As Integer = 10000, Optional MakeLog As Boolean = True) As Integer
  1749. Dim PingResult As NetworkInformation.PingReply
  1750. Try
  1751. PingResult = (New NetworkInformation.Ping).Send(Ip)
  1752. Catch ex As Exception
  1753. If MakeLog Then Log("[Net] Ping " & Ip & " 失败:" & ex.Message)
  1754. Return -1
  1755. End Try
  1756. If PingResult.Status = NetworkInformation.IPStatus.Success Then
  1757. If MakeLog Then Log("[Net] Ping " & Ip & " 结束:" & PingResult.RoundtripTime & "ms")
  1758. Return PingResult.RoundtripTime
  1759. Else
  1760. If MakeLog Then Log("[Net] Ping " & Ip & " 失败")
  1761. Return -1
  1762. End If
  1763. End Function
  1764. End Module