OpenSource/hertzbeat
Public Access
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

[manager,collector] 支持HTTP类型监控的SSL参数

Browse Source
This commit is contained in:
tomsun28
2021-12-03 16:45:26 +08:00
parent 61d4759357
commit 3225961dc8
5 changed files with 108 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
collector/server/src/main/java/com/usthe/collector/collect/http/HttpCollectImpl.java
View File

@@ -71,7 +71,7 @@ public class HttpCollectImpl extends AbstractCollect {
.execute(request, httpContext);
int statusCode = response.getStatusLine().getStatusCode();
log.debug("http response status: {}", statusCode);
if (statusCode < HttpStatus.SC_OK || statusCode >= HttpStatus.SC_MULTIPLE_CHOICES) {
if (statusCode < HttpStatus.SC_OK || statusCode >= HttpStatus.SC_BAD_REQUEST) {
// 1XX 3XX 4XX 5XX 状态码 失败
builder.setCode(CollectRep.Code.FAIL);
builder.setMsg("statusCode: " + statusCode);
@@ -327,7 +327,8 @@ public class HttpCollectImpl extends AbstractCollect {
if (IpDomainUtil.isHasSchema(httpProtocol.getHost())) {
requestBuilder.setUri(httpProtocol.getHost() + ":" + httpProtocol.getPort() + httpProtocol.getUrl());
} else {
if (httpProtocol.isSsl()) {
boolean ssl = Boolean.parseBoolean(httpProtocol.getSsl());
if (ssl) {
requestBuilder.setUri("https://" + httpProtocol.getHost() + ":" + httpProtocol.getPort() + httpProtocol.getUrl());
} else {
requestBuilder.setUri("http://" + httpProtocol.getHost() + ":" + httpProtocol.getPort() + httpProtocol.getUrl());