KERNEL-5825 上传打包请求后端代码 #1
Merged
Zhenfei.Li
merged 1 commits from Jonas/plugin-bi-pack-request:master
into master
4 years ago
16 changed files with 634 additions and 3 deletions
@ -0,0 +1,14 @@ |
|||||||
|
package com.fr.plugin.pack; |
||||||
|
|
||||||
|
/** |
||||||
|
* @author Jonas |
||||||
|
* @version 5.1.3 |
||||||
|
* Created by Jonas on 2020-10-19 |
||||||
|
*/ |
||||||
|
public class PackConstants { |
||||||
|
public final static String WIDGET_EXCEED_ERROR = "61310099"; |
||||||
|
public final static String REPORT_EXCEED_ERROR = "61310098"; |
||||||
|
|
||||||
|
public final static String WIDGET_TRAFFIC_NAME = "Widget"; |
||||||
|
public final static String REPORT_TRAFFIC_NAME = "Report"; |
||||||
|
} |
@ -0,0 +1,19 @@ |
|||||||
|
package com.fr.plugin.pack; |
||||||
|
|
||||||
|
import com.fr.decision.fun.HttpHandler; |
||||||
|
import com.fr.decision.fun.impl.AbstractHttpHandlerProvider; |
||||||
|
import com.fr.plugin.pack.http.PackHttpHandler; |
||||||
|
|
||||||
|
/** |
||||||
|
* @author Jonas |
||||||
|
* @version 5.1.3 |
||||||
|
* Created by Jonas on 2020-10-19 |
||||||
|
*/ |
||||||
|
public class PackHandlerProvider extends AbstractHttpHandlerProvider { |
||||||
|
@Override |
||||||
|
public HttpHandler[] registerHandlers() { |
||||||
|
return new HttpHandler[]{ |
||||||
|
new PackHttpHandler() |
||||||
|
}; |
||||||
|
} |
||||||
|
} |
@ -0,0 +1,20 @@ |
|||||||
|
package com.fr.plugin.pack; |
||||||
|
|
||||||
|
import com.fr.decision.fun.impl.AbstractURLAliasProvider; |
||||||
|
import com.fr.decision.webservice.url.alias.URLAlias; |
||||||
|
import com.fr.decision.webservice.url.alias.URLAliasFactory; |
||||||
|
import com.fr.plugin.pack.http.PackHttpHandler; |
||||||
|
|
||||||
|
/** |
||||||
|
* @author Jonas |
||||||
|
* @version 5.1.3 |
||||||
|
* Created by Jonas on 2020-10-19 |
||||||
|
*/ |
||||||
|
public class PackURLAliasProvider extends AbstractURLAliasProvider { |
||||||
|
@Override |
||||||
|
public URLAlias[] registerAlias() { |
||||||
|
return new URLAlias[]{ |
||||||
|
URLAliasFactory.createPluginAlias(PackHttpHandler.PATH, PackHttpHandler.PATH,false) |
||||||
|
}; |
||||||
|
} |
||||||
|
} |
@ -0,0 +1,62 @@ |
|||||||
|
package com.fr.plugin.pack; |
||||||
|
|
||||||
|
import com.finebi.common.api.vo.table.parameter.Parameters; |
||||||
|
import com.finebi.common.exception.FineEngineException; |
||||||
|
import com.finebi.common.exception.execute.FineWidgetNoDataException; |
||||||
|
import com.finebi.dashboard.api.bean.widget.WidgetBean; |
||||||
|
import com.finebi.dashboard.api.cell.DashboardCellCreator; |
||||||
|
import com.finebi.dashboard.api.fun.AbstractWidgetExecuteProvider; |
||||||
|
import com.finebi.dashboard.api.structure.result.preview.BIPreViewResult; |
||||||
|
import com.finebi.dashboard.impl.widget.EngineResultToPreViewResultVisitor; |
||||||
|
import com.finebi.dashboard.impl.widget.FineWidget; |
||||||
|
import com.finebi.dashboard.impl.widget.visitor.DefaultBeanToWidget; |
||||||
|
import com.finebi.dashboard.impl.widget.visitor.TableAbsentChecker; |
||||||
|
import com.finebi.dashboard.impl.widget.visitor.UrlParameterProcessor; |
||||||
|
import com.finebi.dashboard.impl.widget.visitor.WidgetBeanToFineWidgetVisitor; |
||||||
|
import com.finebi.foundation.api.structure.result.BIResult; |
||||||
|
import com.fr.decision.authority.data.User; |
||||||
|
import com.fr.plugin.pack.exception.WidgetExceedException; |
||||||
|
import com.fr.plugin.pack.traffic.PackTraffic; |
||||||
|
import com.fr.plugin.pack.traffic.PackTrafficFactory; |
||||||
|
|
||||||
|
import java.util.Optional; |
||||||
|
|
||||||
|
/** |
||||||
|
* @author Jonas |
||||||
|
* @version 5.1.3 |
||||||
|
* Created by Jonas on 2020-10-19 |
||||||
|
*/ |
||||||
|
public class PackWidgetExecuteProvider extends AbstractWidgetExecuteProvider { |
||||||
|
private PackTraffic widgetTraffic = PackTrafficFactory.getWidgetTraffic(); |
||||||
|
|
||||||
|
@Override |
||||||
|
public BIPreViewResult getPreViewResult(WidgetBean widgetBean, User user, Parameters parameters) throws FineEngineException { |
||||||
|
String widgetId = null; |
||||||
|
try { |
||||||
|
widgetId = widgetBean.getWid(); |
||||||
|
if (!widgetTraffic.offer(widgetId)) { |
||||||
|
throw new WidgetExceedException(); |
||||||
|
} |
||||||
|
return getResult(widgetBean, user, parameters); |
||||||
|
} finally { |
||||||
|
widgetTraffic.release(widgetId); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private BIPreViewResult getResult(WidgetBean widgetBean, User user, Parameters parameters) throws FineEngineException { |
||||||
|
// bean转widget
|
||||||
|
TableAbsentChecker.check(widgetBean); |
||||||
|
FineWidget widget = new DefaultBeanToWidget<>(new WidgetBeanToFineWidgetVisitor(user)) |
||||||
|
.addProcess(new UrlParameterProcessor(parameters)) |
||||||
|
.translate(widgetBean); |
||||||
|
// 从引擎拿计算数据
|
||||||
|
BIResult engineResult = getEngineExecutorResult(widget); |
||||||
|
EngineResultToPreViewResultVisitor resultTranVisitor = new EngineResultToPreViewResultVisitor(engineResult, parameters); |
||||||
|
return widget.accept(resultTranVisitor); |
||||||
|
} |
||||||
|
|
||||||
|
private BIResult getEngineExecutorResult(FineWidget fineWidget) throws FineEngineException { |
||||||
|
Optional<BIResult> execute = DashboardCellCreator.widgetExecutor().execute(fineWidget); |
||||||
|
return execute.orElseThrow(() -> new FineWidgetNoDataException("widget result is null !widget name is : " + fineWidget.getWidgetName())); |
||||||
|
} |
||||||
|
} |
@ -0,0 +1,23 @@ |
|||||||
|
package com.fr.plugin.pack.bean; |
||||||
|
|
||||||
|
import com.finebi.dashboard.api.bean.widget.WidgetBean; |
||||||
|
|
||||||
|
import java.util.HashMap; |
||||||
|
import java.util.Map; |
||||||
|
|
||||||
|
/** |
||||||
|
* @author Jonas |
||||||
|
* @version 5.1.3 |
||||||
|
* Created by Jonas on 2020-10-19 |
||||||
|
*/ |
||||||
|
public class WidgetsBean { |
||||||
|
private Map<String, WidgetBean> widgets = new HashMap<>(); |
||||||
|
|
||||||
|
public Map<String, WidgetBean> getWidgets() { |
||||||
|
return widgets; |
||||||
|
} |
||||||
|
|
||||||
|
public void setWidgets(Map<String, WidgetBean> widgets) { |
||||||
|
this.widgets = widgets; |
||||||
|
} |
||||||
|
} |
@ -0,0 +1,74 @@ |
|||||||
|
package com.fr.plugin.pack.conf; |
||||||
|
|
||||||
|
import com.fr.config.ConfigContext; |
||||||
|
import com.fr.config.DefaultConfiguration; |
||||||
|
import com.fr.config.Identifier; |
||||||
|
import com.fr.config.Status; |
||||||
|
import com.fr.config.Visualization; |
||||||
|
import com.fr.config.holder.Conf; |
||||||
|
import com.fr.config.holder.factory.Holders; |
||||||
|
|
||||||
|
/** |
||||||
|
* @author Jonas |
||||||
|
* @version 5.1.3 |
||||||
|
* Created by Jonas on 2020-10-20 |
||||||
|
*/ |
||||||
|
@Visualization(category = "打包插件参数") |
||||||
|
public class PackPluginConfig extends DefaultConfiguration { |
||||||
|
private static volatile PackPluginConfig config = null; |
||||||
|
|
||||||
|
// sql查询超时时间(JDBC属性)单位秒
|
||||||
|
@Identifier(value = "sqlQueryTimeout", status = Status.SHOW, name = "SQL查询超时时间", description = "单位秒(JDBC设置queryTimeout)") |
||||||
|
private Conf<Integer> sqlQueryTimeout = Holders.simple(60); |
||||||
|
|
||||||
|
// 组件查询超时时间单位毫秒
|
||||||
|
@Identifier(value = "widgetQueryTimeout", status = Status.SHOW, name = "组件查询超时时间", description = "单位毫秒") |
||||||
|
private Conf<Integer> widgetQueryTimeout = Holders.simple(3 * 60 * 1000); |
||||||
|
|
||||||
|
// 最大模板并发访问度
|
||||||
|
@Identifier(value = "reportQueryMax", status = Status.SHOW, name = "最大模板并发访问度", description = "模板并发个数") |
||||||
|
private Conf<Integer> reportQueryMax = Holders.simple(3); |
||||||
|
|
||||||
|
// 最大组件并发组件并发访问度
|
||||||
|
@Identifier(value = "widgetQueryMax", status = Status.SHOW, name = "最大组件并发组件并发访问度", description = "组件并发个数") |
||||||
|
private Conf<Integer> widgetQueryMax = Holders.simple(6); |
||||||
|
|
||||||
|
public static PackPluginConfig getInstance() { |
||||||
|
if (config == null) { |
||||||
|
config = ConfigContext.getConfigInstance(PackPluginConfig.class); |
||||||
|
} |
||||||
|
return config; |
||||||
|
} |
||||||
|
|
||||||
|
public int getSqlQueryTimeout() { |
||||||
|
return sqlQueryTimeout.get(); |
||||||
|
} |
||||||
|
|
||||||
|
public void setSqlQueryTimeout(int sqlQueryTimeout) { |
||||||
|
this.sqlQueryTimeout.set(sqlQueryTimeout); |
||||||
|
} |
||||||
|
|
||||||
|
public int getWidgetQueryTimeout() { |
||||||
|
return widgetQueryTimeout.get(); |
||||||
|
} |
||||||
|
|
||||||
|
public void setWidgetQueryTimeout(int widgetQueryTimeout) { |
||||||
|
this.widgetQueryTimeout.set(widgetQueryTimeout); |
||||||
|
} |
||||||
|
|
||||||
|
public int getReportQueryMax() { |
||||||
|
return reportQueryMax.get(); |
||||||
|
} |
||||||
|
|
||||||
|
public void setReportQueryMax(int reportQueryMax) { |
||||||
|
this.reportQueryMax.set(reportQueryMax); |
||||||
|
} |
||||||
|
|
||||||
|
public int getWidgetQueryMax() { |
||||||
|
return widgetQueryMax.get(); |
||||||
|
} |
||||||
|
|
||||||
|
public void setWidgetQueryMax(int widgetQueryMax) { |
||||||
|
this.widgetQueryMax.set(widgetQueryMax); |
||||||
|
} |
||||||
|
} |
@ -0,0 +1,16 @@ |
|||||||
|
package com.fr.plugin.pack.exception; |
||||||
|
|
||||||
|
import com.finebi.common.exception.FineEngineException; |
||||||
|
import com.fr.plugin.pack.PackConstants; |
||||||
|
|
||||||
|
/** |
||||||
|
* @author Jonas |
||||||
|
* @version 5.1.3 |
||||||
|
* Created by Jonas on 2020-10-19 |
||||||
|
*/ |
||||||
|
public class ReportExceedException extends FineEngineException { |
||||||
|
@Override |
||||||
|
public String errorCode() { |
||||||
|
return PackConstants.REPORT_EXCEED_ERROR; |
||||||
|
} |
||||||
|
} |
@ -0,0 +1,16 @@ |
|||||||
|
package com.fr.plugin.pack.exception; |
||||||
|
|
||||||
|
import com.finebi.common.exception.FineEngineException; |
||||||
|
import com.fr.plugin.pack.PackConstants; |
||||||
|
|
||||||
|
/** |
||||||
|
* @author Jonas |
||||||
|
* @version 5.1.3 |
||||||
|
* Created by Jonas on 2020-10-19 |
||||||
|
*/ |
||||||
|
public class WidgetExceedException extends FineEngineException { |
||||||
|
@Override |
||||||
|
public String errorCode() { |
||||||
|
return PackConstants.WIDGET_EXCEED_ERROR; |
||||||
|
} |
||||||
|
} |
@ -0,0 +1,150 @@ |
|||||||
|
package com.fr.plugin.pack.http; |
||||||
|
|
||||||
|
import com.finebi.activate.foundation.StableManager; |
||||||
|
import com.finebi.base.concurrent.DefaultThreadFactory; |
||||||
|
import com.finebi.common.api.vo.table.parameter.Parameters; |
||||||
|
import com.finebi.dashboard.api.bean.widget.WidgetBean; |
||||||
|
import com.finebi.dashboard.api.service.FineDashBoardService; |
||||||
|
import com.finebi.dashboard.api.service.FineWidgetExecutorService; |
||||||
|
import com.finebi.dashboard.api.structure.result.preview.BIPreViewResult; |
||||||
|
import com.finebi.dashboard.impl.helper.FineDashBoardUtils; |
||||||
|
import com.finebi.foundation.api.reponse.FineRespond; |
||||||
|
import com.finebi.foundation.api.service.FineService; |
||||||
|
import com.finebi.selector.api.DirectSourceEngineFactory; |
||||||
|
import com.finebi.utils.CollectionUtils; |
||||||
|
import com.finebi.utils.StringUtils; |
||||||
|
import com.finebi.web.action.v5.BaseAction; |
||||||
|
import com.fr.decision.authority.data.User; |
||||||
|
import com.fr.decision.fun.impl.BaseHttpHandler; |
||||||
|
import com.fr.general.IOUtils; |
||||||
|
import com.fr.invoke.Reflect; |
||||||
|
import com.fr.log.FineLoggerFactory; |
||||||
|
import com.fr.plugin.pack.bean.WidgetsBean; |
||||||
|
import com.fr.plugin.pack.conf.PackPluginConfig; |
||||||
|
import com.fr.plugin.pack.exception.ReportExceedException; |
||||||
|
import com.fr.plugin.pack.exception.WidgetExceedException; |
||||||
|
import com.fr.plugin.pack.source.PackDBSourceEngine; |
||||||
|
import com.fr.plugin.pack.traffic.PackTraffic; |
||||||
|
import com.fr.plugin.pack.traffic.PackTrafficFactory; |
||||||
|
import com.fr.third.fasterxml.jackson.databind.ObjectMapper; |
||||||
|
import com.fr.third.springframework.web.bind.annotation.RequestMethod; |
||||||
|
import com.fr.web.utils.WebUtils; |
||||||
|
|
||||||
|
import javax.servlet.http.HttpServletRequest; |
||||||
|
import javax.servlet.http.HttpServletResponse; |
||||||
|
import java.util.ArrayList; |
||||||
|
import java.util.HashMap; |
||||||
|
import java.util.List; |
||||||
|
import java.util.Map; |
||||||
|
import java.util.Set; |
||||||
|
import java.util.concurrent.ExecutorService; |
||||||
|
import java.util.concurrent.Executors; |
||||||
|
import java.util.concurrent.Future; |
||||||
|
import java.util.concurrent.TimeUnit; |
||||||
|
import java.util.concurrent.TimeoutException; |
||||||
|
import java.util.stream.Collectors; |
||||||
|
|
||||||
|
/** |
||||||
|
* @author Jonas |
||||||
|
* @version 5.1.3 |
||||||
|
* Created by Jonas on 2020-10-19 |
||||||
|
*/ |
||||||
|
public class PackHttpHandler extends BaseHttpHandler { |
||||||
|
private PackTraffic reportTraffic = PackTrafficFactory.getReportTraffic(); |
||||||
|
public static String PATH = "/widgets/data"; |
||||||
|
private ExecutorService executorService = Executors.newCachedThreadPool(new DefaultThreadFactory("pack-widget-execute")); |
||||||
|
|
||||||
|
{ |
||||||
|
DirectSourceEngineFactory.INSTANCE.register(new PackDBSourceEngine()); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public RequestMethod getMethod() { |
||||||
|
return RequestMethod.POST; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public String getPath() { |
||||||
|
return PATH; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public boolean isPublic() { |
||||||
|
return false; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void handle(HttpServletRequest request, HttpServletResponse response) throws Exception { |
||||||
|
ObjectMapper mapper = new ObjectMapper(); |
||||||
|
String reportId = null; |
||||||
|
try { |
||||||
|
String body = IOUtils.inputStream2String(request.getInputStream()); |
||||||
|
WidgetsBean widgetsBean = mapper.readValue(body, WidgetsBean.class); |
||||||
|
|
||||||
|
Map<String, Object> result = new HashMap<>(); |
||||||
|
Set<String> reportIds = widgetsBean.getWidgets().values().stream().map(WidgetBean::getReportId).collect(Collectors.toSet()); |
||||||
|
if (CollectionUtils.isEmpty(reportIds)) { |
||||||
|
throw new UnsupportedOperationException(); |
||||||
|
} else { |
||||||
|
reportId = reportIds.iterator().next(); |
||||||
|
if (StringUtils.isEmpty(reportId)) { |
||||||
|
throw new UnsupportedOperationException("reportId must be not emtpy"); |
||||||
|
} |
||||||
|
} |
||||||
|
if (!reportTraffic.offer(reportId)) { |
||||||
|
throw new ReportExceedException(); |
||||||
|
} |
||||||
|
try { |
||||||
|
List<Future<?>> futures = new ArrayList<>(); |
||||||
|
for (Map.Entry<String, WidgetBean> entry : widgetsBean.getWidgets().entrySet()) { |
||||||
|
WidgetBean widgetBean = entry.getValue(); |
||||||
|
User user = FineDashBoardUtils.getUserFromReq(request, widgetBean.getReportId()); |
||||||
|
boolean mobile = FineDashBoardUtils.isMobile(request); |
||||||
|
Parameters parameterFromRequest = FineDashBoardUtils.getParameterFromRequest(request); |
||||||
|
String widgetId = entry.getKey(); |
||||||
|
Future<?> future = executorService.submit(() -> { |
||||||
|
try { |
||||||
|
BIPreViewResult widgetData = Reflect.on(FineDashBoardUtils.class) |
||||||
|
.call("getWidgetData", widgetBean, user, mobile, parameterFromRequest, |
||||||
|
getBean(FineDashBoardService.class), getBean(FineWidgetExecutorService.class)) |
||||||
|
.get(); |
||||||
|
result.put(widgetId, FineRespond.success(widgetData)); |
||||||
|
} catch (Exception e) { |
||||||
|
FineLoggerFactory.getLogger().debug(e.getMessage(), e); |
||||||
|
result.put(widgetId, handleException(e)); |
||||||
|
} |
||||||
|
}); |
||||||
|
futures.add(future); |
||||||
|
} |
||||||
|
for (Future<?> future : futures) { |
||||||
|
try { |
||||||
|
// 设置超时时间,不能一直在等着
|
||||||
|
future.get(PackPluginConfig.getInstance().getWidgetQueryTimeout(), TimeUnit.MILLISECONDS); |
||||||
|
} catch (TimeoutException e) { |
||||||
|
future.cancel(true); |
||||||
|
} |
||||||
|
} |
||||||
|
WebUtils.printAsString(response, mapper.writeValueAsString(FineRespond.success(result))); |
||||||
|
} finally { |
||||||
|
reportTraffic.release(reportId); |
||||||
|
} |
||||||
|
} catch (Exception e) { |
||||||
|
e.printStackTrace(); |
||||||
|
WebUtils.printAsString(response, mapper.writeValueAsString(FineRespond.fail("500", mapper.writeValueAsString(handleException(e))))); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private static FineRespond handleException(Exception e) { |
||||||
|
if (e instanceof ReportExceedException) { |
||||||
|
return FineRespond.fail(((ReportExceedException) e).errorCode(), e.getMessage()); |
||||||
|
} |
||||||
|
if (e instanceof WidgetExceedException) { |
||||||
|
return FineRespond.fail(((WidgetExceedException) e).errorCode(), e.getMessage()); |
||||||
|
} |
||||||
|
return Reflect.on(BaseAction.class).call("getExceptionRespond", e).get(); |
||||||
|
} |
||||||
|
|
||||||
|
private static <T extends FineService> T getBean(Class<T> annotatedClass) { |
||||||
|
return StableManager.getContext().getServiceBean(annotatedClass); |
||||||
|
} |
||||||
|
} |
@ -0,0 +1,25 @@ |
|||||||
|
package com.fr.plugin.pack.source; |
||||||
|
|
||||||
|
import com.finebi.api.criterion.Table; |
||||||
|
import com.finebi.base.datasource.ConnectionCreator; |
||||||
|
import com.fr.data.core.db.dialect.Dialect; |
||||||
|
import com.fr.engine.sql.database.DataBaseSourceEngine; |
||||||
|
import com.fr.plugin.pack.conf.PackPluginConfig; |
||||||
|
|
||||||
|
import java.sql.Connection; |
||||||
|
import java.sql.ResultSet; |
||||||
|
import java.sql.SQLException; |
||||||
|
import java.sql.Statement; |
||||||
|
|
||||||
|
/** |
||||||
|
* @author Jonas |
||||||
|
* @version 5.1.3 |
||||||
|
* Created by Jonas on 2020-10-20 |
||||||
|
*/ |
||||||
|
public class PackDBSourceEngine extends DataBaseSourceEngine { |
||||||
|
@Override |
||||||
|
protected ResultSet executeQuery(Connection conn, Statement statement, String sql, Table table, ConnectionCreator connectionCreator, Dialect dialect) throws SQLException { |
||||||
|
statement.setQueryTimeout(PackPluginConfig.getInstance().getSqlQueryTimeout()); |
||||||
|
return dialect.executeQuery(statement, sql, conn); |
||||||
|
} |
||||||
|
} |
@ -0,0 +1,12 @@ |
|||||||
|
package com.fr.plugin.pack.traffic; |
||||||
|
|
||||||
|
/** |
||||||
|
* @author Jonas |
||||||
|
* @version 5.1.3 |
||||||
|
* Created by Jonas on 2020-10-19 |
||||||
|
*/ |
||||||
|
public interface PackTraffic { |
||||||
|
boolean offer(String id); |
||||||
|
|
||||||
|
void release(String id); |
||||||
|
} |
@ -0,0 +1,22 @@ |
|||||||
|
package com.fr.plugin.pack.traffic; |
||||||
|
|
||||||
|
import com.fr.plugin.pack.PackConstants; |
||||||
|
import com.fr.plugin.pack.conf.PackPluginConfig; |
||||||
|
|
||||||
|
/** |
||||||
|
* @author Jonas |
||||||
|
* @version 5.1.3 |
||||||
|
* Created by Jonas on 2020-10-19 |
||||||
|
*/ |
||||||
|
public class PackTrafficFactory { |
||||||
|
private static PackTraffic widgetTraffic = new PackTrafficImpl(PackConstants.WIDGET_TRAFFIC_NAME,() -> PackPluginConfig.getInstance().getWidgetQueryMax()); |
||||||
|
private static PackTraffic reportTraffic = new PackTrafficImpl(PackConstants.REPORT_TRAFFIC_NAME,() -> PackPluginConfig.getInstance().getReportQueryMax()); |
||||||
|
|
||||||
|
public static PackTraffic getWidgetTraffic() { |
||||||
|
return widgetTraffic; |
||||||
|
} |
||||||
|
|
||||||
|
public static PackTraffic getReportTraffic() { |
||||||
|
return reportTraffic; |
||||||
|
} |
||||||
|
} |
@ -0,0 +1,48 @@ |
|||||||
|
package com.fr.plugin.pack.traffic; |
||||||
|
|
||||||
|
import com.fr.log.FineLoggerFactory; |
||||||
|
|
||||||
|
import java.util.Map; |
||||||
|
import java.util.concurrent.ConcurrentHashMap; |
||||||
|
import java.util.function.Supplier; |
||||||
|
|
||||||
|
/** |
||||||
|
* @author Jonas |
||||||
|
* @version 5.1.3 |
||||||
|
* Created by Jonas on 2020-10-19 |
||||||
|
*/ |
||||||
|
public class PackTrafficImpl implements PackTraffic { |
||||||
|
private Map<String, Integer> mapCount = new ConcurrentHashMap<>(); |
||||||
|
private Supplier<Integer> maxCount; |
||||||
|
private String name; |
||||||
|
|
||||||
|
public PackTrafficImpl(String name, Supplier<Integer> maxCount) { |
||||||
|
this.name = name; |
||||||
|
this.maxCount = maxCount; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public synchronized boolean offer(String id) { |
||||||
|
Integer count = mapCount.get(id); |
||||||
|
if (count == null) { |
||||||
|
count = 0; |
||||||
|
} |
||||||
|
int addCount = count + 1; |
||||||
|
if (addCount > maxCount.get()) { |
||||||
|
FineLoggerFactory.getLogger().info("PackTraffic({}) false {} addCount {}", name, id, addCount); |
||||||
|
return false; |
||||||
|
} |
||||||
|
mapCount.put(id, addCount); |
||||||
|
FineLoggerFactory.getLogger().info("PackTraffic({}) true {} addCount {}", name, id, addCount); |
||||||
|
return true; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public synchronized void release(String id) { |
||||||
|
Integer count = mapCount.get(id); |
||||||
|
if (count <= 1) { |
||||||
|
mapCount.remove(id); |
||||||
|
} |
||||||
|
mapCount.put(id, count - 1); |
||||||
|
} |
||||||
|
} |
File diff suppressed because one or more lines are too long
Loading…
Reference in new issue