区分了ENDXSID和ENDSID。移除了多余的路由表对象的isLoopback(),因为是否是环回是链路的属性，不是路由表的。

# Conflicts:
#	.classpath
#	src/org/kne/cloud/network/klalb/KLALBControllerConfigItem.java

.classpath

@@ -4,7 +4,6 @@
 	<classpathentry kind="lib" path="lib/gson-2.1.jar"/>
 	<classpathentry kind="lib" path="lib/javassist.jar" sourcepath="C:/Users/ADMINI~1/AppData/Local/Temp/1/.org.sf.feeling.decompiler1686963856070/source/javassist-3.29.2-GA-sources.jar"/>
 	<classpathentry kind="lib" path="lib/ini4j.jar"/>
-	<classpathentry kind="lib" path="lib/JFreeChart1.5.2.jar"/>
 	<classpathentry kind="lib" path="lib/toml4j-0.7.1.jar"/>
 	<classpathentry kind="lib" path="lib/pcap4j-core-1.8.2.jar" sourcepath="C:/Users/ADMINI~1/AppData/Local/Temp/1/.org.sf.feeling.decompiler1725520274095/source/pcap4j-core-1.8.2-sources.jar"/>
 	<classpathentry kind="lib" path="lib/pcap4j-packetfactory-propertiesbased-1.8.2.jar"/>
@@ -29,5 +28,8 @@
 			<attribute name="module" value="true"/>
 		</attributes>
 	</classpathentry>
+	<classpathentry kind="lib" path="lib/jfreechart-1.5.3.jar"/>
+	<classpathentry kind="lib" path="lib/jfreechart-1.5.3-javadoc.jar"/>
+	<classpathentry kind="lib" path="lib/jfreechart-1.5.3-sources.jar"/>
 	<classpathentry kind="output" path="bin"/>
 </classpath>

.idea/libraries/jfreechart_1_5_3.xml

@@ -0,0 +1,38 @@
+<component name="libraryTable">
+  <library name="jfreechart-1.5.3">
+    <CLASSES>
+      <root url="jar://$PROJECT_DIR$/lib/jfreechart-1.5.3.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/disruptor-4.0.0.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/gson-2.1.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/ini4j.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/javassist.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/JavaTUN0.3.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/jctools-core-4.0.6.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/KNElib1.0.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/KNEOptimize.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/pcap4j-core-1.8.2.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/pcap4j-packetfactory-propertiesbased-1.8.2.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/pcap4j-packetfactory-static-1.8.2.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/pcap4j-packettest-1.8.2-tests.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/pcap4j-sample-1.8.2.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/slf4j-api-2.0.9.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/slf4j-api-2.0.9-tests.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/toml4j-0.7.1.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/uuid-creator-6.1.1.jar!/" />
+    </CLASSES>
+    <JAVADOC>
+      <root url="jar://$PROJECT_DIR$/lib/jctools-core-4.0.6-javadoc.jar!/" />
+    </JAVADOC>
+    <SOURCES>
+      <root url="jar://$PROJECT_DIR$/lib/jfreechart-1.5.3-sources.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/disruptor-4.0.0-sources.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/ini4j.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/JavaTUN0.3.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/jctools-core-4.0.6-sources.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/KNElib1.0.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/slf4j-api-2.0.9-sources.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/toml4j-0.7.1.jar!/" />
+      <root url="jar://$PROJECT_DIR$/lib/uuid-creator-6.1.1-sources.jar!/" />
+    </SOURCES>
+  </library>
+</component>

.idea/misc.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
-  <component name="ProjectRootManager" version="2">
+  <component name="ProjectRootManager" version="2" languageLevel="JDK_26" project-jdk-name="jdk-26.0.1" project-jdk-type="JavaSDK">
     <output url="file://$PROJECT_DIR$/classes" />
   </component>
 </project>

AGENTS.md

@@ -1,39 +1,101 @@
-# KLALB Repository Guide
+# AGENTS.md
 
-KLALB is a Java SRv6/load-balancing system. Start at `org.kne.cloud.network.klalb.KLALBMain`; runtime configuration is root-relative `klalb-config.json`.
+KLALB ("KLALB Decentralized SRv6 Network") — Java load-balancing/tunnel system that merges multiple WAN links into one virtual IPv6/SRv6 network. Version constant lives in `src/org/kne/cloud/network/klalb/CONST.java`. Protocol specs and manuals are the Chinese `.docx` files in the repo root.
 
-## Build And Run
+## Build & run
 
-- This is an Eclipse Java project, not Maven or Gradle: `src/` contains sources, `lib/` vendored dependencies, and `bin/` compiled output. `.classpath` targets Java 25.
+No Maven/Gradle. Plain Eclipse/IntelliJ project: dependencies are vendored jars in `lib/`, output goes to `bin/` (gitignored). When adding a jar, update **both** `.classpath` and `KLALB.iml`.
-- Source files contain Chinese text, so compile with UTF-8 from the repository root:
+
+Compile (`javac` is NOT on PATH — use the full JDK path; `-encoding UTF-8` is mandatory because sources contain Chinese text):
 
 ```powershell
 & "C:\Program Files\Zulu\zulu-25\bin\javac.exe" -encoding UTF-8 -cp "lib/*" -d bin (Get-ChildItem -Recurse src -Filter *.java | ForEach-Object FullName)
 ```
 
-- Run from the repository root. `src` must stay on the classpath because manual compilation does not copy resource bundles:
+Warnings about `ThreadTool` varargs / deprecated `finalize` are pre-existing and expected — success = exit code 0. After recompiling, restart the running app (IDE-debugged JVMs keep old classes).
+
+Run from the repo root — CWD matters:
+- reads `klalb-config.json` from CWD
+- loads native libs from CWD: `tuntap4j.dll/.so/.dylib`, `wintun.dll`, `fastcopy.dll` (TUN device support)
+- classpath must include `src` as well as `bin`: i18n bundles (`/klalb_*.properties`) and images (`/assets/*`) are classpath resources that Eclipse copies to `bin` but manual `javac` does not
 
 ```powershell
-& "C:\Program Files\Zulu\zulu-25\bin\java.exe" --enable-native-access=ALL-UNNAMED "--add-opens=java.base/jdk.internal.misc=ALL-UNNAMED" -cp "bin;src;lib/*" org.kne.cloud.network.klalb.KLALBMain
+java --enable-native-access=ALL-UNNAMED "--add-opens=java.base/jdk.internal.misc=ALL-UNNAMED" -cp "bin;src;lib/*" org.kne.cloud.network.klalb.KLALBMain
 ```
 
-- Native libraries and `klalb-config.json` are resolved from the current directory; restart the JVM after recompiling. TUN creation requires elevation, so use `"enableTUN": false` for non-admin checks.
+IDE metadata targets JDK 26 (`jdk-26.0.1`); the tree also compiles cleanly on JDK 25. `.classpath` now references the standard container `JavaSE-25` — an execution-environment spec that any JDK ≥25 satisfies, so it works unchanged on JDK 26 machines too (the original named `jdk-26.0.1` VM broke VS Code import on machines without it). `.vscode/settings.json` maps `JavaSE-25` to the locally installed Adoptium JDK; register every installed JDK there when adding another one. Keep compiler compliance ≤25 (`.settings` pins 19) so both JDKs stay usable.
 
-## Dashboard
+Runtime gotchas (all verified):
-
+- On JDK 25, `KNEOptimize.jar`'s `FastLib` reflects into `jdk.internal.misc.Unsafe`; without the two JVM flags above it throws `InaccessibleObjectException` at startup (app still runs).
-- `dashboard/` is a Git submodule. Commit dashboard changes in that repository, then update the parent submodule pointer.
+- Creating the SRv6 TUN adapter (`WintunCreateAdapter`) requires an elevated shell; without admin rights it logs "创建虚拟网卡失败" and continues with only the `inLoopBack` interface — links/bridges still work.
-- Run frontend commands from `dashboard/`: `pnpm install --frozen-lockfile`, `pnpm lint`, `pnpm typecheck`, and `pnpm build`. The build is `tsc -b && vite build` and produces `dashboard/dist`, which the Java server hosts.
+- To disable TUN creation completely (e.g. for non-admin UI/routing testing), set `"enableTUN": false` in `klalb-config.json` or toggle off "启用 TUN 虚拟网卡" in GUI/Web settings.
-- Vite proxies `/api` to `http://127.0.0.1:4665`; use `pnpm dev` only with the Java API running there.
+- Routing broadcast (`RouterInfo`) transmits `deviceName`, which topology and node overview panels display. `deviceDescription` is NOT broadcast — it only leaves the node in full node-info query responses (see srv6 API below); `ExtraRoutes` remain local controller configs.
 
 ## Verification
 
-- No repository test runner or CI workflow is configured. For Java changes, compile and launch the app; for dashboard changes, run `pnpm typecheck` and `pnpm build`.
+No test suite, no CI. Classes named `*Test*` (`nathole/`, `ntp/`) are manual `main()` harnesses requiring real network peers. Practical check = compile succeeds + app launches.
 
-## Important Boundaries
+## Architecture
 
-- `KLALBConfigItem` is a polymorphic JSON array keyed by case-sensitive `Type`. New types need serializer and deserializer support; preserve unknown items' raw JSON.
+- Entrypoint `org.kne.cloud.network.klalb.KLALBMain`: load config → build `KLALBProxySystem` → open Swing GUI (`KLALBStateGUI3`) unless `"nogui": true` → start `KLALBWebServer` (if `"webUI": true` or web server enabled, default port `4665`) → interactive console (`help`, `links-state`, `route`, `kperf`, ...).
-- `/api/config` is field-by-field parsing, not whole-object Gson mapping. Keep legacy key aliases in sync with new fields.
+- `org.kne.cloud.network.klalb.web.KLALBWebServer` — built-in HTTP/SSE server (JDK `HttpServer`):
-- Vendored Gson is `2.1`: responses that are `JsonElement` instances must be serialized with `JsonElement.toString()`, not reflective `gson.toJson(Object)`.
+  - API endpoints: `/api/status`, `/api/events` (SSE stream, 200ms intervals), `/api/links`, `/api/links/action`, `/api/links/reconnect`, `/api/routing-table`, `/api/nodes` (topology graph), `/api/node-info?address=<ipv6>` (on-demand full node info), `/api/config`.
-- UI strings use `UIEnv.getRsb()`; add keys to both `src/klalb_zh_CN.properties` and `src/klalb_en_US.properties`.
+  - Static file hosting / SPA fallback: serves `dashboard/dist/` assets directly.
-- `KLALBController.PublishedNodeInfo` is the thread-safe node-info source. Publish profile, effective external endpoints, and extra routes through the controller so snapshots and update flags remain coherent. Peer queries are separate profile, endpoint, and extra-route requests; use `NodeInfoQueryCoordinator` when a consumer needs an aggregate detail result.
+- `org.kne.cloud.network` — generic socket framework: `VirtualSocket*` hierarchy, `SocketBridge` port-forwarding proxies, `ProtocolDetector` (multi-protocol mux on one port), `MultiProtocolSocketAddress` = URI-style addresses (`tcp://`, `udp://`, `kltp://`, `ntp://`) dispatched through the `SocketType` registry.
-- `RouterInfo` retains an empty legacy UTF slot. `RouterInfoPacket` appends optional update flags behind a marker; treat binary codec changes as mesh-compatibility work and preserve old-reader behavior.
+- `...network.klalb` — app core: `KLALBController` (the virtual SRv6 network), `KLALBRemoteLink` (WAN lines), `*Packet` wire-format classes, virtual socket implementations.
+- `...network.congestion` — pluggable congestion control (BBR, Vegas2, DCTCP...), chosen via `"congestionAlgorithm"` in config.
+- `...network.kltp` — custom reliable transport protocol (packets/streams).
+- `...network.ipv6`, `...network.srv6` — packet codecs, route table, Dijkstra path computation.
+- **Node-info query API** (`...network.srv6`, JSON datagrams on `KLALBRoutingProtocol.DEFAULT_PORT=1001`): `KLALBRoutingProtocolAPIServer/Client` speak two request types —
+  - `nodeinfotinyreq/resp` → device name ONLY; never gated by any flag (name is public via broadcast anyway).
+  - `nodeinfofullreq/resp` → externalEndpoints + deviceName + deviceDescription. `denyExternalEndpointQuery=true` hides ONLY the endpoint list (`data=null`); name/description still answer.
+  - GUI rule: opening `NodeInformationPanel` = Full query; use `requestNodeInfoTiny` for lightweight/background lookups. Legacy `openlines*` message types were removed — mixed-version meshes get silence, so upgrade the whole network together.
+  - `JsonDataPacket` stores its UTF-8 payload length in a 2-byte header field: keep every JSON message under 64 KiB.
+- `...network.frpc` — frp client integration.
+- `...klalb.ui` — all Swing UI code.
+
+## Frontend (Dashboard)
+
+Located in `dashboard/`:
+- **Git layout**: `dashboard/` is a separate git repo wired in as a submodule (own origin on `git.code.cq.cn`). Commit frontend changes inside `dashboard/` first, then bump the submodule pointer in the parent repo — parent-repo commits alone do not capture them.
+- **Stack**: Vite + React 19 + TypeScript + Tailwind CSS v4 + `@base-ui/react` (style: `base-nova`, icons: `lucide-react`, toasts: `@base-ui/react/toast`).
+- **Routing**: Hash-based routing (`#/overview`, `#/connections`, `#/routing-table`, `#/topology`, `#/settings`) for seamless SPA hosting under Java `KLALBWebServer`.
+- **Package Manager**: `pnpm` (run all commands from `dashboard/` directory).
+- **Component installation**: **Must** use CLI via `pnpm dlx shadcn@latest add <component>` (e.g. `pnpm dlx shadcn@latest add alert card badge toast`). Never create or fake shadcn components manually. Non-shadcn libs (`@xyflow/react`, `d3-force`) are installed via plain `pnpm add`.
+- **Commands**:
+  - `pnpm dev` — Start Vite dev server (proxies `/api` to backend `http://127.0.0.1:4665`).
+  - `pnpm build` — Typecheck and build SPA to `dashboard/dist` (which Java `KLALBWebServer` serves directly).
+  - `pnpm lint` / `pnpm typecheck` — Verification.
+- **Pages & data flow**:
+  - Overview / Connections read the SSE stream (`use-klalb-sse.ts`, 200ms pushes of status + links).
+  - Settings loads/saves `/api/config` (`use-klalb-config.ts`); save payload must keep legacy field aliases alongside new names for compatibility.
+  - Routing table polls `/api/routing-table` every 1s (`use-routing-table.ts`); `cost` is delay-derived and displayed in milliseconds.
+  - Topology polls `/api/nodes` every 1s (`use-topology.ts`) — SSE does NOT carry topology.
+  - Selecting a topology node queries `/api/node-info`; remote node descriptions require a full SRv6 node-info request and can time out after 3s.
+  - Topology layout: `d3-force` headless simulation (recomputed only when node/edge structure changes) rendered by `@xyflow/react` with custom `device-node` / `link-edge` components in `src/components/topology/`.
+  - React hooks lint rule forbids `setState` synchronously inside effects — initialize form state via component `key` remount + lazy `useState(() => ...)` initializers (see `SettingsForm` pattern).
+
+## Config
+
+`klalb-config.json` is an array of items discriminated by their `"Type"` field. Adding a new item type requires a `KLALBConfigItem` subclass **plus** new cases in both `KLALBConfigItem.getDefaultJsonDeserializer()` and `getDefaultJsonSerializer()`; unknown types are preserved as `UnknownKLALBConfigItem`. Any Gson instance handling config must register these adapters via `registerToGsonBuilder` (see `KLALBProxySystem`).
+
+Key controller config fields:
+- `externalEndpoints` / `autoConnections`: published vs auto-connect endpoint lists (renamed from `openConnections`, which itself replaced legacy `LineTable`; the old name was a developer naming mistake — these addresses are this node's externally published endpoints, not "connections").
+- `ntpServers`: time server list (replaces `ntpServerTable`).
+- `denyExternalEndpointQuery` / `denyExternalEndpointBroadcast`: safety flags — the query flag hides ONLY the external-endpoint list in full node-info responses (device name/description still answer; Tiny queries are never gated), the broadcast flag disables LAN multicast discovery (renamed from `denyConnectionQuery` / `denyConnectionBroadcast`, which replaced `denyLineTableQuery` / `denyLineTableBroadcast`).
+- `enableTUN`: boolean flag for TUN interface creation (`"TUNName"` configures device name).
+- `webListen`: Web API listen address, normally `http://0.0.0.0:4665`; legacy `webPort` is accepted on load/API input.
+
+Legacy JSON keys are still accepted on load: `KLALBConfigItem.getDefaultJsonDeserializer()` normalizes old key names (`openConnections`/`LineTable`, `denyConnectionQuery`, `denyLineTable*`, ...) before reflective deserialization (manual rewrite because gson-2.1 has no `@SerializedName(alternate=...)`), and `handleConfig` in the web server accepts them too. New saves always write canonical names.
+
+Gson quirks:
+- **gson-2.1 (vendored) is ancient**: its `JSON_ELEMENT` adapter factory only matches exact `JsonElement.class`, NOT subclasses. Calling `gson.toJson(Object)` with a runtime `JsonObject`/`JsonArray` reflectively serializes the internal field as `{"members": {...}}`. `KLALBWebServer.sendJsonResponse` guards against this by using `JsonElement.toString()` for JsonElement instances — keep that guard when adding new response paths. SSE avoids the issue entirely via `JsonObject.toString()`.
+- `/api/config` GET/POST is parsed field-by-field in `KLALBWebServer.handleConfig` (NOT whole-object Gson reflection) because polymorphic fields (`List<InetAddress>`, `List<MultiProtocolSocketAddress>`) break reflective mapping. Keep new config fields in sync there, accepting both legacy and new JSON key names.
+- `InetAddress`, `MultiProtocolSocketAddress`, and `KLALBConfigItem` custom adapters are registered on the shared Gson in `KLALBProxySystem`; the web server reuses that instance via `proxySystem.getGson()`.
+- Saving via web API persists through `KLALBProxySystem.saveConfigToFile()` (GUI save consumer takes precedence when present).
+
+## Conventions
+
+- Sources are UTF-8; comments, log/UI strings, and commit messages are largely Chinese.
+- UI strings go through `UIEnv.getRsb().getString(...)`; add keys to **both** `src/klalb_zh_CN.properties` and `src/klalb_en_US.properties`.
+- `client.cfg`, `server.cfg`, `linetable.txt` at the root are example line-table/port-rule files loaded via the GUI file picker — not hardwired paths.

KLALB.iml

@@ -249,5 +249,6 @@
       </library>
     </orderEntry>
     <orderEntry type="jdk" jdkName="jdk-26.0.1" jdkType="JavaSDK" />
+    <orderEntry type="library" name="jfreechart-1.5.3" level="project" />
   </component>
 </module>

client.cfg

@@ -1,20 +0,0 @@
-//加速线路
-{KLALBRemote}->43.248.189.107:35000
-{KLALBRemote}->cn-bj-bgp-3.openfrp.top:65529
-{KLALBRemote}->180.76.147.250:65529
-{KLALBRemote}->cn-ah-dx-1.natfrp.cloud:65529
-{KLALBRemote}->cn-nn-dx-1.natfrp.cloud:65529
-{KLALBRemote}->cn-wh-dx-1.natfrp.cloud:65529
-{KLALBRemote}->cn-zz-bgp-10.natfrp.cloud:23330
-{KLALBRemote}->cn-zz-bgp-7.natfrp.cloud:33336
-{KLALBRemote}->43.143.109.64:49965
-{KLALBRemote}->frp.104300.xyz:49965
-{KLALBRemote}->us.afrps.cn:49966
-{KLALBRemote}->hk.afrps.cn:49966
-{KLALBRemote}->la.afrps.cn:49966
-{KLALBRemote}->frp.freefrp.net:49965
-{KLALBRemote}->frp1.freefrp.net:49965
-{KLALBRemote}->frp2.freefrp.net:49965
-{KLALBRemote}->frp4.freefrp.net:49965
-
-0.0.0.0:25565->{KLALBVirtual}[171d:a999:e697:4b23:ae52:9f29:4532:e1ee]:25565

klalbconfig-old.json

@@ -1,79 +0,0 @@
-[ 
-  {"Type":"KLALBController" ,
-    "TCPListen" : "0.0.0.0:4565",
-    "UDPListen" : "{UDP}0.0.0.0:4572",
-    "VirtualSocketName" : "KLALB_Stream",
-    "LineTable":["43.248.189.107:65529",
-"cn-bj-bgp-3.openfrp.top:65529",
-"180.76.147.250:65529",
-"cn-ah-dx-1.natfrp.cloud:65529",
-"cn-nn-dx-1.natfrp.cloud:65529",
-"cn-wh-dx-1.natfrp.cloud:65529",
-"cn-zz-bgp-10.natfrp.cloud:23330",
-"cn-zz-bgp-7.natfrp.cloud:33336",
-"43.143.109.64:49965",
-"frp.104300.xyz:49965",
-"us.afrps.cn:49966",
-"hk.afrps.cn:49966",
-"la.afrps.cn:49966",
-"frp.freefrp.net:49965",
-"frp1.freefrp.net:49965",
-"frp2.freefrp.net:49965",
-"frp4.freefrp.net:49965",
-"cn-he-plc-2.openfrp.top:4572",
-"{UDP}cn-he-plc-2.openfrp.top:4572",
-"frp-mom.top:22226",
-"frp-man.top:36555",
-"us-sjc-bgp-2.openfrp.top:36555",
-"us-sjc-bgp-1.openfrp.top:36555",
-"[240e:340:d856:b700:6d02:6a6a:f9fc:865b]:4572"]
-  },
- {"Type":"SocketBridge" ,
-    "Listen" : "0.0.0.0:4572",
-"Bridge":{
-      "KLALB" : "SocketBridge",
-      "RDP":"SocketBridge",
-      "HTTP":"SocketBridge",
-      "HTTPS":"SocketBridge",
-      "DEFAULT":"MinecraftSocketBridge23332"
-    } ,
-    "Connect" : {
-      "KLALB" : "127.0.0.1:4565",
-      "RDP":"127.0.0.1:3389",
-      "HTTP":"127.0.0.1:5212",
-      "HTTPS":"192.168.1.235:443",
-      "DEFAULT":"127.0.0.1:36555"
-    }
-  },
-   {"Type":"SocketBridge" ,
-    "Listen" : "{KLALB_Stream}[::0]:23332",
-"Bridge":"MinecraftSocketBridge23332",
-    "Connect" : "127.0.0.1:36555"
-  },
-  { "Type":"SocketBridge" ,
-    "Listen" : "{KLALB_Stream}[::0]:23333",
-"Bridge":"SocketBridge",
-    "Connect" : "127.0.0.1:5212"
-  },
-
-
-
-
-
- {"Type":"SocketBridge" ,
-    "Listen" : "0.0.0.0:25561",
-"Bridge":{
-      "KLALB" : "SocketBridge",
-      "DEFAULT":"MinecraftSocketBridge23330"
-    } ,
-    "Connect" : {
-      "KLALB" : "127.0.0.1:4565",
-      "DEFAULT":"127.0.0.1:25562"
-    }
-  },
-   {"Type":"SocketBridge" ,
-    "Listen" : "{KLALB_Stream}[::0]:23330",
-"Bridge":"MinecraftSocketBridge23330",
-    "Connect" : "127.0.0.1:25562"
-  }
-]

lines.cfg

@@ -1,29 +0,0 @@
-0.0.0.0:35000(RDP)->192.168.1.233:3389
-0.0.0.0:35000(HTTPS)->192.168.1.233:8444
-0.0.0.0:35000(HTTP)->192.168.1.233:5212
-0.0.0.0:35000(SSH)->192.168.1.236:22
-0.0.0.0:35000(KLALB)->{KLALBRemote}
-0.0.0.0:35000->127.0.0.1:35001   //Winds服(普通线路)
-
-{KLALBVirtual}[::0]:25565->127.0.0.1:35001 //Winds服(加速线路)
-
-//加速线路
-{KLALBRemote}->43.248.189.107:35000
-{KLALBRemote}->cn-bj-bgp-3.openfrp.top:65529
-{KLALBRemote}->180.76.147.250:65529
-{KLALBRemote}->cn-ah-dx-1.natfrp.cloud:65529
-{KLALBRemote}->cn-nn-dx-1.natfrp.cloud:65529
-{KLALBRemote}->cn-wh-dx-1.natfrp.cloud:65529
-{KLALBRemote}->cn-zz-bgp-10.natfrp.cloud:23330
-{KLALBRemote}->cn-zz-bgp-7.natfrp.cloud:33336
-{KLALBRemote}->43.143.109.64:49965
-{KLALBRemote}->frp.104300.xyz:49965
-{KLALBRemote}->us.afrps.cn:49966
-{KLALBRemote}->hk.afrps.cn:49966
-{KLALBRemote}->la.afrps.cn:49966
-{KLALBRemote}->frp.freefrp.net:49965
-{KLALBRemote}->frp1.freefrp.net:49965
-{KLALBRemote}->frp2.freefrp.net:49965
-{KLALBRemote}->frp4.freefrp.net:49965
-
-0.0.0.0:25565->{KLALBVirtual}[171d:a999:e697:4b23:ae52:9f29:4532:e1ee]:25565

linetable - 副本.txt

@@ -1,18 +0,0 @@
-43.248.189.107:65529
-cn-bj-bgp-3.openfrp.top:65529
-180.76.147.250:65529
-cn-ah-dx-1.natfrp.cloud:65529
-cn-nn-dx-1.natfrp.cloud:65529
-cn-wh-dx-1.natfrp.cloud:65529
-cn-zz-bgp-10.natfrp.cloud:23330
-cn-zz-bgp-7.natfrp.cloud:33336
-43.143.109.64:49965
-frp.104300.xyz:49965
-us.afrps.cn:49966
-hk.afrps.cn:49966
-la.afrps.cn:49966
-frp.freefrp.net:49965
-frp1.freefrp.net:49965
-frp2.freefrp.net:49965
-frp4.freefrp.net:49965
-cn-he-plc-2.openfrp.top:4569

server.cfg

@@ -1,8 +0,0 @@
-0.0.0.0:35000(RDP)->192.168.1.233:3389
-0.0.0.0:35000(HTTPS)->192.168.1.233:8444
-0.0.0.0:35000(HTTP)->192.168.1.233:5212
-0.0.0.0:35000(SSH)->192.168.1.236:22
-0.0.0.0:35000(KLALB)->{KLALBRemote}
-0.0.0.0:35000->127.0.0.1:35001   //Winds服(普通线路)
-
-{KLALBVirtual}[::0]:25565->127.0.0.1:35001 //Winds服(加速线路)

src/klalb_en_US.properties

@@ -7,7 +7,6 @@ devicename=Device name
 devicedescription=Device description
 dnsserver=DNS server
 extraroutes=Extra routes
-noextraroutes=No extra routes
 asnumber=AS number
 tcplistening=TCP listening
 udplistening=UDP listening

src/klalb_zh_CN.properties

@@ -7,7 +7,6 @@ devicename=设备名称
 devicedescription=设备描述
 dnsserver=DNS服务器
 extraroutes=额外路由
-noextraroutes=暂无额外路由
 asnumber=AS号码
 tcplistening=TCP监听端口
 udplistening=UDP监听端口

src/org/kne/cloud/network/ipv6/IPv6TUNLoopbackNetworkLink.java

@@ -260,18 +260,18 @@ public class IPv6TUNLoopbackNetworkLink extends AbstractIPv6NetworkLink
 		List<RouteItem> rlist = new ArrayList<>();
 
 		for (IPv6AddressGroup grp : getAddressGroups()) {
-			rlist.add(new RouteItem(new IPv6AddressGroup(grp.getAddress(), 128), grp.getAddress(), this, "Direct", 0, 1,
+			rlist.add(new RouteItem(new IPv6AddressGroup(grp.getAddress(), 128), grp.getAddress(), this, RouteItem.DIRECT, 0, 1,
-					null, "D", true));
+					null, "D"));
 		}
 
 		for (Iterator<Neighbor> iteratorx = getNeighborsInfo().iterator(); iteratorx.hasNext();) {
 			Neighbor addresses = (Neighbor) iteratorx.next();
 			RouteItem ri = new RouteItem(new IPv6AddressGroup(addresses.getAddress().getAddress(), 128),
-					addresses.getAddress().getAddress(), this, "Direct", 0, 128, null, "D", false);
+					addresses.getAddress().getAddress(), this, RouteItem.SRv6_ENDXSID, 0, 128, null, "D");
 			rlist.add(ri);
 
 			RouteItem ris = new RouteItem(addresses.getLocator(), addresses.getLocator().getAddress(), this,
-					"KLALB SRv6", 13, 128, null, "D", false);
+					RouteItem.SRv6_ENDSID, 13, 128, null, "D");
 			rlist.add(ris);
 
 		}

