Skip to content

Commit

Permalink
Improve the logs when the heartbeat response indicates failure (aliba…
Browse files Browse the repository at this point in the history
  • Loading branch information
linlinisme authored Mar 4, 2020
1 parent d07d17b commit 72bfe87
Show file tree
Hide file tree
Showing 4 changed files with 75 additions and 19 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -15,15 +15,15 @@
*/
package com.alibaba.csp.sentinel.transport.config;

import java.util.ArrayList;
import java.util.List;

import com.alibaba.csp.sentinel.config.SentinelConfig;
import com.alibaba.csp.sentinel.log.RecordLog;
import com.alibaba.csp.sentinel.util.HostNameUtil;
import com.alibaba.csp.sentinel.util.StringUtil;
import com.alibaba.csp.sentinel.util.function.Tuple2;

import java.util.ArrayList;
import java.util.List;

/**
* @author leyou
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,27 +15,26 @@
*/
package com.alibaba.csp.sentinel.transport.heartbeat;

import java.util.List;

import com.alibaba.csp.sentinel.Constants;
import com.alibaba.csp.sentinel.config.SentinelConfig;
import com.alibaba.csp.sentinel.log.RecordLog;
import com.alibaba.csp.sentinel.spi.SpiOrder;
import com.alibaba.csp.sentinel.transport.HeartbeatSender;
import com.alibaba.csp.sentinel.transport.config.TransportConfig;
import com.alibaba.csp.sentinel.log.RecordLog;
import com.alibaba.csp.sentinel.util.AppNameUtil;
import com.alibaba.csp.sentinel.util.HostNameUtil;
import com.alibaba.csp.sentinel.transport.HeartbeatSender;
import com.alibaba.csp.sentinel.util.PidUtil;
import com.alibaba.csp.sentinel.util.StringUtil;
import com.alibaba.csp.sentinel.util.function.Tuple2;

import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.utils.URIBuilder;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;

import java.util.List;

/**
* @author Eric Zhao
* @author leyou
Expand All @@ -45,6 +44,9 @@ public class HttpHeartbeatSender implements HeartbeatSender {

private final CloseableHttpClient client;

private static final int OK_STATUS = 200;


private final int timeoutMs = 3000;
private final RequestConfig requestConfig = RequestConfig.custom()
.setConnectionRequestTimeout(timeoutMs)
Expand Down Expand Up @@ -89,11 +91,43 @@ public boolean sendHeartbeat() throws Exception {
// Send heartbeat request.
CloseableHttpResponse response = client.execute(request);
response.close();
return true;
int statusCode = response.getStatusLine().getStatusCode();
if (statusCode == OK_STATUS) {
return true;
} else if (clientErrorCode(statusCode) || serverErrorCode(statusCode)) {
RecordLog.warn("[HttpHeartbeatSender] Failed to send heartbeat to "
+ consoleHost + ":" + consolePort + ", http status code: {0}", statusCode);
}

return false;


}

@Override
public long intervalMs() {
return 5000;
}

/**
* 4XX Client Error
*
* @param code
* @return
*/
private boolean clientErrorCode(int code) {
return code > 399 && code < 500;
}

/**
* 5XX Server Error
*
* @param code
* @return
*/
private boolean serverErrorCode(int code) {
return code > 499 && code < 600;
}


}
Original file line number Diff line number Diff line change
Expand Up @@ -15,19 +15,17 @@
*/
package com.alibaba.csp.sentinel.transport.heartbeat;

import java.net.InetSocketAddress;
import java.util.ArrayList;
import java.util.List;

import com.alibaba.csp.sentinel.log.RecordLog;
import com.alibaba.csp.sentinel.transport.HeartbeatSender;
import com.alibaba.csp.sentinel.transport.config.TransportConfig;
import com.alibaba.csp.sentinel.transport.heartbeat.client.SimpleHttpClient;
import com.alibaba.csp.sentinel.transport.heartbeat.client.SimpleHttpRequest;
import com.alibaba.csp.sentinel.transport.heartbeat.client.SimpleHttpResponse;
import com.alibaba.csp.sentinel.util.StringUtil;
import com.alibaba.csp.sentinel.util.function.Tuple2;

import java.net.InetSocketAddress;
import java.util.List;

/**
* The heartbeat sender provides basic API for sending heartbeat request to provided target.
* This implementation is based on a trivial HTTP client.
Expand Down Expand Up @@ -73,6 +71,8 @@ public boolean sendHeartbeat() throws Exception {
SimpleHttpResponse response = httpClient.post(request);
if (response.getStatusCode() == OK_STATUS) {
return true;
} else if (clientErrorCode(response.getStatusCode()) || serverErrorCode(response.getStatusCode())) {
RecordLog.warn("[SimpleHttpHeartbeatSender] Failed to send heartbeat to " + addr + ", http status code: {0}", response.getStatusCode());
}
} catch (Exception e) {
RecordLog.warn("[SimpleHttpHeartbeatSender] Failed to send heartbeat to " + addr, e);
Expand All @@ -96,4 +96,24 @@ private Tuple2<String, Integer> getAvailableAddress() {
return addressList.get(index);
}


/**
* 4XX Client Error
*
* @param code
* @return
*/
private boolean clientErrorCode(int code) {
return code > 399 && code < 500;
}

/**
* 5XX Server Error
*
* @param code
* @return
*/
private boolean serverErrorCode(int code) {
return code > 499 && code < 600;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -15,11 +15,11 @@
*/
package com.alibaba.csp.sentinel.transport.heartbeat.client;

import com.alibaba.csp.sentinel.config.SentinelConfig;

import java.nio.charset.Charset;
import java.util.Map;

import com.alibaba.csp.sentinel.config.SentinelConfig;

/**
* Simple HTTP response representation.
*
Expand Down Expand Up @@ -112,10 +112,12 @@ public String getBodyAsString() {
public String toString() {
StringBuilder buf = new StringBuilder();
buf.append(statusLine)
.append("\r\n");
for (Map.Entry<String, String> entry : headers.entrySet()) {
buf.append(entry.getKey()).append(": ").append(entry.getValue())
.append("\r\n");
if (headers != null) {
for (Map.Entry<String, String> entry : headers.entrySet()) {
buf.append(entry.getKey()).append(": ").append(entry.getValue())
.append("\r\n");
}
}
buf.append("\r\n");
buf.append(getBodyAsString());
Expand Down

0 comments on commit 72bfe87

Please sign in to comment.