Zabbix已经搭建完毕，搭建方法见通过docker搭建zabbix5.0
 
查阅文档:https://www.zabbix.com/documentation/5.0/manual ，发现zabbix对外提供了很多api接口。
 
 于是从某开源网站上面找到了一个jar包见下图
 
 于是开始使用springboot工程去调用api。直接上代码，先是pom文件
 
<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.7.RELEASE</version>
    </parent>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <java.version>1.8</java.version>
    </properties>


    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
        <dependency>
            <groupId>io.github.hengyunabc</groupId>
            <artifactId>zabbix-api</artifactId>
            <version>0.0.2</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.16</version>
        </dependency>
    </dependencies>
 
yml配置
 
server:
  port: 9003

logging:
  level:
    com.cn.scott: debug

zabbix:
  config:
    url: http://xxxx:8080/api_jsonrpc.php
    username: Admin
    password: zabbix
 
zabbixConfig用于读取配置信息
 
@Component
@ConfigurationProperties(prefix = "zabbix.config")
@Data
public class ZabbixConfig {

    private String url;
    private String username;
    private String password;
}

 
工具类用于初始化zabbixApi对象,并且登录获取token值。
 
@Component
@Slf4j
public class ZabbixUtil {

    private volatile ZabbixApi zabbixApi;

    @Autowired
    private ZabbixConfig zabbixConfig;


    public ZabbixApi getZabbixApi() {
        if (null == zabbixApi) {
            synchronized (ZabbixUtil.class) {
                if (null == zabbixApi) {
                    zabbixApi = new DefaultZabbixApi(zabbixConfig.getUrl());
                    zabbixApi.init();
                    login();
                }
            }
        }
        return zabbixApi;
    }

    private void login(){
        boolean login = zabbixApi.login(zabbixConfig.getUsername(), zabbixConfig.getPassword());
        if(!login){
            throw new RuntimeException("zabbix login failed!");
        }
        log.info("zabbix login success!");
    }

}

 
最后业务类负责调用接口，写了两个demo，其他大同小异
 
@Service
public class ZabbixService  extends AbstractZabbixService{

    @Autowired
    private ZabbixUtil zabbixUtil;

    //获取主机列表
    public String getHostList() throws Exception {
        ZabbixApi zabbixApi = zabbixUtil.getZabbixApi();
        Request request = RequestBuilder.newBuilder().method("host.get")
                .paramEntry("output", new String[]{"host", "name", "description", "hostid"})
                .paramEntry("selectGroups", "extend")
                .build();
        JSONObject response = zabbixRequest(zabbixApi,request);
        zabbixError(response);
        JSONArray result = response.getJSONArray("result");
        return result.toJSONString();
    }

    //获取监控项
    public String getMonitorItems(String hostId) throws Exception {
        ZabbixApi zabbixApi = zabbixUtil.getZabbixApi();
        Request request = RequestBuilder.newBuilder().method("item.get")
                .paramEntry("output","extend").paramEntry("hostids",hostId).build();
        JSONObject response = zabbixRequest(zabbixApi,request);
        zabbixError(response);
        JSONArray result = response.getJSONArray("result");
        return result.toJSONString();
    }


}
 
