Skip to content

feat(monitor): optimize http interface monitoring #5332

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 11 commits into from
Jul 5, 2023
Merged

feat(monitor): optimize http interface monitoring #5332

Changes from 8 commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
5c9ca49
feat(monitor): Optimize http interface monitoring
xxo1shine Jun 26, 2023
82ed309
Merge branch 'release_v4.7.2' of https://github.com/tronprotocol/java…
xxo1shine Jun 26, 2023
08cc798
Merge branch 'develop' of https://github.com/tronprotocol/java-tron i…
xxo1shine Jul 3, 2023
e1b9a0b
feat(monitor): remove unused filed
xxo1shine Jul 3, 2023
1a66522
feat(monitor): optimize http interface monitor
xxo1shine Jul 4, 2023
c43370a
feat(monitor): optimize monitoring logic for different http code
xxo1shine Jul 4, 2023
353587d
feat(monitor): optimize monitoring logic for http interface
xxo1shine Jul 4, 2023
e8a921f
feat(monitor): optimize code
xxo1shine Jul 4, 2023
757c15c
feat(monitor): modify monitoring key
xxo1shine Jul 4, 2023
929dfd9
Merge branch 'develop' of https://github.com/tronprotocol/java-tron i…
xxo1shine Jul 5, 2023
291d9fc
feat(unit): optimize AdvServiceTest
xxo1shine Jul 5, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
76 changes: 30 additions & 46 deletions framework/src/main/java/org/tron/core/services/filter/HttpInterceptor.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,9 @@
public class HttpInterceptor implements Filter {

private String endpoint;
private final int HTTP_NOT_FOUND = 404;
private final int HTTP_SUCCESS = 200;
private final int HTTP_BAD_REQUEST = 400;
private final int HTTP_NOT_ACCEPTABLE = 406;

@Override
public void init(FilterConfig filterConfig) {
Expand All @@ -29,64 +30,47 @@ public void init(FilterConfig filterConfig) {
@Override
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) {
try {
if (request instanceof HttpServletRequest) {
endpoint = ((HttpServletRequest) request).getRequestURI();

CharResponseWrapper responseWrapper = new CharResponseWrapper(
(HttpServletResponse) response);
chain.doFilter(request, responseWrapper);

HttpServletResponse resp = (HttpServletResponse) response;

if (resp.getStatus() != HTTP_NOT_FOUND) { // correct endpoint
String endpointQPS = MetricsKey.NET_API_DETAIL_QPS + endpoint;
MetricsUtil.meterMark(MetricsKey.NET_API_QPS);
MetricsUtil.meterMark(endpointQPS);

int reposeContentSize = responseWrapper.getByteSize();
String endpointOutTraffic = MetricsKey.NET_API_DETAIL_OUT_TRAFFIC + endpoint;
MetricsUtil.meterMark(MetricsKey.NET_API_OUT_TRAFFIC,
reposeContentSize);
MetricsUtil.meterMark(endpointOutTraffic, reposeContentSize);

if (resp.getStatus() != HTTP_SUCCESS) { //http fail
String endpointFailQPS = MetricsKey.NET_API_DETAIL_FAIL_QPS + endpoint;
MetricsUtil.meterMark(MetricsKey.NET_API_FAIL_QPS);
MetricsUtil.meterMark(endpointFailQPS);
}
} else { // wrong endpoint
MetricsUtil.meterMark(MetricsKey.NET_API_QPS);
MetricsUtil.meterMark(MetricsKey.NET_API_FAIL_QPS);
}
if (!(request instanceof HttpServletRequest)) {
chain.doFilter(request, response);
return;
}
endpoint = ((HttpServletRequest) request).getRequestURI();
CharResponseWrapper responseWrapper = new CharResponseWrapper(
(HttpServletResponse) response);
chain.doFilter(request, responseWrapper);
HttpServletResponse resp = (HttpServletResponse) response;
int size = responseWrapper.getByteSize();
MetricsUtil.meterMark(MetricsKey.NET_API_OUT_TRAFFIC, size);
MetricsUtil.meterMark(MetricsKey.NET_API_QPS);
if (resp.getStatus() >= HTTP_BAD_REQUEST && resp.getStatus() <= HTTP_NOT_ACCEPTABLE) {
MetricsUtil.meterMark(MetricsKey.NET_API_FAIL_QPS);
Metrics.histogramObserve(MetricKeys.Histogram.HTTP_BYTES,
responseWrapper.getByteSize(),
Strings.isNullOrEmpty(endpoint) ? MetricLabels.UNDEFINED : endpoint,
String.valueOf(responseWrapper.getStatus()));
size, MetricLabels.UNDEFINED, String.valueOf(responseWrapper.getStatus()));
return;
}
if (resp.getStatus() == HTTP_SUCCESS) {
MetricsUtil.meterMark(MetricsKey.NET_API_DETAIL_QPS + endpoint);
} else {
chain.doFilter(request, response);
MetricsUtil.meterMark(MetricsKey.NET_API_FAIL_QPS);
MetricsUtil.meterMark(MetricsKey.NET_API_DETAIL_FAIL_QPS + endpoint);
}

MetricsUtil.meterMark(MetricsKey.NET_API_DETAIL_OUT_TRAFFIC + endpoint, size);
Metrics.histogramObserve(MetricKeys.Histogram.HTTP_BYTES,
size, endpoint, String.valueOf(responseWrapper.getStatus()));
} catch (Exception e) {

if (MetricsUtil.getMeters(MetricsKey.NET_API_DETAIL_QPS).containsKey(
MetricsKey.NET_API_DETAIL_QPS + endpoint)) { // correct endpoint
MetricsUtil.meterMark(MetricsKey.NET_API_DETAIL_FAIL_QPS
+ endpoint, 1);
MetricsUtil.meterMark(MetricsKey.NET_API_DETAIL_QPS
+ endpoint, 1);
String key = MetricsKey.NET_API_DETAIL_QPS + endpoint;
if (MetricsUtil.getMeters(MetricsKey.NET_API_DETAIL_QPS).containsKey(key)) {
MetricsUtil.meterMark(key, 1);
MetricsUtil.meterMark(MetricsKey.NET_API_DETAIL_QPS + endpoint, 1);
}
MetricsUtil.meterMark(MetricsKey.NET_API_QPS, 1);
MetricsUtil.meterMark(MetricsKey.NET_API_FAIL_QPS, 1);

}

}

@Override
public void destroy() {

}

}


Expand Down