PageLinkMain.xaml.vb 50 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119
  1. Imports System.Globalization
  2. Imports System.Net.Sockets
  3. Public Class PageLinkMain
  4. Private Const INVITE_CODE_VERSION As Integer = 2
  5. '===============================
  6. ' 状态机与前端页面
  7. '===============================
  8. #Region "状态管理"
  9. Public Enum LinkStates
  10. Waiting
  11. Loading
  12. Failed
  13. Finished
  14. End Enum
  15. Public Shared LinkState As LinkStates = LinkStates.Waiting
  16. ''' <summary>
  17. ''' 切换到指定的状态。
  18. ''' </summary>
  19. Private Sub ChangeState(NewState As LinkStates)
  20. If LinkState = NewState Then Return
  21. Dim OldState = LinkState
  22. LinkState = NewState
  23. Log($"[Link] 主状态由 {GetStringFromEnum(OldState)} 变更为 {GetStringFromEnum(NewState)}")
  24. '触发状态切换
  25. RunInUi(
  26. Sub()
  27. Select Case NewState
  28. Case LinkStates.Waiting
  29. SwitchToWaiting(OldState)
  30. Case LinkStates.Loading
  31. SwitchToLoading(OldState)
  32. Case LinkStates.Failed
  33. SwitchToFailed(OldState)
  34. Case LinkStates.Finished
  35. SwitchToFinished(OldState)
  36. End Select
  37. End Sub)
  38. End Sub
  39. '让加载器的 成功/失败 事件触发状态切换
  40. Private Sub LoaderInit() Handles Me.Initialized
  41. PageLoaderInit(Load, PanLoad, PanContent, PanAlways, LinkLoader, AutoRun:=False)
  42. AddHandler LinkLoader.OnStateChangedUi,
  43. Sub(Loader As LoaderBase, NewState As LoadState, OldState As LoadState)
  44. Select Case NewState
  45. Case LoadState.Finished
  46. ChangeState(LinkStates.Finished)
  47. Case LoadState.Failed
  48. Telemetry("联机失败", "Exception", FilterUserName(Loader.Error.GetDetail, "*"))
  49. ChangeState(LinkStates.Failed)
  50. End Select
  51. End Sub
  52. End Sub
  53. '页面动画兼容
  54. Private Sub UpdatePanelVisibility() Handles Me.PageEnter
  55. FrmLinkMain.PanSelect.Visibility = If(LinkState = LinkStates.Waiting, Visibility.Visible, Visibility.Collapsed)
  56. FrmLinkMain.PanFinish.Visibility = If(LinkState = LinkStates.Finished, Visibility.Visible, Visibility.Collapsed)
  57. End Sub
  58. #End Region
  59. #Region "初始页面 (Waiting)"
  60. '由任意状态切换到 Waiting
  61. Private Sub SwitchToWaiting(OldState As LinkStates)
  62. '加载器与进程状态
  63. LinkLoader.Interrupt()
  64. SyncLock LinkLoader.LockState
  65. LinkLoader.State = LoadState.Waiting
  66. End SyncLock
  67. ProcessStop()
  68. '页面切换
  69. If OldState <> LinkStates.Finished Then
  70. '从完成页面退出时,PageOnContentExit 结束会触发 PageEnter 事件,这会调用 UpdatePanelVisibility
  71. '如果在现在提前调用了,会丢失完成页面的退出动画
  72. UpdatePanelVisibility()
  73. End If
  74. PageOnContentExit()
  75. End Sub
  76. '===============================
  77. ' 页面 UI
  78. '===============================
  79. '创建
  80. Private Sub Create_MouseLeftButtonUp() Handles PanSelectCreate.MouseLeftButtonUp
  81. '输入端口号
  82. Dim Port As String = MyMsgBoxInput("输入端口", $"在单人游戏的暂停菜单选择 {vbLQ}对局域网开放{vbRQ},然后输入端口数字。{vbCrLf}甚至可以输入其他游戏的端口……嗯……",
  83. ValidateRules:=New ObjectModel.Collection(Of Validate) From {New ValidateInteger(1024, 65535)},
  84. HintText:="端口号")
  85. If Port Is Nothing Then Return
  86. '基础信息
  87. IsServerSide = True
  88. ServerPort = Port
  89. Dim GenerateRandomCode =
  90. Function() As String
  91. Dim Result As String = ""
  92. For i = 1 To 5
  93. Result &= RadixConvert(RandomInteger(0, 35), 10, 36)
  94. Next
  95. Return Result.Replace("O", "0").Replace("I", "1")
  96. End Function
  97. NetworkName = $"P{RadixConvert(ServerPort, 10, 16).PadLeft(4, "0"c)}-{GenerateRandomCode()}"
  98. NetworkSecret = GenerateRandomCode()
  99. DiscoverNodeID = -1
  100. Log($"[Link] 尝试创建房间,网络名 {NetworkName},网络密码 {NetworkSecret},端口 {ServerPort}")
  101. '启动
  102. ChangeState(LinkStates.Loading)
  103. End Sub
  104. '加入
  105. Private Shared LastCode As String = Nothing
  106. ''' <summary>
  107. ''' 输入邀请码,切换到联机页并立即加入房间。
  108. ''' </summary>
  109. Public Shared Sub Join() Handles PanSelectJoin.MouseLeftButtonUp
  110. Dim Code As String = MyMsgBoxInput("输入邀请码", "输入房主发给你的邀请码。",
  111. HintText:=If(String.IsNullOrEmpty(LastCode), "", "使用上一次的邀请码"))
  112. If Not String.IsNullOrEmpty(LastCode) AndAlso Code IsNot Nothing AndAlso Code = "" Then Code = LastCode
  113. If Code Is Nothing Then Return
  114. Join(Code)
  115. End Sub
  116. Public Sub JoinInternal(Code As String)
  117. If Code Is Nothing Then Return
  118. '基础格式校验
  119. Dim ValidateResult = ValidateCodeFormat(Code)
  120. If ValidateResult IsNot Nothing Then
  121. Hint(ValidateResult, HintType.Red)
  122. Return
  123. End If
  124. Code = FixCodeFormat(Code)
  125. Log($"[Link] 实际使用的邀请码:{Code}")
  126. '基础信息
  127. IsServerSide = False
  128. ServerPort = RadixConvert(Code.Substring(1, 4), 16, 10)
  129. NetworkName = Code.Substring(0, 11)
  130. NetworkSecret = Code.Substring(12, 5)
  131. If Code.Substring(20, 3) = "000" Then
  132. DiscoverNodeID = -2
  133. Else
  134. DiscoverNodeID = RadixConvert(Code.Substring(20, 3), 16, 10)
  135. End If
  136. Log($"[Link] 尝试加入房间,网络名 {NetworkName},网络密码 {NetworkSecret},端口 {ServerPort},发现节点 {DiscoverNodeID}")
  137. '启动
  138. LastCode = Code
  139. ChangeState(LinkStates.Loading)
  140. End Sub
  141. Public Shared Function ValidateCodeFormat(Code As String) As String
  142. If Code Is Nothing Then Return "邀请码为空!"
  143. Code = FixCodeFormat(Code)
  144. '判断类型
  145. If Not (Code.Length >= 14 AndAlso Code(0) = "P"c AndAlso Code(5) = "-"c AndAlso Code(11) = "-"c) Then
  146. If Code.StartsWithF("U/") Then 'HMCL
  147. Return "请让房主使用 PCL 创建房间!"
  148. ElseIf Code.Length = 10 Then 'PCL CE
  149. Return "请让房主使用非社区版的 PCL 创建房间!"
  150. Else
  151. Return "邀请码有误,请让房主使用 PCL 创建房间!"
  152. End If
  153. End If
  154. '校验版本
  155. If Code.Length >= 23 AndAlso Code(17) = "-"c AndAlso
  156. Val(Code.Substring(18, 2)) > INVITE_CODE_VERSION Then Return "你的 PCL 版本太老了,请在更新 PCL 之后再联机!"
  157. Return Nothing
  158. End Function
  159. Private Shared Function FixCodeFormat(Code As String) As String
  160. Code = Code.Between("【", "】").Between("[", "]") '从完整消息中提取
  161. Code = Code.Upper.Replace("O", "0").Replace("I", "1") '输入修正
  162. '版本 1 兼容
  163. If Code.Length >= 17 AndAlso (Code.Length < 23 OrElse (Code.Length >= 18 AndAlso Code(17) <> "-"c)) Then
  164. Code = Code.Substring(0, 17) & "-0105E"
  165. End If
  166. Return Code
  167. End Function
  168. '自动加入
  169. ''' <summary>
  170. ''' 切换到联机页并立即加入指定房间。
  171. ''' </summary>
  172. Public Shared Sub Join(Code As String)
  173. If LinkState <> LinkStates.Waiting Then
  174. Hint("你已经在联机房间中了!", HintType.Red)
  175. ElseIf FrmMain.PageCurrent = FormMain.PageType.Link Then
  176. FrmLinkMain.JoinInternal(Code)
  177. Else
  178. AutoJoinCode = Code
  179. FrmMain.PageChange(FormMain.PageType.Link, FormMain.PageSubType.LinkMain)
  180. End If
  181. End Sub
  182. '在进入页面时自动尝试加入房间
  183. Private Shared AutoJoinCode As String = Nothing
  184. Private Sub PanSelectJoin_Loaded() Handles PanSelectJoin.Loaded
  185. If AutoJoinCode Is Nothing Then Return
  186. If LinkState = LinkStates.Waiting Then JoinInternal(AutoJoinCode)
  187. AutoJoinCode = Nothing
  188. End Sub
  189. #End Region
  190. #Region "加载页面 (Loading | Failed)"
  191. '由 Waiting 或 Failed 状态切换到 Loading
  192. Private Sub SwitchToLoading(OldState As LinkStates)
  193. '清理变量
  194. Peers = Nothing
  195. FailCount = 0
  196. '加载器与进程状态
  197. LinkLoader.Start(IsForceRestart:=True)
  198. '页面切换会由 Loader 调用 MyPageRight 来触发
  199. 'UI 更新
  200. UpdateProgressBar(0)
  201. LabLoadTitle.Text = If(IsServerSide, "创建房间中", "加入房间中")
  202. UpdateLoadingPage("正在初始化……", "准备初始化")
  203. End Sub
  204. '由 Loading 状态切换到 Failed
  205. Private Sub SwitchToFailed(OldState As LinkStates)
  206. '加载器与进程状态
  207. LinkLoader.Interrupt()
  208. ProcessStop()
  209. 'UI 更新
  210. UpdateProgressBar(1)
  211. '显示错误信息
  212. LabLoadTitle.Text = FailReason
  213. Dim Brief As String = LinkLoader.Error.GetBrief
  214. Dim InnerEx As Exception = LinkLoader.Error
  215. If InnerEx.Message.StartsWithF("$") Then Brief = InnerEx.Message
  216. Do Until InnerEx.InnerException Is Nothing
  217. InnerEx = InnerEx.InnerException
  218. If InnerEx.Message.StartsWithF("$") Then Brief = InnerEx.Message
  219. Loop
  220. LabLoadDesc.Text = If(Brief.StartsWithF("$"), Brief.TrimStart("$"), LinkLoader.Error.GetDetail)
  221. Log(LinkLoader.Error, LabLoadTitle.Text)
  222. End Sub
  223. '===============================
  224. ' 页面 UI
  225. '===============================
  226. Private Sub UpdateLoadingPage(Title As String, FailBrief As String)
  227. If FailReason = FailBrief & "失败" Then Return
  228. FailReason = FailBrief & "失败"
  229. Log("[Link] 开始步骤:" & Title)
  230. RunInUiWait(
  231. Sub()
  232. If FrmLinkMain Is Nothing OrElse Not FrmLinkMain.LabLoadDesc.IsLoaded Then Return
  233. FrmLinkMain.LabLoadDesc.Text = Title
  234. End Sub)
  235. End Sub
  236. Private FailReason As String = "准备初始化"
  237. '取消加载
  238. Private Sub BtnLoadCancel_Click() Handles BtnLoadCancel.Click
  239. ChangeState(LinkStates.Waiting)
  240. End Sub
  241. '点击重试
  242. Private Sub CardLoad_MouseLeftButtonUp() Handles CardLoad.MouseLeftButtonUp
  243. ChangeState(LinkStates.Loading)
  244. End Sub
  245. '进度条
  246. Private Sub UpdateProgressBar(Optional Value As Double = -1)
  247. If Value = -1 Then Value = LinkLoader.Progress
  248. Dim DisplayingProgress As Double = ColumnProgressA.Width.Value
  249. If Math.Round(Value - DisplayingProgress, 3) = 0 Then Return
  250. If DisplayingProgress <= Value Then
  251. Dim NewProgress As Double = If(Value = 1, 1, DisplayingProgress +
  252. (Value - DisplayingProgress) ^ 2 * 0.5)
  253. AniStart({
  254. AaGridLengthWidth(ColumnProgressA, NewProgress - ColumnProgressA.Width.Value, 200),
  255. AaGridLengthWidth(ColumnProgressB, (1 - NewProgress) - ColumnProgressB.Width.Value, 200)
  256. }, "Link Progress")
  257. Else
  258. ColumnProgressA.Width = New GridLength(Value, GridUnitType.Star)
  259. ColumnProgressB.Width = New GridLength(1 - Value, GridUnitType.Star)
  260. AniStop("Link Progress")
  261. End If
  262. End Sub
  263. Private Sub CardLoad_SizeChanged() Handles CardLoad.SizeChanged
  264. RectProgressClip.Rect = New Rect(0, 0, CardLoad.ActualWidth, 12)
  265. End Sub
  266. #End Region
  267. #Region "完成页面 (Finished)"
  268. '由 Loading 状态切换到 Finished
  269. Private Sub SwitchToFinished(OldState As LinkStates)
  270. '由于只可能从加载器的完成事件触发,不需要管加载器
  271. UpdatePanelVisibility() '页面的实际切换会由 Loader 调用 MyPageRight 来触发
  272. 'UI 更新
  273. If IsServerSide Then
  274. LabFinishTitle.Text = "已创建房间"
  275. LabFinishDesc.Text = $"把邀请码发给朋友,让大家加入房间吧!{vbCrLf}邀请码:{GetInviteCode()}"
  276. BtnFinishExit.Text = "关闭"
  277. BtnFinishPing.ToolTip = "网络延迟"
  278. BtnFinishCopy.Visibility = Visibility.Visible
  279. Copy() '立即复制邀请码
  280. '下边栏
  281. BtnFinishPort.Visibility = Visibility.Visible
  282. LabFinishPort.Visibility = Visibility.Visible
  283. BtnFinishIp.Visibility = Visibility.Collapsed
  284. LabFinishIp.Visibility = Visibility.Collapsed
  285. LabFinishPort.Text = ServerPort
  286. Else
  287. LabFinishTitle.Text = "已加入房间"
  288. LabFinishDesc.Text = $"在多人游戏页面的最下方就能找到联机房间!{vbCrLf}注意:使用离线登录时不要手动输入 IP!"
  289. BtnFinishExit.Text = "离开"
  290. BtnFinishPing.ToolTip = "与房主的延迟"
  291. BtnFinishCopy.Visibility = Visibility.Collapsed
  292. '下边栏
  293. BtnFinishPort.Visibility = Visibility.Collapsed
  294. LabFinishPort.Visibility = Visibility.Collapsed
  295. LabFinishIp.Text = ClientAddress
  296. BtnFinishIp.Visibility = Visibility.Visible
  297. LabFinishIp.Visibility = Visibility.Visible
  298. End If
  299. Update() '立即刷新
  300. End Sub
  301. '===============================
  302. ' 页面 UI
  303. '===============================
  304. '退出
  305. Private Sub BtnFinishExit_Click() Handles BtnFinishExit.Click
  306. TryExit(False, False)
  307. End Sub
  308. ''' <summary>
  309. ''' 退出联机。
  310. ''' 返回是否弹出了警告窗口并且玩家选择了取消。
  311. ''' </summary>
  312. Public Function TryExit(Slient As Boolean, Closing As Boolean) As Boolean
  313. If LinkState = LinkStates.Waiting OrElse LinkState = LinkStates.Failed Then Return False
  314. If Not Slient Then
  315. If IsServerSide AndAlso PeopleCount > 1 Then
  316. If MyMsgBox("你确定要关闭联机房间吗?" & vbCrLf & "所有玩家都需要重新输入邀请码才可加入游戏!", "退出联机", "确定", "取消", IsWarn:=True) = 2 Then Return True
  317. ElseIf Closing Then
  318. If MyMsgBox(If(IsServerSide, "你确定要关闭联机房间吗?", "你确定要离开联机房间吗?"), "退出联机", "确定", "取消") = 2 Then Return True
  319. End If
  320. End If
  321. ChangeState(LinkStates.Waiting)
  322. Return False
  323. End Function
  324. '复制邀请码
  325. Private Sub Copy() Handles BtnFinishCopy.Click
  326. Dim CodeText As String = $"在 PCL 启动器中输入邀请码【{GetInviteCode()}】,即可加入联机房间!"
  327. ClipboardSet(CodeText, False)
  328. Settings.Set("LinkLastAutoJoinInviteCode", CodeText)
  329. Hint("已复制邀请码!", HintType.Green)
  330. End Sub
  331. Private Function GetInviteCode() As String
  332. Return $"{NetworkName}-{NetworkSecret}-{INVITE_CODE_VERSION.ToString.PadLeft(2, "0"c)}{ _
  333. RadixConvert(If(DiscoverNodeID = -1, 0, DiscoverNodeID), 10, 16).PadLeft(3, "0"c)}"
  334. End Function
  335. '复制 IP
  336. Private Sub BtnFinishIp_MouseLeftButtonUp(sender As Object, e As MouseButtonEventArgs) Handles BtnFinishIp.MouseLeftButtonUp
  337. ClipboardSet(ClientAddress, False)
  338. Hint("已复制服务器地址!", HintType.Green)
  339. End Sub
  340. #End Region
  341. '===============================
  342. ' 后端
  343. '===============================
  344. ''' <summary>
  345. ''' EasyTier 所在的文件夹路径,以 \ 结尾。
  346. ''' </summary>
  347. Private PathEasyTier As String = PathAppdata & "EasyTier\"
  348. ''' <summary>
  349. ''' 当前是服务端还是客户端。
  350. ''' </summary>
  351. Private IsServerSide As Boolean
  352. ''' <summary>
  353. ''' 服务端映射前的端口号。
  354. ''' </summary>
  355. Private ServerPort As Integer
  356. ''' <summary>
  357. ''' 客户端映射后的端口号。
  358. ''' </summary>
  359. Private ClientPort As Integer
  360. ''' <summary>
  361. ''' RPC 端口号。
  362. ''' </summary>
  363. Private RPCPort As Integer
  364. ''' <summary>
  365. ''' 在客户端映射后的地址。
  366. ''' 除非已作为客户端启动 EasyTier,否则一直为 Nothing。
  367. ''' </summary>
  368. Private ClientAddress As String = Nothing
  369. ''' <summary>
  370. ''' 发现节点的 ID。
  371. ''' 若必须设定自定义节点则为 -2;若等待选择则为 -1;选择回退节点则为 0;否则为对应节点的 ID。
  372. ''' </summary>
  373. Private DiscoverNodeID As Integer = -1
  374. ''' <summary>
  375. ''' 网络信息。
  376. ''' </summary>
  377. Private NetworkName As String, NetworkSecret As String
  378. #Region "加载"
  379. Private WithEvents LinkLoader As New LoaderCombo(Of Integer)("联机", {
  380. New LoaderTask(Of Integer, Integer)("获取配置", AddressOf InitConfig) With {.ProgressWeight = 8},
  381. New LoaderTask(Of Integer, List(Of NetFile))("准备下载联机模块", AddressOf InitPrepareDownload) With {.ProgressWeight = 2},
  382. New LoaderDownload("下载联机模块", New List(Of NetFile)) With {.ProgressWeight = 40},
  383. New LoaderTask(Of Integer, Integer)("启动联机模块", AddressOf InitLaunch) With {.ProgressWeight = 50}
  384. })
  385. '1. 获取服务器配置
  386. Private Sub InitConfig(Task As LoaderTask(Of Integer, Integer))
  387. UpdateLoadingPage("正在联网获取配置……", "联网获取配置")
  388. If VersionBranchMain <> "Official" Then
  389. Throw New Exception($"$开源版无法联网获取配置。{vbCrLf}你可以在 PCL 官方版的缓存文件夹下查看 ServerConfig 的当前内容, 并在代码中进行相应修改。")
  390. End If
  391. ServerLoader.WaitForExit(LoaderToSyncProgress:=Task)
  392. If ServerConfig Is Nothing Then Throw New Exception("无法从服务器获取配置")
  393. '检查是否已禁用联机功能
  394. Dim DisableReason = ServerConfig("Link")?("DisableReason2")?.ToString
  395. If Not String.IsNullOrEmpty(DisableReason) Then Throw New Exception("$" & DisableReason) 'TODO: 可能不会显示错误原因?
  396. If CType(ServerConfig("Link"), JObject).ContainsKey("MinVersionCode") AndAlso
  397. VersionCode < ServerConfig("Link")("MinVersionCode").ToObject(Of Integer) Then
  398. Throw New Exception("$你的 PCL 版本太老了,请在更新 PCL 之后再联机!")
  399. End If
  400. End Sub
  401. '2. 获取需要下载的文件
  402. Private ServerVersion As Integer
  403. Private Sub InitPrepareDownload(Task As LoaderTask(Of Integer, List(Of NetFile)))
  404. '获取 CPU 架构
  405. UpdateLoadingPage("正在获取 CPU 架构……", "获取 CPU 架构")
  406. Dim Architecture As String = GetType(String).Assembly.GetName().ProcessorArchitecture
  407. Select Case Architecture
  408. Case Reflection.ProcessorArchitecture.X86
  409. Architecture = "i686"
  410. Case Reflection.ProcessorArchitecture.Amd64
  411. Architecture = "x86_64"
  412. Case Reflection.ProcessorArchitecture.Arm
  413. Architecture = "arm64"
  414. Case Else
  415. Log($"[Link] CPU 是不支持的 {Architecture} 架构,这可能会导致联机模块无法启动!", LogLevel.Debug)
  416. Architecture = "arm64"
  417. End Select
  418. Log("[Link] CPU 架构:" & Architecture)
  419. Telemetry("联机开始")
  420. '检查 EasyTier 版本
  421. UpdateLoadingPage("正在检查联机模块版本……", "检查联机模块版本")
  422. If Not (File.Exists(PathEasyTier & "联机模块 CLI.exe") AndAlso File.Exists(PathEasyTier & "联机模块.exe") AndAlso
  423. File.Exists(PathEasyTier & "Packet.dll")) Then
  424. Settings.Set("LinkEasyTierVersion", -1)
  425. End If
  426. Dim LocalVersion As Integer = Settings.Get("LinkEasyTierVersion")
  427. ServerVersion = ServerConfig("Link")("EasyTierVersion")
  428. Dim RequiredFiles As New List(Of NetFile)
  429. Log($"[Link] EasyTier 本地版本:{LocalVersion},需求版本:{ServerVersion}")
  430. If LocalVersion < ServerVersion Then
  431. RequiredFiles.Add(New NetFile(
  432. ServerConfig("Link")("Downloads").Select(Function(UrlEntry) UrlEntry.ToString.Replace("{arch}", Architecture)),
  433. PathEasyTier & "EasyTier.zip",
  434. New FileChecker(MinSize:=1024 * 1024 * 2)))
  435. End If
  436. '开始下载
  437. UpdateLoadingPage("正在下载联机模块……", "下载联机模块")
  438. Task.Output = RequiredFiles
  439. End Sub
  440. '3. 启动联机模块
  441. Private Sub InitLaunch(Task As LoaderTask(Of Integer, Integer))
  442. '解压文件
  443. UpdateLoadingPage("正在解压联机模块……", "解压联机模块")
  444. If File.Exists(PathEasyTier & "EasyTier.zip") Then
  445. '解压
  446. Dim ExtractPath As String = RequestTaskTempFolder()
  447. ExtractCompressedFile(PathEasyTier & "EasyTier.zip", ExtractPath,
  448. ProgressIncrementHandler:=Sub(Progress) Task.Progress += Progress * 0.05)
  449. Dim ExtractedPath As String = New DirectoryInfo(ExtractPath).EnumerateDirectories.FirstOrDefault?.FullName
  450. Log("[Link] 联机模块解压时的临时路径:" & ExtractedPath)
  451. CopyDirectory(ExtractedPath, PathEasyTier)
  452. '重命名
  453. File.Delete(PathEasyTier & "联机模块.exe")
  454. File.Move(PathEasyTier & "easytier-core.exe", PathEasyTier & "联机模块.exe")
  455. File.Delete(PathEasyTier & "联机模块 CLI.exe")
  456. File.Move(PathEasyTier & "easytier-cli.exe", PathEasyTier & "联机模块 CLI.exe")
  457. '清理
  458. File.Delete(PathEasyTier & "EasyTier.zip")
  459. Settings.Set("LinkEasyTierVersion", ServerVersion)
  460. End If
  461. Task.Progress = 0.07
  462. '获取节点列表
  463. UpdateLoadingPage("正在获取节点列表……", "获取节点列表")
  464. Dim RawPeers As List(Of String)
  465. Dim CustomPeers As String = Settings.Get("LinkCustomPeer")
  466. If String.IsNullOrWhiteSpace(CustomPeers) Then
  467. If DiscoverNodeID = -2 AndAlso Not IsServerSide Then
  468. Panic("未填写自定义节点设置", $"$你必须在 {vbLQ}自定义节点{vbRQ} 设置中填写与房主相同的内容,{vbCrLf}才能进入该房间!")
  469. Return
  470. End If
  471. RawPeers = GetTargetPeers()
  472. Else
  473. If DiscoverNodeID <> -2 AndAlso Not IsServerSide Then Hint("房主可能没有使用自定义节点设置,请确认你们的自定义节点设置是否一致!")
  474. RawPeers = CustomPeers.Split(",,".ToCharArray).Select(Function(p) p.Trim).Where(Function(p) Not String.IsNullOrEmpty(p)).ToList()
  475. Log("[Link] 使用自定义节点:" & CustomPeers)
  476. End If
  477. Task.Progress = 0.13
  478. '获取空闲端口
  479. UpdateLoadingPage("正在启动联机模块……", "启动联机模块")
  480. Dim FreePorts = FindFreePorts(5, ServerPort)
  481. ClientPort = FreePorts(0)
  482. RPCPort = FreePorts(1)
  483. Dim ListenersPort As Integer = FreePorts(2) '它会占用【当前、当前 +1、当前 +2】共三个端口
  484. '获取启动参数
  485. Dim Arguments As String = ServerConfig("Link")("Argument")
  486. Arguments += $" --network-name={NetworkName} --network-secret={NetworkSecret} --listeners {ListenersPort} --rpc-portal {RPCPort} --private-mode true"
  487. Dim HostName = If(IsServerSide, "Server-", "Client-") & RadixConvert(Math.Abs(Identify.GetHashCode), 10, 36)
  488. If IsServerSide Then
  489. Arguments += $" -i 10.114.114.114 --hostname={HostName} --tcp-whitelist={ServerPort} --udp-whitelist={ServerPort}"
  490. Else
  491. Arguments += $" -d --hostname={HostName} --tcp-whitelist=0 --udp-whitelist=0"
  492. '端口转发
  493. ClientAddress = $"localhost:{ClientPort}"
  494. Arguments += $" --port-forward tcp://[{IPAddress.IPv6Loopback}]:{ClientPort}/10.114.114.114:{ServerPort}"
  495. Arguments += $" --port-forward udp://[{IPAddress.IPv6Loopback}]:{ClientPort}/10.114.114.114:{ServerPort}"
  496. Arguments += $" --port-forward tcp://{IPAddress.Loopback}:{ClientPort}/10.114.114.114:{ServerPort}"
  497. Arguments += $" --port-forward udp://{IPAddress.Loopback}:{ClientPort}/10.114.114.114:{ServerPort}"
  498. End If
  499. For Each Peer As String In RawPeers
  500. Arguments += $" -p=""{Peer}"""
  501. Next
  502. If Settings.Get("LinkLatencyMode") = 1 Then Arguments += " --latency-first"
  503. '启动进程
  504. ProcessStart(Arguments)
  505. Task.Progress = 0.15
  506. '等待连接
  507. Dim TimeoutCounter As Integer = 0
  508. Do
  509. Thread.Sleep(500) '为避免还没启动好先跑 CLI 了,先等半秒
  510. '刷新信息
  511. CheckCrash()
  512. RefreshPeerLoader.WaitForExit(IsForceRestart:=True)
  513. '查找目标节点
  514. Dim Ping = GetPeerPing()
  515. If Ping > 0 Then
  516. Log($"[Link] 已与目标建立连接,当前 Ping 为 {Ping:0.0}ms")
  517. Telemetry("联机成功", "Server", IsServerSide, "NAT", NATType)
  518. Exit Do '退出循环
  519. End If
  520. '更新进度
  521. Dim LastProgress = Task.Progress
  522. Dim PeerCount As Integer = If(Peers Is Nothing, -1, Peers.Where(Function(p) p.Ping > 0).Count)
  523. Select Case PeerCount
  524. Case -1 'CLI 无返回
  525. Task.Progress = MathClamp(Task.Progress + 0.02, 0.15, 0.25)
  526. Case 0 'CLI 有返回,但未连接到任何节点
  527. UpdateLoadingPage("正在连接到节点……", "连接节点")
  528. Task.Progress = MathClamp(Task.Progress + 0.02, If(IsServerSide, 0.5, 0.3), If(IsServerSide, 0.95, 0.5))
  529. Case Else '已连接到节点,但未连接到房主
  530. UpdateLoadingPage("正在连接到房主……", "连接房主")
  531. Task.Progress = MathClamp(Task.Progress + 0.02, Math.Min(0.45 + PeerCount * 0.05, 0.65), 0.95)
  532. End Select
  533. '超时判定
  534. If LastProgress <> Task.Progress Then
  535. TimeoutCounter = 0
  536. ElseIf TimeoutCounter < 30 * 2 Then
  537. TimeoutCounter += 1
  538. Else '进度停滞超过 30s
  539. Select Case PeerCount
  540. Case -1 'CLI 无返回
  541. Panic("无法启动联机模块", "近期日志:" & vbCrLf & LogHistory.Join(vbCrLf))
  542. Case 0 'CLI 有返回,但未连接到任何节点
  543. Panic("无法连接到节点", $"请检查你的网络环境是否良好。")
  544. Case Else '已连接到节点,但未连接到房主
  545. Panic("无法连接到房主", $"可能的原因:{vbCrLf}- 你或者房主的网络环境不佳{vbCrLf}- 房主已关闭房间{vbCrLf}- 邀请码输错了")
  546. End Select
  547. End If
  548. Loop Until Task.IsInterrupted
  549. If Task.IsInterrupted Then Throw New ThreadInterruptedException
  550. '等待连接稳定,最多 5s
  551. If IsServerSide Then Return
  552. UpdateLoadingPage("连接优化中……", "优化连接")
  553. Task.Progress = 0.999
  554. For i = 1 To 50
  555. Dim Server = GetTargetPeer()
  556. If Server IsNot Nothing AndAlso Not Server.Relay AndAlso Server.Ping < 100 Then Return '结束
  557. If Task.IsInterrupted Then Throw New ThreadInterruptedException
  558. Thread.Sleep(100)
  559. Next
  560. End Sub
  561. ''' <summary>
  562. ''' 从在线配置和 API 获取需要连接的节点列表,并更新发现节点 ID。
  563. ''' 根据发现节点 ID,会有以下行为变化:
  564. ''' -1:作为房主,根据负载均衡选择一个发现节点。
  565. ''' 0:作为加入者,但邀请码未提供发现节点 ID,使用回退发现节点。
  566. ''' >0:作为加入者,根据 ID 选择对应的发现节点;如果没有,使用回退发现节点。
  567. ''' </summary>
  568. Private Function GetTargetPeers() As List(Of String)
  569. Dim FinalPeers As New List(Of String), FinalDiscoverID As Integer = -1
  570. Dim FallbackDiscoverID = ServerConfig("Link")("DiscoverPeerId").ToObject(Of Integer)
  571. Dim FallbackDiscoverAddress As String = ServerConfig("Link")("DiscoverPeer").ToString()
  572. Try
  573. '从 API 获取节点列表
  574. Dim RawNodes As JObject
  575. Dim IsFallbackRawList As Boolean = False
  576. Try
  577. RawNodes = GetJson(NetRequestByClient("https://uptime.easytier.cn/api/nodes?page=1&per_page=1000", RequireJson:=True))
  578. Catch exx As Exception
  579. Log(exx, "从源站获取节点列表失败,将使用 CDN 缓存")
  580. RawNodes = GetJson(NetRequestByClientRetry("https://easytier.meloong.com/?page=1&per_page=1000", RequireJson:=True))
  581. IsFallbackRawList = True
  582. End Try
  583. '分析节点列表
  584. Dim Nodes As New List(Of JObject) '负载会添加在 load 字段上
  585. Dim BlackList As List(Of String) = ServerConfig("Link")("PeersBlackList").Select(Function(p) p.ToString).ToList()
  586. For Each Node As JObject In RawNodes("data")("items")
  587. '状态检查
  588. Dim ID = Node("id").ToObject(Of Integer)
  589. If Not Node("is_active").ToObject(Of Boolean) OrElse Not Node("is_approved").ToObject(Of Boolean) Then Continue For
  590. If ID = DiscoverNodeID Then GoTo ForcedPass '若为指定的发现节点,忽略后续检查
  591. If ID = FallbackDiscoverID Then Continue For '不主动选取回退发现节点
  592. If BlackList.Contains(Node("address").ToString) Then Continue For 'ServerConfig 黑名单
  593. If Node("usage_percentage").ToObject(Of Double) = 0 AndAlso RandomInteger(1, 100) <> 1 Then Continue For '或许节点有问题才导致是 0 负载,让它只有 1% 概率被选中
  594. '标签检查
  595. Dim Tags = Node("tags").Select(Function(t) t.ToString).ToList
  596. If Not Tags.Contains("国内") OrElse Not Tags.Contains("MC中继") Then Continue For
  597. '计算负载并加入列表
  598. ForcedPass:
  599. Dim Load As Double = Node("usage_percentage").ToObject(Of Double) '负载
  600. Load *= 110 - Node("health_percentage_24h").ToObject(Of Double) '可用率
  601. Node("load") = Load
  602. Nodes.Add(Node)
  603. Next
  604. '排序
  605. If Not IsFallbackRawList Then
  606. Nodes = Nodes.OrderBy(Function(n) n("load").ToObject(Of Double)).ToList() '按负载从低到高排序
  607. Else
  608. Nodes = Nodes.Shuffle().ToList() '回退到 CDN 缓存时,由于负载数据可能过期,直接随机选择
  609. End If
  610. '选取发现节点
  611. Dim SelectedDiscoverNode As JObject = Nothing
  612. If DiscoverNodeID = -1 Then '-1:作为房主,根据负载均衡选择一个发现节点
  613. SelectedDiscoverNode = Nodes.FirstOrDefault(Function(n) Not n("allow_relay").ToObject(Of Boolean))
  614. ElseIf DiscoverNodeID > 0 Then '>0:作为加入者,根据 ID 选择对应的发现节点;如果没有,使用回退发现节点
  615. SelectedDiscoverNode = Nodes.FirstOrDefault(Function(n) n("id").ToObject(Of Integer) = DiscoverNodeID)
  616. If SelectedDiscoverNode Is Nothing Then
  617. Log($"[Link] 未找到 ID {DiscoverNodeID} 的发现节点", LogLevel.Debug)
  618. Panic("房间已过期", "请让房主重新创建房间!")
  619. Throw New ThreadInterruptedException
  620. End If
  621. End If
  622. If SelectedDiscoverNode Is Nothing Then '使用回退发现节点
  623. SelectedDiscoverNode = New JObject From {{"address", FallbackDiscoverAddress}, {"id", FallbackDiscoverID}}
  624. Log("[Link] 将使用回退发现节点", LogLevel.Debug)
  625. End If
  626. FinalPeers.Add(SelectedDiscoverNode("address").ToString())
  627. FinalDiscoverID = SelectedDiscoverNode("id").ToObject(Of Integer)
  628. Log($"[Link] 发现节点:{SelectedDiscoverNode("address")} (ID: {FinalDiscoverID})")
  629. '选取中继节点
  630. If ModeDebug OrElse Not IsServerSide Then '房主只连接发现节点,不连接中继节点
  631. Dim RelayCount As Integer = ServerConfig("Link")("RandomPeer").ToObject(Of Integer)
  632. Dim RelayNodes = Nodes.Where(Function(n) n("allow_relay").ToObject(Of Boolean)).ToList()
  633. If RelayNodes.Count < RelayCount Then Throw New Exception($"可用的中继节点数量不足,需要 {RelayCount} 个,实际 {RelayNodes.Count} 个")
  634. FinalPeers.AddRange(RelayNodes.Take(RelayCount).Select(Function(n) n("address").ToString()))
  635. End If
  636. Catch ex As ThreadInterruptedException
  637. Throw
  638. Catch ex As Exception
  639. Log(ex, "获取节点列表失败,联机质量可能受到影响", LogLevel.Hint)
  640. FinalPeers.AddRange(ServerConfig("Link")("Peers").Select(Function(p) p.ToString))
  641. If FinalDiscoverID <= 0 Then
  642. FinalPeers.Add(FallbackDiscoverAddress)
  643. FinalDiscoverID = FallbackDiscoverID
  644. End If
  645. End Try
  646. '版本 1 兼容
  647. If CType(ServerConfig("Link"), JObject).ContainsKey("EnableForcedPeer") Then
  648. FinalPeers.Add("tcp://mc1.easytier.cn:55558")
  649. If FinalDiscoverID <= 0 Then FinalDiscoverID = 94
  650. End If
  651. '强制添加的节点
  652. FinalPeers.AddRange(ServerConfig("Link")("MandatoryPeers").Select(Function(p) p.ToString))
  653. '结束
  654. DiscoverNodeID = FinalDiscoverID
  655. Return FinalPeers.Distinct.ToList
  656. End Function
  657. #End Region
  658. #Region "进程与日志"
  659. ''' <summary>
  660. ''' EasyTier Core 进程。
  661. ''' </summary>
  662. Private Shared ProcessCore As Process
  663. Private Shared ProcessOutputHandle As AutoResetEvent, ProcessErrorHandle As AutoResetEvent
  664. ''' <summary>
  665. ''' 若程序正在运行,则结束程序进程。
  666. ''' 即使失败也不会抛出异常。
  667. ''' </summary>
  668. Public Shared Sub ProcessStop()
  669. Try
  670. '关闭未捕获的进程
  671. For Each ProcessObject In Process.GetProcesses
  672. If ProcessObject.Id = ProcessCore?.Id Then Continue For
  673. If ProcessObject.ProcessName <> "联机模块" AndAlso ProcessObject.ProcessName <> "联机模块 CLI" Then Continue For
  674. Try
  675. Log("[Link] 停止残留的联机模块,PID:" & ProcessObject.Id & ",进程名:" & ProcessObject.ProcessName)
  676. ProcessObject.Kill()
  677. ProcessObject.Close()
  678. Catch exx As Exception
  679. Log(exx, $"结束进程失败({ProcessObject.ProcessName},PID {ProcessObject.Id})")
  680. End Try
  681. Next
  682. '关闭由自身启动的进程
  683. If ProcessCore IsNot Nothing AndAlso Not ProcessCore.HasExited Then
  684. Log("[Link] 停止所启动的联机模块,PID:" & ProcessCore.Id)
  685. ProcessCore.Kill()
  686. ProcessCore.Close()
  687. ProcessCore = Nothing
  688. End If
  689. '释放资源
  690. ProcessOutputHandle?.Dispose()
  691. ProcessErrorHandle?.Dispose()
  692. Catch ex As Exception
  693. Log(ex, "停止联机模块失败")
  694. End Try
  695. End Sub
  696. ''' <summary>
  697. ''' 出现意外错误,给出错误信息并结束联机。
  698. ''' </summary>
  699. Private Sub Panic(Brief As String, Detail As String)
  700. '常见原因分析
  701. If Detail.Contains("failed to listen on ") Then
  702. Detail = $"监听端口失败。{vbCrLf}请点击重试,如果还是出现此错误,可以重启电脑解决。{vbCrLf}{vbCrLf}{Detail}"
  703. End If
  704. '显示信息
  705. If LinkState = LinkStates.Loading Then
  706. FailReason = Brief
  707. LinkLoader.Failed(New Exception(Detail))
  708. Else
  709. MyMsgBox(Detail, "联机出错:" & Brief, IsWarn:=True)
  710. ChangeState(LinkStates.Waiting)
  711. Telemetry("联机失败", "Exception", FilterUserName(Brief & ":" & Detail, "*"))
  712. End If
  713. End Sub
  714. ''' <summary>
  715. ''' 启动进程。
  716. ''' </summary>
  717. Private Sub ProcessStart(Arguments As String)
  718. Dim Info = New ProcessStartInfo With {
  719. .FileName = PathEasyTier & "联机模块.exe",
  720. .Arguments = Arguments,
  721. .UseShellExecute = False,
  722. .CreateNoWindow = True,
  723. .RedirectStandardError = True,
  724. .RedirectStandardOutput = True,
  725. .StandardOutputEncoding = Encoding.UTF8,
  726. .StandardErrorEncoding = Encoding.UTF8
  727. }
  728. Log("[Link] 正在启动 EasyTier:" & Arguments)
  729. ProcessCore = New Process With {.StartInfo = Info}
  730. Dim LogLineHandler =
  731. Function(sender As Object, e As DataReceivedEventArgs, Handle As AutoResetEvent)
  732. Try
  733. If e.Data Is Nothing Then
  734. Handle.[Set]()
  735. Return Nothing
  736. End If
  737. ProcessLogLine(e.Data)
  738. Catch unused As ObjectDisposedException
  739. Catch ex As Exception
  740. Log(ex, "读取 EasyTier 信息失败")
  741. End Try
  742. Return Nothing
  743. End Function
  744. ProcessOutputHandle = New AutoResetEvent(False)
  745. AddHandler ProcessCore.OutputDataReceived, Function(sender, e) LogLineHandler(sender, e, ProcessOutputHandle)
  746. ProcessErrorHandle = New AutoResetEvent(False)
  747. AddHandler ProcessCore.ErrorDataReceived, Function(sender, e) LogLineHandler(sender, e, ProcessErrorHandle)
  748. ProcessCore.Start()
  749. ProcessCore.BeginOutputReadLine()
  750. ProcessCore.BeginErrorReadLine()
  751. End Sub
  752. Private Sub ProcessLogLine(Line As String)
  753. '记录日志
  754. Log("[EasyTier] " & Line)
  755. LogHistory.Enqueue(Line)
  756. If LogHistory.Count >= 10 Then LogHistory.Dequeue()
  757. '检查日志内容
  758. If Line.ContainsF("new peer connection added", True) Then
  759. Log("[Link] 已建立连接:" & If(RegexSeek(Line, "(?<=remote_addr.+?"")[^""}]{3,}"), Line), LogLevel.Debug)
  760. Update()
  761. ElseIf Line.ContainsF("peer connection removed", True) Then
  762. Log("[Link] 已断开连接:" & If(RegexSeek(Line, "(?<=remote_addr.+?"")[^""}]{3,}"), Line), LogLevel.Debug)
  763. Update()
  764. End If
  765. End Sub
  766. Private LogHistory As New Queue(Of String)(10)
  767. #End Region
  768. #Region "CLI 节点信息获取"
  769. Private Class Peer
  770. ''' <summary>
  771. ''' 该节点的类型。
  772. ''' </summary>
  773. Public ReadOnly Type As Types
  774. Public Enum Types
  775. ''' <summary>
  776. ''' 客户端。
  777. ''' </summary>
  778. Client
  779. ''' <summary>
  780. ''' 服务器。
  781. ''' </summary>
  782. Server
  783. ''' <summary>
  784. ''' 公共节点。
  785. ''' </summary>
  786. Misc
  787. ''' <summary>
  788. ''' 自己,或者自己的重复(它可能返回多个自己)。
  789. ''' </summary>
  790. Self
  791. End Enum
  792. ''' <summary>
  793. ''' 与该节点的延迟 (ms)。
  794. ''' 若是自己则为 0。
  795. ''' </summary>
  796. Public ReadOnly Ping As Double
  797. ''' <summary>
  798. ''' 名称。
  799. ''' </summary>
  800. Public ReadOnly Name As String
  801. ''' <summary>
  802. ''' 是否通过中继连接。
  803. ''' </summary>
  804. Public ReadOnly Relay As Boolean
  805. ''' <summary>
  806. ''' NAT 类型。
  807. ''' </summary>
  808. Public ReadOnly NATType As NATTypes
  809. ''' <summary>
  810. ''' 从 CLI 给出的信息分析对应的数据。
  811. ''' </summary>
  812. Public Sub New(Info As JObject)
  813. '类别
  814. Dim PeerName = Info("hostname").ToString
  815. If Info("cost").ToString = "Local" Then
  816. Type = Types.Self
  817. ElseIf PeerName.StartsWithF("Client") Then
  818. Type = Types.Client
  819. ElseIf Info("ipv4") = "10.114.114.114" Then '只允许这个 IP 作为房主,避免网络被多个房主搞炸的情况
  820. Type = Types.Server
  821. Else
  822. Type = Types.Misc
  823. End If
  824. '基础信息
  825. Double.TryParse(Info("lat_ms"), NumberStyles.Any, CultureInfo.InvariantCulture, Ping)
  826. Name = PeerName
  827. Relay = Info("cost").ToString.ContainsF("relay", True)
  828. NATType = Info("nat_type").ToString.ParseToEnum(Of NATTypes)
  829. End Sub
  830. Public Overrides Function ToString() As String
  831. Return $"{Type} - {Name} - Ping {Ping:0.0}ms [中继? {Relay}] - NAT {NATType}"
  832. End Function
  833. End Class
  834. Private Enum NATTypes
  835. 'https://github.com/EasyTier/EasyTier/blob/6bb2fd9a15ab2499bdeabdcc3a925e9bd9aebf50/easytier/src/proto/common.proto#L129
  836. Unknown = 0
  837. OpenInternet = 1
  838. NoPAT = 2
  839. FullCone = 3
  840. Restricted = 4
  841. PortRestricted = 5
  842. Symmetric = 6
  843. SymUdpFirewall = 7
  844. SymmetricEasyInc = 8
  845. SymmetricEasyDec = 9
  846. ''' <summary>
  847. ''' 尚未获取。
  848. ''' </summary>
  849. Pending = 10
  850. End Enum
  851. ''' <summary>
  852. ''' 当前的节点列表,使用 RefreshPeerLoader 来刷新。
  853. ''' 若尚未成功获取过则为 Nothing,但保证在加载完成后至少是一个列表。
  854. ''' </summary>
  855. Private Peers As List(Of Peer) = Nothing
  856. ''' <summary>
  857. ''' 自己的 NAT 类型。
  858. ''' </summary>
  859. Private NATType As NATTypes = NATTypes.Pending
  860. ''' <summary>
  861. ''' 调用 EasyTier CLI 获取已连接节点信息。
  862. ''' 这会过滤掉尚未完成连接的其他节点以及自己。
  863. ''' 若在加载完成后连续获取失败 3 次,则会强制断开连接。
  864. ''' </summary>
  865. Private RefreshPeerLoader As New LoaderTask(Of Integer, List(Of Peer))("EasyTier CLI", AddressOf RefreshPeer)
  866. Private Sub RefreshPeer()
  867. Try
  868. Dim CliResult = StartProcessAndGetOutput(PathEasyTier & "联机模块 CLI.exe", $"-o json -p 127.0.0.1:{RPCPort} peer", 2000, Encoding:=Encoding.UTF8, PrintLog:=False)
  869. '解析
  870. If Not CliResult.Contains("lat_ms") Then Throw New Exception("CLI 调用失败:" & vbCrLf & CliResult)
  871. If GetUuid() Mod If(ModeDebug, 23, 103) = 0 Then Log("[EasyTier] CLI 输出抽样:" & vbCrLf & CliResult)
  872. Dim NewPeers As New List(Of Peer)
  873. For Each Line As JObject In CType(GetJson(CliResult), JArray)
  874. Try
  875. Dim Peer = New Peer(Line)
  876. If Peer.Type = Peer.Types.Self Then
  877. NATType = Peer.NATType '记录自己的 NAT
  878. Else
  879. NewPeers.Add(Peer)
  880. End If
  881. Catch exx As Exception
  882. Log(exx, $"错误的信息({Line})")
  883. End Try
  884. Next
  885. '完成
  886. Peers = NewPeers
  887. FailCount = 0
  888. Catch ex As Exception
  889. Log(ex, "获取节点信息失败")
  890. If LinkState = LinkStates.Finished Then
  891. FailCount += 1
  892. If FailCount >= 4 Then Panic("获取节点信息失败", ex.Message)
  893. End If
  894. End Try
  895. End Sub
  896. ''' <summary>
  897. ''' CLI 调用连续失败的次数。
  898. ''' </summary>
  899. Private FailCount As Integer = 0
  900. ''' <summary>
  901. ''' 根据当前的节点列表获取 Ping 值。
  902. ''' 服务端会返回所有节点中最低的 Ping,客户端会返回服务端的 Ping。
  903. ''' 0 代表尚不可用。
  904. ''' </summary>
  905. Private Function GetPeerPing() As Double
  906. Dim Peer = GetTargetPeer()
  907. If Peer Is Nothing Then Return 0
  908. Return Peer.Ping
  909. End Function
  910. ''' <summary>
  911. ''' 服务端会返回所有节点中 Ping 大于 0 最低的那一个,客户端会返回服务端。
  912. ''' 若没有则为 Nothing。
  913. ''' </summary>
  914. Private Function GetTargetPeer() As Peer
  915. If Peers Is Nothing Then Return Nothing
  916. Dim Targets As IEnumerable(Of Peer)
  917. If IsServerSide Then
  918. Targets = Peers.Where(Function(p) p.Ping > 0)
  919. Else
  920. Targets = Peers.Where(Function(p) p.Type = Peer.Types.Server AndAlso p.Ping > 0)
  921. End If
  922. If Not Targets.Any Then Return Nothing
  923. '返回 Ping 且最低的那个
  924. Dim MinPing = Targets.Min(Function(p) p.Ping)
  925. Return Targets.First(Function(p) p.Ping = MinPing)
  926. End Function
  927. ''' <summary>
  928. ''' 获取当前房间中的人数,包括自己。
  929. ''' 0 代表不可用。
  930. ''' </summary>
  931. Private ReadOnly Property PeopleCount As Integer
  932. Get
  933. If Peers Is Nothing Then Return 0
  934. Return Peers.Where(Function(p) p.Type <> Peer.Types.Misc).Count() + 1 '加上自己
  935. End Get
  936. End Property
  937. #End Region
  938. #Region "定时任务"
  939. '启动
  940. Private Sub StartTimerThread() Handles Me.Loaded
  941. Static IsTimerStarted As Boolean = False
  942. If IsTimerStarted Then Return
  943. RunInNewThread(
  944. Sub()
  945. Dim Counter As Integer = 0
  946. Do While True
  947. Try
  948. Thread.Sleep(200)
  949. Counter += 200
  950. '每秒执行一次
  951. If Counter >= 1000 Then
  952. Counter = 0
  953. Update()
  954. End If
  955. '每 200ms 更新进度条
  956. If LinkState = LinkStates.Loading Then RunInUi(AddressOf UpdateProgressBar)
  957. Catch ex As Exception
  958. Log(ex, "联机模块主时钟出错", LogLevel.Feedback)
  959. Thread.Sleep(10000)
  960. End Try
  961. Loop
  962. End Sub, "Link Timer")
  963. End Sub
  964. '每秒或进入页面时触发
  965. Private Sub Update() Handles Me.Loaded
  966. If LinkState <> LinkStates.Finished Then Return
  967. '重新获取信息
  968. SyncLock RefreshPeerLoader.LockState
  969. If RefreshPeerLoader.State <> LoadState.Loading Then RefreshPeerLoader.Start(IsForceRestart:=True)
  970. End SyncLock
  971. '更新 UI
  972. If FrmMain.PageCurrent = FormMain.PageType.Link Then
  973. RunInUi(
  974. Sub()
  975. 'Logo 旋转动画
  976. AniStart(AaRotateTransform(ImgFinishLogo, 500, 5000), "Link Logo Rotation")
  977. 'Ping
  978. Dim Ping As Double = GetPeerPing()
  979. Dim Connecting As Boolean = Ping Mod 500 = 0 OrElse $"{Ping:0.0}" = "1.0" OrElse FailCount > 0
  980. If Connecting Then
  981. LabFinishPing.Text = "连接优化中"
  982. Else
  983. LabFinishPing.Text = If(Ping >= 10, $"{Ping:0} ms", $"{Ping:0.0} ms")
  984. End If
  985. '人数显示
  986. LabFinishPlayer.Text = PeopleCount & "  人"
  987. '------------------------
  988. ' 提示条
  989. '------------------------
  990. HintFinish.Visibility = Visibility.Collapsed
  991. If IsServerSide Then Return '服务端没有需要显示的提示
  992. If Connecting Then Return '连接稳定过程中不显示提示
  993. '中继提示
  994. Dim Server As Peer = GetTargetPeer()
  995. If Server Is Nothing Then Return
  996. If Server.Relay Then
  997. If NATType >= NATTypes.Symmetric AndAlso Server.NATType >= NATTypes.Symmetric Then
  998. HintFinish.Text = "你和房主的网络环境都不太好,"
  999. ElseIf NATType >= NATTypes.Symmetric Then
  1000. HintFinish.Text = "你的网络环境不太好,"
  1001. ElseIf Server.NATType >= NATTypes.Symmetric Then
  1002. HintFinish.Text = "房主的网络环境不太好,"
  1003. Else
  1004. HintFinish.Text = "你或者房主的网络环境不太好,"
  1005. End If
  1006. If String.IsNullOrWhiteSpace(Settings.Get("LinkCustomPeer")) Then
  1007. HintFinish.Text &= "正使用社区节点进行中继。"
  1008. Else
  1009. HintFinish.Text &= "正通过自定义节点进行中继。"
  1010. End If
  1011. HintFinish.Visibility = Visibility.Visible
  1012. HintFinish.Theme = MyHint.Themes.Yellow
  1013. Return
  1014. End If
  1015. '环境比房主更好的提示
  1016. If NATType >= NATTypes.PortRestricted Then Return '自身的 NAT 为 2 或更好
  1017. If Server.NATType < NATTypes.PortRestricted Then Return '房主的 NAT 为 3 或更差
  1018. Dim OtherPlayers = Peers.Where(Function(p) p.Type = Peer.Types.Client).ToList()
  1019. If Not OtherPlayers.Any() Then Return '房间里还有其他玩家
  1020. If OtherPlayers.Any(Function(p) p.Relay) Then Return '自己可以与所有玩家打洞
  1021. If OtherPlayers.All(Function(p) p.NATType < NATTypes.PortRestricted) Then Return '任意其他玩家的 NAT 为 3 或更差
  1022. HintFinish.Visibility = Visibility.Visible
  1023. HintFinish.Theme = MyHint.Themes.Blue
  1024. HintFinish.Text = "你的网络环境比房主更好!如果你来当房主,其他玩家或许能更加流畅!"
  1025. End Sub)
  1026. End If
  1027. '检查核心状态
  1028. CheckCrash()
  1029. '检查节点状态
  1030. If Not Peers.Any Then
  1031. Panic("网络连接已断开", "请检查你的网络环境是否正常。")
  1032. Return
  1033. End If
  1034. If Not IsServerSide AndAlso Not Peers.Any(Function(p) p.Type = Peer.Types.Server) Then
  1035. MyMsgBox("房主已离开房间!", "联机结束")
  1036. ChangeState(LinkStates.Waiting)
  1037. Return
  1038. End If
  1039. '广播联机房间端口
  1040. If Not IsServerSide Then
  1041. Try
  1042. Static BroadcastSocket As New Socket(SocketType.Dgram, ProtocolType.Udp)
  1043. BroadcastSocket.SendTo(
  1044. Encoding.UTF8.GetBytes($"[MOTD]PCL 联机房间[/MOTD][AD]{ClientPort}[/AD]"),
  1045. SocketFlags.None,
  1046. New IPEndPoint(IPAddress.Loopback, 4445))
  1047. Catch ex As Exception
  1048. Log(ex, "广播联机房间端口失败")
  1049. End Try
  1050. End If
  1051. End Sub
  1052. ''' <summary>
  1053. ''' 检查联机模块是否崩溃。
  1054. ''' </summary>
  1055. Private Sub CheckCrash()
  1056. If ProcessCore IsNot Nothing AndAlso Not ProcessCore.HasExited Then Return
  1057. Panic("联机模块已崩溃", "近期日志:" & vbCrLf & LogHistory.Join(vbCrLf))
  1058. End Sub
  1059. #End Region
  1060. End Class