hyzl-backEnd/ntrip-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ntrip-caster服务后端

Browse Source
This commit is contained in:
qubiaobiao
2026-05-18 11:44:06 +08:00
parent ee0a5c5c18
commit b85c368f8d
1 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
app/middleware/ntripCaster/ntripCaster.js
View File

@@ -345,12 +345,8 @@ class SimpleNtripCaster {
} }
} }
if (found == 'Client-Type: Virtual-NTRIP-Client/1.0') { if (found == 'Client-Type: Virtual-NTRIP-Client/1.0') {
// 开发/测试环境 const uid = lines.find(line => line.split(': ')[0] == 'uid').split(': ')[1];
const uid = lines[7].split(': ')[1]; const token = lines.find(line => line.split(': ')[0] == 'Authorization').split(': ')[1];
const token = lines[6].split(': ')[1];
// 生产环境
// const uid = lines[9].split(': ')[1];
// const token = lines[5].split(': ')[1];
let decryptUid = CryptoJS.AES.decrypt(uid, KEY, { let decryptUid = CryptoJS.AES.decrypt(uid, KEY, {
mode: CryptoJS.mode.ECB, mode: CryptoJS.mode.ECB,
padding: CryptoJS.pad.Pkcs7 padding: CryptoJS.pad.Pkcs7
@@ -370,7 +366,7 @@ class SimpleNtripCaster {
} }
} }
if (find == 'Request-Type: SIZE') { if (find == 'Request-Type: SIZE') {
const uid = lines[8].split(': ')[1]; const uid = lines.find(line => line.split(': ')[0] == 'uid').split(': ')[1];
// 接受客户端连接 // 接受客户端连接
this.sizeSockets.set(uid + ':' + mountpoint, socket); this.sizeSockets.set(uid + ':' + mountpoint, socket);
const size = [...this.clientSockets.values()].filter(value => value == mountpoint); const size = [...this.clientSockets.values()].filter(value => value == mountpoint);