服务监控系统（客户端实现）

原文链接：服务监控系统（客户端实现）

//单线程运行+睡眠运行package com.heart.beat.runner;import com.heart.beat.heatbeat.HeartSenderHttp;
import com.heart.beat.heatbeat.HeartSenderSocket;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.PropertySource;
import org.springframework.stereotype.Component;/*** 类描述：心跳组件插件* Created by 李泽阳 on 2019/8/6*/
@Component//把对象实例化到spring容器中，等于配置文件
@PropertySource("classpath:heart.properties")
public class HeartPluginRunner implements Runnable {private Logger logger = LoggerFactory.getLogger(HeartPluginRunner.class);private static boolean isStart = false;//初始化默认未启动获取配置文件@Value("${heart.beatKey}")//获取配置文件基础文件参数private String heartKey;@Value("${heart.url}")//心跳返回urlprivate String heartUrl;@Autowiredprivate HeartSenderHttp heartSenderHttp;//组件启动public synchronized void start() {if (isStart) {//防止重复启动return;}try {//文件地址静态加载buildConfig();logger.info("[心跳服务器组件]启用成功......");run();isStart = true;//修改启动状态} catch (Exception e) {e.printStackTrace();logger.info("[心跳服务器组件]启用失败！！！");}}//心跳记录发送 http请求@Overridepublic void run() {try {while (true) {heartSenderHttp.getInstance().sendHttpPost();synchronized (HeartSenderSocket.class) {//单线程等待，激活时间,this.wait(15 * 1000);}}} catch (Exception e) {e.printStackTrace();logger.info("【心跳服务发送失败！！！】");logger.info(e.getMessage());logger.info(e.getStackTrace().toString());}}//加载静态参数对象private void buildConfig() {try {HeartPluginConfig hpc = HeartPluginConfig.getInstance();//参数必填校验if ("".equals(heartKey) || "".equals(heartUrl))return;//静态资源加载hpc.setUrl("http://" + heartUrl + "/monitor/heartBeatController/beat?key=" + heartKey);//封装前、后缀hpc.setKey(heartKey);} catch (Exception e) {logger.info("【文件地址路径加载失败！！！】");}}}

//静态类加载package com.heart.beat.runner;/*** 类描述：静态加载类* Created by 李泽阳 on 2019/8/7*/
public class HeartPluginConfig {public static HeartPluginConfig instance;public static HeartPluginConfig getInstance() {if (instance == null) {instance = new HeartPluginConfig();}return instance;}//private String url="/monitor/heartBeatController/beat";//访问路径前缀private String url;//请求地址private String key;//发送key值public String getUrl() {return url;}public void setUrl(String url) {this.url = url;//this.url = ("http://" + url + "/monitor/heartBeatController/beat");}public String getKey() {return key;}public void setKey(String key) {this.key = key;}}

//监听启动类package com.heart.beat.listener;import com.heart.beat.runner.HeartPluginRunner;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.core.Ordered;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;/*** 类描述：伴随组件启动类* Created by 李泽阳 on 2019/8/6*/
@Component
@Order(Ordered.LOWEST_PRECEDENCE)//过滤器，最低过滤权限，最后执行过滤操作
//@Order(Ordered.HIGHEST_PRECEDENCE)//最高过滤权限
public class HeartUploadListener implements ApplicationListener<ContextRefreshedEvent>, ApplicationRunner {//ApplicationListener spring 监听@Autowiredprivate HeartPluginRunner heartPluginRunner;@Overridepublic void run(ApplicationArguments args) throws Exception {startHearts();}@Overridepublic void onApplicationEvent(ContextRefreshedEvent event) {if (event.getApplicationContext().getParent() != null) {startHearts();}}private void startHearts() {//启动心跳组件heartPluginRunner.start();}}

//http请求package com.heart.beat.heatbeat;import com.heart.beat.runner.HeartPluginConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Repository;import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Date;/*** 类描述:心跳客户端发送类* Created by 李泽阳 on 2019/8/7*/
@Repository
public class HeartSenderHttp {private Logger logger = LoggerFactory.getLogger(HeartSenderHttp.class);private static HeartSenderHttp instance;//初始化类对象>>>单例模式public static HeartSenderHttp getInstance() {if (instance == null) {synchronized (HeartSenderHttp.class) {instance = new HeartSenderHttp();}}return instance;}//心跳发送 http请求public String sendHttpPost() {HttpURLConnection connection = null;InputStream inputStream = null;//输入流OutputStream outputStream = null;//输出流BufferedReader bufferedReader = null;String result = null;try {URL url = new URL(HeartPluginConfig.getInstance().getUrl());//通过远程连接对象connection = (HttpURLConnection) url.openConnection();//设置连接方式connection.setRequestMethod("POST");//设置连接主机服务超时时间 15000毫秒connection.setConnectTimeout(15000);//设置读取主机服务返回数据超时时间：60000毫秒connection.setReadTimeout(60000);//是否向远程服务写入数据/默认falseconnection.setDoOutput(true);//设置传入参数格式connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");// 设置鉴权信息：Authorization: Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0//connection.setRequestProperty("Authorization", "");connection.setRequestProperty("Authorization", "Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0");// 通过连接对象获取一个输出流outputStream = connection.getOutputStream();// 通过输出流对象将参数写出去/传输出去,它是通过字节数组写出的outputStream.write(HeartPluginConfig.getInstance().getKey().getBytes());//通过连接对象获取一个输入流，向远程读取if (connection.getResponseCode() == 200) {inputStream = connection.getInputStream();// 对输入流对象进行包装:charset根据工作项目组的要求来设置bufferedReader = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"));StringBuffer sbf = new StringBuffer();String temp = null;// 循环遍历一行一行读取数据while ((temp = bufferedReader.readLine()) != null) {sbf.append(temp);sbf.append("\r\n");}result = sbf.toString();}logger.info(HeartPluginConfig.getInstance().getKey() + "：[心跳发送成功！]" + new Date());} catch (Exception e) {e.printStackTrace();logger.info(HeartPluginConfig.getInstance().getKey() + "：[心跳消息发送失败！]" + new Date());} finally {//关闭资源if (null != bufferedReader) {try {bufferedReader.close();} catch (IOException e) {e.printStackTrace();}}if (outputStream != null) {try {outputStream.close();} catch (IOException e) {e.printStackTrace();}}if (inputStream != null) {try {inputStream.close();} catch (IOException e) {e.printStackTrace();}}//断开与远程地址url的连接connection.disconnect();}return result;}}

git项目地址：https://github.com/lizyangcoco/monitor_heart.git
面向开发过程，记录学习之路。

服务监控系统（客户端实现）相关推荐

对微服务监控系统分层和监控架构的理解
对微服务监控系统分层和监控架构的理解目录微服务专栏地址目录 1. 简介 2. 为什么需要监控体系 3. 与单体应用有什么区别 4. 要监控什么 5. 监控体系和分层 6. 监控架构和主流技术栈 ...
linux搭建天地伟业easy7,easy7视频监控系统客户端|天地伟业easy7监控客户端简洁版(Easy7 Smart Client Express)下载 V7.12 官方版 - 比克尔下载...
Easy7 Smart Client Express就是天地伟业简洁版的easy7视频监控系统客户端,支持天地伟业的DVR.NVR.网络视频编码器.网络摄像机.高清编码器等设备,该软件属于单机版软件, ...
新思路设计可视化大型微服务监控系统
http://www.infoq.com/cn/articles/visualization-microservice-monitoring-system 背景随着微服务在生产实践中被大量使用,后台 ...
【SpringBoot】51、Spring-Boot-Admin搭建服务监控系统
一.写在前面 Spring Boot Actuator 是 spring-boot 自带监控功能 ,可以帮助实现对程序内部运行情况监控,比如监控状况.Bean 加载情况.环境变量.日志信息.线程信息等 ...
zabbix监控系统客户端安装
服务端的安装可以查看:http://www.cnblogs.com/sunbeidan/p/4940147.html 下载 http://www.zabbix.com/downloads/2.0.3/ ...
网易云基于Prometheus的微服务监控实践
当监控遇上微服务在过去数年里,微服务的落地一直都是业界重点关注的问题,其始终面临着部署.监控.配置和治理等方面的挑战.轻舟微服务平台是网易云为企业提供的一套微服务解决方案,其中微服务监控是其关注的重 ...
Kubernetes 微服务监控体系
作者|无敌码农来源|无敌码农监控系统是运维体系乃至整个软件产品生命周期中最重要的一环,完善的监控可以帮助我们事前及时发现故障,事后快速追查定位问题.而在以微服务为代表的云原生架构体系中,系统分为多 ...
DeVOpS 实战：Kubernetes 微服务监控体系
来源 | 无敌码农责编 | 寇雪芹头图 | 下载于视觉中国监控系统是运维体系乃至整个软件产品生命周期中最重要的一环,完善的监控可以帮助我们事前及时发现故障,事后快速追查定位问题. 而在以微服务为 ...
ULTRON 分布式监控系统
概述在今天这个时代,数据已经成为重要的资源,小到管理系统大到智能AI都脱离不了数据的支持.在面对海量数据的压力下,传统项目不能不走上了变迁的道路.生存还是毁灭,看你自己咯.从传统一个war包走天下, ...

服务监控系统（客户端实现）

服务监控系统（客户端实现）相关推荐

最新文章

热门文章