如需查看具体代码，请移步:https://gitee.com/ErGouGeSiBaKe/zabbixapi

        因为项目保密的原因，实际代码无法贴出，但与他人博客中的代码有一定的相似度，现拷贝部分作为参考，再结合我专栏中的技术文档，以便理解对zabbix的部分封装过程。
 
 Zabbix4jSampleGetHost.java
 
    package com.zabbix4j.apitest;  
      
    import com.zabbix4j.ZabbixApi;  
    import com.zabbix4j.ZabbixApiException;  
    import com.zabbix4j.ZabbixApiParamter;  
    import com.zabbix4j.host.*;  
    import com.zabbix4j.hostinteface.HostInterfaceObject;  
    import com.zabbix4j.item.ItemObject;  
    import com.zabbix4j.usermacro.Macro;  
      
    import java.util.ArrayList;  
    import java.util.List;  
      
    public class Zabbix4jSampleGetHost extends ZabbixApiTestDummyMethodBase {  
      
        public Zabbix4jSampleGetHost(ZabbixApi zabbixApi) {  
            super(zabbixApi);  
        }  
      
        // 这里配置zabbix的url，帐号和密码  
        public static final String ZBX_URL = "http://192.168.4.132/zabbix/api_jsonrpc.php";  
        public static final String USERNAME = "Admin";  
        public static final String PASSWORD = "zabbix";  
      
        // 调用api的host get方法的封装  
        public HostGetResponse getHost() throws ZabbixApiException {  
      
	        Integer targetHostId = 10105;  
	        HostGetRequest request = new HostGetRequest();  
	        HostGetRequest.Params params = request.getParams();  
	      
	        ArrayList<Integer> hostIds = new ArrayList<Integer>();  
	        hostIds.add(targetHostId);  
	        // params.setHostids(hostIds);  
	        // 这里可以设指定的id值，也可以不设值。设值的话，取指定的内容，不设的话，获取全部的host  
	        params.setHostids(null);  
	      
	        params.setSelectDiscoveryRule(ZabbixApiParamter.QUERY.extend.name());  
	        params.setSelectGroups(ZabbixApiParamter.QUERY.extend.name());  
	        params.setSelectItems(ZabbixApiParamter.QUERY.extend.name());  
	        params.setSelectApplications(ZabbixApiParamter.QUERY.extend.name());  
	        params.setSelectDiscoveries(ZabbixApiParamter.QUERY.extend.name());  
	        params.setSelectGraphs(ZabbixApiParamter.QUERY.extend.name());  
	        params.setSelectHostDiscovery(ZabbixApiParamter.QUERY.extend.name());  
	        params.setSelectHttpTests(ZabbixApiParamter.QUERY.extend.name());  
	        params.setSelectInterfaces(ZabbixApiParamter.QUERY.extend.name());  
	        params.setSelectInventory(ZabbixApiParamter.QUERY.extend.name());  
	        params.setSelectMacros(ZabbixApiParamter.QUERY.extend.name());  
	        params.setSelectParentTemplates(ZabbixApiParamter.QUERY.extend.name());  
	        params.setSelectScreens(ZabbixApiParamter.QUERY.extend.name());  
	        params.setSelectTriggers(ZabbixApiParamter.QUERY.extend.name());  
	      
	        System.out.println("parames setting complete...");  
	        HostGetResponse response = zabbixApi.host().get(request);  
	      
	        return response;  
        }  
      
        public static void main(String[] args) {  
      
	        try {  
	            // login to Zabbix  
	            System.out.println("beging...");  
	            ZabbixApi zabbixApi = new ZabbixApi(ZBX_URL);  
	            zabbixApi.login(USERNAME, PASSWORD);  
	      
	            System.out.println("create new get host instance...");  
	            Zabbix4jSampleGetHost myGetHost = new Zabbix4jSampleGetHost(  
	                zabbixApi);  
	      
	            System.out.println("Get host beging...");  
	            HostGetResponse response = myGetHost.getHost();  
	      
	            System.out.println("Get host end...let's print result");  
	      
	            // 对response进行处理  
	            for (int i = 0; i < response.getResult().size(); i++) {  
	      
		            //response 返回的信息非常大，可以赋值给HostObject，也可以其他对象  
		            HostObject myHostObject = response.getResult().get(i);  
		            //response 返回的信息非常大，可以赋值给ItemObject，也可以其他对象  
		            List<ItemObject> myItemObjectList = response.getResult().get(i)  
		                .getItems();  
		      
		            //打印host信息  
		            if (null == myHostObject)  
		                System.out.println("Get host null, program will exit");  
		            else {  
		                System.out.println("++++++Print Result " + i  
		                    + " HostObject+++++++++++");  
		                System.out.println(myHostObject.getHost());  
		                System.out.println(myHostObject.getName());  
		                System.out.println(myHostObject.getAvailable());  
		                System.out.println(myHostObject.getHostid());  
		                System.out.println(myHostObject.getStatus());  
		            }  
		      
		            //打印这个host下的item信息  
		            for (int j = 0; j < myItemObjectList.size(); j++) {  
		                if (j == 0)  
		                System.out.println("++++++Print ItemObject List "  
		                    + "+++++++++++");  
		                ItemObject tmpItemObject = myItemObjectList.get(j);  
		                System.out.println("Itemid:" + tmpItemObject.getItemid());  
		                System.out.println("Templateid:"  
		                    + tmpItemObject.getTemplateid());  
		                System.out.println("Hostid:" + tmpItemObject.getHostid());  
		                System.out.println("Name:" + tmpItemObject.getName());  
		                System.out.println("Key:" + tmpItemObject.getKey_());  
		                System.out.println("Lastvalue:"  
		                    + tmpItemObject.getLastvalue());  
		                System.out.println("Lastclock:"  
		                    + tmpItemObject.getLastclock());  
		                System.out.println("------------------------------------------");  
		      
		            }  
		      
		            System.out.println("*****************%%%%%%%%%%%%%%************");  
		      
	            }  
	      
	        } catch (ZabbixApiException e) {  
	            e.printStackTrace();  
	        }  
        }  
}  
 
