@Controller
public class UserRegisterController { //用户注册使用的 Controller，数据监控可根据自身需求放在任意层级，例如 Service 层、Dao 层。
    
    private final ExecutionMonitor monitor = NaiveExecutionMonitorFactory.get("UserRegister"); //获取用户注册操作执行信息监控器
    
    @Autowired
    private UserService userService;
    
    @RequestMapping(value = "/register")
    @ResponseBody
    public boolean register(@RequestParam("username") String username, @RequestParam("password") String password) {
        long startTime = System.nanoTime();
        try {
            if (userService.isExist(username)) { //如果用户名已存在
                monitor.onError(-1); //对用户名已存在的错误进行监控
                return false;
            }
            userService.add(username, password); //创建用户
            return true;
        } catch (Execution e) {
            monitor.onError(-2); //对执行过程中出现预期外异常进行监控
            return false;
        } finally{
            monitor.onExecuted(startTime); //对每一个注册操作进行监控
        }
    }
}

public class UserRegisterDataCollector extends AbstractExecutionDataCollector {
    
    @Override
    protected Map<Integer, String> getErrorMetricSuffixMap() {
        Map<Integer, String> errorMetricSuffixMap = new HashMap<>();
        errorMetricSuffixMap.put(-1, "_duplicate_username"); //对用户名已存在的错误次数进行统计
        errorMetricSuffixMap.put(-2, "_exec_error"); //对执行过程中出现预期外的异常次数进行统计
        return errorMetricSuffixMap;
    }

    @Override
    protected String getCollectorName() {
        return "register"; //采集器名称，表明为用户注册操作
    }

    @Override
    protected List<ExecutionMonitor> getExecutionMonitorList() {
        return Collections.singletonList(NaiveExecutionMonitorFactory.get("UserRegister"));
    }

    @Override
    protected String getModuleName() {
        return "bookstore"; //用户注册操作所在的项目名称
    } 

    @Override
    public int getPeriod() {
        return 30; //监控数据推送周期为 30 秒
    }
} 

public class NaiveServiceAlarmTester {
    
    @Autowired
    private NaiveServiceAlarm naiveServiceAlarm;
    
    //服务不可用报警信息发送 Demo
    public void testSendCrashMessage() { 
        ServiceContext serviceContext = new ServiceContext();
        serviceContext.setHost(MonitorUtil.getLocalHostName()); //设置本机地址信息
        serviceContext.setProject("bookstore"); //设置当前项目名称
        serviceContext.setName("Memcached"); //设置服务名称
        serviceContext.setRemoteHost("127.0.0.1:11211"); //提供服务的远程主机地址信息，如果为本地服务，不需要进行此设置
        
        naiveServiceAlarm.onCrashed(serviceContext); //进行服务不可用报警通知
    }
    
    //服务恢复信息发送 Demo
    public void testSendRecoverMessage() { 
        ServiceContext serviceContext = new ServiceContext();
        serviceContext.setHost(MonitorUtil.getLocalHostName()); //设置本机地址信息
        serviceContext.setProject("bookstore"); //设置当前项目名称
        serviceContext.setName("Memcached"); //设置服务名称
        serviceContext.setRemoteHost("127.0.0.1:11211"); //提供服务的远程主机地址信息，如果为本地服务，不需要进行此设置
        
        naiveServiceAlarm.onRecovered(serviceContext); //进行服务不可用报警通知
    
    }
}

/**
 * 短信报警通知器。
 */
public class SmsServiceAlarmMessageNotifier implements ServiceAlarmMessageNotifier {
    
    private static final Logger LOGGER = LoggerFactory.getLogger(SmsServiceAlarmMessageNotifier.class);
    
    /**
     * 短信服务 URL 地址。
     */
    private final String url;
    
    public SmsServiceAlarmMessageNotifier(String url) {
        this.url = url;
    }
    
    @Override
    public boolean send(ServiceAlarmMessage serviceAlarmMessage) {
        if (url != null && !url.isEmpty()) {
            long startTime = System.currentTimeMillis();
            HashMap<String, Object> params = new HashMap<>(); //组装短信服务需要的参数，应根据短信服务接口定义进行设置
            params.put("phoneNums", "13700000000,13811111111"); //设置短信接收人手机号码
            params.put("message", serviceAlarmMessage.toText()); //设置短信内容
            try {
                NaiveHttpPost post = new NaiveHttpPost(url, 5000); //Post 请求的超时时间设置为 5 秒
                String responseText = post.doPost(NaiveHttpPost.getPostBody(params)); //发起 Post 请求
                if ("true".equals(responseText)) { //根据返回内容判断请求是否成功，应根据短信服务接口返回值定义进行判断
                    LOGGER.info("Send ServiceAlarmMessage to sms success. Cost: `{} ms`. ServiceAlarmMessage: `{}`. Url: `{}`.",
                            System.currentTimeMillis() - startTime, serviceAlarmMessage, url);
                } else {
                    LOGGER.error("Send ServiceAlarmMessage to sms failed. Cost: `{} ms`. ResponseText: `{}`. ServiceAlarmMessage: `{}`. Url: `{}`.",
                            System.currentTimeMillis() - startTime, responseText, serviceAlarmMessage, url);
                }
                return isSuccess;
            } catch (Exception e) {
                LOGGER.error("Send ServiceAlarmMessage to sms failed. Cost: `" + (System.currentTimeMillis() - startTime)
                        + " ms`. ServiceAlarmMessage: `" + serviceAlarmMessage + "`. Url: `" + url + "`.", e);
                return false;
            }
        } else {
            LOGGER.warn("SmsServiceAlarmMessageNotifier is inactive. ServiceAlarmMessage: `{}`.", serviceAlarmMessage);
            return false;
        }
    }
}

@Repository
public class UserDaoImpl implements UserDao {
    
    @Resource(name = "bookstoreSqlMapClientTemplate")
    private SqlMapClientTemplate sqlMapClientTemplate;
    
    public void add(User user) {
        sqlMapClientTemplate.insert("UserDao.add", user);
    }
}