ModNet.vb 100 KB

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