ZabbixApiTestDummyMethodBase.java
 
package com.zabbix4j.apitest;

import com.zabbix4j.ZabbixApi;

public class ZabbixApiTestDummyMethodBase {  
	  
    protected ZabbixApi zabbixApi;  
  
    public ZabbixApiTestDummyMethodBase(ZabbixApi zabbixApi) {  
        this.zabbixApi = zabbixApi;  
    }  
}
 
相关jar包下载地址：http://zabbix.org/wiki/Docs/api/libraries#Java

上文说了，我是对zabbix做第二次开发的小白，既然要对zabbix做第二次开发又是小白，那么就得来研究zabbix提供的相关API了。
 于是我在zabbix网站各种找，终于在下面网址找到了：
 　　http://zabbix.org/wiki/Docs/api/libraries；这里面有各个开发语言的API，大家可以去看看。
 
　　接下来继续说Java的API，如下：
 
 
第一和第三都是连接zabbix server的api，第一个需要自己构造json格式的参数。 第二个sender 是开发向server 输送数据的api。
 　　第三个即是本次我研究的对象，这个api里面，进一步做了封装，也提供了一些测试代码。本次就从这里研究吧。（一起学习呀( ⊙ o ⊙ )！）
 　　要用这个API，可以导入zabbix4j这个包就好，相关的包都会导入进来，（我第一次就走了弯路，都是一个个的导包，后来想zabbix既然提供了API应该zabbix包啊？就试了试，果然有，吼吼吼~~）
 　
 　　为了测试我们还要导入其他包，如下：
 
 
下面就正式开始研究代码了：
 　　在zabbix的web界面中首先是从创建主机开始的，那么，这儿我们也先从创建主机开始研究吧，创建主机的代码如下：
 
 
 
import static org.junit.Assert.*;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import org.junit.Test;

import com.zabbix4j.host.HostCreateRequest;
import com.zabbix4j.host.HostCreateResponse;
import com.zabbix4j.hostinteface.HostInterfaceObject;
import com.zabbix4j.usermacro.Macro;

public class testCreateHost extends ZabbixApiTestBase{
	public testCreateHost(){
		super();
	}
	
	@Test
	public void createHost(){
//		这两个变量数据库中必须存在（我第一次就在这儿捣鼓了半天，以为创建主机就什么都是新的，
//		这是对zabbix本身的不理解导致的）
		final Integer groupId = 4;
		final Integer templateId = 10081;
		
		 try {
	            HostCreateRequest request = new HostCreateRequest();
	            HostCreateRequest.Params params = request.getParams();

	            params.addTemplateId(templateId);
	            params.addGroupId(groupId);
	            //添加宏
	            List<Macro> macros = new ArrayList<Macro>();
	            Macro macro1 = new Macro();
	            macro1.setMacro("{$MACRO1}");
	            macro1.setValue("value1");
	            macros.add(macro1);
	            params.setMacros(macros);
	            //添加主机接口
	            HostInterfaceObject hostInterface = new HostInterfaceObject();
	            hostInterface.setIp("192.168.106.133");
	            params.addHostInterfaceObject(hostInterface);
	            //添加主机，和主机名
	            params.setHost("test host created1." + new Date().getTime());
	            params.setName("test host created1 name" + new Date().getTime());

	            HostCreateResponse response = zabbixApi.host().create(request);
	            assertNotNull(response);
	            logger.debug(getGson().toJson(response));

	        } catch (Exception e) {
	            fail(e.getMessage());
	        }
	    }

	}

 
