zabbix java api
zabbix官方的api文档地址：https://www.zabbix.com/documentation/3.0/manual/api
Zabbix功能
概观
Zabbix是一个高度集成的网络监控解决方案，在单个软件包中提供了多种功能。
数据采集
可用性和性能检查
支持SNMP（捕获和轮询），IPMI，JMX，VMware监控
定制检查
以定制的间隔收集所需的数据
由服务器/代理和代理执行
灵活的阈值定义
您可以定义非常灵活的问题阈值，称为触发器，从后端数据库引用值
高度可配置的警报
可以为升级计划，收件人，媒体类型定制发送通知
使用宏变量可以使通知变得有意义和有用
自动操作包括远程命令
实时绘图
使用内置的图形功能立即绘制被监视的项目
Web监控功能
Zabbix可以按照网站上模拟鼠标点击的路径，并检查功能和响应时间
广泛的可视化选项
能够创建可以将多个项目组合成单个视图的自定义图形
网络地图
自定义屏幕和幻灯片，以显示仪表板风格的概述
报告
监控资源的高级（业务）视图
历史数据存储
存储在数据库中的数据
可配置历史
内置内务程序
轻松配置
将监控的设备添加为主机
主机被拾取用于监视，一次在数据库中
将模板应用于受监控设备
使用模板
在模板中分组检查
模板可以继承其他模板
网络发现
自动发现网络设备
代理商自动注册
发现文件系统，网络接口和SNMP OID
快速的Web界面
PHP中的基于Web的前端
可从任何地方访问
你可以点击你的方式
审核日志
Zabbix API
Zabbix API为Zabbix 提供了可编程接口，用于大规模操作，第三方软件集成和其他目的。
权限系统
安全的用户认证
某些用户可以限于某些视图
全功能和易于扩展的代理
部署在监测目标上
可以部署在Linux和Windows上
二进制程序
写在C中，用于性能和小内存占用
容易携带
准备复杂的环境
通过使用Zabbix代理，远程监控变得容易
zabbix最近问题列表
pom.xml
<dependency> <groupId>io.github.hengyunabc</groupId> <artifactId>zabbix-api</artifactId> <version>0.0.1</version> </dependency>
zabbix获取最近问题列表
JSONObject jo = new JSONObject();
jo.put("value", 1);
jo.put("priority", new String[]{"2", "3", "4", "5"});
Request request = RequestBuilder.newBuilder().method("trigger.get")
.paramEntry("output", new String[]{"description", "priority", "lastchange"})
.paramEntry("selectHosts", new String[]{"host", "name", "hostid"})
.paramEntry("selectDependencies", "extend")
.paramEntry("expandData", "host")
.paramEntry("skipDependent", "1")
.paramEntry("monitored", "1")
.paramEntry("active", "1")
.paramEntry("expandDescription", "1")
.paramEntry("sortfield", "priority")
.paramEntry("sortorder", "DESC")
.paramEntry("filter", jo)
.build();zabbix Api
import io.github.hengyunabc.zabbix.api.DefaultZabbixApi;import io.github.hengyunabc.zabbix.api.Request;import io.github.hengyunabc.zabbix.api.RequestBuilder;import io.github.hengyunabc.zabbix.api.ZabbixApi;import org.apache.commons.lang.StringUtils;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONArray;import com.alibaba.fastjson.JSONObject;/**
* zabbix Api
* @author can
*/public class ZabbixUtil { private static final Logger LOGGER = LoggerFactory.getLogger(ZabbixUtil.class); private ZabbixApi zabbixApi; public ZabbixUtil(String username, String password, String url) throws Exception { if (StringUtils.isBlank(username) || StringUtils.isBlank(password) || StringUtils.isBlank(url)){ throw new Exception("ZabbixApi初始化失败！参数不全！");
}
login(username, password, url);
} private ZabbixApi login(String username, String password, String url) throws Exception {
zabbixApi = new DefaultZabbixApi(url);
zabbixApi.init(); boolean login = zabbixApi.login(username, password); if(!login){
LOGGER.info(username + " login in Zabbix " + (login ? "SUCCESS" : "FALURE") + " !");
} return zabbixApi;
} /**
* 获取zabbix中所以的主机群组列表
* @return 主机群组列表json
*/
public String getHostGroupList() throws Exception {
Request request = RequestBuilder.newBuilder().method("hostgroup.get")
.paramEntry("output", "extend")
.build();
JSONObject response = zabbixRequest(request);
zabbixError(response);
JSONArray result = response.getJSONArray("result"); return result.toJSONString();
}
public String getHostList() throws Exception {
Request request = RequestBuilder.newBuilder().method("host.get")
.paramEntry("output", new String[]{"host", "name", "description", "hostid"})
.paramEntry("selectGroups", "extend")
.build();
JSONObject response = zabbixRequest(request);
zabbixError(response);
JSONArray result = response.getJSONArray("result"); return result.toJSONString();
} /**
* 获取主机ID
* @param hostIp
* @return 主机ID
*/
public String getHostByGroupid(Integer groupid) throws Exception {
Request request = RequestBuilder.newBuilder().method("host.get")
.paramEntry("groupids", groupid)
.paramEntry("output", new String[]{"host", "name", "description", "hostid"})
.paramEntry("selectGroups", "extend")
.build();
JSONObject response = zabbixRequest(request);
zabbixError(response);
JSONArray result = response.getJSONArray("result"); return result.toJSONString();
} /**
* 获取zabbix报警列表
* @param timeFrom 仅返回在给定时间之后生成的警报。
* @return
*/
public String getAlertList(Long timeFrom) throws Exception {
Request request = RequestBuilder.newBuilder().method("alert.get")
.paramEntry("output", new String[]{"sendto", "subject", "clock", "message"})
.paramEntry("selectHosts", new String[]{"host"})
.paramEntry("time_from", timeFrom)
.build();
JSONObject response = zabbixRequest(request);
zabbixError(response);
JSONArray result = response.getJSONArray("result"); return result.toJSONString();
} /**
* 获取zabbix报警列表
* @param timeFrom 仅返回在给定时间之后生成的警报。
* @return
*/
public String getAlertListByGroupids(Integer groupid, Long timeFrom) throws Exception {
Request request = RequestBuilder.newBuilder().method("alert.get")
.paramEntry("time_from", timeFrom)
.paramEntry("groupids", groupid)
.paramEntry("output", new String[]{"sendto", "subject", "clock", "message","triggerid"})
.paramEntry("selectHosts", new String[]{"host"})
.build();
JSONObject response = zabbixRequest(request);
zabbixError(response);
JSONArray result = response.getJSONArray("result"); return result.toJSONString();
} /**
* 获取zabbix最近问题列表
* @return
* @throws Exception
*/
public String getTriggerInfoList() throws Exception {
JSONObject jo = new JSONObject();
jo.put("value", 1);
jo.put("priority", new String[]{"2", "3", "4", "5"});
Request request = RequestBuilder.newBuilder().method("trigger.get")
.paramEntry("output", new String[]{"description", "priority", "lastchange"})
.paramEntry("selectHosts", new String[]{"host", "name", "hostid"})
.paramEntry("selectDependencies", "extend")
.paramEntry("expandData", "host")
.paramEntry("skipDependent", "1")
.paramEntry("monitored", "1")
.paramEntry("active", "1")
.paramEntry("expandDescription", "1")
.paramEntry("sortfield", "priority")
.paramEntry("sortorder", "DESC")
.paramEntry("filter", jo)
.build();
JSONObject response = zabbixRequest(request);
zabbixError(response);
JSONArray result = response.getJSONArray("result"); return result.toJSONString();
}
/**
* 根据群组id和机器host获取触发器信息列表
* @param groupid
* @param host
* @return
* @throws Exception
*/
public String getTrigger(Integer groupid, String host) throws Exception {
Request request = RequestBuilder.newBuilder().method("trigger.get")
.paramEntry("groupids", groupid)
.paramEntry("host", host)
.paramEntry("monitored", 1)
.paramEntry("output", new String[]{"expression","description", "priority", "lastchange","status"})
.build();
JSONObject response = zabbixRequest(request);
zabbixError(response);
JSONArray result = response.getJSONArray("result"); return result.toJSONString();
}
/**
* 根据触发器id获取触发器信息
* @param triggerId
* @return
* @throws Exception
*/
public String getTriggerByTriggerId(Integer triggerId) throws Exception {
Request request = RequestBuilder.newBuilder().method("trigger.get")
.paramEntry("triggerids", triggerId)
.paramEntry("output", "extend")
.build();
JSONObject response = zabbixRequest(request);
zabbixError(response);
JSONArray result = response.getJSONArray("result"); return result.toJSONString();
} public String getItemList() throws Exception {
Request request = RequestBuilder.newBuilder().method("item.get").paramEntry("output", "extend").paramEntry("monitored", "true").build();
JSONObject response = zabbixRequest(request);
zabbixError(response);
JSONArray result = response.getJSONArray("result"); return result.toJSONString();
} public String getTriggerPrototypeByGroupid(Integer groupid) throws Exception {
Request request = RequestBuilder.newBuilder().method("triggerprototype.get")
.paramEntry("groupids", groupid)
.paramEntry("selectHosts", new String[]{"host", "hostid"})
.paramEntry("selectGroups", "extend")
.paramEntry("output", new String[]{"expression", "triggerid", "description", "priority", "status"})
.build();
JSONObject response = zabbixRequest(request);
zabbixError(response);
JSONArray result = response.getJSONArray("result"); return result.toJSONString();
}
public String getTriggerPrototypeByTriggerids(Integer triggerid) throws Exception {
Request request = RequestBuilder.newBuilder().method("triggerprototype.get")
.paramEntry("triggerids", triggerid)
.paramEntry("output", "extend")
.build();
JSONObject response = zabbixRequest(request);
zabbixError(response);
JSONArray result = response.getJSONArray("result"); return result.toJSONString();
}
public String getTriggerInfo(Integer groupid,Long lastChangeSince) throws Exception {
Request request = RequestBuilder.newBuilder().method("trigger.get")
.paramEntry("groupids", groupid)
.paramEntry("lastChangeSince", lastChangeSince)
.paramEntry("output", new String[]{"description", "priority", "lastchange"})
.paramEntry("selectHosts", new String[]{"host", "name", "hostid"})
.paramEntry("skipDependent", "1")
.paramEntry("monitored", "1")
.paramEntry("active", "1")
.paramEntry("expandDescription", "1")
.paramEntry("sortfield", "priority")
.build();
JSONObject response = zabbixRequest(request);
zabbixError(response);
JSONArray result = response.getJSONArray("result"); return result.toJSONString();
} private JSONObject zabbixRequest(Request request) throws Exception {
JSONObject response = zabbixApi.call(request); return response;
} private void zabbixError(JSONObject response) throws Exception { if (!StringUtils.isBlank(response.getString("error"))) throw new Exception("向Zabbix请求出错了！" + JSON.parseObject(response.getString("error")).getString("data"));
}运行结果
作者：全能程序猿
链接：https://www.jianshu.com/p/382378fbfea3