fix: 降低logger等级

This commit is contained in:
yarnom 2025-10-28 15:34:47 +08:00
parent ec7f1b8ea9
commit 69b1ccdfee

View File

@ -216,13 +216,13 @@ public class RtkClusterService implements ApplicationRunner {
// OUT connection (NMEA etc.) // OUT connection (NMEA etc.)
closeQuietly(outConn); closeQuietly(outConn);
outConn = s; outConn = s;
LOGGER.info("Endpoint {} OUT connected", port); LOGGER.debug("Endpoint {} OUT connected", port);
pumpOut(outConn, probe, n); pumpOut(outConn, probe, n);
} else { } else {
// IN connection (RTCM sink) // IN connection (RTCM sink)
closeQuietly(inConn); closeQuietly(inConn);
inConn = s; inConn = s;
LOGGER.info("Endpoint {} IN connected", port); LOGGER.debug("Endpoint {} IN connected", port);
} }
} catch (IOException e) { } catch (IOException e) {
LOGGER.warn("classifyConnection error: {}", e.getMessage()); LOGGER.warn("classifyConnection error: {}", e.getMessage());
@ -247,16 +247,16 @@ public class RtkClusterService implements ApplicationRunner {
int read; int read;
// deliver first classified bytes if any // deliver first classified bytes if any
if (firstLen > 0) { if (firstLen > 0) {
String preview = new String(firstBuf, 0, Math.min(firstLen, 64), StandardCharsets.US_ASCII).replaceAll("\n", "\\n"); String preview = new String(firstBuf, 0, firstLen, StandardCharsets.US_ASCII).replaceAll("\n", "\\n");
LOGGER.info("[OUT:{}] {} bytes: {}...", port, firstLen, preview); LOGGER.info("[OUT:{}] {}", port, preview);
} }
while ((read = in.read(buf)) != -1) { while ((read = in.read(buf)) != -1) {
// For now, just log a short preview // For now, just log a short preview
String preview = new String(buf, 0, Math.min(read, 64), StandardCharsets.US_ASCII).replaceAll("\n", "\\n"); String preview = new String(buf, 0, read, StandardCharsets.US_ASCII).replaceAll("\n", "\\n");
LOGGER.info("[OUT:{}] {} bytes: {}...", port, read, preview); LOGGER.info("[OUT:{}] {}", port, preview);
} }
} catch (IOException e) { } catch (IOException e) {
LOGGER.info("OUT connection closed on {}: {}", port, e.getMessage()); LOGGER.debug("OUT connection closed on {}: {}", port, e.getMessage());
} finally { } finally {
if (outConn == s) outConn = null; if (outConn == s) outConn = null;
closeQuietly(s); closeQuietly(s);