要在zabbix里面创建主机（做其他操作也一样），就要先通过身份验证，首先你要通过你自己的zabbix接口地址：http://IP/zabbix/api_jsonrpc.php；
 　　我将这个前提工作放在了一个类中，代码如下：
 
import static org.junit.Assert.fail;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.zabbix4j.ZabbixApi;
import com.zabbix4j.ZabbixApiException;



public class ZabbixApiTestBase {

    protected static Logger logger = LoggerFactory.getLogger(ZabbixApiTestBase.class);
    protected static String user = "Admin";//zabbix登录账号
    protected static String password = "zabbix";//zabbix登录密码

    protected ZabbixApi zabbixApi;

    public ZabbixApiTestBase() {
        login(user, password);
    }

    protected void login(String user, String password) {
        try {
            zabbixApi = new ZabbixApi("http://192.168.2.118/zabbix/api_jsonrpc.php");
            zabbixApi.login(user, password);
        } catch (ZabbixApiException e) {
            fail(e.getMessage());
        }
    }
   

    protected Gson getGson() {

        return new GsonBuilder().setPrettyPrinting().create();
    }

}
 

 小白的我正在学习的路上，希望各位大佬多多指教，谢谢，谢谢！
 

欢迎进群：747509472 一起交流学习！
 
 
 
 
 
 

前提：本人参与到一个关于调用zabbix API实现监控主机资源的项目。故将zabbixAPI的使用简单总结一下。有什么不对的地方还 
 
请指正。
 
一、zabbix相关网站
 
Zabbix是企业级软件，专为实时监控从数以万计的服务器，虚拟机和网络设备收集的数百万个指标而设计。
 
官网地址：https://www.zabbix.com
 
zabbix中文社区：http://www.zabbix.org.cn/
 
zabbix api 官方文档地址：https://www.zabbix.com/documentation/3.0/manual/api
 
官方中文文档地址：https://www.zabbix.com/documentation/3.4/zh/manual/introduction/manual_structure
 
zabibix学习网站：https://blog.cactifans.com/archives/page/2/
 
二、项目中SDK的引入
 
<dependency>
	<groupId>io.github.hengyunabc</groupId>
	<artifactId>zabbix-api</artifactId>
	<version>0.0.2</version>
</dependency>
 
 
 
 三、 API接口说明（此次只是说明本项目中用到的接口，接口使用大同小异）
 
由于使用zabbixAPI必须进行用户登录验证，所以在调用接口之前，必须先部署一个zabbix后台，拿到一个用户信息（包括用户名和密码）。
 
DefaultZabbixApi zabbixApi = new DefaultZabbixApi("http://zabbix服务器的主机IP/zabbix/api_jsonrpc.php");
// init方法中创建CloseableHttpClient客户端
zabbixApi.init();
//进行权限验证
boolean loginResult = zabbixApi.login("Admin", "zabbix");
if (!loginResult) {
	System.out.println("login fail");
}
 
代码说明：
 
一般 API  调用规则都是：前缀 url+参数；
 
http://zabbix服务器主机IP/zabbix/api_jsonrpc.php  是调用API的统一前缀 url。 
 
由于 zabbixapi 已经封装好了传递参数的方法。所以我们只需要调用 login 方法即可，如下所示
 
zabbixApi.login("username", "password");
 
login 方法源码解析：
 
public boolean login(String user, String password)
    {
        this.auth = null;
        Request request = RequestBuilder.newBuilder().
                          paramEntry("user", user).
                          paramEntry("password", password).
                          method("user.login").build();
        JSONObject response = call(request);
        String auth = response.getString("result");
        if(auth != null && !auth.isEmpty())
        {
            this.auth = auth;
            return true;
        } else
        {
            return false;
        }
 }
 
