Compare commits

...
14 Commits
25 changed files with 1278 additions and 416 deletions
+7
View File
@@ -29,6 +29,7 @@ Releases [https://github.com/EasyTier/EasytierGame/releases](https://github.c
![game-step5](/assets/game-step5.png)
- easytier内核升级后,可以点击内核管理按钮就可以进行内核切换和更新,但是需要出国或者github加速链接,如果无法更新,可以在群里获取
- 1.2.6内核管理下载的内核 保存于easytier/cache目录,下次切换不用二次下载
![game-step6](/assets/game-step6.png)
- 1.1.4更新了 配置分享功能 可以与朋友之间分享配置,方便联机
@@ -49,6 +50,12 @@ Releases [https://github.com/EasyTier/EasytierGame/releases](https://github.c
- 1.2.3新增了帮助.txt 位于“easytier/帮助.txt" 内含 无法打开界面和卸载EasytierGame的办法,新增 "easytier/clear_local_data.bat" 用于清除easytierGame的本地缓存数据(需要管理员模式运行)
![game-step11](/assets/game-step11.png)
- 1.2.5新增 自建服务器功能,可以自行搭建服务器,但是需要一些网络知识,具体可以查看文档[自建服务器](https://www.easytier.top/guide/network/host-public-server.html)
![game-step12](/assets/game-step12.png)
- 1.2.6重写 自建服务器功能,可以自行搭建服务器,但是需要一些网络知识,具体可以查看文档[自建服务器](https://www.easytier.top/guide/network/host-public-server.html),也可查看帮助.txt
![game-step13](/assets/game-step13.png)
## 特性
- 基于easytier组网工具开发,界面清晰简单
+10
View File
@@ -27,6 +27,9 @@ html.dark body {
}
#__easytier {
display: flex;
flex-direction: column;
flex-wrap: nowrap;
height: 100%;
overflow: hidden;
box-sizing: border-box;
@@ -36,4 +39,11 @@ html.dark body {
.full-label .el-form-item__label {
width: 100%;
padding-right: 0;
}
.full-content .el-form-item__content {
/* height: 100%; */
align-items: flex-start;
overflow: auto;
flex: 1;
}
Binary file not shown.

After

Width:  |  Height:  |  Size: 27 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 55 KiB

+25
View File
@@ -0,0 +1,25 @@
import useMainStore from "@/stores/index";
export const getServerArgs = () => {
const mainStore = useMainStore();
const args = [];
if (!mainStore.serverConfig.port) {
mainStore.serverConfig.port = "11010";
}
args.push("-l", mainStore.serverConfig.port);
if (mainStore.serverConfig.relayAllPeerrpc) {
args.push("--relay-all-peer-rpc");
}
const whiteList = mainStore.serverConfig.serverWhiteList
.trim()
.split("\n")
.map(el => el.trim())
.filter(el => el)
.join(" ");
if (whiteList && mainStore.serverConfig.enableWhiteList) {
args.push("--relay-network-whitelist", whiteList);
}
if (!whiteList && mainStore.serverConfig.enableWhiteList) {
args.push("--relay-network-whitelist");
}
return args;
};
+1
View File
@@ -1,4 +1,5 @@
VITE_CONFIG_PATH=easytier/config/
VITE_CONFIG_FILE_NAME=easytier/config.json
VITE_LOG_PATH=easytier/logs/
VITE_CACHE_PATH=easytier/cache/
VITE_AUTO_START_SERVICE_NAME=easytierGameAutoStart
+1
View File
@@ -1,4 +1,5 @@
VITE_CONFIG_PATH=easytier/config/
VITE_CONFIG_FILE_NAME=easytier/config.json
VITE_LOG_PATH=easytier/logs/
VITE_CACHE_PATH=easytier/cache/
VITE_AUTO_START_SERVICE_NAME=easytierGameAutoStart
+5 -3
View File
@@ -3,10 +3,11 @@
"private": true,
"author": "leizi97",
"description": "A simple network initiator based on Easytier",
"version": "1.2.4",
"version": "1.2.7",
"scripts": {
"dev": "nuxt dev --dotenv env/.env.dev --host 0.0.0.0",
"build": "nuxt generate --dotenv env/.env.prod"
"build": "nuxt generate --dotenv env/.env.prod",
"release": "node zip.js"
},
"devDependencies": {
"@element-plus/icons-vue": "^2.3.1",
@@ -26,10 +27,11 @@
"@types/lodash-es": "^4.17.12",
"@vitejs/plugin-vue-jsx": "^4.1.0",
"@vueuse/core": "^11.2.0",
"archiver": "^7.0.1",
"element-plus": "^2.8.7",
"less": "^4.2.0",
"lodash-es": "^4.17.21",
"nuxt": "^3.13.2",
"nuxt": "^3.14.1592",
"pinia": "^2.2.6",
"pinia-plugin-persistedstate": "^4.1.3",
"postcss": "^8.4.38",
+1 -1
View File
@@ -77,7 +77,7 @@
<ElDivider />
<div><ElCheckbox v-model="mainStore.config.enablExitNode">允许此节点成为出口节点</ElCheckbox></div>
<div><ElCheckbox v-model="mainStore.config.disableEncryption">禁用对等节点通信的加密默认为启用必须与对等节点相同</ElCheckbox></div>
<div><ElCheckbox v-model="mainStore.config.multiThread">使用多线程运行默认为单线程</ElCheckbox></div>
<div><ElCheckbox v-model="mainStore.config.multiThread">用多线程运行</ElCheckbox></div>
<ElDivider />
<div><ElCheckbox v-model="mainStore.config.useSmoltcp">为子网代理启用smoltcp堆栈</ElCheckbox></div>
+295 -168
View File
@@ -4,11 +4,6 @@
label-position="top"
:model="config"
>
<!-- element-loading-custom-class="config-start"
v-loading="mainStore.configStartEnable"
:element-loading-spinner="'<path />'"
element-loading-text="-------已经启用配置文件,界面配置不再生效-------" -->
<!-- <div> -->
<ElFormItem
label="服务器"
prop="serverUrl"
@@ -40,29 +35,18 @@
</ElTag>
</ElTooltip>
</div>
<!-- <ElPopconfirm
width="325"
cancel-button-text="取消"
confirm-button-text="继续"
title="内核从github下载,需要出国工具,可能下载缓慢或失败,是否继续?
也可以从官方群里手动下载后解压到easytier-game.exe同级目录下的easytier目录里,全部覆盖即可"
@confirm="handleCoreManagement"
>
<template #reference> -->
<ElButton
class="ml-auto"
:disabled="data.isStart"
@click="handleCoreManagement"
:loading="data.update"
type="primary"
size="small"
>
内核管理
<!-- {{ data.coreVersion ? "更新内核" : "下载内核" }} -->
</ElButton>
<!-- </template>
</ElPopconfirm> -->
<ElTooltip content="请先停止自建服务和联机后再使用,否则内核被占用的情况下,无法进行内核更换">
<ElButton
class="ml-auto"
:disabled="data.isStart || listenObj.server_thread_id.value"
@click="handleCoreManagement"
:loading="data.update"
type="primary"
size="small"
>
内核管理
</ElButton>
</ElTooltip>
</div>
</template>
<ElSelect
@@ -196,129 +180,139 @@
></ElInput>
</ElFormItem>
</div>
<!-- </div> -->
<div class="flex items-start">
</ElForm>
<div class="flex items-start mt-auto">
<div>
<div>
<div>
<ElDropdown
@command="handleStartCommand"
split-button
trigger="click"
size="default"
:type="!data.isStart ? 'primary' : 'danger'"
:disabled="data.startLoading || !data.coreVersion || data.update"
@click="handleConnection"
>
{{ !data.isStart ? "启动联机" : "停止联机" }}
<template #dropdown>
<ElDropdownMenu>
<ElDropdownItem
command="import_config"
:icon="Link"
>
导入配置
</ElDropdownItem>
<ElDropdownItem
command="share_config"
:icon="Share"
>
分享配置
</ElDropdownItem>
<ElDropdownItem
:icon="Tools"
command="toml"
:disabled="data.isStart"
>
使用外部配置文件
</ElDropdownItem>
</ElDropdownMenu>
</template>
</ElDropdown>
</div>
<div class="mt-[6px] pl-[2px]">
<ElTooltip
placement="left"
content="日志"
>
<ElButton
:type="!data.logVisible ? 'info' : 'warning'"
@click="handleShowLogDialog"
:icon="List"
size="small"
plain
></ElButton>
</ElTooltip>
<ElTooltip
placement="left"
content="成员"
>
<ElButton
@click="handleShowMemberDialog"
:icon="UserFilled"
plain
type="success"
size="small"
></ElButton>
</ElTooltip>
</div>
<ElDropdown
@command="handleStartCommand"
split-button
trigger="click"
size="default"
:type="!data.isStart ? 'primary' : 'danger'"
:disabled="data.startLoading || !data.coreVersion || data.update"
@click="handleConnection"
>
{{ !data.isStart ? "启动联机" : "停止联机" }}
<template #dropdown>
<ElDropdownMenu>
<ElDropdownItem
command="import_config"
:icon="Link"
>
导入配置
</ElDropdownItem>
<ElDropdownItem
command="share_config"
:icon="Share"
>
分享联机相关配置
</ElDropdownItem>
<ElDropdownItem disabled>
<ElDivider class="!h-[2px] !m-0" />
</ElDropdownItem>
<ElDropdownItem
:icon="SetUp"
command="create_server"
>
自建服务({{ listenObj.server_thread_id.value ? "运行中" : "未运行" }})
</ElDropdownItem>
<ElDropdownItem
:icon="Tools"
command="toml"
:disabled="data.isStart"
>
使用外部配置文件
</ElDropdownItem>
</ElDropdownMenu>
</template>
</ElDropdown>
</div>
<div class="ml-auto">
<ElCheckbox
v-model="config.disbleP2p"
size="small"
>
强制中转
</ElCheckbox>
<div class="mt-[6px] pl-[2px]">
<ElTooltip
placement="top-start"
content="自启后隐藏于托盘,不显示界面"
placement="left"
content="日志"
>
<ElCheckbox
@change="handleAutoStartByTask"
:model-value="config.autoStart"
<ElButton
:type="!data.logVisible ? 'info' : 'warning'"
@click="handleShowLogDialog"
:icon="List"
size="small"
>
开机自启
</ElCheckbox>
plain
></ElButton>
</ElTooltip>
<div>
<ElTooltip
placement="left"
content="成员"
>
<ElButton
@click="handleShowCidrDialog"
:icon="Share"
>
子网代理
</ElButton>
<ElButton
@click="handleShowAdvanceDialog"
:icon="Setting"
>
高级选项
</ElButton>
</div>
<div class="flex items-center gap-[0_5px]">
<div>
<ElButton
plain
type="primary"
size="small"
:icon="MagicStick"
@click="handleShowToolDialog"
>
增强工具
</ElButton>
</div>
<ElLink
class="!text-[9px] pb-[2px] ml-[8px] truncate"
type="info"
:underline="false"
@click="open('https://github.com/EasyTier/EasytierGame')"
>
EasytierGame主页
</ElLink>
</div>
@click="handleShowMemberDialog"
:icon="UserFilled"
plain
type="success"
size="small"
></ElButton>
</ElTooltip>
</div>
</div>
</ElForm>
<div class="ml-auto">
<ElCheckbox
v-model="config.disbleP2p"
size="small"
>
强制中转
</ElCheckbox>
<ElTooltip
placement="top-start"
content="自启后隐藏于托盘,不显示界面"
>
<ElCheckbox
@change="handleAutoStartByTask"
:model-value="config.autoStart"
size="small"
>
开机自启
</ElCheckbox>
</ElTooltip>
<div>
<ElButton
@click="handleShowCidrDialog"
:icon="Share"
size="small"
>
子网代理
</ElButton>
<ElButton
@click="handleShowAdvanceDialog"
:icon="Setting"
size="small"
>
高级选项
</ElButton>
</div>
<div class="flex items-center gap-[0_5px]">
<div>
<ElButton
plain
type="primary"
size="small"
:icon="MagicStick"
@click="handleShowToolDialog"
>
增强工具
</ElButton>
</div>
<ElLink
class="!text-[9px] pb-[2px] ml-[8px] truncate"
type="info"
:underline="false"
@click="open('https://github.com/EasyTier/EasytierGame')"
>
EasytierGame主页
</ElLink>
</div>
</div>
</div>
<ElDialog
width="95%"
top="10px"
@@ -341,6 +335,9 @@
>
刷新
</ElButton>
<ElTooltip content="打开内核缓存目录">
<ElButton :icon="Folder" size="small" @click="handleOpenCache"></ElButton>
</ElTooltip>
</div>
<ElSelect
placeholder="请选择内核版本"
@@ -485,8 +482,8 @@
import { invoke } from "@tauri-apps/api/core";
import { listen } from "@tauri-apps/api/event";
import { open, Command } from "@tauri-apps/plugin-shell";
import { QuestionFilled, Delete, List, UserFilled, Setting, Share, RefreshRight, Link, Tools, MagicStick } from "@element-plus/icons-vue";
import { reactive, onBeforeUnmount, onMounted } from "vue";
import { QuestionFilled, Delete, List, UserFilled, Setting, Share, RefreshRight, Link, Tools, MagicStick, SetUp, Folder } from "@element-plus/icons-vue";
import { reactive, onBeforeUnmount, onMounted, ref } from "vue";
import { useTray, setTrayRunState, setTrayTooltip } from "~/composables/tray";
import { initStartWinIpBroadcast } from "~/composables/netcard";
import useMainStore from "@/stores/index";
@@ -501,31 +498,40 @@
import { writeText, readText } from "@tauri-apps/plugin-clipboard-manager";
import { sortedUniq, uniq } from "lodash-es";
import { bounce, addQQGroup } from "~/utils";
import { ElConfirmDanger, ElConfirmPrimary } from "~/utils/element";
import { getServerArgs } from "@/composables/server";
let is_close = false;
const tray = await useTray(true, async () => {
is_close = true;
await invoke("stop_command", { child_id: listenObj.thread_id || 0 });
await invoke("stop_command", { child_id: data.winipBcPid || 0 });
}, async () => {
await handleConnection();
return data.isStart
});
const tray = await useTray(
true,
async () => {
is_close = true;
await invoke("stop_command", { child_id: listenObj.thread_id || 0 });
await invoke("stop_command", { child_id: data.winipBcPid || 0 });
await invoke("stop_command", { child_id: listenObj.server_thread_id.value || 0 });
},
async () => {
await handleConnection();
return data.isStart;
}
);
const mainStore = useMainStore();
const config = mainStore.config;
// console.error(config);
const protocols = ["tcp", "udp", "ws", "wss", "wg", "quic"];
const protocols = ["tcp", "udp", "ws", "wss", "quic"];
const data = reactive<{ [key: string]: any; releaseList: Array<Array<string>> }>({
logVisible: false,
cidrVisible: false,
advanceVisible: false,
toolVisible: false,
serverVisible: false,
winipBcPid: 0, //WinIPBroadcast进程id
winipBcStart: false,
memberVisible: false,
log: "",
serverLog: "", //服务端日志
update: false,
releaseList: [],
coreVersion: "-",
@@ -568,6 +574,20 @@
}
};
const handleOpenCache = async () => {
const cache_path = import.meta.env.VITE_CACHE_PATH;
const resourceDir = await getResourceDir();
const configPath = await join(resourceDir, cache_path);
const isExists = await exists(cache_path, { baseDir: BaseDirectory.Resource });
if (!isExists) {
try {
await mkdir(cache_path, { baseDir: BaseDirectory.Resource });
} catch (err) {}
}
// console.error(configPath);
await Command.create("explorer", [configPath]).execute();
}
const handleDeleteServerUrl = (url: string) => {
const newBasePeers = [...mainStore.basePeers];
const idx = newBasePeers.indexOf(url);
@@ -601,17 +621,29 @@
const listenObj: { [key: string]: any } = {
unListenOutPut: null,
unListenThreadId: null,
unListenServerOutPut: null,
unListenServerThreadId: null,
unListenConfigStart: null,
unListenStartStopServer: null,
thread_id: null,
server_thread_id: ref(null),
async listenOutput() {
// const appWindow = getCurrentWindow();
const unListen = await listen("command-output", async event => {
const unListen = await listen<string>("command-output", async event => {
data.isStart = true;
// console.error(event.payload);
if (event.payload) {
data.startLoading = false;
let ipv4 = /dhcp ip changed. old: None, new: Some\((\d+\.\d+\.\d+\.\d+).*\)/g.exec(event.payload as string)?.[1];
let devName = /tun device ready. dev: (.*)/g.exec(event.payload as string)?.[1];
if (event.payload.includes("peer connection removed")) {
data.isSuccessGetIp = false;
}
if (event.payload.includes("new peer connection added") && !data.isSuccessGetIp) {
await setTrayRunState(tray, true);
data.isSuccessGetIp = true;
await setTrayTooltip(tray, `IP: ${config.ipv4}`);
}
if (config.dhcp || mainStore.configStartEnable) {
if (ipv4) {
config.ipv4 = ipv4;
@@ -619,12 +651,6 @@
data.isSuccessGetIp = true;
await setTrayTooltip(tray, `IP: ${ipv4}`);
}
} else {
if ((event.payload as string).includes("new peer connection added") && !data.isSuccessGetIp) {
await setTrayRunState(tray, true);
data.isSuccessGetIp = true;
await setTrayTooltip(tray, `IP: ${config.ipv4}`);
}
}
if (
devName &&
@@ -662,6 +688,24 @@
});
this.unListenThreadId = unListen;
},
async listenServerOutPut() {
const unListen = await listen<string>("server-command-output", async event => {
// console.log("server-command-output", event);
const logArr = data.serverLog.split("\n");
const start = logArr.length > 1000 ? logArr.length - 1000 : 0;
data.serverLog = logArr.slice(start).join("\n");
data.serverLog += (event.payload || "") + "\n";
});
this.unListenServerOutPut = unListen;
},
async listenServerThreadId() {
const unListen = await listen("server-thread-id", event => {
if (event.payload) {
this.server_thread_id.value = event.payload;
}
});
this.unListenServerThreadId = unListen;
},
async listenConfigStart() {
const unListen = await listen("config", event => {
// console.error("config", event.payload);
@@ -670,6 +714,23 @@
config.ipv4 = ipv4;
});
this.unListenConfigStart = unListen;
},
async listenStartStopServer() {
const unListen = await listen<{ args: Array<string> }>("startStopServer", async event => {
await listenObj?.unListenServerOutPut?.();
await invoke("stop_command", { child_id: listenObj.server_thread_id.value || 0 });
if (listenObj.server_thread_id.value) {
listenObj.server_thread_id.value = null;
} else {
data.serverLog = "";
await listenObj.listenServerOutPut();
await invoke("run_command", {
args: event.payload.args,
is_server: true
});
}
});
this.unListenStartStopServer = unListen;
}
};
@@ -882,18 +943,35 @@
});
};
const initAutoStartServer = async () => {
if (mainStore.serverConfig.autoStart && data.coreVersion) {
const args = getServerArgs();
await listenObj?.unListenServerOutPut?.();
await invoke("stop_command", { child_id: listenObj.server_thread_id.value || 0 });
data.serverLog = "";
await listenObj.listenServerOutPut();
await invoke("run_command", {
args,
is_server: true
});
}
};
let logsTimer: NodeJS.Timeout | null = null;
let serverLogsTimer: NodeJS.Timeout | null = null;
onMounted(async () => {
// await handleUpdateCore(); //默认不自动更新
await initGuiJson();
await compatibleInitAutoStart();
// await initAutoStart();
await initStartWinIpBroadcast();
await getCoreVersion();
await listenObj.listenThreadId();
await listenObj.listenServerThreadId();
await listenObj.listenConfigStart();
await listenObj.listenStartStopServer();
await initConfigDir();
await initAutoStartServer();
await initConnectAfterStart();
closePrevent();
});
@@ -902,7 +980,9 @@
unListenAll();
listenObj.unListenReleaseList && listenObj.unListenReleaseList();
listenObj.unListenConfigStart && listenObj.unListenConfigStart();
listenObj.unListenStartStopServer && listenObj.unListenStartStopServer();
logsTimer && clearInterval(logsTimer);
serverLogsTimer && clearInterval(serverLogsTimer);
});
const getArgs = async () => {
@@ -934,6 +1014,7 @@
return [];
}
}
if (config.dhcp) {
args.push("-d");
}
@@ -1103,14 +1184,33 @@
importConfigData.data = "";
importConfigData.visible = true;
}
if (command === "create_server") {
await handleShowServerDialog();
// if (data.isStart) {
// const [error] = await ElConfirmDanger("切换会停止{action},是否继续?", "提示", {
// action: "`联机/服务`",
// confirmButtonText: "继续",
// cancelButtonText: "取消"
// });
// if (!error) await reset();
// }
// mainStore.enableCreateServer = !mainStore.enableCreateServer;
// if (mainStore.config.relayAllPeerrpc && !mainStore.enableCreateServer) {
// const [error] = await ElConfirmPrimary("是否关闭RPC流量转发?", "提示", {
// confirmButtonText: "关闭",
// cancelButtonText: "取消"
// });
// if (!error) mainStore.config.relayAllPeerrpc = false;
// }
}
};
const handleStartImport = async () => {
try {
await ElMessageBox.confirm("确定导入?", "提示", {
confirmButtonText: "确定",
cancelButtonText: "取消"
});
const [err] = await ElConfirmPrimary("确定导入?", "提示", {
confirmButtonText: "确定",
cancelButtonText: "取消"
});
if (!err) {
const payload = JSON.parse(decodeURIComponent(atob(importConfigData.data)));
mainStore.$patch({
config: {
@@ -1121,7 +1221,7 @@
ElMessage.success("导入成功");
importConfigData.visible = false;
mainStore.basePeers = uniq([config.serverUrl, ...mainStore.basePeers]);
} catch (err) {
} else {
console.error(err);
if (err !== "cancel") {
ElMessage.error("导入失败");
@@ -1190,9 +1290,10 @@
logsTimer && clearInterval(logsTimer);
logsTimer = setInterval(() => {
appWindow.emitTo("log", "logs", data.log);
}, 600);
}, 650);
},
() => {
logsTimer && clearInterval(logsTimer);
data.logVisible = false;
}
);
@@ -1254,4 +1355,30 @@
}
);
};
const handleShowServerDialog = async () => {
await etWindows(
"server",
{
title: "自建服务器",
minWidth: 550,
minHeight: 460,
width: 550,
height: 460,
resizable: true,
url: "#/server"
},
(_, appWindow) => {
data.serverVisible = true;
serverLogsTimer && clearInterval(serverLogsTimer);
serverLogsTimer = setInterval(() => {
appWindow.emitTo("server", "server_logs", { log: data.serverLog, threadId: listenObj.server_thread_id.value });
}, 650);
},
() => {
serverLogsTimer && clearInterval(serverLogsTimer);
data.serverVisible = false;
}
);
};
</script>
+70 -23
View File
@@ -6,21 +6,25 @@
stripe
border
:data="data.member"
v-else>
v-else
>
<ElTableColumn
sortable
width="140"
label="主机名"
prop="hostname"></ElTableColumn>
prop="hostname"
></ElTableColumn>
<ElTableColumn
sortable
width="90"
prop="cost"
label="路由">
label="路由"
>
<template #default="{ row }">
<ElTag
effect="dark"
:type="row.cost == 'p2p' ? 'success' : 'info'">
:type="row.cost == 'p2p' ? 'success' : 'info'"
>
{{ row.cost }}
</ElTag>
</template>
@@ -29,17 +33,20 @@
sortable
width="120"
prop="ipv4"
label="虚拟网IP"></ElTableColumn>
label="虚拟网IP"
></ElTableColumn>
<ElTableColumn
sortable
prop="lat_ms"
width="130"
label="延迟/ms"></ElTableColumn>
label="延迟/ms"
></ElTableColumn>
<ElTableColumn
sortable
width="120"
prop="loss_rate"
label="丢包率">
label="丢包率"
>
<template #default="{ row }">
{{ row.loss_rate && row.loss_rate != "-" ? Number(row.loss_rate * 100).toFixed(2) + "%" : row.loss_rate }}
</template>
@@ -48,15 +55,23 @@
sortable
width="120"
label="nat_type"
prop="NAT类型">
prop="NAT类型"
>
<template #default="{ row }">
{{ natMaps[row.nat_type.toLowerCase() as natKyes] || row.nat_type || "-" }}
</template>
</ElTableColumn>
<ElTableColumn
sortable
width="120"
prop="version"
label="版本"></ElTableColumn>
label="版本"
></ElTableColumn>
<ElTableColumn
sortable
prop="tunnel_proto"
label="隧道协议"
></ElTableColumn>
</ElTable>
</div>
</div>
@@ -64,7 +79,9 @@
<script setup lang="ts">
import { invoke } from "@tauri-apps/api/core";
import { reactive, onMounted, onBeforeUnmount } from "vue";
import { parsePeerInfo } from "@/utils";
import { ATJ, parsePeerInfo } from "@/utils";
import { ElConfirmDanger } from "~/utils/element";
import { getCurrentWindow } from "@tauri-apps/api/window";
// enum NatType {
// // has NAT; but own a single public IP, port is not changed
// Unknown = 0;
@@ -86,14 +103,14 @@
restricted: "nat2",
portrestricted: "nat3",
symmetric: "nat4",
SymmetricEasyDec: "nat4-easydec",
SymmetricEasyInc: "nat4-easyinc",
SymUdpFirewall: "nat4-udpfirewall",
symmetriceasydec: "nat4-easydec",
symmetriceasyinc: "nat4-easyinc",
symUdpfirewall: "nat4-udpfirewall"
};
type natKyes = keyof typeof natMaps;
const data = reactive<{ member: any[] }>({
member: [],
member: []
});
const _showTableHeader = [
@@ -104,12 +121,35 @@
["loss_rate", "丢包率"],
["nat_type", "NAT类型"],
["version", "版本"],
["tunnel_proto", "隧道协议"]
];
let timer: NodeJS.Timeout | null = null;
const listenOutput = async () => {
const member = await invoke<string>("get_members_by_cli");
const [error, member] = await ATJ(invoke<string>("get_members_by_cli"));
// if(!member) return;
if (error) {
data.member = [];
return "";
}
if (member === "_EasytierGameCliFailedToConnect_") {
data.member = [];
stopTimer();
const [error] = await ElConfirmDanger("连接已断开,是否重新尝试?", "警告", {
confirmButtonText: "重试",
cancelButtonText: "关闭窗口"
});
if (!error) {
await listenOutput();
} else {
const appWindow = getCurrentWindow();
await appWindow.close();
}
return;
}
const peerInfo = parsePeerInfo(member);
peerInfo.forEach((value) => {
peerInfo.forEach(value => {
if (value.cost === "Local") {
value.cost = "本机";
}
@@ -117,20 +157,27 @@
value.ipv4 = value.ipv4.split("/")[0];
}
});
// console.error(peerInfo);
data.member = peerInfo;
startTimer();
};
let timer: NodeJS.Timeout | null = null;
const startTimer = () => {
timer && clearTimeout(timer);
timer = setTimeout(() => {
listenOutput();
}, 1000);
};
const stopTimer = () => {
timer && clearTimeout(timer);
timer = null;
}
onMounted(async () => {
listenOutput();
timer = setInterval(() => {
listenOutput();
}, 1000 * 10);
await listenOutput();
});
onBeforeUnmount(() => {
timer && clearInterval(timer);
stopTimer();
});
</script>
+128
View File
@@ -0,0 +1,128 @@
<template>
<div class="flex flex-col gap-[10px] h-full">
<ElForm
size="small"
label-position="top"
:model="mainStore.serverConfig"
>
<ElFormItem
label="白名单"
prop="ServerWhiteList"
class="full-label full-content overflow-hidden !flex flex-col h-full !mb-[0]"
>
<template #label>
<div class="flex items-center gap-[10px]">
白名单
<ElSwitch
v-model="mainStore.serverConfig.enableWhiteList"
inline-prompt
active-text="启用"
inactive-text="禁用"
></ElSwitch>
<div class="ml-auto">
<ElTooltip
placement="top"
content="打开软件的时候,就会开启这个自建服务"
>
<ElCheckbox v-model="mainStore.serverConfig.autoStart">自动启动</ElCheckbox>
</ElTooltip>
<ElTooltip
placement="top"
content="帮助其他虚拟网建立P2P链接"
>
<ElCheckbox v-model="mainStore.serverConfig.relayAllPeerrpc">转发所有对等节点的RPC数据包</ElCheckbox>
</ElTooltip>
</div>
</div>
</template>
<div class="h-full w-full flex flex-col overflow-hidden">
<div class="flex-1 overflow-auto">
<ElInput
:disabled="!mainStore.serverConfig.enableWhiteList"
placeholder="一行一个,支持通配符列表,如(ab*)。当该参数的列表为空时,就不会为所有其他网络提供转发服务。"
:maxlength="1000"
v-model="mainStore.serverConfig.serverWhiteList"
type="textarea"
:rows="3"
resize="none"
></ElInput>
</div>
</div>
</ElFormItem>
</ElForm>
<div class="flex items-center gap-[10px]">
<div class="flex items-center gap-[5px]">
<ElText>服务器端口</ElText>
<div class="max-w-[100px]">
<ElTooltip content="端口号">
<ElInput v-model="mainStore.serverConfig.port"></ElInput>
</ElTooltip>
</div>
</div>
<ElButton
size="large"
:loading="data.loading"
:type="data.isStart ? 'danger' : 'primary'"
@click="hanldeClickStart"
>
{{ !data.isStart ? "启动服务器" : "停止服务器" }}
</ElButton>
</div>
<ElInput
placeholder="服务器日志"
:model-value="data.log"
type="textarea"
:rows="14"
resize="none"
></ElInput>
</div>
</template>
<script setup lang="ts">
import useMainStore from "@/stores/index";
import { reactive, onMounted, onBeforeUnmount } from "vue";
import { getCurrentWindow } from "@tauri-apps/api/window";
import { listen, type UnlistenFn } from "@tauri-apps/api/event";
import { getServerArgs } from "@/composables/server";
const appWindow = getCurrentWindow();
const mainStore = useMainStore();
const data = reactive({
log: "",
isStart: false,
loading: true
});
const listenStart = async () => {
const unListen = await listen<{ log: string; threadId: number | null }>("server_logs", event => {
data.log = event.payload.log || "";
if (event.payload.threadId) {
data.isStart = true;
} else {
data.isStart = false;
}
data.loading = false;
});
return unListen;
};
let unlistenStart: UnlistenFn | null = null;
onMounted(async () => {
unlistenStart = await listenStart();
});
onBeforeUnmount(() => {
unlistenStart && unlistenStart();
});
const hanldeClickStart = async () => {
data.loading = true;
const args = getServerArgs();
await appWindow.emitTo("main", "startStopServer", { args });
};
mainStore.$subscribe(async (...a) => {
await appWindow.emitTo("main", "config", { serverConfig: { ...mainStore.serverConfig }});
});
</script>
+485 -153
View File
File diff suppressed because it is too large Load Diff
+5 -3
View File
@@ -1176,7 +1176,7 @@ checksum = "0d6ef0072f8a535281e4876be788938b528e9a1d43900b82c2569af7da799125"
[[package]]
name = "easytier-game"
version = "1.2.4"
version = "1.2.7"
dependencies = [
"log",
"planif",
@@ -1193,6 +1193,7 @@ dependencies = [
"tauri-plugin-shell",
"tauri-plugin-single-instance",
"tauri-plugin-window-state",
"tokio",
"whoami",
"windows 0.58.0",
"zip",
@@ -4782,15 +4783,16 @@ checksum = "1f3ccbac311fea05f86f61904b462b55fb3df8837a366dfc601a0161d0532f20"
[[package]]
name = "tokio"
version = "1.40.0"
version = "1.41.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "e2b070231665d27ad9ec9b8df639893f46727666c6767db40317fbe920a5d998"
checksum = "22cfb5bee7a6a52939ca9224d6ac897bb669134078daa8735560897f69de4d33"
dependencies = [
"backtrace",
"bytes",
"libc",
"mio",
"pin-project-lite",
"signal-hook-registry",
"socket2",
"windows-sys 0.52.0",
]
+2 -1
View File
@@ -1,6 +1,6 @@
[package]
name = "easytier-game"
version = "1.2.4"
version = "1.2.7"
homepage = "https://github.com/EasyTier/EasyTier"
repository = "https://github.com/EasyTier/EasytierGame"
description = "A simple network initiator based on Easytier"
@@ -40,6 +40,7 @@ planif = { git = "https://github.com/mattrobineau/planif", tag = "1.0.1" }
whoami = "1.5.2"
tauri-plugin-fs = "2"
tauri-plugin-clipboard-manager = "2.0.2"
tokio = { version = "1.41.1", features = ["process"] }
# prost = "0.13"
# prost-types = "0.13"
+2 -1
View File
@@ -8,7 +8,8 @@
"member",
"cidr",
"advance",
"tool"
"tool",
"server"
],
"permissions": [
"core:default",
@@ -0,0 +1,77 @@
# 实例名称,用于在同一台机器上标识此节点
instance_name = ""
# 主机名,用于标识此设备的主机名
hostname = ""
# 实例 ID,一般为 UUID,在同一个虚拟网络中唯一
instance_id = ""
# 此节点的虚拟网 IPv4 地址,如果为空,则此节点将仅转发数据包,不会创建 TUN 设备
ipv4 = ""
# 由 Easytier 自动确定并设置IP地址,默认从10.0.0.1开始。警告:在使用 DHCP 时,如果网络中出现 IP 冲突,IP 将自动更改
dhcp = false
# 监听器列表,用于接受连接
listeners = [
"tcp://0.0.0.0:11010",
"udp://0.0.0.0:11010",
"wg://0.0.0.0:11011",
"ws://0.0.0.0:11011/",
"wss://0.0.0.0:11012/",
]
# 退出节点列表
exit_nodes = [
]
# 用于管理的 RPC 门户地址
rpc_portal = "127.0.0.1:15888"
[network_identity]
# 网络名称,用于标识虚拟网络
network_name = ""
# 网络密钥,用于验证此节点属于虚拟网络
network_secret = ""
# 这里是对等连接节点配置,可以多段配置
[[peer]]
uri = "tcp://public.easytier.top:11010"
[[peer]]
uri = "udp://public.easytier.top:11010"
# 这里是子网代理节点配置,可以有多段配置
[[proxy_network]]
cidr = "10.0.1.0/24"
[[proxy_network]]
cidr = "10.0.2.0/24"
# WireGuard 配置信息
[vpn_portal_config]
# WireGuard 客户端所在的网段,下面为示例
client_cidr = "10.14.14.0/24"
#wg所监听的端口(请勿和listeners的wg冲突)
wireguard_listen = "0.0.0.0:11012"
[flags]
# 连接到对等节点使用的默认协议
default_protocol = "tcp"
# TUN 设备名称,如果为空,则使用默认名称
dev_name = ""
# 禁用p2p
disable_p2p = false
# 是否启用加密
enable_encryption = true
# 是否启用 IPv6 支持
enable_ipv6 = true
# TUN 设备的 MTU
mtu = 1380
# 延迟优先模式,将尝试使用最低延迟路径转发流量,默认使用最短路径
latency_first = false
# 将本节点配置为退出节点
enable_exit_node = false
# 禁用 TUN 设备
no_tun = false
# 为子网代理启用 smoltcp 堆栈
use_smoltcp = false
# 仅转发白名单网络的流量,支持通配符字符串。多个网络名称间可以使用英文空格间隔。如果该参数为空,则禁用转发。默认允许所有网络。例如:'*'(所有网络),'def*'(以def为前缀的网络),'net1 net2'(只允许net1和net2
foreign_network_whitelist = "*"
-23
View File
@@ -1,23 +0,0 @@
hostname = "Test1"
instance_name = "default"
instance_id = "8803362c-e4f1-4df1-93e8-721653945f77"
dhcp = true
listeners = [
"tcp://0.0.0.0:11010",
"udp://0.0.0.0:11010",
"wg://0.0.0.0:11011",
"ws://0.0.0.0:11011/",
"wss://0.0.0.0:11012/",
]
exit_nodes = []
rpc_portal = "0.0.0.0:15888"
[network_identity]
network_name = "default"
network_secret = ""
[[peer]]
uri = "tcp://public.easytier.top:11010"
[[peer]]
uri = "udp://public.easytier.top:11010"
+60 -34
View File
@@ -9,10 +9,7 @@ use std::fs::{self, File};
use std::io::{BufRead, BufReader, Write};
use std::os::windows::process::CommandExt;
use std::process::{Command, Stdio};
use std::sync::{
atomic::{AtomicBool, Ordering},
mpsc, Arc,
};
use std::sync::mpsc;
use std::{path, thread};
use sysinfo::System;
use tauri::tray::{MouseButton, MouseButtonState, TrayIconBuilder, TrayIconEvent};
@@ -24,6 +21,8 @@ use windows::Win32::Foundation::VARIANT_BOOL;
use windows::Win32::System::Com::*;
use windows::Win32::System::TaskScheduler::*;
use tokio::process::Command as tokioCommand;
// 定义GitHub Release的结构体
#[derive(Debug, Deserialize)]
pub struct Release {
@@ -133,24 +132,41 @@ struct MyResponse {
}
#[tauri::command(rename_all = "snake_case")]
fn get_members_by_cli() -> String {
async fn get_members_by_cli() -> String {
let cli_path = get_tool_exe_path(String::from("\\easytier\\easytier-cli.exe"));
match Command::new(&cli_path)
match tokioCommand::new(&cli_path)
.arg("peer")
.arg("list")
.creation_flags(0x08000000)
.output()
.output().await
{
Ok(output) => {
let output_str = String::from_utf8_lossy(&output.stdout);
return output_str.trim().to_string();
if output.status.success() {
let output_str = String::from_utf8_lossy(&output.stdout);
return output_str.trim().to_string();
}else {
let output_str = String::from_utf8_lossy(&output.stderr);
log::error!("{}", output_str.trim().to_string());
return "_EasytierGameCliFailedToConnect_".to_string();
}
}
Err(_e) => return _e.to_string(),
Err(_e) => {
log::error!("get member list error");
return "".to_string();
},
}
}
#[tauri::command(rename_all = "snake_case")]
async fn download_easytier_zip(download_url: String, file_name: String) {
let cache_dir_path = get_tool_exe_path(String::from("\\easytier\\cache"));
let cache_file_name = format!("{}\\{}", cache_dir_path, file_name);
let cache_file_name_path = path::Path::new(&cache_file_name);
if cache_file_name_path.exists() {
unzip(cache_file_name_path);
return;
}
let target = format!("{}", download_url);
let response = reqwest::get(target)
.await
@@ -177,10 +193,19 @@ async fn download_easytier_zip(download_url: String, file_name: String) {
file.write_all(&content).expect("error to write easytier");
println!("写入完成");
unzip(path);
match fs::remove_file(path) {
Ok(_) => println!("删除zip文件成功"),
Err(_) => log::error!("删除zip文件失败"),
let cache_dir_path = path::Path::new(&cache_dir_path);
if !cache_dir_path.exists() {
fs::create_dir_all(&cache_dir_path).unwrap();
}
match fs::rename(path, cache_file_name) {
Ok(_) => println!("保存zip文件至easytier/cache成功"),
Err(_) => log::error!("保存zip文件失败"),
}
// match fs::remove_file(path) {
// Ok(_) => println!("删除zip文件成功"),
// Err(_) => log::error!("删除zip文件失败"),
// }
}
fn unzip(fname: &path::Path) {
@@ -228,18 +253,22 @@ fn unzip(fname: &path::Path) {
}
#[tauri::command(rename_all = "snake_case")]
fn run_command(
app_handle: tauri::AppHandle,
args: Vec<String>,
stop_signal: tauri::State<Arc<AtomicBool>>,
) {
fn run_command(app_handle: tauri::AppHandle, args: Vec<String>, is_server: Option<bool>) {
let is_server = is_server.unwrap_or(false);
let (tx, rx) = mpsc::channel();
stop_signal.store(false, Ordering::Relaxed);
let app_handle1 = app_handle.clone();
let app_handle2 = app_handle.clone();
let stop_signal1 = Arc::clone(&stop_signal);
let stop_signal2 = Arc::clone(&stop_signal);
let args2 = args.clone();
let mut thread_id_str = "thread-id";
if is_server {
thread_id_str = "server-thread-id";
}
let mut command_output_str = "command-output";
if is_server {
command_output_str = "server-command-output";
}
thread::spawn(move || {
let core_path = get_tool_exe_path(String::from("\\easytier\\easytier-core.exe"));
// trace, debug, info, warn, error, off
@@ -252,36 +281,36 @@ fn run_command(
println!("child id: {}", child.id());
app_handle1
.emit("thread-id", child.id())
.emit(thread_id_str, child.id())
.expect("failed to emit id event");
app_handle1
.emit("command-output", args2.join(" "))
.emit(command_output_str, args2.join(" "))
.expect("error output args");
let stdout = child.stdout.take().expect("failed to capture stdout");
let reader = BufReader::new(stdout);
for line in reader.lines() {
match line {
Ok(line) => {
tx.send(line).expect("failed to send line");
}
Ok(line) => match tx.send(line) {
Ok(_) => {}
Err(e) => {
log::error!("error sending line: {}", e);
break;
}
},
Err(e) => {
log::error!("error reading line: {}", e);
break;
}
}
}
stop_signal1.store(true, Ordering::Relaxed);
println!("end");
});
thread::spawn(move || {
while let Ok(line) = rx.recv() {
if stop_signal2.load(Ordering::Relaxed) {
break;
}
app_handle2
.emit("command-output", line)
.emit(command_output_str, line)
.expect("failed to emit event");
}
});
@@ -523,8 +552,6 @@ pub fn run() {
// 获取命令行参数
let args: Vec<String> = std::env::args().collect();
let stop_signal = Arc::new(AtomicBool::new(false)); // 创建一个原子布尔值,用于控制命令的停止
let stop_signal_clone = Arc::clone(&stop_signal); // 创建一个原子布尔值的克隆,用于传递给命令
let context = tauri::generate_context!();
tauri::Builder::default()
.plugin(
@@ -592,7 +619,6 @@ pub fn run() {
Ok(())
})
.manage(stop_signal_clone)
.invoke_handler(tauri::generate_handler![
run_command,
stop_command,
+3 -3
View File
@@ -1,7 +1,7 @@
{
"$schema": "../node_modules/@tauri-apps/cli/config.schema.json",
"productName": "easytier-game",
"version": "1.2.4",
"version": "1.2.7",
"identifier": "com.tauri.easytier-game",
"build": {
@@ -13,7 +13,7 @@
"app": {
"windows": [
{
"title": "easytier-game 1.2.4",
"title": "easytier-game 1.2.7",
"label": "main",
"minWidth": 340,
"width": 340,
@@ -49,7 +49,7 @@
"easytier/Packet.dll",
"easytier/wintun.dll",
"easytier/clear_local_data.bat",
"easytier/帮助.txt"
"帮助.txt"
],
"windows": {
"webviewInstallMode": {
@@ -13,4 +13,12 @@
2. 运行easytier-game安装目录下的 easytier/clear_local_data.bat (需要管理员权限) 输入y确认,清除本地存储数据
3. 删除easytierGame文件夹
3. 删除easytierGame文件夹
[没有服务器,怎么自建服务]
1. 点击 启动联机 按钮旁边的箭头 选择自建服务 设置好端口号后 点击启动服务器
2. 搜索一下 openFrp mossFrp sakurafrp 等 将你的本地服务通过它(们)代理到公网
3. 将代理之后的地址发给别人,他们就可以通过这个加入你的服务了
+19 -2
View File
@@ -14,7 +14,7 @@ export default defineStore("main", {
connectAfterStart: false, //软件打开后,是否自动连接
disableIpv6: false, // 是否禁用IPv6
disbleListenner: false, // 是否禁用监听
disableEncryption: false, // 是否禁用加密
disableEncryption: true, // 是否禁用加密
multiThread: false, //使用多线程
enablExitNode: false, // 是否启用退出节点
noTun: false, // 是否使用TUN
@@ -31,6 +31,14 @@ export default defineStore("main", {
enableNetCardMetric: false, //启用网卡自定义跃点
netCardMetricValue: 1 //自定义网卡跃点值
},
serverConfig: {
enableWhiteList: true, // 是否启用白名单
relayAllPeerrpc: false, // 是否启用所有对等RPC
serverWhiteList: "", // 服务器流量转发白名单
// enableListener: true, // 是否启用监听
autoStart: false, //随软件自启
port: "11010", // 服务器端口
},
cidrEnable: false,
basePeers: ["public.easytier.top:11010"],
theme: false, //主题 false light true dark
@@ -40,6 +48,7 @@ export default defineStore("main", {
createConfigInEasytier: false, //在easytier目录生成config.json文件吗
githubFastUrl: "https://ghproxy.cc/",
winipBcPid: 0,
winipBcStart: false
};
@@ -75,6 +84,14 @@ export default defineStore("main", {
"config.enableNetCardMetric",
"config.netCardMetricValue",
"serverConfig.autoStart",
// 'serverConfig.enableListener',
'serverConfig.enableWhiteList',
'serverConfig.relayAllPeerrpc',
'serverConfig.serverWhiteList',
'serverConfig.port',
"cidrEnable",
"basePeers",
"theme",
@@ -82,7 +99,7 @@ export default defineStore("main", {
"configPath",
"winIpBcAutoStart",
"createConfigInEasytier",
"githubFastUrl"
"githubFastUrl",
],
// // 除了这些,其他都要存下来
// omit: ["winipBcPid", "winipBcStart"]
+6
View File
@@ -29,6 +29,8 @@ export const ElConfirmDanger = (
}
return ATJ(
ElMessageBox.confirm(message, title, {
closeOnClickModal: false, // 点击遮罩层不关闭弹窗
closeOnPressEscape: false, // 按下Esc键不关闭弹窗
cancelButtonText,
confirmButtonText,
confirmButtonClass: "el-button--danger"
@@ -63,6 +65,8 @@ export const ElConfirmSucces = (
}
return ATJ(
ElMessageBox.confirm(message, title, {
closeOnClickModal: false, // 点击遮罩层不关闭弹窗
closeOnPressEscape: false, // 按下Esc键不关闭弹窗
cancelButtonText,
confirmButtonText,
confirmButtonClass: "el-button--success"
@@ -97,6 +101,8 @@ export const ElConfirmPrimary = (
}
return ATJ(
ElMessageBox.confirm(message, title, {
closeOnClickModal: false, // 点击遮罩层不关闭弹窗
closeOnPressEscape: false, // 按下Esc键不关闭弹窗
cancelButtonText,
confirmButtonText,
confirmButtonClass: "el-button--primary"
+1
View File
@@ -65,6 +65,7 @@ export const ATJ = (promise: Promise<any>, errorExt: string | undefined = undefi
};
export const parsePeerInfo = (content: string) => {
if(!content) return [];
// 将表格字符串分割成行
const lines = content.split("\n");
+66
View File
@@ -0,0 +1,66 @@
/**
* 生成 release 发布包 zip 文件
*/
const releaseDir = "./src-tauri/target/release";
const releaseDirEasytier = `${releaseDir}/easytier/`;
const releaseExe = `${releaseDir}/easytier-game.exe`;
const releaseHelp = `${releaseDir}/帮助.txt`;
const deleteEasytierFiles = ["logs/", "guiLogs/", "cache/"];
const pkg = require("./package.json");
const fileName = `easytier-game_windows_x86_64_${pkg.version}.zip`; // 发布包格式
const releaseZipDir = "./release";
const releaseZip = `${releaseZipDir}/${fileName}`;
const fs = require("fs");
const path = require("path");
const archiver = require("archiver");
const output = fs.createWriteStream(path.join(__dirname, releaseZip));
const archive = archiver("zip", {
zlib: { level: 8 } // Sets the compression level.
});
// listen for all archive data to be written
// 'close' event is fired only when a file descriptor is involved
output.on("close", function () {
console.log(archive.pointer() + " total bytes");
console.log(`archiver has been finalized and the output ${releaseZip}`);
});
// This event is fired when the data source is drained no matter what was the data source.
// It is not part of this library but rather from the NodeJS Stream API.
// @see: https://nodejs.org/api/stream.html#stream_event_end
output.on("end", function () {
console.log("Data has been drained");
});
// good practice to catch warnings (ie stat failures and other non-blocking errors)
archive.on("warning", function (err) {
if (err.code === "ENOENT") {
// log warning
} else {
// throw error
throw err;
}
});
archive.on("error", function (err) {
throw err;
});
for (const f of deleteEasytierFiles) {
fs.rmSync(path.join(__dirname, releaseDirEasytier + f), { recursive: true, force: true });
}
const r = path.join(__dirname, releaseZipDir);
if (!fs.existsSync(r)) {
fs.mkdirSync(r);
}
// pipe archive data to the file
archive.pipe(output);
archive
.append(fs.createReadStream(path.join(__dirname, releaseExe)), { name: "easytier-game.exe" })
.append(fs.createReadStream(path.join(__dirname, releaseHelp)), { name: "帮助.txt" })
.directory(path.join(__dirname, releaseDirEasytier), "easytier")
.finalize();