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-15 10:40:26 +08:00
parent 6e761f3727
commit 63b8263dbb
2 changed files with 100 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
app/controller/home.js
View File

@@ -1,15 +1,5 @@
const { Controller } = require('egg'); const { Controller } = require('egg');
const GBK = require("gbk.js");
const decode = (data) => {
let arr = [];
data.match(/..?/g).forEach((element) => {
arr.push(parseInt(element, 16));
});
return GBK.decode(arr);
}
const CryptoJS = require("crypto-js"); const CryptoJS = require("crypto-js");
const KEY = CryptoJS.enc.Utf8.parse('BDQH'); const KEY = CryptoJS.enc.Utf8.parse('BDQH');

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

@@ -124,46 +124,106 @@ class SimpleNtripCaster {
const headers = this.parseHeaders(lines.slice(1, lines.indexOf(''))); const headers = this.parseHeaders(lines.slice(1, lines.indexOf('')));
let table = ''; let table = '';
this.sourcetable.forEach(element => { this.sourcetable.forEach(element => {
const { mountpoint, MountpointOptions } = element; // SourceID 数据源唯一标识
// 源ID // StreamFormat 0=RTCM 2, 1=RTCM 3.0, 2=RTCM 3.1/3.2, ...
const SourceID = MountpointOptions[0] || 'STR: '; // Details 位掩码，支持的 RTCM 消息类型
// 格式 // StreamType 1=OBS, 2=NAV, 3=STA, 4=COR
const Format = MountpointOptions[1] || 'RTCM'; // Carrier 载波相位类型
// 格式详情 // NavSys 导航系统位掩码
const FormatDetails = MountpointOptions[2] || ''; // Net 网络标识符
// 载体 // Country ISO 3166 数字代码
const Carrier = MountpointOptions[3] || ''; // Latitude 纬度
// 导航系统 // Longitude 经度
const NavSystem = MountpointOptions[4] || ''; // NMEA NMEA 消息支持
// 网络 // Solution 解算类型
const NetWork = MountpointOptions[5] || ''; // Compressed Y/N 是否压缩
// 国家 // Framed Y/N 是否帧格式
const Country = MountpointOptions[6] || ''; // MSM MSM 支持掩码
// 纬度 const { mountpoint, SourceAgent, MountpointOptions } = element;
const Latitude = MountpointOptions[7] || 0.0; let SourceID, Format, FormatDetails, StreamType, Carrier, NavSystem, NetWork, Country, Latitude, Longitude, NMEA, Soution, Compressed, Framed, MSM, Description, StreamID, Generator, Compression, Authenticated, Fee, Bitrate;
// 经度 if (SourceAgent == 'NTRIP RTKLIB/demo5_b34L_pre1') {
const Longitude = MountpointOptions[8] || 0.0; // 源ID
// NMEA SourceID = MountpointOptions[0] == '' ? '' : MountpointOptions[0];
const NMEA = MountpointOptions[9] || ''; // 格式
// 解决方案 Format = MountpointOptions[1] == '' ? 'RTCM 3.2' : MountpointOptions[1];
const Soution = MountpointOptions[10] || ''; // 格式详情
// 发生器 FormatDetails = MountpointOptions[2] == '' ? '1005(1),1033(1),1074(1),1084(1),1094(1),1114(1),1124(1)' : MountpointOptions[2];
const Generator = MountpointOptions[11] || ''; // 载体
// 压缩加密 Carrier = MountpointOptions[3] == '' ? 2 : MountpointOptions[3];
const ComprEncryp = MountpointOptions[12] || ''; // 导航系统
// 认证 NavSystem = MountpointOptions[4] == '' ? 'GPS+GLO+GAL+BDS+QZS' : MountpointOptions[4];
const Auth = MountpointOptions[13] || ''; // 网络
// 费用 NetWork = MountpointOptions[5] == '' ? '' : MountpointOptions[5];
const Fee = MountpointOptions[14] || ''; // 国家
// 比特率 Country = MountpointOptions[6] == '' ? '' : MountpointOptions[6];
const Bitrate = MountpointOptions[15] || ''; // 纬度
Latitude = MountpointOptions[7] == '' ? 0.0 : MountpointOptions[7];
// 经度
Longitude = MountpointOptions[8] == '' ? 0.0 : MountpointOptions[8];
// NMEA 消息支持
NMEA = MountpointOptions[9] == '' ? 0 : MountpointOptions[9];
// 解算类型
Soution = MountpointOptions[10] == '' ? 0 : MountpointOptions[10];
// 发生器
Generator = MountpointOptions[11] == '' ? 'B' : MountpointOptions[11];
// 压缩加密
Compression = MountpointOptions[12] == '' ? 'N' : MountpointOptions[12];
// 认证
Authenticated = MountpointOptions[13] == '' ? 'N' : MountpointOptions[13];
// 费用
Fee = MountpointOptions[14] == '' ? 'N' : MountpointOptions[14];
// 比特率
Bitrate = MountpointOptions[15] == '' ? '115200' : MountpointOptions[15];
// 描述
Description = 'RTK';
// 流ID
StreamID = 'none';
} else {
// 源ID
SourceID = MountpointOptions[0] == '' ? '' : MountpointOptions[0];
// 格式
Format = MountpointOptions[1] == '' ? 'RTCM 3.2' : MountpointOptions[1];
// 格式详情
FormatDetails = MountpointOptions[2] == '' ? '1005(1),1033(1),1074(1),1084(1),1094(1),1114(1),1124(1)' : MountpointOptions[2];
StreamType = MountpointOptions[3] == '' ? '' : MountpointOptions[3];
// 载体
Carrier = MountpointOptions[4] == '' ? 2 : MountpointOptions[4];
// 导航系统
NavSystem = MountpointOptions[5] == '' ? 'GPS+GLO+GAL+BDS+QZS' : MountpointOptions[5];
// 网络
NetWork = MountpointOptions[6] == '' ? '' : MountpointOptions[6];
// 国家
Country = MountpointOptions[7] == '' ? '' : MountpointOptions[7];
// 纬度
Latitude = MountpointOptions[8] == '' ? 0.0 : MountpointOptions[8];
// 经度
Longitude = MountpointOptions[9] == '' ? 0.0 : MountpointOptions[9];
// NMEA
NMEA = MountpointOptions[10] == '' ? 0 : MountpointOptions[10];
// 解决方案
Soution = MountpointOptions[11] == '' ? 0 : MountpointOptions[11];
// 描述
Description = 'RTK';
// 流ID
StreamID = 'none';
// 发生器
Generator = 'B';
// 压缩加密
Compression = 'N';
}
const found = lines.find(line => line.startsWith('Ntrip-Version: Ntrip/2.0')); const found = lines.find(line => line.startsWith('Ntrip-Version: Ntrip/2.0'));
if (found == 'Ntrip-Version: Ntrip/2.0') { if (found == 'Ntrip-Version: Ntrip/2.0') {
// 变体B：RTCM/ntrip-2风格 if (SourceAgent == 'NTRIP RTKLIB/demo5_b34L_pre1') {
table += `STR;${Format};${mountpoint};${FormatDetails};;${Carrier};${NavSystem};${NetWork};${Country};${Latitude};${Longitude};${NMEA};${SourceID};;;;\r\n`; table += `STR;${mountpoint};${SourceID};${Format};${FormatDetails};${Carrier};${NavSystem};${NetWork};${Country};${Latitude};${Longitude};${NMEA};${Soution};${Description};${StreamID};${Generator};${Compression};${Authenticated};${Fee};${Bitrate};none\r\n`;
} else {
// 变体B：RTCM/ntrip-2风格
// table += `STR;${Format};${mountpoint};${FormatDetails};;${Carrier};${NavSystem};${NetWork};${Country};${Latitude};${Longitude};${NMEA};${SourceID};;;;\r\n`;
table += `STR;${Format};${SourceID};${mountpoint};${Format};${FormatDetails};${Carrier};${NavSystem};${NetWork};${Country};${Latitude};${Longitude};${NMEA};${Soution};${Description};${StreamID};${Generator};${Compression};${Authenticated};${Fee};${Bitrate};0\r\n`;
}
} else { } else {
// 变体A：BKG/NTRIP 1.0风格 // 变体A：BKG/NTRIP 1.0风格
table += `STR;${Format};${mountpoint};${FormatDetails};;${Carrier};${NavSystem};${SourceID};${Latitude};${Longitude};0.0;${NetWork};${Country};;;;\r\n`; // table += `STR;${Format};${mountpoint};${FormatDetails};;${Carrier};${NavSystem};${SourceID};${Latitude};${Longitude};0.0;${NetWork};${Country};;;;\r\n`;
table += `STR;${Format};${mountpoint};${Format};${FormatDetails};${Carrier};${NavSystem};${NetWork};${Country};${Latitude};${Longitude};${NMEA};${Soution};${Description};${StreamID};${Generator};${Compression};0\r\n`;
} }
}); });
table += 'ENDSOURCETABLE\r\n'; table += 'ENDSOURCETABLE\r\n';
@@ -206,8 +266,9 @@ class SimpleNtripCaster {
this.sendResponse(socket, 401, 'Unauthorized', {}); this.sendResponse(socket, 401, 'Unauthorized', {});
return; return;
} }
const MountpointOptions = lines[2].split(';'); const SourceAgent = lines[1].split(': ')[1];
this.sourcetable.push({ password, mountpoint, MountpointOptions }); const MountpointOptions = lines[2].split(': ')[1].split(';');
this.sourcetable.push({ password, mountpoint, SourceAgent, MountpointOptions });
this.serverSockets.set(mountpoint, socket); this.serverSockets.set(mountpoint, socket);
this.mountData.set(mountpoint, { this.mountData.set(mountpoint, {
socket: socket, socket: socket,
@@ -278,7 +339,7 @@ class SimpleNtripCaster {
if (find !== 'Request-Type: SIZE') { if (find !== 'Request-Type: SIZE') {
if (!this.mountData.has(mountpoint)) { if (!this.mountData.has(mountpoint)) {
this.sendResponse(socket, 404, 'Mountpoint Not Found', { this.sendResponse(socket, 404, 'Mountpoint Not Found', {
'Access-Control-Allow-Origin': headers.origin 'Access-Control-Allow-Origin': '*'
}); });
return; return;
} }