username和password 传入后，会调用 user.login 方法，来获取 一个 auth .存放到本地 属性 auth。
 
    private CloseableHttpClient httpClient;
    private URI uri;
    private volatile String auth;
 
用户验证通过之后，便可以用上述创建的 zabbixApi 进行方法的调用。
 
【*-*1】ZabbixAPI支持的参数类型：
 
 
【*-*2】通用参数简要说明
 
 
output参数：当传递的是 extend 时，返回所有字段，当我们只需要返回特定字段的时候，output的值只需传递一个 属性名称数组即可。下面示例中会有代码实例。
 
 
filter 参数： 以下有示例代码。
 
示例1、获取所有主机组（hostgroup）
 
Request request = RequestBuilder.newBuilder().method("hostgroup.get").
				  paramEntry("output", "extend").build();
 
method("hostgroup.get")中填写的是调用的方法名，paramEntry("output", "extend")传递的是接口需要的参数，可同时设置多个paramEntry("paramName", "paramValue")。接下来的示例会有具体的代码。
 
示例2、获取所有主机（host）
 
Request request2 = RequestBuilder.newBuilder().method("host.get").
				   paramEntry("output", "extend").build();
 
示例3、获取报警信息（alert）
 
Request request3 = RequestBuilder.newBuilder().method("alert.get").
                    paramEntry("output","extend").
                    paramEntry("time_from",DateUtil.getTimeMs(6)/1000).//从某个时间点开始
                    paramEntry("time_till",DateUtil.getTimeMs(5)/1000).//截止某个时间点
		    paramEntry("hostids", new String[]{"10084","10109"}). build();
 
 api截图说明，
 
 
从截图中可以看出 hostids 参数可传递的值的类型 为 String，例如 “10084”；
 
也可以是 array ,所以示例中参数值传递的是一个string类型的数组 new String[]{"10084","10109"}。以下示例中同理
 
示例4、获取触发器信息（trigger）
 
//获取所有触发器信息
Request request123 = RequestBuilder.newBuilder().method("trigger.get").
		paramEntry("output","extend").build();
//获取 监控项id为 24028、24015 的触发器信息
Request request456 = RequestBuilder.newBuilder().method("trigger.get").
		paramEntry("output","extend").
		paramEntry("itemids", new String[]{"24028","24015"}). build();
 
示例5、获取监控项信息（item）
 
通过 Key 查询 Items
 
从key中具有“system”一词的ID为“10112”的主机检索所有监控项
 
JSONObject json = new JSONObject();
json.put("key_", new String[]{"system"});
Request request55 = RequestBuilder.newBuilder().method("item.get").
    paramEntry("output", new String[]{"hostid","key_","itemid","lastvalue","prevvalue"})
    .paramEntry("hostids", new String[]{"10112"})
	.paramEntry("filter",json).build();
 
===========================================================================
 
完整示例
 
public class za {
	public static void main(String[] args) {
		DefaultZabbixApi zabbixApi = new DefaultZabbixApi("http://zabbix服务器IP/zabbix/api_jsonrpc.php");
		zabbixApi.init();
                try{
		    boolean loginResult = zabbixApi.login("登录用户名", "密码");
		    if (!loginResult) {
			    System.out.println("login fail");
                return；                        
		    }
		    //查询所有主机
		    Request request = RequestBuilder.newBuilder().method     ("hostgroup.get").paramEntry("output", "extend").build();
		    //执行请求
		    JSONObject resJson = zabbixApi.call(request);
		    //处理结果
		    String error = String.valueOf(resJson.get("error"));
		    if (!StringUtils.isEmpty(error) && error != "null") {
			System.out.println("调用zabbix接口出错");
		    }else{
			JSONArray jsonArray = resJson.getJSONArray("result");
			String resultStr = jsonArray.toJSONString();
			System.out.println("结果：：：：："+resultStr);
		    }
                }catch(Exception e){
                    e.printStackTrace();
                }finally {
                    if (zabbixApi!=null) {
		        zabbixApi.destroy();
		    }
                }    
	}
}