JAVA实现对阿里云DNS的解析管理

 更新时间:2022年01月18日 08:28:23   作者:网无忌  
本文主要介绍了JAVA实现对阿里云DNS的解析管理,文中通过示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

1、阿里云DNS的SDK依赖

<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>tea-openapi</artifactId>
    <version>0.0.19</version>
</dependency>
<dependency>
    <groupId>com.aliyun</groupId>
    <artifactId>alidns20150109</artifactId>
    <version>2.0.1</version>
</dependency>

2、第一个方法:创建SDK客户端实例

所有解析记录的操作都要通过这个客户端实例来进行,所以要首先创建这个实例,需要阿里云的AccessKey(AppId和AppSecret)

/**
 * <p>
 * 创建客户端实例
 * </p>
 * 
 * @return
 * @throws Exception
 */
private Client createClient() throws Exception{
    AliConfig api = APIKit.getAliConfig(); //返回阿里云的AccessKey参数
    if(api == null) throw new ErrException("未配置阿里云API参数!");
    Config config = new Config();
    config.accessKeyId = api.getAppId();
    config.accessKeySecret = api.getAppSecret();
    config.endpoint = "alidns.cn-beijing.aliyuncs.com";
    return new Client(config);
}

3、第二个方法:返回指定的记录ID(RecordId)

在阿里云的SDK中,对解析记录进行修改和删除时,都需要传入 RecordId 这个参数,所以提前写一个获取记录ID的方法。

/**
 * <p>
 * 返回指定主机记录的ID,不存在时返回null
 * </p>
 * 
 * @param DomainName
 * @param RR 记录名称
 * @return
 */
private String getRecId(Client client, String DomainName, String RR){
    String recId = null;
    try {
        DescribeDomainRecordsRequest request = new DescribeDomainRecordsRequest();
        request.setDomainName(DomainName);
        request.setRRKeyWord(RR);
        DescribeDomainRecordsResponse response = client.describeDomainRecords(request);
        if(response.getBody().getTotalCount() > 0){
            List<DescribeDomainRecordsResponseBodyDomainRecordsRecord> recs = response.getBody().getDomainRecords().getRecord();
            for(DescribeDomainRecordsResponseBodyDomainRecordsRecord rec: recs){
                if(rec.getRR().equalsIgnoreCase(RR)){
                    recId = rec.getRecordId();
                    break;
                }
            }
        }
    } catch (Exception e) {
    }
    return recId;
}

4、第三个方法:添加或修改指定的记录

方便起见,这里我将添加和修改集成到了一个方法,相当于SaveOrUpdate。

/**
 * <p>
 * 添加或修改解析记录
 * </p>
 * 
 * @param DomainName 域名
 * @param RR 记录名称
 * @param Type 记录类型(A、AAAA、MX、TXT、CNAME)
 * @param Value 记录值
 */
public void update(String DomainName, String RR, String Type, String Value){
    try {
        if(EStr.isEmpty(DomainName)) throw new RuntimeException("域名(DomainName)为空!");
        if(EStr.isEmpty(RR)) throw new RuntimeException("主机记录(RR)为空!");
        if(EStr.isEmpty(Type)) throw new RuntimeException("记录类型(Type)为空!");
        if(EStr.isEmpty(Value)) throw new RuntimeException("记录值(Value)为空!");
        Client client = createClient();
        String recId = getRecId(client, DomainName, RR);
        if(EStr.isNull(recId)){ //添加
            AddDomainRecordRequest request = new AddDomainRecordRequest();
            request.setDomainName(DomainName);
            request.setRR(RR);
            request.setType(Type);
            request.setValue(Value);
            AddDomainRecordResponse response = client.addDomainRecord(request);
            recId = response.getBody().getRecordId();
        }else{ //修改
            UpdateDomainRecordRequest request = new UpdateDomainRecordRequest();
            request.setRecordId(recId);
            request.setRR(RR);
            request.setType(Type);
            request.setValue(Value);
            UpdateDomainRecordResponse response = client.updateDomainRecord(request);
            recId = response.getBody().getRecordId();
        }
        renderJson(Result.success("recId", recId));
    } catch (Exception e) {
        renderJson(Result.fail(e.getMessage()));
    }
}

5、第四个方法:删除指定的记录

这个很简单,根据查找到的RecordId直接删除即可。

/**
 * <p>
 * 删除记录
 * </p>
 * 
 * @param DomainName
 * @param RR
 */
