- Java锁的逻辑(结合对象头和ObjectMonitor)
- 还在用饼状图?来瞧瞧这些炫酷的百分比可视化新图形(附代码实现)⛵
- 自动注册实体类到EntityFrameworkCore上下文,并适配ABP及ABPVNext
- 基于Sklearn机器学习代码实战
业务监控是指通过技术手段监控业务代码执行的最终结果或者状态是否符合预期,实现业务监控主要分成两步:1、在业务系统中选择节点发送消息触发业务监控;2、系统在接收到mq消息或者定时任务调度时,根据消息中或者任务中的业务数据查询业务执行的结果或状态并与业务预期的结果相对比。目前供销系统的方案如下:
由业务系统发送消息触发规则中心的校验任务,校验逻辑和报警规则通过规则中心的groovy脚本代码实现,该方案的缺点如下: 1.业务监控代码掺杂在正常的业务代码中,业务监控的代码侵入性高; 2.业务监控消息触发代码可复用性极低,各个应用都要维护一套代码,后期若要增加或维护某个功能时成本大; 3.增加业务监控的开发工作量,开发人员需要开发和维护与业务监控功能无关的代码,如:消息触发降级功能、性能监控、异步触发等功能; 为解决上述问题,本文提出了一种通用的业务监控触发方案.
public class BusinessCheckMessage {
/**
* 监控类型
*/
private String businessType;
/**
* 业务监控需要的参数
*/
private Object data;
/**
* 业务方
*/
private String businessSource;
/**
* 当前所属的topic
*/
private String topic;
}
其中, businessType用于区分业务监控的类型,如:终止合作、提单等; data用于存储和业务相关的关键数据,如订单id、商家id等; businessSource用于区分不同业务方的业务,如:万商的提单、供销的提单等; topic用于隔离消息,如:业务监控任务执行快的可以用主题A、执行慢的的可以用主题B等; 。
2.自定义注解 + 切面 以供销系统业务监控为例,接近50%的场景是将方法体中的参数作为业务数据来触发业务监控,针对此场景,本文采用 注解+切面 解耦业务监控代码和正常业务代码,降低业务监控代码对正常的业务代码的侵入,其中自定义注解负责获取业务监控需要用到的方法入参中的相关数据,切面负责组装通用mq数据模型并完成消息的发送。自定义注解定义如下:
public @interface BusinessCheckPoint {
/**
* 业务监控类型
*/
String businessType();
/**
* 业务方
*/
String businessSource();
/**
* 要发送的消息的topic
*/
String businessTopic();
/**
* 方法参数的第几个参数作为消息内容,从0开始
*/
int dataIndex();
/**
* 在执行业务流程前发送消息
* 默认在业务流程执行后发送消息
*/
boolean beforeOperate() default false;
}
其中, businesstype用于获取业务监控类型; businessSource用于获取业务方; businessTopic用于获取当前要发送的消息主体; dataIndex用于获取方法体参数中的数据,从0开始; beforeOperate用于获取消息发送的时间,在业务流程执行后发送消息还是业务流程执行前发消息; 。
3.侵入式触发业务监控 考虑到业务系统可能会在复杂场景下触发业务监控,本文也提供了通用的解决方案,具体如何使用见下一章节的实战介绍.
1.引入依赖 。
<dependency>
<groupId>com.jd</groupId>
<artifactId>business.check</artifactId>
<version>1.0.0</version>
</dependency>
2.初始化切面 。
<bean id="businessCheckAspect" class="com.jd.gmall.monitor.aspect.BusinessCheckAspect"/>
3.Producer及线程池赋值 。
<bean id="businessCheckHandler" class="com.jd.gmall.monitor.service.impl.BusinessCheckHandlerImpl">
<property name="messageProducerMap">
<map>
<entry key="gx_bussiness_check" value-ref="businessCheckProducer" />
</map>
</property>
<property name="commonExecutor" ref="asyncTaskThreadPoolTaskExecutor"/>
</bean>
其中, messageProducerMap类型为Map<String, Producer>,用于指定topic对应的Producer; commonExecutor用于指定异步发送消息时用到的线程池(建议自行创建线程池); 。
4.业务监控消息发送 场景一: 简单场景下可使用自定义注解来发送消息,如下所示 。
业务监控类型 = "100" 消息主题 = "gx_bussiness_check" 业务方 = "ws" 消息体中的业务数据data = req 。
场景二: 复杂场景下,可在服务中注入sdk中的消息发送服务,如下所示 。
场景二与场景一发送的消息内容一致.
5.业务监控降级不发送消息 sdk中的类BusinessCheckHandlerImpl中定义了控制降级的方法:
public static void setBusinessCheckSwitch(boolean businessCheckSwitch) {
BusinessCheckHandlerImpl.businessCheckSwitch = businessCheckSwitch;
}
此处给出了通过ducc控制降级的方法:
@LafValue("business.check.switch")
public void setBusinessCheckSwitch(boolean switch) {
BusinessCheckHandlerImpl.setBusinessCheckSwitch(b);
}
switch:true,开启消息发送;false,降级 。
作者:京东零售 胡飞 。
内容来源:京东云开发者社区 。
最后此篇关于一种通用的业务监控触发方案设计的文章就讲到这里了,如果你想了解更多关于一种通用的业务监控触发方案设计的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我已经在 ubuntu 14.0 上成功安装了 Zabbix 3.2 服务器主机上的 Z 是绿色的。不幸的是,JMX 是红色的。 Zabbix 服务器:192.168.1.112 带有 tomcat
我想制作一个仪表板,显示我们的 Azure 服务总线队列的状态,并显示“添加到队列的消息”、“队列长度”和“已处理的消息”等的历史记录。使用 Azure 管理门户,我可以看到,这些统计信息大部分是手动
我的 MYSQL 每天晚上都有事件,但我不太确定发生了什么,因为即使我将其设置得早于其他事件,它仍然在早上运行。 问题是,我如何检查运行事件的历史记录或日志,哪一个晚上锁了,哪一个是跑了没跑? 谢谢
1、监控log文件大小超过10g的server 和db 复制代码代码如下: create procedure db_sendmail_mssqllogsize as&n
本教程讨论如何使用 AspectJ 开源框架监控 Spring 应用程序在方法执行方面的性能。 传统上,监控每个 Java 方法所花费的时间的最简单方法是在方法的开头和结尾包含一些跟踪行: publi
有什么可以帮助 msmq 监控的吗?当消息出现在队列中并且在休假时相同时,我想获得一些事件/监视器。 最佳答案 查看 Windows 管理性能计数器。 如果您查看管理工具并找到“性能计数器”,您将能够
我的 Tomcat 中的一个巨大的 web 应用程序有时会开始使用过多的 DBCP 连接,从而导致问题。 为了进行调查,我想在每个时间点准确地知道什么线程/方法持有池的连接。不需要是实时的,事后分析就
在浏览器的整个页面生命周期中监视 cookie 并在 cookie 更改时触发事件的最佳 JS 或 JQuery 特定方法是什么? 最佳答案 据我所知,不可能将 change (或类似)事件直接绑定(
我想尽可能详细地报告我的笔记本的执行情况。简而言之,我想实时查看我的笔记本正在执行的每个操作。例如,我的一个函数有一个 sleep 周期为 5 秒的循环,我希望看到程序实际上正在 sleep 并且循环
Azure 容器服务是否与 Azure Monitor 集成?想知道对 kubernetes 集群进行日志记录/监控的最佳方法是什么? 最佳答案 如果您正在 Azure 上寻找监视工具,您可能需要使用
我一直在尝试使用 erlang:monitor/2 来监视 gen_server。不幸的是,每次我尝试这个时,Erlang shell 都会进入无限循环。 这是我为测试这一点而编写的测试程序。 -mo
Azure 容器服务是否与 Azure Monitor 集成?想知道对 kubernetes 集群进行日志记录/监控的最佳方法是什么? 最佳答案 如果您正在 Azure 上寻找监视工具,您可能需要使用
我想使用 编写一个 shell 脚本来监控集群中的消费者滞后 bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zkconnect
在 .NET 中,假设 thread A 锁定了一个对象。同时,线程B和线程C被阻塞,等待线程A解锁对象。 现在,线程 A 解锁了对象。接下来将选择哪个线程(B 或 C)?它是如何确定的? 最佳答案
我搜索过这个主题,但发现很少有有用的细节。有了这些细节,我尝试编写一些代码如下。 注意:在将此帖子标记为重复之前,请将此帖子中共享的详细信息与其他帖子进行比较,而不仅仅是按主题。 - (NSArray
目录 1、指标监控 2、常用的监控端点 3、定制EndPoint 4、spring boot admin(可以使用)
我们使用 Prometheus 和 Grafana 来监控我们的 Kafka 集群。 在我们的应用程序中,我们使用 Kafka 流,Kafka 流有可能因异常而停止。我们正在记录事件 setUnCau
我正在建立一个复杂的网络仿真,并试图捕捉一些重要的性能测量。 我在服务器上运行了 mininet,并且我将视频从一个 mininet 主机流式传输到另一个(使用 -nodisp 选项,因为我没有 GU
Jenkins 的 openstack-plugin 使用 openstack4j 与 openstack 云对话。我正在寻找一种方法,我们可以从客户端的角度监控 openstack4j 所做的 ht
我正在处理一项需要监控 Thunderbolt 端口连接变化的要求。 (当连接或断开 Thunderbolt 电缆时)。 我尝试使用 IOServiceMatching(kIOUSBInterface
我是一名优秀的程序员,十分优秀!