ModNet.vb 95 KB

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