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

[collector]http公共客户端,公共缓存

Browse Source
This commit is contained in:
tomsun28
2022-02-05 16:41:52 +08:00
parent 1cac5251b0
commit 79e7040b68
3 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
collector/src/main/java/com/usthe/collector/common/CollectorProperties.java → collector/src/main/java/com/usthe/collector/collect/common/CollectorProperties.java
View File

@@ -1,4 +1,4 @@
package com.usthe.collector.common; package com.usthe.collector.collect.common;
import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

10
collector/src/main/java/com/usthe/collector/collect/database/JdbcCommonCollect.java
View File

@@ -1,9 +1,9 @@
package com.usthe.collector.collect.database; package com.usthe.collector.collect.database;
import com.usthe.collector.collect.AbstractCollect; import com.usthe.collector.collect.AbstractCollect;
import com.usthe.collector.common.cache.CacheIdentifier; import com.usthe.collector.collect.common.cache.CacheIdentifier;
import com.usthe.collector.common.cache.CommonCache; import com.usthe.collector.collect.common.cache.CommonCache;
import com.usthe.collector.common.cache.support.CommonJdbcConnect; import com.usthe.collector.collect.common.cache.JdbcConnect;
import com.usthe.collector.util.CollectorConstants; import com.usthe.collector.util.CollectorConstants;
import com.usthe.common.entity.job.Metrics; import com.usthe.common.entity.job.Metrics;
import com.usthe.common.entity.job.protocol.JdbcProtocol; import com.usthe.common.entity.job.protocol.JdbcProtocol;
@@ -88,7 +88,7 @@ public class JdbcCommonCollect extends AbstractCollect {
Optional<Object> cacheOption = CommonCache.getInstance().getCache(identifier, true); Optional<Object> cacheOption = CommonCache.getInstance().getCache(identifier, true);
Statement statement = null; Statement statement = null;
if (cacheOption.isPresent()) { if (cacheOption.isPresent()) {
CommonJdbcConnect jdbcConnect = (CommonJdbcConnect) cacheOption.get(); JdbcConnect jdbcConnect = (JdbcConnect) cacheOption.get();
try { try {
statement = jdbcConnect.getConnection().createStatement(); statement = jdbcConnect.getConnection().createStatement();
// 设置查询超时时间10秒 // 设置查询超时时间10秒
@@ -119,7 +119,7 @@ public class JdbcCommonCollect extends AbstractCollect {
statement.setQueryTimeout(10); statement.setQueryTimeout(10);
// 设置查询最大行数1000行 // 设置查询最大行数1000行
statement.setMaxRows(1000); statement.setMaxRows(1000);
CommonJdbcConnect jdbcConnect = new CommonJdbcConnect(connection); JdbcConnect jdbcConnect = new JdbcConnect(connection);
CommonCache.getInstance().addCache(identifier, jdbcConnect, 10000L); CommonCache.getInstance().addCache(identifier, jdbcConnect, 10000L);
return statement; return statement;
} }

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

@@ -5,7 +5,7 @@ import com.google.gson.JsonElement;
import com.google.gson.JsonObject; import com.google.gson.JsonObject;
import com.google.gson.JsonParser; import com.google.gson.JsonParser;
import com.usthe.collector.collect.AbstractCollect; import com.usthe.collector.collect.AbstractCollect;
import com.usthe.collector.common.http.HttpClientPool; import com.usthe.collector.collect.common.http.CommonHttpClient;
import com.usthe.collector.dispatch.DispatchConstants; import com.usthe.collector.dispatch.DispatchConstants;
import com.usthe.collector.util.CollectorConstants; import com.usthe.collector.util.CollectorConstants;
import com.usthe.collector.util.JsonPathParser; import com.usthe.collector.util.JsonPathParser;
@@ -67,7 +67,7 @@ public class HttpCollectImpl extends AbstractCollect {
HttpContext httpContext = createHttpContext(metrics.getHttp()); HttpContext httpContext = createHttpContext(metrics.getHttp());
HttpUriRequest request = createHttpRequest(metrics.getHttp()); HttpUriRequest request = createHttpRequest(metrics.getHttp());
try { try {
CloseableHttpResponse response = HttpClientPool.getHttpClient() CloseableHttpResponse response = CommonHttpClient.getHttpClient()
.execute(request, httpContext); .execute(request, httpContext);
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();
log.debug("http response status: {}", statusCode); log.debug("http response status: {}", statusCode);