public void remove(String DomainName, String RR){
    try {
        if(EStr.isEmpty(DomainName)) throw new RuntimeException("域名(DomainName)为空!");
        if(EStr.isEmpty(RR)) throw new RuntimeException("主机记录(RR)为空!");
        Client client = createClient();
        String recId = getRecId(client, DomainName, RR);
        if(EStr.isNull(recId)){
            renderJson(Result.success("recId", null));
        }else{
            DeleteDomainRecordRequest request = new DeleteDomainRecordRequest();
            request.setRecordId(recId);
            DeleteDomainRecordResponse response = client.deleteDomainRecord(request);
            renderJson(Result.success("recId", response.getBody().getRecordId()));
        }
    } catch (Exception e) {
        renderJson(Result.fail(e.getMessage()));
    }
}

6、完整代码

package itez.alidns.controller;
import java.util.List;
import com.aliyun.alidns20150109.Client;
import com.aliyun.alidns20150109.models.AddDomainRecordRequest;
import com.aliyun.alidns20150109.models.AddDomainRecordResponse;
import com.aliyun.alidns20150109.models.DeleteDomainRecordRequest;
import com.aliyun.alidns20150109.models.DeleteDomainRecordResponse;
import com.aliyun.alidns20150109.models.DescribeDomainRecordsRequest;
import com.aliyun.alidns20150109.models.DescribeDomainRecordsResponse;
import com.aliyun.alidns20150109.models.DescribeDomainRecordsResponseBody.DescribeDomainRecordsResponseBodyDomainRecordsRecord;
import com.aliyun.alidns20150109.models.UpdateDomainRecordRequest;
import com.aliyun.alidns20150109.models.UpdateDomainRecordResponse;
import com.aliyun.teaopenapi.models.Config;
 
import itez.core.wrapper.controller.ControllerDefine;
import itez.core.wrapper.controller.EController;
import itez.kit.EStr;
import itez.kit.exception.ErrException;
import itez.kit.restful.Result;
import itez.plat.main.model.CompWx;
import itez.plat.main.service.CompWxService;
import itez.weixin.api.ApiConfigKit.ConfigType;
 
/**
 * <p>
 * 阿里云DNS解析
 * 示例:http://localhost/alidns/update?DomainName=domain.com&RR=test&Type=A&Value=8.8.8.8
 * </p>
 * 
 * <p>Copyright(C) 2017-2022 <a href="http://www.itez.com.cn">上游科技</a></p>
 * 
 * @author        <a href="mailto:netwild@qq.com">Z.Mingyu</a>
 * @date        2022年1月12日 下午2:38:31
 */
@ControllerDefine(key = "/alidns", summary = "阿里云DNS解析", view = "/")
public class AliDnsController extends EController {
        
    /**
     * <p>
     * 添加或修改解析记录
     * </p>
     * 
     * @param DomainName 域名
     * @param RR 记录名称
     * @param Type 记录类型(A、AAAA、MX、TXT、CNAME)
     * @param Value 记录值
     */
    public void update(String DomainName, String RR, String Type, String Value){
        try {
            if(EStr.isEmpty(DomainName)) throw new RuntimeException("域名(DomainName)为空!");
            if(EStr.isEmpty(RR)) throw new RuntimeException("主机记录(RR)为空!");
            if(EStr.isEmpty(Type)) throw new RuntimeException("记录类型(Type)为空!");
            if(EStr.isEmpty(Value)) throw new RuntimeException("记录值(Value)为空!");
            Client client = createClient();
            String recId = getRecId(client, DomainName, RR);
            if(EStr.isNull(recId)){ //添加
                AddDomainRecordRequest request = new AddDomainRecordRequest();
                request.setDomainName(DomainName);
                request.setRR(RR);
                request.setType(Type);
                request.setValue(Value);
                AddDomainRecordResponse response = client.addDomainRecord(request);
                recId = response.getBody().getRecordId();
            }else{ //修改
                UpdateDomainRecordRequest request = new UpdateDomainRecordRequest();
                request.setRecordId(recId);
                request.setRR(RR);
                request.setType(Type);
                request.setValue(Value);
                UpdateDomainRecordResponse response = client.updateDomainRecord(request);
                recId = response.getBody().getRecordId();
            }
            renderJson(Result.success("recId", recId));
        } catch (Exception e) {
            renderJson(Result.fail(e.getMessage()));
        }
    }
    
    /**
     * <p>
     * 删除记录
     * </p>
     * 
     * @param DomainName
     * @param RR
     */
    public void remove(String DomainName, String RR){
        try {
            if(EStr.isEmpty(DomainName)) throw new RuntimeException("域名(DomainName)为空!");
            if(EStr.isEmpty(RR)) throw new RuntimeException("主机记录(RR)为空!");
            Client client = createClient();
            String recId = getRecId(client, DomainName, RR);
            if(EStr.isNull(recId)){
                renderJson(Result.success("recId", null));
            }else{
                DeleteDomainRecordRequest request = new DeleteDomainRecordRequest();
                request.setRecordId(recId);
                DeleteDomainRecordResponse response = client.deleteDomainRecord(request);
                renderJson(Result.success("recId", response.getBody().getRecordId()));
            }
        } catch (Exception e) {
            renderJson(Result.fail(e.getMessage()));
        }
    }
 
