登录
当前位置： 首页 > 工具软件 > Apache Eagle > 使用案例 >

Apache Eagle代码逻辑分析--后台REST接口代码逻辑

谷梁晟
2023-12-01
  1. SiteResource.java相当于 Dropwizard框架里的Resource类。
  2. SiteEntity.java相当于Dropwizard框架里的Representation类，用来定义返回的结果的数据字段。
  3. 在JDBCMetadataStore.java里面绑定的SiteEntityServiceJDBCImpl和SiteEntityService相当于封装的底层数据库查询类。然后在SiteResource里被调用。
  4. SiteResource在ServerApplication的run函数中注册，不需要在指定文件中注册，由程序启动时对org.apache.eagle这个package下的所有进行注册。

(Dropwizard简单入门https://www.cnblogs.com/sunfie/p/6831517.html)

 

SiteResource

Resource有两个声明：@Path和@Produces。@Path("/sites")告诉Jersey这个resource可以通过 "/sites"URL被访问。

@Produces(MediaType.APPLICATION_JSON)让Jersey的内容协商代码知道这个资源产生的是application/json.

E:\code\eagle\eagle-master-0.5.0-SNAPSHOT\eagle-core\eagle-metadata\eagle-metadata-base\src\main\java\org\apache\eagle\metadata\resource\SiteResource.java

@Path("/sites")
@Singleton
public class SiteResource {
    private final SiteEntityService siteEntityService;
    private final ApplicationEntityService entityService;

    @Inject
    public SiteResource(SiteEntityService siteEntityService,
                        ApplicationEntityService applicationEntityService) {
        this.siteEntityService = siteEntityService;
        this.entityService = applicationEntityService;
    }

    @GET
    @Produces(MediaType.APPLICATION_JSON)
    public RESTResponse<Collection<SiteEntity>> getAllSites() {
        return RESTResponse.async(siteEntityService::findAll).get();
    }

    @POST
    @Consumes(MediaType.APPLICATION_JSON)
    @Produces(MediaType.APPLICATION_JSON)
    public RESTResponse<SiteEntity> createSite(SiteEntity siteEntity) {
        return RESTResponse.<SiteEntity>async((builder) -> {
            SiteEntity entity = siteEntityService.create(siteEntity);
            builder.message("Successfully created site (siteId:" + entity.getSiteId() + ", uuid: " + entity.getUuid() + ")");
            builder.data(entity);
        }).get();
    }

    @GET
    @Path("/{siteId}")
    @Produces(MediaType.APPLICATION_JSON)
    public RESTResponse<SiteEntity> getSiteBySiteId(@PathParam("siteId") String siteId) {
        return RESTResponse.async(() -> siteEntityService.getBySiteId(siteId)).get();
    }

    @DELETE
    @Path("/{siteId}")
    @Produces(MediaType.APPLICATION_JSON)
    public RESTResponse<SiteEntity> deleteSiteBySiteId(@PathParam("siteId") String siteId) {
        return RESTResponse.async(() -> {
            int appCount = entityService.findBySiteId(siteId).size();
            if (appCount > 0) {
                throw new SiteDeleteException("This site has enabled applications, remove them first");
            }
            return siteEntityService.deleteBySiteId(siteId);
        }).get();
    }

    @DELETE
    @Consumes(MediaType.APPLICATION_JSON)
    @Produces(MediaType.APPLICATION_JSON)
    public RESTResponse<SiteEntity> deleteSiteByUUID(UUIDRequest uuidRequest) {
        return RESTResponse.async(() -> {
            int appCount = entityService.findBySiteId(siteEntityService.getByUUID(uuidRequest.getUuid()).getSiteId()).size();
            if (appCount > 0) {
                throw new SiteDeleteException("This site has enabled applications, remove them first");
            }
            return siteEntityService.deleteByUUID(uuidRequest.getUuid());
        }).get();
    }

    @PUT
    @Path("/{siteId}")
    @Produces(MediaType.APPLICATION_JSON)
    @Consumes(MediaType.APPLICATION_JSON)
    public RESTResponse<SiteEntity> updateSite(@PathParam("siteId") String siteId, SiteEntity siteEntity) {
        return RESTResponse.async(() -> {
            siteEntity.setSiteId(siteId);
            return siteEntityService.update(siteEntity);
        }).get();
    }

    @PUT
    @Produces(MediaType.APPLICATION_JSON)
    @Consumes(MediaType.APPLICATION_JSON)
    public RESTResponse<SiteEntity> updateSite(SiteEntity siteEntity) {
        return RESTResponse.async(() -> {
            return siteEntityService.update(siteEntity);
        }).get();
    }
}
 

 

JDBCMetadataStore

public class JDBCMetadataStore extends MetadataStore {
    @Override
    protected void configure() {
        bind(IMetadataDao.class).to(JdbcMetadataDaoImpl.class).in(Singleton.class);
        bind(DataSource.class).toProvider(JDBCDataSourceProvider.class).in(Singleton.class);
        bind(JDBCDataSourceConfig.class).toProvider(JDBCMetadataStoreConfigProvider.class).in(Singleton.class);
        bind(JDBCMetadataQueryService.class).to(JDBCMetadataMetadataStoreServiceImpl.class).in(Singleton.class);
        bind(ApplicationEntityService.class).to(ApplicationEntityServiceJDBCImpl.class).in(Singleton.class);
        bind(SiteEntityService.class).to(SiteEntityServiceJDBCImpl.class).in(Singleton.class);
        bind(DashboardEntityService.class).to(DashboardEntityServiceJDBCImpl.class).in(Singleton.class);
        bind(PolicyEntityService.class).to(PolicyEntityServiceJDBCImpl.class).in(Singleton.class);
    }
}

 

SiteEntityServiceJDBCImpl:定义了所有的site的数据库操作函数

E:\code\eagle\eagle-master-0.5.0-SNAPSHOT\eagle-core\eagle-metadata\eagle-metadata-jdbc\src\main\java\org\apache\eagle\metadata\store\jdbc\service\SiteEntityServiceJDBCImpl.java

public class SiteEntityServiceJDBCImpl implements SiteEntityService {

    private static final Logger LOGGER = LoggerFactory.getLogger(SiteEntityServiceJDBCImpl.class);
    private static final String insertSql = "INSERT INTO sites (siteid, sitename, description, createdtime, modifiedtime, uuid) VALUES (?, ?, ?, ?, ?, ?)";
    private static final String selectSql = "SELECT * FROM sites";
    private static final String selectSqlByUUID = "SELECT * FROM sites where uuid = ?";
    private static final String selectSqlBySiteId = "SELECT * FROM sites where siteid = ?";
    private static final String deleteSqlByUUID = "DELETE FROM sites where uuid = ?";
    private static final String deleteSqlBySiteId = "DELETE FROM sites where siteid = ?";
    private static final String updateSqlByUUID = "UPDATE sites SET siteid = ? , sitename = ? , description = ? , createdtime = ? , modifiedtime = ?  where uuid = ?";
    @Inject
    JDBCMetadataQueryService queryService;

    @Override
    public SiteEntity getBySiteId(String siteId) throws EntityNotFoundException {
        List<SiteEntity> results;
        SiteEntity siteEntity = new SiteEntity("", siteId);
        try {
            results = queryService.queryWithCond(selectSqlBySiteId, siteEntity, new SiteEntityToRelation(), new RelationToSiteEntity());
        } catch (SQLException e) {
            LOGGER.error("Error to getBySiteId SiteEntity: {}", e);
            throw new EntityNotFoundException(e);
        }
        if (results.isEmpty()) {
            throw new EntityNotFoundException("getBySiteId " + siteId + " Not Found");
        }
        return results.get(0);
    }

    @Override
    public SiteEntity deleteBySiteId(String siteId) throws EntityNotFoundException {
        SiteEntity siteEntity = new SiteEntity("", siteId);
        int result;
        try {
            result = queryService.update(deleteSqlBySiteId, siteEntity, new SiteEntityToRelation());
        } catch (SQLException e) {
            LOGGER.error("Error to deleteBySiteId SiteEntity: {}", siteEntity, e);
            throw new EntityNotFoundException(e);
        }
        if (result == 0) {
            throw new EntityNotFoundException("deleteBySiteId " + siteEntity + "Not Found");
        }
        return siteEntity;
    }

    @Override
    public SiteEntity deleteByUUID(String uuid) throws EntityNotFoundException {
        SiteEntity siteEntity = new SiteEntity(uuid, "");
        int result;
        try {
            result = queryService.update(deleteSqlByUUID, siteEntity, new SiteEntityToRelation());
        } catch (SQLException e) {
            LOGGER.error("Error to deleteByUUID SiteEntity: {}", siteEntity, e);
            throw new EntityNotFoundException(e);
        }
        if (result == 0) {
            throw new EntityNotFoundException("deleteByUUID " + siteEntity + "Not Found");
        }
        return siteEntity;
    }

    @Override
    public SiteEntity update(SiteEntity siteEntity) throws EntityNotFoundException {

        if (siteEntity.getSiteId() == null && siteEntity.getUuid() == null) {
            throw new IllegalArgumentException("siteId and UUID are both null, don't know how to update");
        }
        int result;
        try {
            SiteEntity oldEntity = getBySiteId(siteEntity.getSiteId());
            siteEntity.setUuid(oldEntity.getUuid());
            siteEntity.setCreatedTime(oldEntity.getCreatedTime());
            siteEntity.ensureDefault();
            result = queryService.update(updateSqlByUUID, siteEntity, new SiteEntityToRelation());
        } catch (SQLException e) {
            LOGGER.error("Error to update SiteEntity: {}", siteEntity, e);
            throw new EntityNotFoundException(e);
        }
        if (result == 0) {
            throw new EntityNotFoundException("update " + siteEntity + "Not Found");
        }

        return siteEntity;
    }

    @Override
    public Collection<SiteEntity> findAll() {
        List<SiteEntity> results = new ArrayList<>();
        try {
            results = queryService.query(selectSql, new RelationToSiteEntity());
        } catch (SQLException e) {
            LOGGER.error("Error to findAll SiteEntity: {}", e);
        }
        return results;
    }

    @Override
    public SiteEntity getByUUID(String uuid) throws EntityNotFoundException {
        List<SiteEntity> results;
        SiteEntity siteEntity = new SiteEntity(uuid, "");
        try {
            results = queryService.queryWithCond(selectSqlByUUID, siteEntity, new SiteEntityToRelation(), new RelationToSiteEntity());
        } catch (SQLException e) {
            LOGGER.error("Error to getByUUID SiteEntity: {}", e);
            throw new EntityNotFoundException(e);
        }
        if (results.isEmpty()) {
            throw new EntityNotFoundException("getByUUID " + uuid + " Not Found");
        }
        return results.get(0);
    }

    @Override
    public SiteEntity create(SiteEntity entity) {
        Preconditions.checkNotNull(entity.getSiteId(), "SiteId is null: " + entity.getSiteId());
        List<SiteEntity> entities = new ArrayList<>(1);
        entity.ensureDefault();
        entities.add(entity);
        try {
            queryService.insert(insertSql, entities, new SiteEntityToRelation());
        } catch (SQLException e) {
            LOGGER.error("Error to insert SiteEntity: {}", entity, e);
            throw new IllegalArgumentException("Error to insert SiteEntity: " + entity + e);
        }
        return entity;
    }
}

 

SiteEntity.java

E:\code\eagle\eagle-master-0.5.0-SNAPSHOT\eagle-core\eagle-metadata\eagle-metadata-base\src\main\java\org\apache\eagle\metadata\model\SiteEntity.java

public class SiteEntity extends PersistenceEntity {
    private String siteId;
    private String siteName;
    private String description;
    private Map<String, String> context;

    public SiteEntity() {
    }

    public SiteEntity(String uuid, String siteId) {
        super.setUuid(uuid);
        this.siteId = siteId;
    }

    public String getDescription() {
        return description;
    }

    public void setDescription(String description) {
        this.description = description;
    }

    @Override
    public String toString() {
        return String.format("SiteEntity[siteId = %s, siteName =%s, description = %s, uuid = %s]", getSiteId(), getSiteName(), getDescription(), getUuid());
    }

    public String getSiteId() {
        return siteId;
    }

    public void setSiteId(String siteId) {
        this.siteId = siteId;
    }

    public String getSiteName() {
        return siteName;
    }

    public void setSiteName(String siteName) {
        this.siteName = siteName;
    }

    public Map<String, String> getContext() {
        return context;
    }

    public void setContext(Map<String, String> context) {
        this.context = context;
    }
}

 

 类似资料：

相关阅读

Struts逻辑：迭代输入字段java代码执行字符串中的逻辑运算方法分析PHP代码jquery向后台提交数组的代码分析jsp servlet javaBean后台分页实例代码解析

相关文章

MySQL逻辑运算符Python逻辑运算符Java逻辑运算符逻辑回归 Logistic RegressionR语言逻辑回归

相关问答

Firebase和后端逻辑如何停止到达率从源代码中的任何逻辑？使用Java代码处理自定义逻辑的模拟服务器从代码后编辑web.config中的httpErrors部分有关于35114安全认证核心逻辑以及相关代码吗？

相关文档

逻辑十九讲Tendermint 源码分析Memcached 源码分析OpenStack Neutron 源码分析OpenStack HeatClient 源码分析
快捷导航： 新手教程 算法原理 架构设计 Java进阶 数据库进阶 大厂专栏 面试经验 编程笔记 编程问答 所有专题 文档资料 工具软件 电子书籍 小牛导航
在线工具： 房贷计算器 个税计算器 Linux命令查询 Json格式化 正则表达式 颜色转换 AES加解密 SHA1加密 MD5加密 毒鸡汤 字数统计 随机密码生成 进制转换 Base64编解码 励志句子
Copyright © 2019-2024 小牛知识库@xnip.cn. All Rights Reserved.