diff --git a/client/src/main/java/com/inscloudtech/alog/client/udp/HttpSender.java b/client/src/main/java/com/inscloudtech/alog/client/udp/HttpSender.java index 1bc461c..e4c1dd9 100644 --- a/client/src/main/java/com/inscloudtech/alog/client/udp/HttpSender.java +++ b/client/src/main/java/com/inscloudtech/alog/client/udp/HttpSender.java @@ -124,11 +124,11 @@ public class HttpSender { if(ModeHolder.getSendMode().getUnicast()){ //挑一个worker rawIpPort = WorkerInfoHolder.chooseWorker(); - ipPort = rawIpPort.substring(0, rawIpPort.lastIndexOf(":")) + ":8080"; + ipPort = rawIpPort.substring(0, rawIpPort.lastIndexOf(":")) + ":8086"; }else{ //直接从TracerData中获取地址 rawIpPort=HttpSender.address.getHostName(); - ipPort=rawIpPort+":8080"; + ipPort=rawIpPort+":8086"; } String url = "http://" + ipPort + "/big/receive"; diff --git a/client/src/main/java/com/inscloudtech/alog/client/udp/UdpClient.java b/client/src/main/java/com/inscloudtech/alog/client/udp/UdpClient.java index 217dda9..1f2aceb 100644 --- a/client/src/main/java/com/inscloudtech/alog/client/udp/UdpClient.java +++ b/client/src/main/java/com/inscloudtech/alog/client/udp/UdpClient.java @@ -83,8 +83,11 @@ public class UdpClient { byte[] compressBytes = ZstdUtils.compress(bytes); + //20250210-全部修改为发http + //判断压缩完是否过大,过大走http接口请求worker - if (compressBytes.length >= COMPRESS_BYTES_LEN) { +// if (compressBytes.length >= COMPRESS_BYTES_LEN) { + if (1 == 1) { //放入发okhttp的队列 HttpSender.offerBean(compressBytes,tracerData.getAddress()); return;