src/org/kne/cloud/network/ipv6/LoopbackIPv6NetworkLink.java

@@ -98,19 +98,18 @@ public class LoopbackIPv6NetworkLink extends AbstractIPv6NetworkLink implements
 			List<RouteItem> rlist = new ArrayList<>();
 			for(IPv6AddressGroup group:addressGroups) {
 			rlist.add(new RouteItem(new IPv6AddressGroup(group.getAddress(), 128),
-					group.getAddress(), this, "Direct", 0, 0, null, "D", true));
+					group.getAddress(), this, RouteItem.DIRECT, 0, 0, null, "D"));
 			}
 
 			for (Iterator<Neighbor> iteratorx = getNeighborsInfo().iterator(); iteratorx.hasNext();) {
 				Neighbor addresses = (Neighbor) iteratorx.next();
 				RouteItem ri = new RouteItem(new IPv6AddressGroup(addresses.getAddress().getAddress(), 128),
-						addresses.getAddress().getAddress(), this, "Direct", 0, 128, null, "D",
+						addresses.getAddress().getAddress(), this,RouteItem.SRv6_ENDXSID, 0, 128, null, "D");
-						false);
 				rlist.add(ri);
 
 				RouteItem ris = new RouteItem(addresses.getLocator(),
-						 addresses.getLocator().getAddress(), this, "KLALB SRv6", 13, 128,
+						 addresses.getLocator().getAddress(), this, RouteItem.SRv6_ENDSID, 13, 128,
-						 null, "D", false);
+						 null, "D");
 				rlist.add(ris);
 
 			}

src/org/kne/cloud/network/ipv6/RouteItem.java