    /**
     * <p>
     * 返回指定主机记录的ID,不存在时返回null
     * </p>
     * 
     * @param DomainName
     * @param RR 记录名称
     * @return
     */
    private String getRecId(Client client, String DomainName, String RR){
        String recId = null;
        try {
            DescribeDomainRecordsRequest request = new DescribeDomainRecordsRequest();
            request.setDomainName(DomainName);
            request.setRRKeyWord(RR);
            DescribeDomainRecordsResponse response = client.describeDomainRecords(request);
            if(response.getBody().getTotalCount() > 0){
                List<DescribeDomainRecordsResponseBodyDomainRecordsRecord> recs = response.getBody().getDomainRecords().getRecord();
                for(DescribeDomainRecordsResponseBodyDomainRecordsRecord rec: recs){
                    if(rec.getRR().equalsIgnoreCase(RR)){
                        recId = rec.getRecordId();
                        break;
                    }
                }
            }
        } catch (Exception e) {
        }
        return recId;
    }
    
    /**
     * <p>
     * 创建客户端实例
     * </p>
     * 
     * @return
     * @throws Exception
     */
    private Client createClient() throws Exception{
        AliConfig api = APIKit.getAliConfig(); //返回阿里云的AccessKey参数
        if(api == null) throw new ErrException("未配置阿里云API参数!");
        Config config = new Config();
        config.accessKeyId = api.getAppId();
        config.accessKeySecret = api.getAppSecret();
        config.endpoint = "alidns.cn-beijing.aliyuncs.com";
        return new Client(config);
    }  
}

到此这篇关于JAVA实现对阿里云DNS的解析管理的文章就介绍到这了,更多相关JAVA 阿里云DNS 内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Java 基于tcp协议实现文件上传

    Java 基于tcp协议实现文件上传

    这篇文章主要介绍了Java 基于tcp协议实现文件上传,帮助大家更好的理解和使用Java,感兴趣的朋友可以了解下
    2020-11-11
  • SpringMvc @Valid如何抛出拦截异常

    SpringMvc @Valid如何抛出拦截异常

    这篇文章主要介绍了SpringMvc @Valid如何抛出拦截异常,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-09-09
  • Java8新特性Optional类处理空值判断回避空指针异常应用

    Java8新特性Optional类处理空值判断回避空指针异常应用

    这篇文章主要介绍了Java8新特性Optional类处理空值判断回避空指针异常应用,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步早日升职加薪
    2022-04-04
  • java 实现局域网文件传输的实例

    java 实现局域网文件传输的实例

    这篇文章主要介绍了java 实现局域网文件传输的实例的相关资料,这里提供了实现代码可以帮助大家理解TCP及文件读写的知识,需要的朋友可以参考下
    2017-07-07
  • springboot应用中使用过滤器的过程详解

    springboot应用中使用过滤器的过程详解

    过滤器通常用于实现跨切面的功能,例如身份验证、日志记录、请求和响应的修改、性能监控等,这篇文章主要介绍了springboot应用中使用过滤器,需要的朋友可以参考下
    2023-06-06
  • 使用linux部署Spring Boot程序

    使用linux部署Spring Boot程序

    springboot程序在linux服务器上应该怎么部署?这次就分享下linux下如何正确部署springboot程序,感兴趣的朋友一起看看吧
    2018-01-01
  • SpringBoot如何通过webjars管理静态资源文件夹

    SpringBoot如何通过webjars管理静态资源文件夹

    这篇文章主要介绍了SpringBoot如何通过webjars管理静态资源文件夹,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-10-10
  • 扩展tk.mybatis的流式查询功能实现

    扩展tk.mybatis的流式查询功能实现

    mybatis查询默认是一次获取全部,如果数据过于庞大,就会导致OOM问题,本文就介绍了tk.mybatis 流式查询,具有一定的参考价值,感兴趣的可以了解一下
    2021-12-12
  • 基于Java8 函数式接口理解及测试

    基于Java8 函数式接口理解及测试

    下面小编就为大家带来一篇基于Java8 函数式接口理解及测试。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-08-08
  • Feign调用全局异常处理解决方案

    Feign调用全局异常处理解决方案

    这篇文章主要介绍了Feign调用全局异常处理解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-06-06

最新评论