Browse Source

udp ->http

master
583641232@qq.com 7 months ago
parent
commit
78d7acaec4
  1. 4
      client/src/main/java/com/inscloudtech/alog/client/udp/HttpSender.java
  2. 5
      client/src/main/java/com/inscloudtech/alog/client/udp/UdpClient.java

4
client/src/main/java/com/inscloudtech/alog/client/udp/HttpSender.java

@ -124,11 +124,11 @@ public class HttpSender {
if(ModeHolder.getSendMode().getUnicast()){ if(ModeHolder.getSendMode().getUnicast()){
//挑一个worker //挑一个worker
rawIpPort = WorkerInfoHolder.chooseWorker(); rawIpPort = WorkerInfoHolder.chooseWorker();
ipPort = rawIpPort.substring(0, rawIpPort.lastIndexOf(":")) + ":8080";
ipPort = rawIpPort.substring(0, rawIpPort.lastIndexOf(":")) + ":8086";
}else{ }else{
//直接从TracerData中获取地址 //直接从TracerData中获取地址
rawIpPort=HttpSender.address.getHostName(); rawIpPort=HttpSender.address.getHostName();
ipPort=rawIpPort+":8080";
ipPort=rawIpPort+":8086";
} }
String url = "http://" + ipPort + "/big/receive"; String url = "http://" + ipPort + "/big/receive";

5
client/src/main/java/com/inscloudtech/alog/client/udp/UdpClient.java

@ -83,8 +83,11 @@ public class UdpClient {
byte[] compressBytes = ZstdUtils.compress(bytes); byte[] compressBytes = ZstdUtils.compress(bytes);
//20250210-全部修改为发http
//判断压缩完是否过大过大走http接口请求worker //判断压缩完是否过大过大走http接口请求worker
if (compressBytes.length >= COMPRESS_BYTES_LEN) {
// if (compressBytes.length >= COMPRESS_BYTES_LEN) {
if (1 == 1) {
//放入发okhttp的队列 //放入发okhttp的队列
HttpSender.offerBean(compressBytes,tracerData.getAddress()); HttpSender.offerBean(compressBytes,tracerData.getAddress());
return; return;

Loading…
Cancel
Save