@@ -4,6 +4,10 @@ import java.util.Objects;
 import java.util.function.Supplier;
 
 public class RouteItem implements Comparable<RouteItem>,Cloneable{
+	public static final String DIRECT="Direct";
+	public static final String SRv6_ENDSID="SRv6 ENDSID";
+	public static final String SRv6_ENDXSID="SRv6 ENDXSID";
+	
 	private IPv6AddressGroup destination;
 	private IPv6Address nexthop;
 	private IPv6NetworkLink destlink;
@@ -12,7 +16,6 @@ public class RouteItem implements Comparable<RouteItem>,Cloneable{
 	private long cost;
 	private String flag;
 	private Supplier<Long> costSupplier;
-	private boolean isLoopback;
 	public String getFlag() {
 		return flag;
 	}
@@ -34,7 +37,7 @@ public class RouteItem implements Comparable<RouteItem>,Cloneable{
 				 && pre == other.pre && Objects.equals(proto, other.proto);
 	}
 	public RouteItem(IPv6AddressGroup destination, IPv6Address nexthop, IPv6NetworkLink destlink, String proto, int pre,
-			long cost,String flag,boolean isLoopback) {
+			long cost,String flag) {
 		super();
 		this.destination = destination;
 		this.nexthop = nexthop;
@@ -43,10 +46,9 @@ public class RouteItem implements Comparable<RouteItem>,Cloneable{
 		this.pre = pre;
 		this.cost = cost;
 		this.flag=flag;
-		this.isLoopback=isLoopback;
 	}
 	public RouteItem(IPv6AddressGroup destination, IPv6Address nexthop, IPv6NetworkLink destlink, String proto, int pre,
-			long cost,Supplier<Long> costSupplier,String flag,boolean isLoopback) {
+			long cost,Supplier<Long> costSupplier,String flag) {
 		super();
 		this.destination = destination;
 		this.nexthop = nexthop;
@@ -56,7 +58,6 @@ public class RouteItem implements Comparable<RouteItem>,Cloneable{
 		this.cost = cost;
 		this.costSupplier=costSupplier;
 		this.flag=flag;
-		this.isLoopback=isLoopback;
 	}
 	public IPv6AddressGroup getDestination() {
 		return destination;
@@ -73,9 +74,6 @@ public class RouteItem implements Comparable<RouteItem>,Cloneable{
 	public int getPre() {
 		return pre;
 	}
-	public boolean isLoopback() {
-		return isLoopback;
-	}
 	@Override
 	public String toString() {
 		return getDestination()+"\t"+getProto()+"\t"+getPre()+"\t"+getCost()+"\t"+getFlag()+"\t"+getNexthop()+"\t"+getDestlink().getName();

src/org/kne/cloud/network/klalb/CONST.java

@@ -12,7 +12,7 @@ public class CONST {
 
 	public static final String KLALB_S_RV6 = "KLALB_SRv6";
 	
-	
+	public static final String KLTP_VIRTUAL_SOCKET_NAME="kltp";
 
 	public static final int itemwidth = 1000;
 	public static final int linepanelheight = 41;

src/org/kne/cloud/network/klalb/KLALBController.java

@@ -11,13 +11,11 @@ import java.net.SocketException;
 import java.net.SocketTimeoutException;
 import java.net.UnknownHostException;
 import java.util.ArrayList;
-import java.util.Collections;
 import java.util.Enumeration;
 import java.util.HashSet;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
-import java.util.Objects;
 import java.util.Set;
 import java.util.Timer;
 import java.util.TimerTask;
@@ -56,7 +54,6 @@ import org.kne.cloud.network.ntp.NTPv4Protocol.NTPPeer;
 import org.kne.cloud.network.srv6.KLALBRoutingProtocol;
 import org.kne.cloud.network.srv6.KLALBRoutingProtocolAPIClient;
 import org.kne.cloud.network.srv6.KLALBRoutingProtocolAPIServer;
-import org.kne.cloud.network.srv6.NodeInfoQueryStatus;
 import org.kne.cloud.network.srv6.SRv6Router;
 import org.kne.cloud.network.srv6.SRv6RouterListener;
 import org.kne.cloud.network.tcp.UDPPacket;
@@ -80,49 +77,6 @@ public class KLALBController {
 			new HashMapTimestampMonitor<UUID>(HighAccuracyClock.SYSTEM_CLOCK, "down", 100, TIME_WINDOW));
 
 	private List<MultiProtocolSocketAddress> externalEndpoints = new ArrayList<>();
-	private List<MultiProtocolSocketAddress> configuredExternalEndpoints = new ArrayList<>();
-	private List<MultiProtocolSocketAddress> discoveredExternalEndpoints = new ArrayList<>();
-
-	public static final class PublishedNodeInfo {
-		private final String deviceName;
-		private final String deviceDescription;
-		private final List<MultiProtocolSocketAddress> externalEndpoints;
-		private final List<String> extraRoutes;
-		private final long fullRevision;
-
-		private PublishedNodeInfo(String deviceName, String deviceDescription,
-				List<MultiProtocolSocketAddress> externalEndpoints, List<String> extraRoutes, long fullRevision) {
-			this.deviceName = deviceName;
-			this.deviceDescription = deviceDescription;
-			this.externalEndpoints = Collections.unmodifiableList(
-					new ArrayList<MultiProtocolSocketAddress>(externalEndpoints));
-			this.extraRoutes = Collections.unmodifiableList(new ArrayList<String>(extraRoutes));
-			this.fullRevision = fullRevision;
-		}
-
-		public String getDeviceName() {
-			return deviceName;
-		}
-
-		public String getDeviceDescription() {
-			return deviceDescription;
-		}
-
-		public List<MultiProtocolSocketAddress> getExternalEndpoints() {
-			return externalEndpoints;
-		}
-
-		public List<String> getExtraRoutes() {
-			return extraRoutes;
-		}
-
-		public long getFullRevision() {
-			return fullRevision;
-		}
-	}
-
-	private volatile PublishedNodeInfo publishedNodeInfo = new PublishedNodeInfo(null, null,
-			Collections.<MultiProtocolSocketAddress>emptyList(), Collections.<String>emptyList(), 0L);
 
 	private List<MultiProtocolSocketAddress> listensSocketAddress = new CopyOnWriteArrayList<>();
 
@@ -172,7 +126,6 @@ public class KLALBController {
 		public void run() {
 			try {
 				List<InetAddress> localaddress = networkInterfaceManager.getAllNetworkInterfaceAddress();
-				List<MultiProtocolSocketAddress> currentDiscoveredExternalEndpoints = new ArrayList<>();
 			
 				for (InetAddress inetAddress : localaddress) {
 						for (Iterator<MultiProtocolSocketAddress> iterator = listensSocketAddress.iterator(); iterator.hasNext();) {
@@ -184,8 +137,10 @@ public class KLALBController {
 									MultiProtocolSocketAddress bind = new MultiProtocolSocketAddress(tcpl.getProtocol(),
 											inetAddress.getHostAddress(), tcpl.getPort());
 									// System.out.println(bind);
-									if (!currentDiscoveredExternalEndpoints.contains(bind)) {
+									synchronized (externalEndpoints) {
-										currentDiscoveredExternalEndpoints.add(bind);
+										if (!externalEndpoints.contains(bind)) {
+											externalEndpoints.add(bind);
+										}
 									}
 								}
 							} catch (UnknownHostException e) {
@@ -195,12 +150,6 @@ public class KLALBController {
 
 						}
 				}
-				synchronized (externalEndpoints) {
-					if (!discoveredExternalEndpoints.equals(currentDiscoveredExternalEndpoints)) {
-						discoveredExternalEndpoints = currentDiscoveredExternalEndpoints;
-						publishDiscoveredExternalEndpointLocked();
-					}
-				}
 			
 			lineslock.writeLock().lock();
 			try {
@@ -350,7 +299,7 @@ public class KLALBController {
 	private boolean checkIsSelf(MultiProtocolSocketAddress inetAddress) throws UnknownHostException {
 
 		return inetAddress.getInetAddress().isAnyLocalAddress() || inetAddress.getInetAddress().isLoopbackAddress()
-				|| publishedNodeInfo.getExternalEndpoints().contains(inetAddress);
+				|| externalEndpoints.contains(inetAddress);
 	}
 
 	private boolean checkIsSelfLocator(InetAddress inetAddress) {
@@ -390,11 +339,9 @@ public class KLALBController {
 				try {
 					InetSocketAddress iaddr = new InetSocketAddress(neighbor.getAddress().toInet6Address(),
 							KLALBRoutingProtocol.DEFAULT_PORT);
-					apiClient.requestExternalEndpoints(iaddr, (v) -> {
+					apiClient.requestNodeInfoFull(iaddr, (v) -> {
-						if (v == null || v.getStatus() != NodeInfoQueryStatus.OK) return;
 						ThreadTool.makeVDaemonThreadIfSupport("线路添加任务", () -> {
-							if (v.getExternalEndpoints() == null) return;
+							for (MultiProtocolSocketAddress msa : v.getOpenLines()) {
-							for (MultiProtocolSocketAddress msa : v.getExternalEndpoints()) {
 								// System.out.print(msa);
 								addRemoteLines(msa);
 							}
@@ -455,102 +402,7 @@ public class KLALBController {
 
 
 	public List<MultiProtocolSocketAddress> getExternalEndpoints() {
-		return publishedNodeInfo.getExternalEndpoints();
+		return externalEndpoints;
-	}
-
-	public List<MultiProtocolSocketAddress> getExternalEndpointsSnapshot() {
-		return new ArrayList<MultiProtocolSocketAddress>(publishedNodeInfo.getExternalEndpoints());
-	}
-
-	public PublishedNodeInfo getPublishedNodeInfo() {
-		return publishedNodeInfo;
-	}
-
-	private List<MultiProtocolSocketAddress> createEffectiveExternalEndpointsLocked() {
-		List<MultiProtocolSocketAddress> effective = new ArrayList<MultiProtocolSocketAddress>();
-		for (MultiProtocolSocketAddress endpoint : configuredExternalEndpoints) {
-			if (!effective.contains(endpoint)) {
-				effective.add(endpoint);
-			}
-		}
-		for (MultiProtocolSocketAddress endpoint : discoveredExternalEndpoints) {
-			if (!effective.contains(endpoint)) {
-				effective.add(endpoint);
-			}
-		}
-		return effective;
-	}
-
-	private void publishNodeInfoLocked(String deviceName, String deviceDescription,
-			List<MultiProtocolSocketAddress> configEndpoints, List<String> extraRoutes) {
-		configuredExternalEndpoints = configEndpoints == null
-				? new ArrayList<MultiProtocolSocketAddress>()
-				: new ArrayList<MultiProtocolSocketAddress>(configEndpoints);
-		List<String> publishedExtraRoutes = extraRoutes == null
-				? new ArrayList<String>() : new ArrayList<String>(extraRoutes);
-		List<MultiProtocolSocketAddress> effective = createEffectiveExternalEndpointsLocked();
-		PublishedNodeInfo previous = publishedNodeInfo;
-		boolean nameChanged = !Objects.equals(previous.getDeviceName(), deviceName);
-		boolean fullChanged = !Objects.equals(previous.getDeviceDescription(), deviceDescription)
-				|| !previous.getExternalEndpoints().equals(effective)
-				|| !previous.getExtraRoutes().equals(publishedExtraRoutes);
-
-		externalEndpoints.clear();
-		externalEndpoints.addAll(effective);
-		if (srv6Router != null) {
-			srv6Router.setDeviceName(deviceName);
-		}
-		long fullRevision = previous.getFullRevision() + (fullChanged ? 1L : 0L);
-		publishedNodeInfo = new PublishedNodeInfo(deviceName, deviceDescription, effective, publishedExtraRoutes,
-				fullRevision);
-		if (routingProtocol != null) {
-			if (nameChanged) {
-				routingProtocol.announceNodeInfoUpdate(
-						org.kne.cloud.network.srv6.RouterInfoPacket.NODE_INFO_TINY_UPDATE_REQUIRED);
-			}
-			if (fullChanged) {
-				routingProtocol.announceNodeInfoUpdate(
-						org.kne.cloud.network.srv6.RouterInfoPacket.NODE_INFO_FULL_UPDATE_REQUIRED);
-			}
-		}
-	}
-
-	public void publishNodeInfo(String deviceName, String deviceDescription,
-			List<MultiProtocolSocketAddress> configEndpoints, List<String> extraRoutes) {
-		synchronized (externalEndpoints) {
-			if (configItem != null) {
-				configItem.setDeviceName(deviceName);
-				configItem.setDeviceDescription(deviceDescription);
-				configItem.setExternalEndpoints(new ArrayList<MultiProtocolSocketAddress>(configEndpoints == null
-						? Collections.<MultiProtocolSocketAddress>emptyList() : configEndpoints));
-				configItem.setExtraRoutes(new ArrayList<String>(extraRoutes == null
-						? Collections.<String>emptyList() : extraRoutes));
-			}
-			publishNodeInfoLocked(deviceName, deviceDescription, configEndpoints, extraRoutes);
-		}
-	}
-
-	private void publishDiscoveredExternalEndpointLocked() {
-		List<MultiProtocolSocketAddress> effective = createEffectiveExternalEndpointsLocked();
-		if (new HashSet<MultiProtocolSocketAddress>(effective)
-				.equals(new HashSet<MultiProtocolSocketAddress>(externalEndpoints))) {
-			return;
-		}
-		externalEndpoints.clear();
-		externalEndpoints.addAll(effective);
-		PublishedNodeInfo previous = publishedNodeInfo;
-		publishedNodeInfo = new PublishedNodeInfo(previous.getDeviceName(), previous.getDeviceDescription(), effective,
-				previous.getExtraRoutes(), previous.getFullRevision() + 1L);
-		if (routingProtocol != null) {
-			routingProtocol.announceNodeInfoUpdate(
-					org.kne.cloud.network.srv6.RouterInfoPacket.NODE_INFO_FULL_UPDATE_REQUIRED);
-		}
-	}
-
-	public void replaceExternalEndpoints(List<MultiProtocolSocketAddress> endpoints) {
-		PublishedNodeInfo published = publishedNodeInfo;
-		publishNodeInfo(published.getDeviceName(), published.getDeviceDescription(), endpoints,
-				published.getExtraRoutes());
 	}
 
 
@@ -752,7 +604,8 @@ public class KLALBController {
 
 	private String generateExternalEndpointsString() {
 		StringBuilder sbd = new StringBuilder();
-		for (MultiProtocolSocketAddress klalbRemoteLine : publishedNodeInfo.getExternalEndpoints()) {
+		for (Iterator<MultiProtocolSocketAddress> iterator = externalEndpoints.iterator(); iterator.hasNext();) {
+			MultiProtocolSocketAddress klalbRemoteLine = (MultiProtocolSocketAddress) iterator.next();
 			sbd.append(klalbRemoteLine.toString());
 			sbd.append('\n');
 		}
@@ -834,7 +687,7 @@ public class KLALBController {
 		// System.out.println(context);
 		try {
 			NTPv4Protocol nvc = new NTPv4Protocol(context,
-					new MultiProtocolSocketAddress(iproxyname + "_Datagram","0.0.0.0",123));
+					new MultiProtocolSocketAddress(iproxyname + "datagram","0.0.0.0",123));
 			srv6Router.addSRv6RouterListener(new SRv6RouterListener() {
 
 				@Override
@@ -845,7 +698,7 @@ public class KLALBController {
 					for (Neighbor neighbor : nb) {
 						if (neighbor.getLocator() != null)
 							sp.add(new NTPPeer(
-									new MultiProtocolSocketAddress(iproxyname + "_Datagram",
+									new MultiProtocolSocketAddress(iproxyname + "datagram",
 											neighbor.getLocator().getAddress().toString(), 123),
 									NTPv4Packet.NTP_SYMMETRIC_ACTIVE));
 
@@ -912,9 +765,6 @@ public class KLALBController {
 			}
 		}).start();
 		loadSRv6ProtocolStack(selfg, enableVirtualAdapter);
-		if (configItem == null) {
-			publishNodeInfo(srv6Router.getDeviceName(), null, null, null);
-		}
 		loadController();
 	}
 
@@ -952,8 +802,9 @@ public class KLALBController {
 		}
 
 		List<MultiProtocolSocketAddress> linele = configItem.getExternalEndpoints();
-		publishNodeInfo(configItem.getDeviceName(), configItem.getDeviceDescription(), linele,
+		if (linele != null) {
-				configItem.getExtraRoutes());
+			getExternalEndpoints().addAll(linele);
+		}
 		List<MultiProtocolSocketAddress> linetoc = configItem.getAutoConnections();
 		if (linetoc != null) {
 			linetoc.forEach((aline) -> {
@@ -1127,8 +978,8 @@ public class KLALBController {
 
 
 	public void registerToProxyTypeAs(String proxyname) {
-		MultiProtocolSocketAddress.getSocketTypeRegister().put(proxyname + "_Stream", streamSocketType);
+		MultiProtocolSocketAddress.getSocketTypeRegister().put(proxyname + "stream", streamSocketType);
-		MultiProtocolSocketAddress.getSocketTypeRegister().put(proxyname + "_Datagram", datagramSocketType);
+		MultiProtocolSocketAddress.getSocketTypeRegister().put(proxyname + "datagram", datagramSocketType);
 		// ProxyProfileEntry.getRegister().put(proxyname, this);
 	}
 

src/org/kne/cloud/network/klalb/KLALBMain.java

@@ -22,8 +22,7 @@ import org.kne.cloud.network.klalb.ui.UIEnv;
 import org.kne.cloud.network.perf.Kperf;
 import org.kne.cloud.network.perf.NodeBenchmark;
 import org.kne.debug.TimeDebugger;
-import org.kne.membandboost.MembandBenchmark;
+import org.kne.membandboost.benchmark.*;;
-import org.kne.membandboost.ObjectPoolBandwidthTest;
 
 public class KLALBMain {
 	public static KLALBStateGUI3 ksg;
@@ -239,10 +238,6 @@ public class KLALBMain {
 		case "membandbenchmark":
 			MembandBenchmark.main(args);
 			break;
-		case "memqueuebenchmark":
-
-			ObjectPoolBandwidthTest.main(args);
-			break;
 		//case "$$SYSTEM:":
 			//System.out.println();
 			//break;

src/org/kne/cloud/network/klalb/KLALBProxySystem.java

@@ -168,9 +168,11 @@ public class KLALBProxySystem {
 				
 				
 				String vsne=kcci.getVirtualSocketName();
-				//if(vsne!=null) {
+				if(vsne!=null) {
 					MultiProtocolSocketAddress.getSocketTypeRegister().put(vsne, klalbController.getStreamSocketType());
-				//}
+				}else{
+					MultiProtocolSocketAddress.getSocketTypeRegister().put(CONST.KLTP_VIRTUAL_SOCKET_NAME, klalbController.getStreamSocketType());
+				}
 				MultiProtocolSocketAddress tcple=kcci.getTCPListen();
 				if(tcple!=null) {
 					

src/org/kne/cloud/network/klalb/KLALBRemoteLink.java

@@ -959,12 +959,12 @@ public class KLALBRemoteLink extends AbstractControlledIPv6NetworkLink implement
 		for (Iterator<Neighbor> iteratorx = getNeighborsInfo().iterator(); iteratorx.hasNext(); ) {
 			Neighbor addresses = (Neighbor) iteratorx.next();
 			RouteItem ri = new RouteItem(new IPv6AddressGroup(addresses.getAddress().getAddress(), 128),
-					addresses.getAddress().getAddress(), this, "Direct", 0, 128, CostSupplierFactory.expectedDelaySupplier((DelayMonitorData) addresses.getMonitor(), status, algorithm::getRTO), "D", false);
+					addresses.getAddress().getAddress(), this, RouteItem.SRv6_ENDXSID, 0, 128, CostSupplierFactory.expectedDelaySupplier((DelayMonitorData) addresses.getMonitor(), status, algorithm::getRTO), "D");
 			rlist.add(ri);
 
 			if (addresses.getLocator() != null) {
 				RouteItem ris = new RouteItem(addresses.getLocator(), addresses.getLocator().getAddress(), this,
-						"KLALB SRv6", 13, 128, CostSupplierFactory.expectedDelaySupplier((DelayMonitorData) addresses.getMonitor(), status, algorithm::getRTO), "D", false);
+						RouteItem.SRv6_ENDSID, 13, 128, CostSupplierFactory.expectedDelaySupplier((DelayMonitorData) addresses.getMonitor(), status, algorithm::getRTO), "D");
 				rlist.add(ris);
 			}
 		}

src/org/kne/cloud/network/klalb/NodeInfoQueryCoordinator.java

@@ -1,211 +0,0 @@
-package org.kne.cloud.network.klalb;
-
-import java.net.SocketAddress;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Objects;
-import java.util.Optional;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
-
-import org.kne.cloud.network.MultiProtocolSocketAddress;
-import org.kne.cloud.network.srv6.ExternalEndpointsResult;
-import org.kne.cloud.network.srv6.ExtraRoutesResult;
-import org.kne.cloud.network.srv6.KLALBRoutingProtocolAPIClient;
-import org.kne.cloud.network.srv6.NodeInfoQueryStatus;
-import org.kne.cloud.network.srv6.NodeProfile;
-
-/** Coordinates the three independent sections of a remote node-info query. */
-public final class NodeInfoQueryCoordinator {
-    private static final long DEADLINE_MILLIS = 3000L;
-    private static final ExecutorService REQUEST_EXECUTOR = Executors.newVirtualThreadPerTaskExecutor();
-    private static final ScheduledExecutorService DEADLINE_EXECUTOR = Executors
-            .newSingleThreadScheduledExecutor(r -> {
-                Thread thread = new Thread(r, "KLALB-node-info-deadline");
-                thread.setDaemon(true);
-                return thread;
-            });
-
-    private final KLALBRoutingProtocolAPIClient client;
-
-    public NodeInfoQueryCoordinator(KLALBRoutingProtocolAPIClient client) {
-        this.client = Objects.requireNonNull(client, "client");
-    }
-
-    /** Starts all section requests and completes at the first all-sections response or the shared deadline. */
-    public CompletableFuture<Result> query(SocketAddress address) {
-        Objects.requireNonNull(address, "address");
-        Pending pending = new Pending();
-        pending.result.whenComplete((ignored, error) -> {
-            if (pending.result.isCancelled()) pending.cancel();
-        });
-        pending.deadline = DEADLINE_EXECUTOR.schedule(pending::timeout, DEADLINE_MILLIS, TimeUnit.MILLISECONDS);
-
-        issue(pending, () -> client.requestNodeProfile(address, pending::profile), pending::profileFailed);
-        issue(pending, () -> client.requestExternalEndpoints(address, pending::externalEndpoints),
-                pending::externalEndpointsFailed);
-        issue(pending, () -> client.requestExtraRoutes(address, pending::extraRoutes), pending::extraRoutesFailed);
-        return pending.result;
-    }
-
-    private void issue(Pending pending, ThrowingRequest request, Runnable failure) {
-        REQUEST_EXECUTOR.execute(() -> pending.issue(request, failure));
-    }
-
-    @FunctionalInterface
-    private interface ThrowingRequest {
-        void run() throws Exception;
-    }
-
-    public static final class Section<T> {
-        private final boolean received;
-        private final Optional<T> value;
-        private final Optional<NodeInfoQueryStatus> status;
-
-        private Section(boolean received, T value, NodeInfoQueryStatus status) {
-            this.received = received;
-            this.value = Optional.ofNullable(value);
-            this.status = Optional.ofNullable(status);
-        }
-
-        public boolean isReceived() {
-            return received;
-        }
-
-        public Optional<T> getValue() {
-            return value;
-        }
-
-        public Optional<NodeInfoQueryStatus> getStatus() {
-            return status;
-        }
-
-        private static <T> Section<T> missing() {
-            return new Section<T>(false, null, null);
-        }
-
-        private static <T> Section<T> received(T value, NodeInfoQueryStatus status) {
-            return new Section<T>(true, value, status);
-        }
-    }
-
-    public static final class Result {
-        private final Section<NodeProfile> profile;
-        private final Section<List<MultiProtocolSocketAddress>> externalEndpoints;
-        private final Section<List<String>> extraRoutes;
-
-        private Result(Section<NodeProfile> profile,
-                Section<List<MultiProtocolSocketAddress>> externalEndpoints,
-                Section<List<String>> extraRoutes) {
-            this.profile = profile;
-            this.externalEndpoints = externalEndpoints;
-            this.extraRoutes = extraRoutes;
-        }
-
-        public Section<NodeProfile> getProfile() {
-            return profile;
-        }
-
-        public Section<List<MultiProtocolSocketAddress>> getExternalEndpoints() {
-            return externalEndpoints;
-        }
-
-        public Section<List<String>> getExtraRoutes() {
-            return extraRoutes;
-        }
-    }
-
-    private final class Pending {
-        private final CompletableFuture<Result> result = new CompletableFuture<>();
-        private final AtomicBoolean finished = new AtomicBoolean();
-        private int remaining = 3;
-        private Section<NodeProfile> profile = Section.missing();
-        private Section<List<MultiProtocolSocketAddress>> externalEndpoints = Section.missing();
-        private Section<List<String>> extraRoutes = Section.missing();
-        private java.util.concurrent.ScheduledFuture<?> deadline;
-
-        private synchronized void profile(NodeProfile value) {
-            if (profile.isReceived()) return;
-            profile = Section.received(value, NodeInfoQueryStatus.OK);
-            completeSection();
-        }
-
-        private synchronized void profileFailed() {
-            if (profile.isReceived()) return;
-            profile = Section.missing();
-            completeSection();
-        }
-
-        private synchronized void externalEndpoints(ExternalEndpointsResult value) {
-            if (externalEndpoints.isReceived()) return;
-            if (value == null) {
-                externalEndpoints = Section.missing();
-            } else {
-                List<MultiProtocolSocketAddress> endpoints = value.getExternalEndpoints();
-                externalEndpoints = Section.received(endpoints == null
-                        ? Collections.<MultiProtocolSocketAddress>emptyList()
-                        : Collections.unmodifiableList(new ArrayList<MultiProtocolSocketAddress>(endpoints)),
-                        value.getStatus());
-            }
-            completeSection();
-        }
-
-        private synchronized void externalEndpointsFailed() {
-            if (externalEndpoints.isReceived()) return;
-            externalEndpoints = Section.missing();
-            completeSection();
-        }
-
-        private synchronized void extraRoutes(ExtraRoutesResult value) {
-            if (extraRoutes.isReceived()) return;
-            if (value == null) {
-                extraRoutes = Section.missing();
-            } else {
-                List<String> routes = value.getExtraRoutes();
-                extraRoutes = Section.received(routes == null
-                        ? Collections.<String>emptyList()
-                        : Collections.unmodifiableList(new ArrayList<String>(routes)), value.getStatus());
-            }
-            completeSection();
-        }
-
-        private synchronized void extraRoutesFailed() {
-            if (extraRoutes.isReceived()) return;
-            extraRoutes = Section.missing();
-            completeSection();
-        }
-
-        private synchronized void issue(ThrowingRequest request, Runnable failure) {
-            if (finished.get() || result.isDone() || result.isCancelled()) return;
-            try {
-                request.run();
-            } catch (Exception e) {
-                failure.run();
-            }
-        }
-
-        private synchronized void cancel() {
-            finish();
-        }
-
-        private void completeSection() {
-            remaining--;
-            if (remaining == 0) finish();
-        }
-
-        private synchronized void timeout() {
-            finish();
-        }
-
-        private void finish() {
-            if (!finished.compareAndSet(false, true)) return;
-            if (deadline != null) deadline.cancel(false);
-            result.complete(new Result(profile, externalEndpoints, extraRoutes));
-        }
-    }
-}

src/org/kne/cloud/network/klalb/ui/KLALBStateGUI3.java

@@ -7,7 +7,6 @@ import java.io.IOException;
 import java.net.*;
 import java.util.ArrayList;
 import java.util.List;
-import java.util.Objects;
 import java.util.Timer;
 import java.util.TimerTask;
 import java.util.function.Consumer;
@@ -1064,17 +1063,6 @@ public class KLALBStateGUI3 extends XFrame {
         for (KLALBConfigItem item : config) {
             if (item instanceof KLALBControllerConfigItem) {
                 KLALBControllerConfigItem kck = (KLALBControllerConfigItem) item;
-                String oldDeviceName = kck.getDeviceName();
-                String oldDeviceDescription = kck.getDeviceDescription();
-                List<MultiProtocolSocketAddress> oldExternalEndpoints = kck.getExternalEndpoints() == null
-                        ? null
-                        : new ArrayList<MultiProtocolSocketAddress>(kck.getExternalEndpoints());
-                List<String> oldExtraRoutes = kck.getExtraRoutes() == null
-                        ? null : new ArrayList<String>(kck.getExtraRoutes());
-                String newDeviceName;
-                String newDeviceDescription;
-                List<String> newExtraRoutes;
-                List<MultiProtocolSocketAddress> newExternalEndpoints;
                 
                 // 保存语言设置
                 kck.setLanguage(((Language) comboLang.getSelectedItem()).name());
@@ -1084,16 +1072,20 @@ public class KLALBStateGUI3 extends XFrame {
                 // 保存设备名称
                 String dnametext = deviceNameSet.getText().trim();
                 if (dnametext.equals("")) {
-                    newDeviceName = null;
+                    kck.setDeviceName(null);
                 } else {
-                    newDeviceName = dnametext;
+                    kck.setDeviceName(dnametext);
                 }
+                if (kcontroller != null && kcontroller.getIpv6Router() != null) {
+                    kcontroller.getIpv6Router().setDeviceName(kck.getDeviceName());
+                }
+                
                 // 保存设备描述
                 String ddesctext = deviceDescriptionSet.getText().trim();
                 if (ddesctext.equals("")) {
-                    newDeviceDescription = null;
+                    kck.setDeviceDescription(null);
                 } else {
-                    newDeviceDescription = ddesctext;
+                    kck.setDeviceDescription(ddesctext);
                 }
                 
                 
@@ -1149,7 +1141,7 @@ public class KLALBStateGUI3 extends XFrame {
                         }
                     }
                 }
-                newExtraRoutes = eroutes;
+                kck.setExtraRoutes(eroutes);
                 
                 // 保存ASN
                 String asntext = asnFieldSet.getText();
@@ -1240,7 +1232,7 @@ public class KLALBStateGUI3 extends XFrame {
                         }
                     }
                 }
-                newExternalEndpoints = iaddr1;
+                kck.setExternalEndpoints(iaddr1);
                 
                 // 保存自动连接线路表
                 String[] splt11 = connectLineTabelSet.getText().split("\n");
@@ -1313,22 +1305,6 @@ public class KLALBStateGUI3 extends XFrame {
                 kck.setNagleDelayTime(nagleDelayTime.getSlider().getValue()*100000L);
                 
                 kck.setLinkNagleDelayTime(linkNagleDelayTime.getSlider().getValue()*100000L);
-
-                boolean deviceNameChanged = !Objects.equals(oldDeviceName, newDeviceName);
-                boolean deviceDescriptionChanged = !Objects.equals(oldDeviceDescription, newDeviceDescription);
-                boolean externalEndpointsChanged = !Objects.equals(oldExternalEndpoints, newExternalEndpoints);
-                boolean extraRoutesChanged = !Objects.equals(oldExtraRoutes, newExtraRoutes);
-                if (deviceNameChanged || deviceDescriptionChanged || externalEndpointsChanged || extraRoutesChanged) {
-                    if (kcontroller != null) {
-                        kcontroller.publishNodeInfo(newDeviceName, newDeviceDescription, newExternalEndpoints,
-                                newExtraRoutes);
-                    } else {
-                        kck.setDeviceName(newDeviceName);
-                        kck.setDeviceDescription(newDeviceDescription);
-                        kck.setExternalEndpoints(newExternalEndpoints);
-                        kck.setExtraRoutes(newExtraRoutes);
-                    }
-                }
             }
         }
         
@@ -1430,19 +1406,17 @@ public class KLALBStateGUI3 extends XFrame {
         tsk5 = new TimerTask() {
             @Override
             public void run() {
-                SwingUtilities.invokeLater(() -> {
+                if (isVisible()) {
-                    if (isVisible()) {
+                    graph.loadNodes();
-                        graph.loadNodes();
+                    for (int i = 0; i < 100; i++) {
-                        for (int i = 0; i < 100; i++) {
+                        graph.runPhy();
-                            graph.runPhy();
-                        }
-                        graph.repaint();
-                        graph.revalidate();
                     }
-                });
+                    graph.repaint();
+                    graph.revalidate();
+                }
             }
         };
-        t.scheduleAtFixedRate(tsk5, 0, 1000);
+        t.scheduleAtFixedRate(tsk5, 1000, 1000);
     }
 
     /**
@@ -1788,15 +1762,6 @@ public class KLALBStateGUI3 extends XFrame {
      * 关闭窗口并清理资源
      */
     public void close() {
-        for (int i = 0; i < tabbedPane.getTabCount(); i++) {
-            Component component = tabbedPane.getComponentAt(i);
-            if (component instanceof NodeInformationPanel) {
-                ((NodeInformationPanel) component).close();
-            }
-        }
-        if (graph != null) {
-            graph.close();
-        }
         setVisible(false);
         if (tsk != null) {
             tsk.cancel();

src/org/kne/cloud/network/klalb/ui/NetworkGraphPanel.java

@@ -8,58 +8,28 @@ import java.awt.event.ActionEvent;
 import java.awt.event.ActionListener;
 import java.awt.event.MouseEvent;
 import java.awt.event.MouseListener;
-import java.io.IOException;
-import java.net.InetSocketAddress;
-import java.util.HashMap;
 import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
 import java.util.Set;
-import java.util.function.BiConsumer;
 
 import javax.swing.JMenuItem;
 import javax.swing.JPopupMenu;
-import javax.swing.SwingUtilities;
 
 import org.kne.cloud.network.MultiProtocolSocketAddress;
 import org.kne.cloud.network.ipv6.IPv6Address;
 import org.kne.cloud.network.klalb.KLALBController;
-import org.kne.cloud.network.srv6.KLALBRoutingProtocol;
-import org.kne.cloud.network.srv6.KLALBRoutingProtocolAPIClient;
 import org.kne.cloud.network.srv6.KLALBRoutingProtocol.LinkDirection;
-import org.kne.cloud.network.srv6.NodeProfile;
-import org.kne.cloud.network.srv6.RouterInfoPacket;
 
 public class NetworkGraphPanel extends GraphPanel {
 	private KLALBController controller;
 	private KLALBStateGUI3 klbgui;
-	private final KLALBRoutingProtocolAPIClient nodeInfoClient;
-	private final KLALBRoutingProtocol nodeInfoRoutingProtocol;
-	private final BiConsumer<IPv6Address, Integer> nodeInfoUpdateListener;
-	private final Object nodeInfoLock = new Object();
-	private final Map<IPv6Address, String> nodeNameCache = new HashMap<IPv6Address, String>();
-	private final Map<IPv6Address, Long> nodeNameCacheTimes = new HashMap<IPv6Address, Long>();
-	private final Map<IPv6Address, Long> nodeInfoRequestTimes = new HashMap<IPv6Address, Long>();
-	private final Map<IPv6Address, Long> nodeInfoRequestGenerations = new HashMap<IPv6Address, Long>();
-	private static final long NODE_INFO_REQUEST_TIMEOUT = 3000L;
-	private static final long NODE_INFO_CACHE_TTL = 60000L;
-	private long nextNodeInfoRequestGeneration;
-	private volatile boolean nodeInfoClosed;
 	
 	public NetworkGraphPanel(KLALBController controller,KLALBStateGUI3 klbgui) {
 		super();
 		this.controller = controller;
 		this.klbgui=klbgui;
-		this.nodeInfoRoutingProtocol = controller.getIpv6Router().getKlalbRouteProtol();
-		this.nodeInfoClient = new KLALBRoutingProtocolAPIClient(nodeInfoRoutingProtocol);
-		this.nodeInfoUpdateListener = (address, flags) -> {
-			if ((flags & RouterInfoPacket.NODE_INFO_TINY_UPDATE_REQUIRED) != 0) {
-				SwingUtilities.invokeLater(() -> invalidateTinyNodeInfo(address));
-			}
-		};
-		nodeInfoRoutingProtocol.addNodeInfoUpdateListener(nodeInfoUpdateListener);
-		cacheLocalNodeName();
 	}
 	
 	public NetworkGraphPanel(KLALBController kc) {
@@ -183,145 +153,17 @@ public class NetworkGraphPanel extends GraphPanel {
 	}
 
 	/**
-	 * 节点标签：显示 Tiny API 查询的设备名称（若有）+IP地址
+	 * 节点标签：显示广播得知的设备名称（若有）+IP地址
 	 */
 	private String getNodeText(IPv6Address address) {
 		StringBuilder sb=new StringBuilder();
-		String dname;
+		String dname=controller.getIpv6Router().getKlalbRouteProtol().getDeviceName(address);
-		synchronized (nodeInfoLock) {
+		if(dname!=null)
-			dname = nodeNameCache.get(address);
-		}
-		if(dname!=null&&!dname.isEmpty())
 			sb.append(dname).append('\n');
 		sb.append(InetGraphNode.getText(address));
 		return sb.toString();
 	}
 
-	private void cacheLocalNodeName() {
-		IPv6Address localAddress = controller.getIpv6Router().getLocator().getAddress();
-		synchronized (nodeInfoLock) {
-			nodeNameCache.put(localAddress, controller.getIpv6Router().getDeviceName());
-			nodeNameCacheTimes.put(localAddress, System.currentTimeMillis());
-		}
-	}
-
-	private void requestNodeProfile(final IPv6Address address) {
-		final long requestTime = System.currentTimeMillis();
-		final long requestGeneration;
-		synchronized (nodeInfoLock) {
-			if (nodeInfoClosed)
-				return;
-			Long cachedAt = nodeNameCacheTimes.get(address);
-			if (nodeNameCache.containsKey(address) && cachedAt != null
-					&& requestTime - cachedAt < NODE_INFO_CACHE_TTL)
-				return;
-			nodeNameCache.remove(address);
-			nodeNameCacheTimes.remove(address);
-			Long previousRequestTime = nodeInfoRequestTimes.get(address);
-			if (previousRequestTime != null && requestTime - previousRequestTime < NODE_INFO_REQUEST_TIMEOUT)
-				return;
-			nodeInfoRequestTimes.put(address, requestTime);
-			requestGeneration = ++nextNodeInfoRequestGeneration;
-			nodeInfoRequestGenerations.put(address, requestGeneration);
-		}
-		try {
-			nodeInfoClient.requestNodeProfile(
-					new InetSocketAddress(address.toInet6Address(), KLALBRoutingProtocol.DEFAULT_PORT),
-					(profile) -> SwingUtilities.invokeLater(() -> handleNodeProfile(address, requestGeneration, profile)));
-		} catch (IOException e) {
-			synchronized (nodeInfoLock) {
-				if (nodeInfoRequestGenerations.get(address) != null
-						&& nodeInfoRequestGenerations.get(address).longValue() == requestGeneration) {
-					nodeInfoRequestTimes.remove(address);
-					nodeInfoRequestGenerations.remove(address);
-				}
-			}
-		}
-	}
-
-	private void handleNodeProfile(IPv6Address address, long requestGeneration, NodeProfile profile) {
-		if (nodeInfoClosed)
-			return;
-		boolean currentRequest;
-		boolean nodeExists = getNodes().containsKey(address);
-		String deviceName = profile == null ? "" : profile.getDeviceName();
-		if (deviceName == null || deviceName.isEmpty())
-			deviceName = "";
-		synchronized (nodeInfoLock) {
-			if (nodeInfoClosed)
-				return;
-			Long activeRequestGeneration = nodeInfoRequestGenerations.get(address);
-			currentRequest = activeRequestGeneration != null
-					&& activeRequestGeneration.longValue() == requestGeneration;
-			if (currentRequest) {
-				nodeInfoRequestTimes.remove(address);
-				nodeInfoRequestGenerations.remove(address);
-				if (nodeExists)
-					nodeNameCache.put(address, deviceName);
-				else
-					nodeNameCache.remove(address);
-				if (nodeExists)
-					nodeNameCacheTimes.put(address, System.currentTimeMillis());
-				else
-					nodeNameCacheTimes.remove(address);
-			}
-		}
-		if (currentRequest && nodeExists) {
-			((InetGraphNode) getNodes().get(address)).updateLabel();
-			repaint();
-		}
-	}
-
-	private void removeNodeInfoState(IPv6Address address) {
-		synchronized (nodeInfoLock) {
-			nodeNameCache.remove(address);
-			nodeNameCacheTimes.remove(address);
-			nodeInfoRequestTimes.remove(address);
-			nodeInfoRequestGenerations.remove(address);
-		}
-	}
-
-	private void invalidateTinyNodeInfo(IPv6Address address) {
-		synchronized (nodeInfoLock) {
-			if (nodeInfoClosed)
-				return;
-			nodeNameCache.remove(address);
-			nodeNameCacheTimes.remove(address);
-			nodeInfoRequestTimes.remove(address);
-			nodeInfoRequestGenerations.remove(address);
-		}
-		InetGraphNode node = (InetGraphNode) getNodes().get(address);
-		if (node != null) {
-			node.updateLabel();
-		}
-		repaint();
-		requestNodeProfile(address);
-	}
-
-	public void close() {
-		synchronized (nodeInfoLock) {
-			if (nodeInfoClosed)
-				return;
-			nodeInfoClosed = true;
-			nodeNameCache.clear();
-			nodeNameCacheTimes.clear();
-			nodeInfoRequestTimes.clear();
-			nodeInfoRequestGenerations.clear();
-		}
-		nodeInfoRoutingProtocol.removeNodeInfoUpdateListener(nodeInfoUpdateListener);
-		nodeInfoClient.close();
-	}
-
-	@Override
-	public void removeNotify() {
-		super.removeNotify();
-		SwingUtilities.invokeLater(() -> {
-			if (!isDisplayable() && getParent() == null) {
-				close();
-			}
-		});
-	}
-
 	private double nsPerPixel=5000L;
 	private class InetGraphEdgeGroup extends GraphEdgeGroup{
 		public InetGraphEdgeGroup(GraphNode nodeA, GraphNode nodeB) {
@@ -339,8 +181,6 @@ public class NetworkGraphPanel extends GraphPanel {
 	}
 	protected void loadNodes() {
 		Map<IPv6Address, Long> addr= controller.getIpv6Router().getKlalbRouteProtol().getAddresses();
-		IPv6Address localAddress = controller.getIpv6Router().getLocator().getAddress();
-		cacheLocalNodeName();
 		Set<IPv6Address> ks=addr.keySet();
 		for (Iterator<IPv6Address> iterator = ks.iterator(); iterator.hasNext();) {
 			IPv6Address inet6Address = (IPv6Address) iterator.next();
@@ -348,15 +188,12 @@ public class NetworkGraphPanel extends GraphPanel {
 				Vector2 v2pos=super.getRandomPos();
 				getNodes().put(inet6Address,new InetGraphNode(inet6Address,Color.BLACK,v2pos.x,v2pos.y,inet6Address.equals(controller.getIpv6Router().getLocator().getAddress())));
 			}
-			if(!inet6Address.equals(localAddress))
-				requestNodeProfile(inet6Address);
 			}
 		Set<IPv6Address> kns=getNodes().keySet();
 		for (Iterator<IPv6Address> iterator = kns.iterator(); iterator.hasNext();) {
 			IPv6Address inet6Address = (IPv6Address) iterator.next();
 			if(!addr.containsKey(inet6Address)) {
 				iterator.remove();
-				removeNodeInfoState(inet6Address);
 			}else {
 				((InetGraphNode)getNodes().get(inet6Address)).updateLabel();
 			}

src/org/kne/cloud/network/klalb/ui/NodeInformationPanel.java

@@ -4,8 +4,8 @@ import java.awt.BorderLayout;
 import java.awt.Image;
 import java.awt.Toolkit;
 import java.awt.datatransfer.StringSelection;
+import java.io.IOException;
 import java.net.InetSocketAddress;
-import java.util.Collections;
 import java.util.List;
 
 import javax.swing.Icon;
@@ -24,11 +24,8 @@ import org.kne.cloud.klalb.uitool.XDefaultListModel;
 import org.kne.cloud.network.MultiProtocolSocketAddress;
 import org.kne.cloud.network.ipv6.IPv6Address;
 import org.kne.cloud.network.klalb.KLALBController;
-import org.kne.cloud.network.klalb.NodeInfoQueryCoordinator;
 import org.kne.cloud.network.srv6.KLALBRoutingProtocol;
 import org.kne.cloud.network.srv6.KLALBRoutingProtocolAPIClient;
-import org.kne.cloud.network.srv6.NodeInfoQueryStatus;
-import org.kne.cloud.network.srv6.NodeProfile;
 import javax.swing.JTabbedPane;
 import javax.swing.JList;
 import javax.swing.JMenuItem;
@@ -37,20 +34,14 @@ import java.awt.event.ActionListener;
 import java.awt.event.MouseEvent;
 import java.awt.event.MouseListener;
 import java.awt.event.ActionEvent;
-import java.util.concurrent.atomic.AtomicLong;
 
 public class NodeInformationPanel extends JPanel {
 	private IPv6Address address;
 	private KLALBRoutingProtocolAPIClient client;
-	private NodeInfoQueryCoordinator queryCoordinator;
 	private KLALBController controller;
 	private Image image;
 	
 	private XDefaultListModel<MultiProtocolSocketAddress> listModel=new XDefaultListModel<>();
-	private XDefaultListModel<String> extraRoutesModel=new XDefaultListModel<>();
-	private volatile boolean active=true;
-	private final AtomicLong fullInfoGeneration=new AtomicLong();
-	private final java.util.function.BiConsumer<IPv6Address,Integer> nodeInfoUpdateListener;
 	public KLALBController getController() {
 		return controller;
 	}
@@ -82,21 +73,17 @@ public class NodeInformationPanel extends JPanel {
 		overviewArea.setWrapStyleWord(true);
 		overviewArea.setFont(UIEnv.getFont().deriveFont(14.0f));
 		overviewArea.setBorder(BorderFactory.createEmptyBorder(8, 8, 8, 8));
-		overviewArea.setText(buildOverviewText(null, null));
+		String dname=controller.getIpv6Router().getKlalbRouteProtol().getDeviceName(address);
+		String ddesc=null;
+		if(address.equals(controller.getIpv6Router().getLocator().getAddress())&&controller.getConfigItem()!=null) {
+			ddesc=controller.getConfigItem().getDeviceDescription();
+			if(ddesc!=null&&ddesc.isEmpty()) {
+				ddesc=null;
+			}
+		}
+		overviewArea.setText(buildOverviewText(dname, ddesc));
 		panel.add(new JScrollPane(overviewArea), BorderLayout.CENTER);
 		
-		JPanel extraRoutesPanel = new JPanel(new BorderLayout());
-		JList<String> extraRoutesList = new JList<String>(extraRoutesModel);
-		extraRoutesList.setSelectionMode(ListSelectionModel.SINGLE_SELECTION);
-		extraRoutesList.setFont(UIEnv.getFont().deriveFont(14.0f));
-		extraRoutesPanel.add(new JScrollPane(extraRoutesList), BorderLayout.CENTER);
-		javax.swing.JLabel extraRoutesEmptyLabel=new javax.swing.JLabel(UIEnv.getRsb().getString("noextraroutes"));
-		extraRoutesEmptyLabel.setText("...");
-		extraRoutesEmptyLabel.setBorder(BorderFactory.createEmptyBorder(8, 8, 8, 8));
-		extraRoutesEmptyLabel.setHorizontalAlignment(javax.swing.SwingConstants.CENTER);
-		extraRoutesPanel.add(extraRoutesEmptyLabel, BorderLayout.SOUTH);
-		tabbedPane.addTab(UIEnv.getRsb().getString("extraroutes"), null, extraRoutesPanel, null);
-		
 		JPanel panel_1 = new JPanel();
 		panel_1.setLayout(new BorderLayout(0, 0));
 		panel_1.add(scrollPane);
@@ -176,111 +163,29 @@ public class NodeInformationPanel extends JPanel {
 		
 		panel_1.add(btnNewButton, BorderLayout.SOUTH);
 		
-		KLALBRoutingProtocol routingProtocol=controller.getIpv6Router().getKlalbRouteProtol();
+		client=new KLALBRoutingProtocolAPIClient(controller.getIpv6Router().getKlalbRouteProtol());
-		client=new KLALBRoutingProtocolAPIClient(routingProtocol);
-		queryCoordinator=new NodeInfoQueryCoordinator(client);
-		nodeInfoUpdateListener=(updatedAddress, flags) -> {
-			if(active && address.equals(updatedAddress)
-					&& (flags & org.kne.cloud.network.srv6.RouterInfoPacket.NODE_INFO_FULL_UPDATE_REQUIRED) != 0) {
-				requestFullInfo(overviewArea, extraRoutesEmptyLabel);
-			}
-		};
-		routingProtocol.addNodeInfoUpdateListener(nodeInfoUpdateListener);
-		requestFullInfo(overviewArea, extraRoutesEmptyLabel);
-	}
-
-	private void requestFullInfo(JTextArea overviewArea, javax.swing.JLabel extraRoutesEmptyLabel) {
-		final long generation=fullInfoGeneration.incrementAndGet();
-		if (controller.getIpv6Router().getLocator().getAddress().equals(address)) {
-			KLALBController.PublishedNodeInfo published=controller.getPublishedNodeInfo();
-			applyNodeInfo(overviewArea, extraRoutesEmptyLabel, published.getDeviceName(),
-					published.getDeviceDescription(), published.getExternalEndpoints(), published.getExtraRoutes());
-			return;
-		}
 		try {
-			queryCoordinator.query(new InetSocketAddress(address.toInet6Address(), KLALBRoutingProtocol.DEFAULT_PORT)).whenComplete((info, error)->{
+			client.requestNodeInfoFull(new InetSocketAddress( address.toInet6Address(), KLALBRoutingProtocol.DEFAULT_PORT), (info)->{
-				if(!active || generation!=fullInfoGeneration.get()) return;
+				listModel.clear();
-				javax.swing.SwingUtilities.invokeLater(() -> {
+				for (MultiProtocolSocketAddress multiProtocolSocketAddress : info.getOpenLines()) {
-					if(!active || generation!=fullInfoGeneration.get()) return;
+					listModel.addElement(multiProtocolSocketAddress);
-					if (error != null || info == null) {
+				}
-						return;
+				// 用对端返回的设备名称/描述更新概览（旧版本节点无该字段时保留原显示）
-					}
+				String dn=info.getDeviceName();
-					applyRemoteNodeInfo(overviewArea, extraRoutesEmptyLabel, info);
+				if(dn==null||dn.isEmpty()) {
-				});
+					dn=controller.getIpv6Router().getKlalbRouteProtol().getDeviceName(address);
+				}
+				String dd=info.getDeviceDescription();
+				if(dd!=null&&dd.isEmpty()) {
+					dd=null;
+				}
+				overviewArea.setText(buildOverviewText(dn, dd));
 			});
-		} catch (RuntimeException e) {
+		} catch (IOException e) {
-			if(active) e.printStackTrace();
+			e.printStackTrace();
 		}
 	}
 
-	private void applyNodeInfo(JTextArea overviewArea, javax.swing.JLabel extraRoutesEmptyLabel,
-			String deviceName, String deviceDescription, List<MultiProtocolSocketAddress> endpoints,
-			List<String> routes) {
-		applyProfile(overviewArea, deviceName, deviceDescription);
-		applyEndpoints(endpoints == null ? Collections.<MultiProtocolSocketAddress>emptyList() : endpoints);
-		applyRoutes(extraRoutesEmptyLabel, routes == null ? Collections.<String>emptyList() : routes);
-	}
-
-	private void applyRemoteNodeInfo(JTextArea overviewArea, javax.swing.JLabel extraRoutesEmptyLabel,
-			NodeInfoQueryCoordinator.Result info) {
-		if (info.getProfile().isReceived()) {
-			NodeProfile profile=info.getProfile().getValue().orElse(null);
-			applyProfile(overviewArea, profile == null ? null : profile.getDeviceName(),
-					profile == null ? null : profile.getDeviceDescription());
-		}
-
-		if (info.getExternalEndpoints().isReceived()) {
-			List<MultiProtocolSocketAddress> endpoints=info.getExternalEndpoints().getStatus()
-					.filter(NodeInfoQueryStatus.OK::equals).isPresent()
-					? info.getExternalEndpoints().getValue().orElse(Collections.<MultiProtocolSocketAddress>emptyList())
-					: Collections.<MultiProtocolSocketAddress>emptyList();
-			applyEndpoints(endpoints);
-		}
-
-		if (info.getExtraRoutes().isReceived()) {
-			List<String> routes=info.getExtraRoutes().getStatus().filter(NodeInfoQueryStatus.OK::equals).isPresent()
-					? info.getExtraRoutes().getValue().orElse(Collections.<String>emptyList())
-					: Collections.<String>emptyList();
-			applyRoutes(extraRoutesEmptyLabel, routes);
-		}
-}
-
-	private void applyProfile(JTextArea overviewArea, String deviceName, String deviceDescription) {
-	overviewArea.setText(buildOverviewText(deviceName,
-				deviceDescription == null || deviceDescription.isEmpty() ? null : deviceDescription));
-}
-
-	private void applyEndpoints(List<MultiProtocolSocketAddress> endpoints) {
-		listModel.clear();
-		if (endpoints != null) for (MultiProtocolSocketAddress item : endpoints) listModel.addElement(item);
-	}
-
-	private void applyRoutes(javax.swing.JLabel extraRoutesEmptyLabel, List<String> routes) {
-		extraRoutesModel.clear();
-		if (routes != null) for (String route : routes) extraRoutesModel.addElement(route);
-		extraRoutesEmptyLabel.setText(UIEnv.getRsb().getString("noextraroutes"));
-		extraRoutesEmptyLabel.setVisible(extraRoutesModel.isEmpty());
-	}
-
-	public synchronized void close() {
-		if (!active)
-			return;
-		active=false;
-		fullInfoGeneration.incrementAndGet();
-		KLALBRoutingProtocol routingProtocol=controller.getIpv6Router().getKlalbRouteProtol();
-		routingProtocol.removeNodeInfoUpdateListener(nodeInfoUpdateListener);
-		if(client!=null) {
-			client.close();
-			client=null;
-		}
-	}
-
-	@Override
-	public void removeNotify() {
-		close();
-		super.removeNotify();
-	}
-
 	private String buildOverviewText(String dname,String ddesc) {
 		StringBuilder sb=new StringBuilder();
 		sb.append(UIEnv.getRsb().getString("ipv6addr")).append(": ").append(address.toCompressedString()).append('\n');

src/org/kne/cloud/network/klalb/web/KLALBWebServer.java

@@ -7,7 +7,6 @@ import java.nio.file.*;
 import java.util.*;
 import java.util.concurrent.*;
 import java.util.concurrent.atomic.AtomicBoolean;
-import java.util.function.BiConsumer;
 
 import com.sun.net.httpserver.*;
 import com.google.gson.*;
@@ -20,14 +19,12 @@ import org.kne.cloud.network.ipv6.IPv6NetworkLink;
 import org.kne.cloud.network.ipv6.RouteItem;
 import org.kne.cloud.network.klalb.*;
 import org.kne.cloud.network.monitor.LinkStatus;
+import org.kne.cloud.network.srv6.KLALBNodeInformation;
 import org.kne.cloud.network.srv6.KLALBRoutingProtocol;
 import org.kne.cloud.network.srv6.KLALBRoutingProtocol.LinkDirection;
 import org.kne.cloud.network.srv6.KLALBRoutingProtocolAPIClient;
-import org.kne.cloud.network.srv6.NodeInfoQueryStatus;
-import org.kne.cloud.network.srv6.NodeProfile;
 import org.kne.cloud.network.srv6.NeighborInfo;
 import org.kne.cloud.network.srv6.RouterInfo;
-import org.kne.cloud.network.srv6.RouterInfoPacket;
 import org.kne.cloud.network.srv6.SRv6Router;
 
 /**
@@ -38,12 +35,14 @@ public class KLALBWebServer {
 	private final KLALBProxySystem proxySystem;
 	private final MultiProtocolSocketAddress listen;
 	private HttpServer server;
-	private ExecutorService httpExecutor;
 	private final Gson gson;
-	private ScheduledExecutorService sseExecutor = createSseExecutor();
+	private final ScheduledExecutorService sseExecutor = Executors.newSingleThreadScheduledExecutor(r -> {
+		Thread t = new Thread(r, "KLALB-Web-SSE");
+		t.setDaemon(true);
+		return t;
+	});
 	private final Set<HttpExchange> sseClients = Collections.newSetFromMap(new ConcurrentHashMap<>());
 	private final AtomicBoolean running = new AtomicBoolean(false);
-	private final Object configUpdateLock = new Object();
 
 	public KLALBWebServer(KLALBProxySystem proxySystem, int port) {
 		this(proxySystem, new MultiProtocolSocketAddress("http", "0.0.0.0", port));
@@ -53,36 +52,15 @@ public class KLALBWebServer {
 		this.proxySystem = proxySystem;
 		this.listen = listen;
 		this.gson = proxySystem.getGson();
-		this.nodeInfoUpdateListener = (address, flags) -> {
-			if ((flags & RouterInfoPacket.NODE_INFO_FULL_UPDATE_REQUIRED) != 0) {
-				nodeInfoRevisions.merge(address, 1L, Long::sum);
-			}
-			if ((flags & RouterInfoPacket.NODE_INFO_TINY_UPDATE_REQUIRED) != 0) {
-				long lifecycleGeneration;
-				synchronized (this) {
-					lifecycleGeneration = nodeInfoLifecycleGeneration;
-				}
-				invalidateTinyDeviceName(address);
-				KLALBController kc = this.proxySystem.getKlalbController();
-				if (kc != null && kc.getIpv6Router() != null
-						&& kc.getIpv6Router().getKlalbRouteProtol() != null) {
-					refreshTinyDeviceNameAsync(kc, address, lifecycleGeneration);
-				}
-			}
-		};
 	}
 
 	public synchronized void start() throws IOException {
 		if (running.get()) return;
-		if (sseExecutor == null || sseExecutor.isShutdown()) {
-			sseExecutor = createSseExecutor();
-		}
 
 		InetSocketAddress socketAddress = "0.0.0.0".equals(listen.getHost())
 				? new InetSocketAddress(listen.getPort()) : listen.getSocketAddress();
 		server = HttpServer.create(socketAddress, 0);
-		ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor();
+		server.setExecutor(Executors.newVirtualThreadPerTaskExecutor());
-		server.setExecutor(executor);
 
 		// API Contexts
 		server.createContext("/api/status", this::handleStatus);
@@ -98,13 +76,7 @@ public class KLALBWebServer {
 		// Static Files / SPA Fallback Handler
 		server.createContext("/", this::handleStatic);
 
-		try {
+		server.start();
-			server.start();
-			httpExecutor = executor;
-		} catch (RuntimeException e) {
-			executor.shutdownNow();
-			throw e;
-		}
 		running.set(true);
 		startSseBroadcaster();
 
@@ -112,11 +84,7 @@ public class KLALBWebServer {
 	}
 
 	public synchronized void stop() {
-		if (!running.get()) {
+		if (!running.get()) return;
-			closeHttpExecutor();
-			closeNodeInfoClient();
-			return;
-		}
 		running.set(false);
 		sseExecutor.shutdownNow();
 		for (HttpExchange client : sseClients) {
@@ -129,18 +97,9 @@ public class KLALBWebServer {
 			server.stop(1);
 			server = null;
 		}
-		closeHttpExecutor();
-		closeNodeInfoClient();
 		System.out.println("KLALB Web Dashboard stopped.");
 	}
 
-	private void closeHttpExecutor() {
-		if (httpExecutor != null) {
-			httpExecutor.shutdownNow();
-			httpExecutor = null;
-		}
-	}
-
 	public boolean isRunning() {
 		return running.get();
 	}
@@ -497,159 +456,14 @@ public class KLALBWebServer {
 	}
 
 	private KLALBRoutingProtocolAPIClient nodeInfoClient;
-	private static final long TINY_NAME_REQUEST_TIMEOUT_MS = 3000L;
-	private final ConcurrentMap<IPv6Address, String> tinyDeviceNameCache = new ConcurrentHashMap<>();
-	private final ConcurrentMap<IPv6Address, Long> tinyDeviceNameCacheTimes = new ConcurrentHashMap<>();
-	private final Set<IPv6Address> tinyNameRequestsInFlight = ConcurrentHashMap.newKeySet();
-	private final ConcurrentMap<IPv6Address, Long> tinyNameRequestTimes = new ConcurrentHashMap<>();
-	private final ConcurrentMap<IPv6Address, Long> tinyNameRequestGenerations = new ConcurrentHashMap<>();
-	private final ConcurrentMap<IPv6Address, Long> nodeInfoRevisions = new ConcurrentHashMap<>();
-	private final Object tinyNameStateLock = new Object();
-	private static final long TINY_NAME_CACHE_TTL_MS = 60000L;
-	private long nextTinyNameRequestGeneration;
-	private KLALBRoutingProtocol nodeInfoRoutingProtocol;
-	private final BiConsumer<IPv6Address, Integer> nodeInfoUpdateListener;
-	private long nodeInfoLifecycleGeneration;
-
-	private static ScheduledExecutorService createSseExecutor() {
-		return Executors.newSingleThreadScheduledExecutor(r -> {
-			Thread t = new Thread(r, "KLALB-Web-SSE");
-			t.setDaemon(true);
-			return t;
-		});
-	}
 
 	private synchronized KLALBRoutingProtocolAPIClient getNodeInfoClient(KLALBController kc) {
-		return getNodeInfoClient(kc, -1L);
-	}
-
-	private synchronized KLALBRoutingProtocolAPIClient getNodeInfoClient(KLALBController kc,
-			long expectedLifecycleGeneration) {
-		if (!running.get() || (expectedLifecycleGeneration >= 0
-				&& expectedLifecycleGeneration != nodeInfoLifecycleGeneration)
-				|| kc == null || kc.getIpv6Router() == null
-				|| kc.getIpv6Router().getKlalbRouteProtol() == null) {
-			return null;
-		}
 		if (nodeInfoClient == null) {
-			nodeInfoRoutingProtocol = kc.getIpv6Router().getKlalbRouteProtol();
+			nodeInfoClient = new KLALBRoutingProtocolAPIClient(kc.getIpv6Router().getKlalbRouteProtol());
-			nodeInfoClient = new KLALBRoutingProtocolAPIClient(nodeInfoRoutingProtocol);
-			nodeInfoRoutingProtocol.addNodeInfoUpdateListener(nodeInfoUpdateListener);
 		}
 		return nodeInfoClient;
 	}
 
-	private synchronized void closeNodeInfoClient() {
-		nodeInfoLifecycleGeneration++;
-		if (nodeInfoRoutingProtocol != null) {
-			nodeInfoRoutingProtocol.removeNodeInfoUpdateListener(nodeInfoUpdateListener);
-			nodeInfoRoutingProtocol = null;
-		}
-		if (nodeInfoClient != null) {
-			nodeInfoClient.close();
-			nodeInfoClient = null;
-		}
-		synchronized (tinyNameStateLock) {
-			tinyDeviceNameCache.clear();
-			tinyDeviceNameCacheTimes.clear();
-			tinyNameRequestsInFlight.clear();
-			tinyNameRequestTimes.clear();
-			tinyNameRequestGenerations.clear();
-		}
-	}
-
-	private String getTinyDeviceName(KLALBController kc, IPv6Address addr) {
-		return getTinyDeviceName(kc, addr, -1L);
-	}
-
-	private String getTinyDeviceName(KLALBController kc, IPv6Address addr, long lifecycleGeneration) {
-		String cachedName;
-		long requestStartedAt = 0L;
-		long requestGeneration;
-		synchronized (tinyNameStateLock) {
-			cachedName = tinyDeviceNameCache.get(addr);
-			Long cachedAt = tinyDeviceNameCacheTimes.get(addr);
-			long now = System.currentTimeMillis();
-			if (cachedName != null && cachedAt != null && now - cachedAt < TINY_NAME_CACHE_TTL_MS) return cachedName;
-			tinyDeviceNameCache.remove(addr);
-			tinyDeviceNameCacheTimes.remove(addr);
-
-			if (tinyNameRequestsInFlight.contains(addr)) {
-				Long requestedAt = tinyNameRequestTimes.get(addr);
-				if (requestedAt != null && now - requestedAt < TINY_NAME_REQUEST_TIMEOUT_MS) {
-					return "";
-				}
-				tinyNameRequestsInFlight.remove(addr);
-				tinyNameRequestTimes.remove(addr);
-			}
-
-			if (!tinyNameRequestsInFlight.add(addr)) return "";
-			requestStartedAt = now;
-			tinyNameRequestTimes.put(addr, requestStartedAt);
-			requestGeneration = ++nextTinyNameRequestGeneration;
-			tinyNameRequestGenerations.put(addr, requestGeneration);
-		}
-
-		final long requestGenerationToken = requestGeneration;
-		try {
-			KLALBRoutingProtocolAPIClient client = lifecycleGeneration < 0
-					? getNodeInfoClient(kc) : getNodeInfoClient(kc, lifecycleGeneration);
-			if (client == null) {
-				synchronized (tinyNameStateLock) {
-					if (Long.valueOf(requestGenerationToken).equals(tinyNameRequestGenerations.get(addr))) {
-						tinyNameRequestsInFlight.remove(addr);
-						tinyNameRequestTimes.remove(addr);
-						tinyNameRequestGenerations.remove(addr);
-					}
-				}
-				return "";
-			}
-			client.requestNodeProfile(
-					new InetSocketAddress(addr.toInet6Address(), KLALBRoutingProtocol.DEFAULT_PORT),
-					profile -> {
-						synchronized (tinyNameStateLock) {
-							Long activeRequestGeneration = tinyNameRequestGenerations.get(addr);
-							if (!Long.valueOf(requestGenerationToken).equals(activeRequestGeneration)) return;
-							tinyDeviceNameCache.put(addr,
-									profile != null && profile.getDeviceName() != null ? profile.getDeviceName() : "");
-							tinyDeviceNameCacheTimes.put(addr, System.currentTimeMillis());
-							tinyNameRequestsInFlight.remove(addr);
-							tinyNameRequestTimes.remove(addr);
-							tinyNameRequestGenerations.remove(addr);
-						}
-					});
-		} catch (IOException e) {
-			synchronized (tinyNameStateLock) {
-				Long activeRequestGeneration = tinyNameRequestGenerations.get(addr);
-				if (Long.valueOf(requestGenerationToken).equals(activeRequestGeneration)) {
-					tinyNameRequestsInFlight.remove(addr);
-					tinyNameRequestTimes.remove(addr);
-					tinyNameRequestGenerations.remove(addr);
-				}
-			}
-		}
-		return "";
-	}
-
-	private void refreshTinyDeviceNameAsync(KLALBController kc, IPv6Address address, long lifecycleGeneration) {
-		CompletableFuture.runAsync(() -> {
-			synchronized (this) {
-				if (!running.get() || nodeInfoLifecycleGeneration != lifecycleGeneration) return;
-				getTinyDeviceName(kc, address, lifecycleGeneration);
-			}
-		});
-	}
-
-	private void invalidateTinyDeviceName(IPv6Address address) {
-		synchronized (tinyNameStateLock) {
-			tinyDeviceNameCache.remove(address);
-			tinyDeviceNameCacheTimes.remove(address);
-			tinyNameRequestsInFlight.remove(address);
-			tinyNameRequestTimes.remove(address);
-			tinyNameRequestGenerations.remove(address);
-		}
-	}
-
 	private void handleNodeInfo(HttpExchange exchange) throws IOException {
 		if (handleCorsPreflight(exchange)) return;
 		if (!"GET".equalsIgnoreCase(exchange.getRequestMethod())) {
@@ -686,70 +500,56 @@ public class KLALBWebServer {
 
 		if (isSelf) {
 			// 本机：描述直接取本地控制器配置
-			KLALBController.PublishedNodeInfo published = kc.getPublishedNodeInfo();
+			KLALBControllerConfigItem cfg = proxySystem.getControllerConfig();
 			resp.addProperty("isSelf", true);
-			resp.addProperty("reachable", true);
+			String dname = router.getDeviceName() != null ? router.getDeviceName()
-			resp.addProperty("deviceName", published.getDeviceName() != null ? published.getDeviceName() : "");
+					: (cfg != null && cfg.getDeviceName() != null ? cfg.getDeviceName() : "");
+			resp.addProperty("deviceName", dname);
 			resp.addProperty("deviceDescription",
-					published.getDeviceDescription() != null ? published.getDeviceDescription() : "");
+					cfg != null && cfg.getDeviceDescription() != null ? cfg.getDeviceDescription() : "");
 			JsonArray lines = new JsonArray();
-			for (MultiProtocolSocketAddress mpsa : published.getExternalEndpoints()) {
+			for (MultiProtocolSocketAddress mpsa : kc.getExternalEndpoints()) {
 				lines.add(new JsonPrimitive(mpsa.toString()));
 			}
 			resp.add("openLines", lines);
-			JsonArray extraRoutes = new JsonArray();
-			if (published.getExtraRoutes() != null) {
-				for (String route : published.getExtraRoutes()) {
-					extraRoutes.add(new JsonPrimitive(route != null ? route : ""));
-				}
-			}
-			resp.add("extraRoutes", extraRoutes);
 			sendJsonResponse(exchange, 200, resp);
 			return;
 		}
 
 		// 远端节点：经 SRv6 虚拟网络发送完整节点信息查询（异步回调，限时等待）
 		resp.addProperty("isSelf", false);
+		CompletableFuture<KLALBNodeInformation> future = new CompletableFuture<>();
 		try {
-			KLALBRoutingProtocolAPIClient client = getNodeInfoClient(kc);
+			getNodeInfoClient(kc).requestNodeInfoFull(
-			if (client == null) {
+					new InetSocketAddress(target.toInet6Address(), KLALBRoutingProtocol.DEFAULT_PORT),
-				sendError(exchange, 503, "Node info service stopped");
+					info -> future.complete(info));
-				return;
+
+			KLALBNodeInformation info;
+			try {
+				info = future.get(3, TimeUnit.SECONDS);
+			} catch (TimeoutException te) {
+				info = null;
 			}
-			NodeInfoQueryCoordinator.Result info = new NodeInfoQueryCoordinator(client)
+
-					.query(new InetSocketAddress(target.toInet6Address(), KLALBRoutingProtocol.DEFAULT_PORT)).get();
+			String dname = info != null && info.getDeviceName() != null && !info.getDeviceName().isEmpty()
-			NodeInfoQueryCoordinator.Section<NodeProfile> profile = info.getProfile();
+					? info.getDeviceName()
-			NodeProfile nodeProfile = profile.getValue().orElse(null);
+					: router.getKlalbRouteProtol().getDeviceName(target);
-			String dname = nodeProfile != null && nodeProfile.getDeviceName() != null
+			resp.addProperty("deviceName", dname != null ? dname : "");
-					&& !nodeProfile.getDeviceName().isEmpty() ? nodeProfile.getDeviceName() : "";
-			resp.addProperty("deviceName", dname);
 			resp.addProperty("deviceDescription",
-						nodeProfile != null && nodeProfile.getDeviceDescription() != null
+					info != null && info.getDeviceDescription() != null ? info.getDeviceDescription() : "");
-								? nodeProfile.getDeviceDescription() : "");
+			resp.addProperty("reachable", info != null);
-			resp.addProperty("reachable", profile.isReceived()
-					|| info.getExternalEndpoints().isReceived() || info.getExtraRoutes().isReceived());
 			JsonArray lines = new JsonArray();
-			if (info.getExternalEndpoints().getStatus().filter(NodeInfoQueryStatus.OK::equals).isPresent()
+			if (info != null && info.getOpenLines() != null) {
-					&& info.getExternalEndpoints().getValue().isPresent()) {
+				for (MultiProtocolSocketAddress mpsa : info.getOpenLines()) {
-				for (MultiProtocolSocketAddress mpsa : info.getExternalEndpoints().getValue().get()) {
 					lines.add(new JsonPrimitive(mpsa.toString()));
 				}
 			}
 			resp.add("openLines", lines);
-			JsonArray extraRoutes = new JsonArray();
-			if (info.getExtraRoutes().getStatus().filter(NodeInfoQueryStatus.OK::equals).isPresent()
-					&& info.getExtraRoutes().getValue().isPresent()) {
-				for (String route : info.getExtraRoutes().getValue().get()) {
-					extraRoutes.add(new JsonPrimitive(route != null ? route : ""));
-				}
-			}
-			resp.add("extraRoutes", extraRoutes);
 		} catch (Exception e) {
 			resp.addProperty("deviceName", "");
 			resp.addProperty("deviceDescription", "");
 			resp.addProperty("reachable", false);
 			resp.add("openLines", new JsonArray());
-			resp.add("extraRoutes", new JsonArray());
 		}
 		sendJsonResponse(exchange, 200, resp);
 	}
@@ -784,17 +584,6 @@ public class KLALBWebServer {
 			KLALBRoutingProtocol rproto = kc.getIpv6Router().getKlalbRouteProtol();
 			Map<IPv6Address, Long> addrs = rproto.getAddresses();
 			IPv6Address selfAddr = kc.getIpv6Router().getLocator().getAddress();
-			KLALBController.PublishedNodeInfo published = kc.getPublishedNodeInfo();
-			Set<IPv6Address> activeAddresses = addrs == null
-					? Collections.<IPv6Address>emptySet() : new HashSet<IPv6Address>(addrs.keySet());
-			synchronized (tinyNameStateLock) {
-				tinyDeviceNameCache.keySet().removeIf(address -> !activeAddresses.contains(address));
-				tinyDeviceNameCacheTimes.keySet().removeIf(address -> !activeAddresses.contains(address));
-				tinyNameRequestsInFlight.removeIf(address -> !activeAddresses.contains(address));
-				tinyNameRequestTimes.keySet().removeIf(address -> !activeAddresses.contains(address));
-				tinyNameRequestGenerations.keySet().removeIf(address -> !activeAddresses.contains(address));
-			}
-			nodeInfoRevisions.keySet().removeIf(address -> !activeAddresses.contains(address));
 
 			if (addrs != null) {
 				for (IPv6Address addr : addrs.keySet()) {
@@ -803,12 +592,8 @@ public class KLALBWebServer {
 					nodeObj.addProperty("address", addr.toString());
 					nodeObj.addProperty("compressedAddress", addr.toCompressedString());
 					nodeObj.addProperty("isSelf", addr.equals(selfAddr));
-					String dname = addr.equals(selfAddr) ? kc.getIpv6Router().getDeviceName()
+					String dname = rproto.getDeviceName(addr);
-							: getTinyDeviceName(kc, addr);
 					nodeObj.addProperty("deviceName", dname != null ? dname : "");
-					long nodeInfoRevision = addr.equals(selfAddr) ? published.getFullRevision()
-							: nodeInfoRevisions.getOrDefault(addr, 0L);
-					nodeObj.addProperty("nodeInfoRevision", nodeInfoRevision);
 					nodesArray.add(nodeObj);
 				}
 			}
@@ -859,33 +644,21 @@ public class KLALBWebServer {
 				sendError(exchange, 404, "Configuration not found");
 			}
 		} else if ("POST".equalsIgnoreCase(method) || "PUT".equalsIgnoreCase(method)) {
-			synchronized (configUpdateLock) {
 			String body = readRequestBody(exchange);
 			try {
 				JsonObject json = new JsonParser().parse(body).getAsJsonObject();
 				KLALBControllerConfigItem current = proxySystem.getControllerConfig();
 				if (current != null) {
-					String oldDeviceName = current.getDeviceName();
-					String oldDeviceDescription = current.getDeviceDescription();
-					List<MultiProtocolSocketAddress> oldExternalEndpoints = current.getExternalEndpoints() == null
-							? null
-							: new ArrayList<MultiProtocolSocketAddress>(current.getExternalEndpoints());
-					List<String> oldExtraRoutes = current.getExtraRoutes() == null
-							? null : new ArrayList<String>(current.getExtraRoutes());
-					String newDeviceName = oldDeviceName;
-					String newDeviceDescription = oldDeviceDescription;
-					List<MultiProtocolSocketAddress> newExternalEndpoints = current.getExternalEndpoints();
-					List<String> newExtraRoutes = current.getExtraRoutes();
 					if (json.has("deviceName") && !json.get("deviceName").isJsonNull()) {
-						newDeviceName = json.get("deviceName").getAsString();
+						current.setDeviceName(json.get("deviceName").getAsString());
 					} else if (json.has("DeviceName") && !json.get("DeviceName").isJsonNull()) {
-						newDeviceName = json.get("DeviceName").getAsString();
+						current.setDeviceName(json.get("DeviceName").getAsString());
 					}
 
 					if (json.has("deviceDescription") && !json.get("deviceDescription").isJsonNull()) {
-						newDeviceDescription = json.get("deviceDescription").getAsString();
+						current.setDeviceDescription(json.get("deviceDescription").getAsString());
 					} else if (json.has("DeviceDescription") && !json.get("DeviceDescription").isJsonNull()) {
-						newDeviceDescription = json.get("DeviceDescription").getAsString();
+						current.setDeviceDescription(json.get("DeviceDescription").getAsString());
 					}
 
 					if (json.has("language") && !json.get("language").isJsonNull()) {
@@ -960,7 +733,7 @@ public class KLALBWebServer {
 								list.add(new MultiProtocolSocketAddress(el.getAsString()));
 							}
 						}
-						newExternalEndpoints = list;
+						current.setExternalEndpoints(list);
 					}
 
 					if (json.has("autoConnections") || json.has("AutoConnections") || json.has("connectLineTable") || json.has("ConnectLineTable")) {
@@ -1010,7 +783,7 @@ public class KLALBWebServer {
 								list.add(el.getAsString());
 							}
 						}
-						newExtraRoutes = list;
+						current.setExtraRoutes(list);
 					}
 
 					if (json.has("networkInterfaceExcepts") || json.has("NetworkInterfaceExcepts")) {
@@ -1072,23 +845,6 @@ public class KLALBWebServer {
 						current.setDenyExternalEndpointBroadcast(json.get("denyLineTableBroadcast").getAsBoolean());
 					}
 
-					boolean deviceNameChanged = !Objects.equals(oldDeviceName, newDeviceName);
-					boolean deviceDescriptionChanged = !Objects.equals(oldDeviceDescription, newDeviceDescription);
-					boolean externalEndpointsChanged = !Objects.equals(oldExternalEndpoints, newExternalEndpoints);
-					boolean extraRoutesChanged = !Objects.equals(oldExtraRoutes, newExtraRoutes);
-					if (deviceNameChanged || deviceDescriptionChanged || externalEndpointsChanged || extraRoutesChanged) {
-						KLALBController kc = proxySystem.getKlalbController();
-						if (kc != null) {
-							kc.publishNodeInfo(newDeviceName, newDeviceDescription, newExternalEndpoints,
-									newExtraRoutes);
-						} else {
-							current.setDeviceName(newDeviceName);
-							current.setDeviceDescription(newDeviceDescription);
-							current.setExternalEndpoints(newExternalEndpoints);
-							current.setExtraRoutes(newExtraRoutes);
-						}
-					}
-
 					// Trigger GUI save consumer or save directly
 					if (proxySystem.getKLALBGUI() != null && proxySystem.getKLALBGUI().getSaveComsumer() != null) {
 						proxySystem.getKLALBGUI().getSaveComsumer().accept(proxySystem.getConfig());
@@ -1106,7 +862,6 @@ public class KLALBWebServer {
 			} catch (Exception e) {
 				sendError(exchange, 400, "Failed to update configuration: " + e.getMessage());
 			}
-			}
 		} else {
 			sendError(exchange, 405, "Method not allowed");
 		}

src/org/kne/cloud/network/srv6/ExternalEndpointsResult.java

@@ -1,49 +0,0 @@
-package org.kne.cloud.network.srv6;
-
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Objects;
-
-import org.kne.cloud.network.MultiProtocolSocketAddress;
-
-public final class ExternalEndpointsResult {
-	private final List<MultiProtocolSocketAddress> externalEndpoints;
-	private final NodeInfoQueryStatus status;
-
-	public ExternalEndpointsResult(List<MultiProtocolSocketAddress> externalEndpoints, NodeInfoQueryStatus status) {
-		this.externalEndpoints = Collections.unmodifiableList(new ArrayList<MultiProtocolSocketAddress>(
-				externalEndpoints == null ? Collections.<MultiProtocolSocketAddress>emptyList() : externalEndpoints));
-		this.status = status;
-	}
-
-	public List<MultiProtocolSocketAddress> getExternalEndpoints() {
-		return externalEndpoints;
-	}
-
-	public NodeInfoQueryStatus getStatus() {
-		return status;
-	}
-
-	@Override
-	public int hashCode() {
-		return Objects.hash(externalEndpoints, status);
-	}
-
-	@Override
-	public boolean equals(Object obj) {
-		if (this == obj) {
-			return true;
-		}
-		if (!(obj instanceof ExternalEndpointsResult)) {
-			return false;
-		}
-		ExternalEndpointsResult other = (ExternalEndpointsResult) obj;
-		return Objects.equals(externalEndpoints, other.externalEndpoints) && status == other.status;
-	}
-
-	@Override
-	public String toString() {
-		return "ExternalEndpointsResult [externalEndpoints=" + externalEndpoints + ", status=" + status + "]";
-	}
-}

src/org/kne/cloud/network/srv6/ExtraRoutesResult.java

@@ -1,47 +0,0 @@
-package org.kne.cloud.network.srv6;
-
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Objects;
-
-public final class ExtraRoutesResult {
-	private final List<String> extraRoutes;
-	private final NodeInfoQueryStatus status;
-
-	public ExtraRoutesResult(List<String> extraRoutes, NodeInfoQueryStatus status) {
-		this.extraRoutes = Collections.unmodifiableList(new ArrayList<String>(
-				extraRoutes == null ? Collections.<String>emptyList() : extraRoutes));
-		this.status = status;
-	}
-
-	public List<String> getExtraRoutes() {
-		return extraRoutes;
-	}
-
-	public NodeInfoQueryStatus getStatus() {
-		return status;
-	}
-
-	@Override
-	public int hashCode() {
-		return Objects.hash(extraRoutes, status);
-	}
-
-	@Override
-	public boolean equals(Object obj) {
-		if (this == obj) {
-			return true;
-		}
-		if (!(obj instanceof ExtraRoutesResult)) {
-			return false;
-		}
-		ExtraRoutesResult other = (ExtraRoutesResult) obj;
-		return Objects.equals(extraRoutes, other.extraRoutes) && status == other.status;
-	}
-
-	@Override
-	public String toString() {
-		return "ExtraRoutesResult [extraRoutes=" + extraRoutes + ", status=" + status + "]";
-	}
-}

src/org/kne/cloud/network/srv6/JsonDataPacket.java

@@ -34,7 +34,6 @@ public class JsonDataPacket extends KLALBRoutingProtocolPacket implements Serial
 	private String data;
 
 	private static final int HEADER_LENGTH=3;
-	private static final int MAX_JSON_PAYLOAD_LENGTH=65535-HEADER_LENGTH;
 
 	private static Gson gson;
 	static{
@@ -76,9 +75,6 @@ public class JsonDataPacket extends KLALBRoutingProtocolPacket implements Serial
 	@Override
 	public void writeToChannel(WritableByteChannel dto) throws IOException {
 		byte[]bta=data.getBytes(Charset.forName("UTF-8"));
-		if(bta.length>MAX_JSON_PAYLOAD_LENGTH) {
-			throw new IOException("JSON payload exceeds " + MAX_JSON_PAYLOAD_LENGTH + " bytes");
-		}
 		getHeader().putChar(1,(char) bta.length);
 		super.writeToChannel(dto);
 		dto.write(ByteBuffer.wrap(bta));

src/org/kne/cloud/network/srv6/KLALBNodeInformation.java

@@ -0,0 +1,52 @@
+package org.kne.cloud.network.srv6;
+
+import java.util.List;
+
+import org.kne.cloud.network.MultiProtocolSocketAddress;
+
+/**
+ * 节点信息（开放线路 + 设备名称 + 设备描述），由路由协议 JSON API 查询获得。
+ */
+public class KLALBNodeInformation {
+	private List<MultiProtocolSocketAddress> openLines;
+	private String deviceName;
+	private String deviceDescription;
+
+	public KLALBNodeInformation(List<MultiProtocolSocketAddress> openLines, String deviceName,
+			String deviceDescription) {
+		super();
+		this.openLines = openLines;
+		this.deviceName = deviceName;
+		this.deviceDescription = deviceDescription;
+	}
+
+	public List<MultiProtocolSocketAddress> getOpenLines() {
+		return openLines;
+	}
+
+	public void setOpenLines(List<MultiProtocolSocketAddress> openLines) {
+		this.openLines = openLines;
+	}
+
+	public String getDeviceName() {
+		return deviceName;
+	}
+
+	public void setDeviceName(String deviceName) {
+		this.deviceName = deviceName;
+	}
+
+	public String getDeviceDescription() {
+		return deviceDescription;
+	}
+
+	public void setDeviceDescription(String deviceDescription) {
+		this.deviceDescription = deviceDescription;
+	}
+
+	@Override
+	public String toString() {
+		return "KLALBNodeInformation [openLines=" + openLines + ", deviceName=" + deviceName
+				+ ", deviceDescription=" + deviceDescription + "]";
+	}
+}

src/org/kne/cloud/network/srv6/KLALBRoutingProtocol.java

@@ -14,7 +14,6 @@ import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.Iterator;
-import java.util.LinkedHashSet;
 import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
@@ -22,8 +21,6 @@ import java.util.Objects;
 import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.CopyOnWriteArraySet;
-import java.util.concurrent.atomic.AtomicInteger;
-import java.util.concurrent.atomic.AtomicLong;
 import java.util.concurrent.locks.ReentrantLock;
 import java.util.function.BiConsumer;
 
@@ -46,10 +43,6 @@ public class KLALBRoutingProtocol extends Thread{
 
 	private RouterInfo selfRouterInfo;
 	private Map<IPv6Address, RouterInfo> netmap=new ConcurrentHashMap<>();
-	private final AtomicLong selfCreateTime = new AtomicLong();
-	private final AtomicInteger pendingNodeInfoUpdateFlags = new AtomicInteger();
-	private static final int NODE_INFO_UPDATE_REPLAY_WINDOW_SIZE = 64;
-	private final Map<IPv6Address, LinkedHashSet<Long>> seenNodeInfoUpdates = new HashMap<>();
 
 	public Map<IPv6Address, RouterInfo> getNetmap() {
 		return netmap;
@@ -92,7 +85,6 @@ public class KLALBRoutingProtocol extends Thread{
 		private ReentrantLock sendLock=new ReentrantLock();
 		
 	private Set<BiConsumer<SocketAddress,JsonDataPacket>>receivers=new CopyOnWriteArraySet<BiConsumer<SocketAddress,JsonDataPacket>>();
-	private Set<BiConsumer<IPv6Address,Integer>> nodeInfoUpdateListeners = new CopyOnWriteArraySet<BiConsumer<IPv6Address,Integer>>();
 	
 	public void addReceiver(BiConsumer<SocketAddress,JsonDataPacket> rec) {
 		receivers.add(rec);
@@ -102,57 +94,6 @@ public class KLALBRoutingProtocol extends Thread{
 		receivers.remove(rec);
 	}
 	
-	public void addNodeInfoUpdateListener(BiConsumer<IPv6Address,Integer> listener) {
-		nodeInfoUpdateListeners.add(listener);
-	}
-
-	public void removeNodeInfoUpdateListener(BiConsumer<IPv6Address,Integer> listener) {
-		nodeInfoUpdateListeners.remove(listener);
-	}
-
-	public void announceNodeInfoUpdate(int flags) {
-		int validFlags = flags & (RouterInfoPacket.NODE_INFO_TINY_UPDATE_REQUIRED
-				| RouterInfoPacket.NODE_INFO_FULL_UPDATE_REQUIRED);
-		if(validFlags != 0) {
-			pendingNodeInfoUpdateFlags.getAndUpdate(old -> old | validFlags);
-		}
-	}
-
-	private boolean markNodeInfoUpdateSeen(IPv6Address origin, long createTime) {
-		synchronized(seenNodeInfoUpdates) {
-			LinkedHashSet<Long> createTimes = seenNodeInfoUpdates.get(origin);
-			if(createTimes == null) {
-				createTimes = new LinkedHashSet<>();
-				seenNodeInfoUpdates.put(origin, createTimes);
-			}
-			if(!createTimes.add(createTime)) {
-				return false;
-			}
-			while(createTimes.size() > NODE_INFO_UPDATE_REPLAY_WINDOW_SIZE) {
-				createTimes.remove(createTimes.iterator().next());
-			}
-			return true;
-		}
-	}
-
-	private void removeNodeInfoUpdateWindow(IPv6Address origin) {
-		synchronized(seenNodeInfoUpdates) {
-			seenNodeInfoUpdates.remove(origin);
-		}
-	}
-
-	private void notifyNodeInfoUpdate(IPv6Address origin, int flags) {
-		for(BiConsumer<IPv6Address,Integer> listener : nodeInfoUpdateListeners) {
-			try {
-				listener.accept(origin, flags);
-			} catch(Throwable e) {
-				if(debug) {
-					e.printStackTrace();
-				}
-			}
-		}
-	}
-	
 	@Override
 	public void run() {
 		Thread.currentThread().setName("KLALB路由协议接收线程");
@@ -167,17 +108,6 @@ public class KLALBRoutingProtocol extends Thread{
 					selfRouterInfo = getSelfRouterInfo();
 					RouterInfo oslf=netmap.put(selfRouterInfo.getLocator().getAddress(), selfRouterInfo);
 					noticeUpdate();
-					int nodeInfoUpdateFlags = pendingNodeInfoUpdateFlags.getAndSet(0);
-					if(nodeInfoUpdateFlags != 0) {
-						RouterInfoPacket updatePacket = new RouterInfoPacket(getSelfRouterInfo(), true, -1);
-						updatePacket.setNodeInfoUpdateFlags(nodeInfoUpdateFlags);
-						try {
-							floodPacket(null, updatePacket);
-						} catch(IOException e) {
-							pendingNodeInfoUpdateFlags.getAndUpdate(old -> old | nodeInfoUpdateFlags);
-							e.printStackTrace();
-						}
-					}
 					/*if(oslf==null||(!selfRouterInfo.equals(oslf))) {
 					long cur=System.nanoTime();
 					if(cur-floodTimer2>5000000000L) {
@@ -218,10 +148,8 @@ public class KLALBRoutingProtocol extends Thread{
 							timeout=2000000000L;
 						}
 						if(val.checkTimeOut(timeout)) {
-							if(netmap.remove(type.getKey(), val)) {
+							iterator.remove();
-								removeNodeInfoUpdateWindow(type.getKey());
+							noticeUpdate();
-								noticeUpdate();
-							}
 						}
 						/*List<NeighborInfo> ads=val.getNeighborAddresses();
 						for (Iterator<NeighborInfo> iterator2 = ads.iterator(); iterator2.hasNext();) {
@@ -283,12 +211,12 @@ public class KLALBRoutingProtocol extends Thread{
 		while(true) {
 
 			try {
-			byte[]ca=MembandBoost.allocateUninitializedArray(65535);
+			byte[]ca=MembandBoost.allocateUninitializedByteArray(65535);
 			DatagramPacket dgp=new DatagramPacket(ca, ca.length);
 			ds.receive(dgp);
 			//System.out.println(Arrays.toString( Arrays.copyOf( dgp.getData(),dgp.getLength())));
 			ByteArrayInputStream bi=new ByteArrayInputStream(dgp.getData(),0,dgp.getLength());
-			KLALBRoutingProtocolPacket kp=KLALBRoutingProtocolPacket.readKLALBPacketFromChannel(Channels.newChannel(bi), dgp.getLength());
+			KLALBRoutingProtocolPacket kp=KLALBRoutingProtocolPacket.readKLALBPacketFromChannel(Channels.newChannel(bi));
 			
 			switch(kp.getType()) {
 			case KLALBRoutingProtocolPacket.RINFO_REQ:
@@ -309,30 +237,24 @@ public class KLALBRoutingProtocol extends Thread{
 				RouterInfoPacket rifp=(RouterInfoPacket) kp;
 				RouterInfo rif=rifp.getRinfo();
 				RouterInfo oldrif=netmap.get(rif.getLocator().getAddress());
-				IPv6Address origin = rif.getLocator().getAddress();
-				int nodeInfoUpdateFlags = rifp.getNodeInfoUpdateFlags();
-				boolean newNodeInfoUpdate = nodeInfoUpdateFlags != 0
-						&& markNodeInfoUpdateSeen(origin, rif.getCreateTime());
 
 				if(debug)
 					System.out.println(rif);
-				boolean topologyUpdated = oldrif==null||oldrif.getCreateTime()<rif.getCreateTime();
+				if(oldrif==null||oldrif.getCreateTime()<rif.getCreateTime()) {
-				if(topologyUpdated) {
 					if(debug)
 						System.out.println("update RouterInfo");
 				netmap.put(rif.getLocator().getAddress(), rif);
 				noticeUpdate();
+				if(rifp.isFlood()) {
+					floodPacket( dgp.getSocketAddress(), rifp);
+				
+				}
+				
 				}else {
 
 					if(debug)
 						System.out.println("dispose RouterInfo");
 				}
-				if(newNodeInfoUpdate) {
-					notifyNodeInfoUpdate(origin, nodeInfoUpdateFlags);
-				}
-				if(rifp.isFlood() && (topologyUpdated || newNodeInfoUpdate)) {
-					floodPacket(dgp.getSocketAddress(), rifp);
-				}
 				computeShortestPathIfUpdated();
 				break;
 			case KLALBRoutingProtocolPacket.JSON_DATA:
@@ -395,7 +317,6 @@ public class KLALBRoutingProtocol extends Thread{
 		}catch(BindException e) {
 			e.printStackTrace();
 			System.err.println("Cannot assign:"+dest);
-			throw e;
 		}finally {
 			sendLock.unlock();
 		}
@@ -627,9 +548,8 @@ public class KLALBRoutingProtocol extends Thread{
 	private RouterInfo getSelfRouterInfo() {
 		List<IPv6NetworkLink>links=router.getLinkTabel();
 		Object[] nls=links.toArray();
-		long currentTime = System.currentTimeMillis();
+		RouterInfo ri=new RouterInfo(System.currentTimeMillis(),router.getLocator(),router.getASN());
-		long createTime = selfCreateTime.updateAndGet(previous -> Math.max(currentTime, previous + 1));
+		ri.setDeviceName(router.getDeviceName());
-		RouterInfo ri=new RouterInfo(createTime,router.getLocator(),router.getASN());
 		for(int i=0;i<nls.length;i++) {
 			IPv6NetworkLink nl=(IPv6NetworkLink) nls[i];
 			if((!nl.isLoopBack())&&nl.isUp()) {
@@ -685,6 +605,12 @@ public class KLALBRoutingProtocol extends Thread{
 	 * 查询某地址广播的设备名称（未知返回null）
 	 */
 	public String getDeviceName(IPv6Address address) {
+		RouterInfo ri=netmap.get(address);
+		if(ri!=null) {
+			String dn=ri.getDeviceName();
+			if(dn!=null&&!dn.isEmpty())
+				return dn;
+		}
 		return null;
 	}
 	public Map<IPv6Address, List<LinkDirection>> getPaths() {

src/org/kne/cloud/network/srv6/KLALBRoutingProtocolAPIClient.java

@@ -3,19 +3,16 @@ package org.kne.cloud.network.srv6;
 import java.io.IOException;
 import java.lang.ref.Cleaner;
 import java.net.InetSocketAddress;
-import java.net.InetAddress;
 import java.net.SocketAddress;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.UUID;
-import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.BiConsumer;
 import java.util.function.Consumer;
 
 import org.kne.cloud.network.MultiProtocolSocketAddress;
 import org.kne.cloud.network.congestion.NOCongestionAlgorithm;
 import org.kne.cloud.network.congestion.SendPacketSlidingWindow;
-import org.kne.cloud.network.klalb.SendItem;
 import org.kne.opencl64.Releaser;
 
 public class KLALBRoutingProtocolAPIClient {
@@ -27,105 +24,37 @@ public class KLALBRoutingProtocolAPIClient {
 
 	private BiConsumer<SocketAddress, JsonDataPacket> rec = (addr, data) -> {
 		KLALBRoutingProtocolJsonData dataobj = data.getDecodedData();
+		InetSocketAddress addrs = (InetSocketAddress) addr;
 		UUID ruid = dataobj.getUuid();
+		JsonDataPacket relate = null;
+		//System.out.println(ruid + " " + window.getSendmap());
 		switch (dataobj.getType()) {
-		case KLALBRoutingProtocolJsonData.NODE_PROFILE_RESP:
+		case KLALBRoutingProtocolJsonData.NODE_INFO_FULL_RESP:
-			PendingRequest profileRequest = acknowledgeResponse(ruid,
+		case KLALBRoutingProtocolJsonData.NODE_INFO_TINY_RESP:
-					KLALBRoutingProtocolJsonData.NODE_PROFILE_REQ, addr);
-			if (profileRequest != null) {
-				((Consumer<NodeProfile>) profileRequest.callback)
-						.accept(new NodeProfile(dataobj.getDeviceName(), dataobj.getDeviceDescription()));
-			}
-			break;
-		case KLALBRoutingProtocolJsonData.NODE_EXTERNAL_ENDPOINTS_RESP:
-			PendingRequest endpointsRequest = acknowledgeResponse(ruid,
-					KLALBRoutingProtocolJsonData.NODE_EXTERNAL_ENDPOINTS_REQ, addr);
-			if (endpointsRequest != null) {
-				((Consumer<ExternalEndpointsResult>) endpointsRequest.callback).accept(
-						new ExternalEndpointsResult(decodeExternalEndpoints(dataobj.getData()), dataobj.getStatus()));
-			}
-			break;
-		case KLALBRoutingProtocolJsonData.NODE_EXTRA_ROUTES_RESP:
-			PendingRequest routesRequest = acknowledgeResponse(ruid,
-					KLALBRoutingProtocolJsonData.NODE_EXTRA_ROUTES_REQ, addr);
-			if (routesRequest != null) {
-				((Consumer<ExtraRoutesResult>) routesRequest.callback).accept(
-						new ExtraRoutesResult(decodeExtraRoutes(dataobj.getData()), dataobj.getStatus()));
-			}
-			break;
-		}
-	};
 
-	private PendingRequest acknowledgeResponse(UUID uuid, String expectedRequestType, SocketAddress sourceAddress) {
+			if ((relate = window.ack(ruid)) != null) {
-		SendItem<JsonDataPacket> pending = window.getSendmap().get(uuid);
+				List<?> connects = (List<?>) dataobj.getData();
-		if (pending == null) {
+				List<MultiProtocolSocketAddress> connectsm = new ArrayList<MultiProtocolSocketAddress>(
-			return null;
+						connects == null ? 0 : connects.size());
-		}
+				if (connects != null) {
-		KLALBRoutingProtocolJsonData request = pending.getPacket().getDecodedData();
+					for (Object open : connects) {
-		if (request == null || !expectedRequestType.equals(request.getType())) {
+						if (open instanceof MultiProtocolSocketAddress) {
-			return null;
+							connectsm.add((MultiProtocolSocketAddress) open);
-		}
+						} else {
-		Object callback = pending.getPacket().getUserCallback();
+							connectsm.add(new MultiProtocolSocketAddress((String) open));
-		if (!(callback instanceof PendingRequest)) {
-			return null;
-		}
-		PendingRequest pendingRequest = (PendingRequest) callback;
-		if (!expectedRequestType.equals(pendingRequest.expectedRequestType)
-				|| !sameDestination(pendingRequest.expectedDestination, sourceAddress)) {
-			return null;
-		}
-		return window.ack(uuid) == null ? null : pendingRequest;
-	}
 
-	private static boolean sameDestination(SocketAddress expected, SocketAddress actual) {
+						}
-		if (expected instanceof InetSocketAddress && actual instanceof InetSocketAddress) {
+					}
-			InetSocketAddress expectedInet = (InetSocketAddress) expected;
-			InetSocketAddress actualInet = (InetSocketAddress) actual;
-			if (expectedInet.getPort() != actualInet.getPort()) return false;
-			InetAddress expectedAddress = expectedInet.getAddress();
-			InetAddress actualAddress = actualInet.getAddress();
-			if (expectedAddress != null && actualAddress != null) return expectedAddress.equals(actualAddress);
-			if (expectedAddress == null && actualAddress == null) {
-				return expectedInet.getHostString().equalsIgnoreCase(actualInet.getHostString());
-			}
-			return false;
-		}
-		return expected != null && expected.equals(actual);
-	}
-
-	private List<MultiProtocolSocketAddress> decodeExternalEndpoints(Object data) {
-		if (!(data instanceof List<?>)) {
-			return new ArrayList<MultiProtocolSocketAddress>();
-		}
-		List<?> encoded = (List<?>) data;
-		List<MultiProtocolSocketAddress> endpoints = new ArrayList<MultiProtocolSocketAddress>(encoded.size());
-		for (Object value : encoded) {
-			if (value instanceof MultiProtocolSocketAddress) {
-				endpoints.add((MultiProtocolSocketAddress) value);
-			} else if (value instanceof String) {
-				try {
-					endpoints.add(new MultiProtocolSocketAddress((String) value));
-				} catch (RuntimeException ignored) {
-					// Ignore malformed entries while preserving the rest of the response.
 				}
+				// 组装节点信息（线路 + 设备名称 + 设备描述，精简模式下线路与描述为 null）
+				KLALBNodeInformation info = new KLALBNodeInformation(connectsm, dataobj.getDeviceName(),
+						dataobj.getDeviceDescription());
+				((Consumer<KLALBNodeInformation>) relate.getUserCallback()).accept(info);
 			}
+			break;
 		}
-		return endpoints;
-	}
 
-	private List<String> decodeExtraRoutes(Object data) {
+	};
-		if (!(data instanceof List<?>)) {
-			return new ArrayList<String>();
-		}
-		List<?> encoded = (List<?>) data;
-		List<String> routes = new ArrayList<String>(encoded.size());
-		for (Object value : encoded) {
-			if (value instanceof String) {
-				routes.add((String) value);
-			}
-		}
-		return routes;
-	}
 
 	public KLALBRoutingProtocolAPIClient(KLALBRoutingProtocol routingProtocol) {
 		this.routingProtocol = routingProtocol;
@@ -134,29 +63,31 @@ public class KLALBRoutingProtocolAPIClient {
 		clr.register(this, releaser);
 	}
 
-	public void requestNodeProfile(SocketAddress addr, Consumer<NodeProfile> callback) throws IOException {
+	/**
-		sendNodeInfoRequest(KLALBRoutingProtocolJsonData.NODE_PROFILE_REQ, addr, callback);
+	 * 精简查询：仅获取对端设备名称（开销最小，适用于未查看节点详情的场景）。
-	}
+	 */
-
+	public void requestNodeInfoTiny(SocketAddress addr, Consumer<KLALBNodeInformation> callback)
-	public void requestExternalEndpoints(SocketAddress addr, Consumer<ExternalEndpointsResult> callback)
 			throws IOException {
-		sendNodeInfoRequest(KLALBRoutingProtocolJsonData.NODE_EXTERNAL_ENDPOINTS_REQ, addr, callback);
+		sendNodeInfoRequest(KLALBRoutingProtocolJsonData.NODE_INFO_TINY_REQ, addr, callback);
 	}
 
-	public void requestExtraRoutes(SocketAddress addr, Consumer<ExtraRoutesResult> callback) throws IOException {
+	/**
-		sendNodeInfoRequest(KLALBRoutingProtocolJsonData.NODE_EXTRA_ROUTES_REQ, addr, callback);
+	 * 完整查询：获取对端开放线路 + 设备名称 + 设备描述（查看节点信息时使用）。
+	 */
+	public void requestNodeInfoFull(SocketAddress addr, Consumer<KLALBNodeInformation> callback)
+			throws IOException {
+		sendNodeInfoRequest(KLALBRoutingProtocolJsonData.NODE_INFO_FULL_REQ, addr, callback);
 	}
 
-	private void sendNodeInfoRequest(String type, SocketAddress addr, Object callback) throws IOException {
+	private void sendNodeInfoRequest(String type, SocketAddress addr, Consumer<KLALBNodeInformation> callback)
+			throws IOException {
 		UUID suid = UUID.randomUUID();
 		KLALBRoutingProtocolJsonData json = new KLALBRoutingProtocolJsonData(type, suid, null);
 		JsonDataPacket packet = new JsonDataPacket(json);
-		packet.setUserCallback(new PendingRequest(addr, type, callback));
+		packet.setUserCallback(callback);
-		synchronized (this) {
+		window.put(suid, packet);
-			if (closed.get() || releaser.isReleased()) throw new IOException("Node info client is closed");
+		routingProtocol.sendJsonPacketToAddress(packet, addr);
-			window.put(suid, packet);
+
-			routingProtocol.sendJsonPacketToAddress(packet, addr);
-		}
 	}
 
 	public KLALBRoutingProtocol getRoutingProtocol() {
@@ -165,27 +96,13 @@ public class KLALBRoutingProtocolAPIClient {
 
 	private KLALBRoutingProtocolAPIClientReleaser releaser;
 
-	public synchronized void close() {
+	public void close() {
-		if (closed.compareAndSet(false, true)) releaser.run();
+		releaser.run();
 	}
 
 	public boolean isClosed() {
-		return closed.get() || releaser.isReleased();
+		return releaser.isReleased();
 	}
-
-	private static final class PendingRequest {
-		private final SocketAddress expectedDestination;
-		private final String expectedRequestType;
-		private final Object callback;
-
-		private PendingRequest(SocketAddress expectedDestination, String expectedRequestType, Object callback) {
-			this.expectedDestination = expectedDestination;
-			this.expectedRequestType = expectedRequestType;
-			this.callback = callback;
-		}
-	}
-
-	private final AtomicBoolean closed = new AtomicBoolean();
 }
 
 class KLALBRoutingProtocolAPIClientReleaser extends Releaser<BiConsumer<SocketAddress, JsonDataPacket>> {

src/org/kne/cloud/network/srv6/KLALBRoutingProtocolAPIServer.java

@@ -2,8 +2,8 @@ package org.kne.cloud.network.srv6;
 
 import java.io.IOException;
 import java.lang.ref.Cleaner;
+import java.net.InetSocketAddress;
 import java.net.SocketAddress;
-import java.util.ArrayList;
 import java.util.function.BiConsumer;
 
 import org.kne.cloud.network.klalb.KLALBController;
@@ -13,52 +13,41 @@ public class KLALBRoutingProtocolAPIServer {
 	private KLALBController controller;
 	private KLALBRoutingProtocol routingProtocol;
 	
-	private static final Cleaner clr = Cleaner.create();
 
-	private BiConsumer<SocketAddress, JsonDataPacket> rec = (addr, data) -> {
+	private static final Cleaner clr=Cleaner.create();
+	
+	private BiConsumer<SocketAddress, JsonDataPacket> rec=(addr,data)->{
 		try {
-			KLALBRoutingProtocolJsonData dataobj = data.getDecodedData();
+		KLALBRoutingProtocolJsonData dataobj= data.getDecodedData();
-			switch (dataobj.getType()) {
+		InetSocketAddress addrs=(InetSocketAddress) addr;
-			case KLALBRoutingProtocolJsonData.NODE_PROFILE_REQ:
+		switch(dataobj.getType()){
-				KLALBController.PublishedNodeInfo profilePublished = controller.getPublishedNodeInfo();
+		case KLALBRoutingProtocolJsonData.NODE_INFO_TINY_REQ:
-				KLALBRoutingProtocolJsonData profile = new KLALBRoutingProtocolJsonData(
+			// 精简查询：仅返回设备名称（设备名称随路由信息广播公开，不受 denyExternalEndpointQuery 限制）
-						KLALBRoutingProtocolJsonData.NODE_PROFILE_RESP, dataobj.getUuid(), null);
+			KLALBRoutingProtocolJsonData tinyjson=new KLALBRoutingProtocolJsonData(KLALBRoutingProtocolJsonData.NODE_INFO_TINY_RESP,dataobj.getUuid(),null);
-				profile.setDeviceName(profilePublished.getDeviceName());
+			tinyjson.setDeviceName(controller.getIpv6Router().getDeviceName());
-				profile.setDeviceDescription(profilePublished.getDeviceDescription());
+			routingProtocol.sendJsonPacketToAddress(new JsonDataPacket(tinyjson),addr);
-				profile.setStatus(NodeInfoQueryStatus.OK);
+			break;
-				routingProtocol.sendJsonPacketToAddress(new JsonDataPacket(profile), addr);
+		case KLALBRoutingProtocolJsonData.NODE_INFO_FULL_REQ:
-				break;
+			// 完整查询：设备名称与描述总是正常响应；denyExternalEndpointQuery 仅隐藏外部端点列表
-			case KLALBRoutingProtocolJsonData.NODE_EXTERNAL_ENDPOINTS_REQ:
+			boolean denyEndpoints=controller.getConfigItem()!=null&&controller.getConfigItem().isDenyExternalEndpointQuery();
-				boolean denyEndpoints = controller.getConfigItem() != null
+			KLALBRoutingProtocolJsonData json=new KLALBRoutingProtocolJsonData(KLALBRoutingProtocolJsonData.NODE_INFO_FULL_RESP,dataobj.getUuid(),denyEndpoints?null:controller.getExternalEndpoints());
-						&& controller.getConfigItem().isDenyExternalEndpointQuery();
+			json.setDeviceName(controller.getIpv6Router().getDeviceName());// 附带本机设备名称
-				KLALBController.PublishedNodeInfo endpointsPublished = controller.getPublishedNodeInfo();
+			if(controller.getConfigItem()!=null) {
-				KLALBRoutingProtocolJsonData endpoints = new KLALBRoutingProtocolJsonData(
+				json.setDeviceDescription(controller.getConfigItem().getDeviceDescription());// 附带本机设备描述
-						KLALBRoutingProtocolJsonData.NODE_EXTERNAL_ENDPOINTS_RESP, dataobj.getUuid(),
-						denyEndpoints ? new ArrayList<org.kne.cloud.network.MultiProtocolSocketAddress>()
-								: new ArrayList<org.kne.cloud.network.MultiProtocolSocketAddress>(
-										endpointsPublished.getExternalEndpoints()));
-				endpoints.setStatus(denyEndpoints ? NodeInfoQueryStatus.DENIED : NodeInfoQueryStatus.OK);
-				routingProtocol.sendJsonPacketToAddress(new JsonDataPacket(endpoints), addr);
-				break;
-			case KLALBRoutingProtocolJsonData.NODE_EXTRA_ROUTES_REQ:
-				KLALBController.PublishedNodeInfo routesPublished = controller.getPublishedNodeInfo();
-				KLALBRoutingProtocolJsonData routes = new KLALBRoutingProtocolJsonData(
-						KLALBRoutingProtocolJsonData.NODE_EXTRA_ROUTES_RESP, dataobj.getUuid(),
-						new ArrayList<String>(routesPublished.getExtraRoutes()));
-				routes.setStatus(NodeInfoQueryStatus.OK);
-				routingProtocol.sendJsonPacketToAddress(new JsonDataPacket(routes), addr);
-				break;
 			}
+			routingProtocol.sendJsonPacketToAddress(new JsonDataPacket(json),addr);
+			break;
+		}
 		} catch (IOException e) {
 			e.printStackTrace();
 		}
 	};
 
-	public KLALBRoutingProtocolAPIServer(KLALBRoutingProtocol routingProtocol, KLALBController controller) {
+	public KLALBRoutingProtocolAPIServer(KLALBRoutingProtocol routingProtocol,KLALBController controller) {
-		this.controller = controller;
+		this.controller=controller;
-		this.routingProtocol = routingProtocol;
+		this.routingProtocol=routingProtocol;
 		routingProtocol.addReceiver(rec);
-		this.releaser = new KLALBRoutingProtocolAPIServerReleaser(this.routingProtocol, rec);
+		this.releaser=new KLALBRoutingProtocolAPIServerReleaser(this.routingProtocol,rec);
 		clr.register(this, releaser);
 	}
 
@@ -70,25 +59,26 @@ public class KLALBRoutingProtocolAPIServer {
 		return routingProtocol;
 	}
 	
-	private KLALBRoutingProtocolAPIServerReleaser releaser;
+	
+private KLALBRoutingProtocolAPIServerReleaser releaser;
 	
 	public void close() {
 		releaser.run();
 	}
 	
+	
 	public boolean isClosed() {
 		return releaser.isReleased();
 	}
-}
 	
-class KLALBRoutingProtocolAPIServerReleaser extends Releaser<BiConsumer<SocketAddress, JsonDataPacket>> {
+}
+class KLALBRoutingProtocolAPIServerReleaser extends Releaser<BiConsumer<SocketAddress, JsonDataPacket>>{
 
 	private KLALBRoutingProtocol routingProtocol;
 
-	public KLALBRoutingProtocolAPIServerReleaser(KLALBRoutingProtocol routingProtocol,
+	public KLALBRoutingProtocolAPIServerReleaser(KLALBRoutingProtocol routingProtocol,BiConsumer<SocketAddress, JsonDataPacket> resource) {
-			BiConsumer<SocketAddress, JsonDataPacket> resource) {
 		super(resource);
-		this.routingProtocol = routingProtocol;
+		this.routingProtocol=routingProtocol;
 	}
 
 	@Override

src/org/kne/cloud/network/srv6/KLALBRoutingProtocolJsonData.java

@@ -1,89 +1,95 @@
 package org.kne.cloud.network.srv6;
 
-import java.util.Objects;
 import java.util.UUID;
 
 public class KLALBRoutingProtocolJsonData {
-	public static final String NODE_PROFILE_REQ = "nodeprofilereq";
+	public static final String NODE_INFO_TINY_REQ="nodeinfotinyreq";// 精简查询：仅设备名称
-	public static final String NODE_PROFILE_RESP = "nodeprofileresp";
+	public static final String NODE_INFO_TINY_RESP="nodeinfotinyresp";
-	public static final String NODE_EXTERNAL_ENDPOINTS_REQ = "nodeexternalendpointsreq";
+	public static final String NODE_INFO_FULL_REQ="nodeinfofullreq";// 完整查询：开放线路+设备名称+设备描述
-	public static final String NODE_EXTERNAL_ENDPOINTS_RESP = "nodeexternalendpointsresp";
+	public static final String NODE_INFO_FULL_RESP="nodeinfofullresp";
-	public static final String NODE_EXTRA_ROUTES_REQ = "nodeextraroutesreq";
-	public static final String NODE_EXTRA_ROUTES_RESP = "nodeextraroutesresp";
-
 	private String type;
 	private UUID uuid;
 	private Object data;
-	private String deviceName;
+	private String deviceName;// 对端设备名称
-	private String deviceDescription;
+	private String deviceDescription;// 对端设备描述
-	private NodeInfoQueryStatus status;
+	public String getDeviceName() {
-
+		return deviceName;
+	}
+	public void setDeviceName(String deviceName) {
+		this.deviceName = deviceName;
+	}
+	public String getDeviceDescription() {
+		return deviceDescription;
+	}
+	public void setDeviceDescription(String deviceDescription) {
+		this.deviceDescription = deviceDescription;
+	}
+	public String getType() {
+		return type;
+	}
+	public Object getData() {
+		return data;
+	}
+	public UUID getUuid() {
+		return uuid;
+	}
+	@Override
+	public int hashCode() {
+		final int prime = 31;
+		int result = 1;
+		result = prime * result + ((data == null) ? 0 : data.hashCode());
+		result = prime * result + ((type == null) ? 0 : type.hashCode());
+		result = prime * result + ((uuid == null) ? 0 : uuid.hashCode());
+		result = prime * result + ((deviceName == null) ? 0 : deviceName.hashCode());
+		result = prime * result + ((deviceDescription == null) ? 0 : deviceDescription.hashCode());
+		return result;
+	}
+	@Override
+	public boolean equals(Object obj) {
+		if (this == obj)
+			return true;
+		if (obj == null)
+			return false;
+		if (getClass() != obj.getClass())
+			return false;
+		KLALBRoutingProtocolJsonData other = (KLALBRoutingProtocolJsonData) obj;
+		if (data == null) {
+			if (other.data != null)
+				return false;
+		} else if (!data.equals(other.data))
+			return false;
+		if (type == null) {
+			if (other.type != null)
+				return false;
+		} else if (!type.equals(other.type))
+			return false;
+		if (uuid == null) {
+			if (other.uuid != null)
+				return false;
+		} else if (!uuid.equals(other.uuid))
+			return false;
+		if (deviceName == null) {
+			if (other.deviceName != null)
+				return false;
+		} else if (!deviceName.equals(other.deviceName))
+			return false;
+		if (deviceDescription == null) {
+			if (other.deviceDescription != null)
+				return false;
+		} else if (!deviceDescription.equals(other.deviceDescription))
+			return false;
+		return true;
+	}
 	public KLALBRoutingProtocolJsonData(String type, UUID uuid, Object data) {
+		super();
 		this.type = type;
 		this.uuid = uuid;
 		this.data = data;
 	}
-
-	public String getType() {
-		return type;
-	}
-
-	public UUID getUuid() {
-		return uuid;
-	}
-
-	public Object getData() {
-		return data;
-	}
-
-	public String getDeviceName() {
-		return deviceName;
-	}
-
-	public void setDeviceName(String deviceName) {
-		this.deviceName = deviceName;
-	}
-
-	public String getDeviceDescription() {
-		return deviceDescription;
-	}
-
-	public void setDeviceDescription(String deviceDescription) {
-		this.deviceDescription = deviceDescription;
-	}
-
-	public NodeInfoQueryStatus getStatus() {
-		return status;
-	}
-
-	public void setStatus(NodeInfoQueryStatus status) {
-		this.status = status;
-	}
-
-	@Override
-	public int hashCode() {
-		return Objects.hash(type, uuid, data, deviceName, deviceDescription, status);
-	}
-
-	@Override
-	public boolean equals(Object obj) {
-		if (this == obj) {
-			return true;
-		}
-		if (!(obj instanceof KLALBRoutingProtocolJsonData)) {
-			return false;
-		}
-		KLALBRoutingProtocolJsonData other = (KLALBRoutingProtocolJsonData) obj;
-		return Objects.equals(type, other.type) && Objects.equals(uuid, other.uuid)
-				&& Objects.equals(data, other.data) && Objects.equals(deviceName, other.deviceName)
-				&& Objects.equals(deviceDescription, other.deviceDescription)
-				&& Objects.equals(status, other.status);
-	}
-
 	@Override
 	public String toString() {
-		return "KLALBRoutingProtocolJsonData [type=" + type + ", uuid=" + uuid + ", data=" + data
+		return "KLALBRoutingProtocolJsonData [type=" + type + ", uuid=" + uuid + ", data=" + data + ", deviceName="
-				+ ", deviceName=" + deviceName + ", deviceDescription=" + deviceDescription + ", status=" + status
+				+ deviceName + ", deviceDescription=" + deviceDescription + "]";
-				+ "]";
 	}
+	
 }

src/org/kne/cloud/network/srv6/KLALBRoutingProtocolPacket.java

@@ -96,10 +96,6 @@ public abstract class KLALBRoutingProtocolPacket extends NetworkPacket {
 	}
 	
 	public static KLALBRoutingProtocolPacket readKLALBPacketFromChannel(ReadableByteChannel in) throws IOException {
-		return readKLALBPacketFromChannel(in, -1);
-	}
-
-	public static KLALBRoutingProtocolPacket readKLALBPacketFromChannel(ReadableByteChannel in, long packetLength) throws IOException {
 		while(true) {
 		ByteBuffer bb=NetworkPacket.bufferAllocator.allocate(40);
 		bb.limit(1);
@@ -115,13 +111,11 @@ public abstract class KLALBRoutingProtocolPacket extends NetworkPacket {
 				switch(type) {
 				case RINFO_REQ:
 					klp=new RouterInfoRequestPacket(bb);
-					if(packetLength < 0) klp.readFromChannel(in);
+					klp.readFromChannel(in);
-					else klp.readFromChannel(in, packetLength);
 					return klp;
 				case RINFO:
 					klp=new RouterInfoPacket(bb);
-					if(packetLength < 0) klp.readFromChannel(in);
+					klp.readFromChannel(in);
-					else klp.readFromChannel(in, packetLength);
 					return klp;
 				case JSON_DATA:
 					klp=new JsonDataPacket(bb);

src/org/kne/cloud/network/srv6/NodeInfoQueryStatus.java

@@ -1,6 +0,0 @@
-package org.kne.cloud.network.srv6;
-
-public enum NodeInfoQueryStatus {
-	OK,
-	DENIED
-}

src/org/kne/cloud/network/srv6/NodeProfile.java

@@ -1,44 +0,0 @@
-package org.kne.cloud.network.srv6;
-
-import java.util.Objects;
-
-public final class NodeProfile {
-	private final String deviceName;
-	private final String deviceDescription;
-
-	public NodeProfile(String deviceName, String deviceDescription) {
-		this.deviceName = deviceName;
-		this.deviceDescription = deviceDescription;
-	}
-
-	public String getDeviceName() {
-		return deviceName;
-	}
-
-	public String getDeviceDescription() {
-		return deviceDescription;
-	}
-
-	@Override
-	public int hashCode() {
-		return Objects.hash(deviceName, deviceDescription);
-	}
-
-	@Override
-	public boolean equals(Object obj) {
-		if (this == obj) {
-			return true;
-		}
-		if (!(obj instanceof NodeProfile)) {
-			return false;
-		}
-		NodeProfile other = (NodeProfile) obj;
-		return Objects.equals(deviceName, other.deviceName)
-				&& Objects.equals(deviceDescription, other.deviceDescription);
-	}
-
-	@Override
-	public String toString() {
-		return "NodeProfile [deviceName=" + deviceName + ", deviceDescription=" + deviceDescription + "]";
-	}
-}

src/org/kne/cloud/network/srv6/RouterInfo.java

@@ -60,6 +60,7 @@ public class RouterInfo implements Serializable{
 		return Objects.equals(locator, other.locator) && Objects.equals(neighborAddresses, other.neighborAddresses);
 	}
 	private List<NeighborInfo> neighborAddresses=new ArrayList<>();
+	private String deviceName=""; // 设备名称（广播时携带，描述不广播）
 	private long createTime;
 	
 	
@@ -68,7 +69,6 @@ public class RouterInfo implements Serializable{
 	}
 	private static final long INFO_UPDATETIME=10000000000L;
 	private static final long INFO_TIMEOUT=60000000000L;
-	private static final int MAX_NEIGHBOR_COUNT = 512;
 	private long putTime=System.nanoTime();
 	public boolean checkUpdateTime() {
 		return System.nanoTime()-putTime>INFO_UPDATETIME;
@@ -91,6 +91,14 @@ public class RouterInfo implements Serializable{
 		return neighborAddresses;
 	}
 	
+	public String getDeviceName() {
+		return deviceName;
+	}
+	
+	public void setDeviceName(String deviceName) {
+		this.deviceName = deviceName;
+	}
+	
 	public RouterInfo( long createTime,IPv6AddressGroup locator,long asn) {
 		this.createTime = createTime;
 		this.locator=locator;
@@ -100,19 +108,14 @@ public class RouterInfo implements Serializable{
 	public RouterInfo() {
 	}
 	public void writeToStream(DataOutputStream out) throws IOException {
-		int neighborCount = neighborAddresses == null ? -1 : neighborAddresses.size();
-		if(neighborCount<0 || neighborCount>MAX_NEIGHBOR_COUNT) {
-			throw new IOException("Invalid neighbor count: " + neighborCount);
-		}
 		locator.writeToStream(out);
 		out.writeLong(asn);
 		out.writeLong(createTime);
-		out.writeInt(neighborCount);
+		out.writeInt(neighborAddresses.size());
 		for(	NeighborInfo neighborInfo :neighborAddresses) {
 			neighborInfo.writeToStream(out);
 		}
-		// Keep the legacy UTF slot so older RINFO decoders stay aligned.
+		out.writeUTF(deviceName==null?"":deviceName);
-		out.writeUTF("");
 	}
 	
 	protected void writeToChannel(WritableByteChannel dto) throws IOException {
@@ -126,9 +129,6 @@ public class RouterInfo implements Serializable{
 		asn=in.readLong();
 		createTime=in.readLong();
 		int size=in.readInt();
-		if(size<0 || size>MAX_NEIGHBOR_COUNT) {
-			throw new IOException("Invalid neighbor count: " + size);
-		}
 		neighborAddresses=new ArrayList<>(size);
 		for (int i = 0; i < size; i++) {
 			NeighborInfo nif=new NeighborInfo();
@@ -136,8 +136,7 @@ public class RouterInfo implements Serializable{
 			neighborAddresses.add(nif);
 			
 		}
-		// Consume the legacy device-name slot; names are no longer broadcast here.
+		deviceName=in.readUTF();
-		in.readUTF();
 	}
 	
 }

src/org/kne/cloud/network/srv6/RouterInfoPacket.java

@@ -2,7 +2,6 @@ package org.kne.cloud.network.srv6;
 
 import java.io.DataInputStream;
 import java.io.DataOutputStream;
-import java.io.ByteArrayInputStream;
 import java.io.Externalizable;
 import java.io.IOException;
 import java.io.ObjectInput;
@@ -24,11 +23,6 @@ import org.kne.cloud.network.NetworkPacket;
 import org.kne.cloud.network.ipv6.IPv6AddressGroup;
 
 public class RouterInfoPacket extends KLALBRoutingProtocolPacket implements Serializable{
-	public static final int NODE_INFO_TINY_UPDATE_REQUIRED = 1;
-	public static final int NODE_INFO_FULL_UPDATE_REQUIRED = 2;
-	private static final int NODE_INFO_UPDATE_FLAGS_MASK = NODE_INFO_TINY_UPDATE_REQUIRED
-			| NODE_INFO_FULL_UPDATE_REQUIRED;
-	private static final int NODE_INFO_UPDATE_MAGIC = 0xA5;
 
 	public RouterInfoPacket(RouterInfo routerInfo, boolean flood,long asn) {
 		super(RINFO);
@@ -41,7 +35,6 @@ public class RouterInfoPacket extends KLALBRoutingProtocolPacket implements Seri
 	}
 	
 	private RouterInfo rinfo;
-	private transient int nodeInfoUpdateFlags;
 	
 	public boolean isFlood() {
 		return (getHeader().get(1)&1)==1;
@@ -54,14 +47,6 @@ public class RouterInfoPacket extends KLALBRoutingProtocolPacket implements Seri
 	public RouterInfo getRinfo() {
 		return rinfo;
 	}
-
-	public int getNodeInfoUpdateFlags() {
-		return nodeInfoUpdateFlags;
-	}
-
-	public void setNodeInfoUpdateFlags(int flags) {
-		nodeInfoUpdateFlags = flags & NODE_INFO_UPDATE_FLAGS_MASK;
-	}
 	@Override
 	protected long getHeaderSize() {
 		return super.getHeaderSize()+9;
@@ -83,43 +68,12 @@ public class RouterInfoPacket extends KLALBRoutingProtocolPacket implements Seri
 	public void writeToChannel(WritableByteChannel dto) throws IOException {
 		super.writeToChannel(dto);
 		rinfo.writeToChannel(dto);
-		int flags = nodeInfoUpdateFlags & NODE_INFO_UPDATE_FLAGS_MASK;
-		if(flags != 0) {
-			ByteBuffer extension = ByteBuffer.wrap(new byte[] {(byte) NODE_INFO_UPDATE_MAGIC, (byte) flags});
-			while(extension.hasRemaining()) {
-				dto.write(extension);
-			}
-		}
 	}
 	@Override
 	public void readFromChannel(ReadableByteChannel din, long length) throws IOException {
 		super.readFromChannel(din, length);
 		rinfo=new RouterInfo();
-		if(length < 0) {
+		rinfo.readFromChannel(din, length);
-			rinfo.readFromChannel(din, length);
-			nodeInfoUpdateFlags = 0;
-			return;
-		}
-		long payloadLength = length - getHeaderSize();
-		if(payloadLength < 0 || payloadLength > Integer.MAX_VALUE) {
-			throw new IOException("Invalid RINFO packet length: " + length);
-		}
-		byte[] payload = new byte[(int) payloadLength];
-		ByteBuffer payloadBuffer = ByteBuffer.wrap(payload);
-		while(payloadBuffer.hasRemaining()) {
-			if(din.read(payloadBuffer) == -1) {
-				throw new java.io.EOFException();
-			}
-		}
-		ByteArrayInputStream payloadInput = new ByteArrayInputStream(payload);
-		rinfo.readFromStream(new DataInputStream(payloadInput));
-		nodeInfoUpdateFlags = 0;
-		int marker = payloadInput.read();
-		int flags = payloadInput.read();
-		int trailing = payloadInput.read();
-		if(marker == NODE_INFO_UPDATE_MAGIC && flags >= 0 && trailing == -1) {
-			nodeInfoUpdateFlags = flags & NODE_INFO_UPDATE_FLAGS_MASK;
-		}
 	}
 
 }