“携手创作,共同生长!这是我参与「日新方案 10 月更文应战」的第二天,点击检查活动详情”

本文是在建立了Neo4j的前提下进行,假如还未建立能够先看这篇文章【云原生专题】根据Docker+Neo4j图数据库建立企业级分布式运用拓扑图,但是只介绍了运用Cypher言语在Neo4j的浏览器中执行增删查改的操作,现在咱们想要根据SpringBoot来实现代码层面的增删查改。

一、环境建立

最便捷的方式便是访问start.spring.io,新建一个项目,挑选的依靠有:

  • spring-boot-starter-data-neo4j
  • spring-boot-starter-web
  • lombok

然后JDK需求挑选11版别,因为咱们当前运用的Neo4j版别是4.4.7,能够在Neo4j的浏览器中左下角“About Neo4j”中看到运用的版别号,其对应需求支撑的JDK版别能够在官网中查到:

1. JDK 11
Neo4j 4.0 is the first major release that requires JDK 11. Custom extensions and procedures can be compiled now for JDK 11, for example, -target 11. It is generally recommended to use the latest available JDK 11 to access all available fixes and performance improvements.

假如本地Neo4j是经过Docker镜像装置的,咱们能够进入镜像内部,运用命令检查Neo4j运转的Java版别信息:

# java -version
openjdk version "11.0.15" 2022-04-19
OpenJDK Runtime Environment 18.9 (build 11.0.15+10)
OpenJDK 64-Bit Server VM 18.9 (build 11.0.15+10, mixed mode, sharing)

假如不是经过Docker镜像装置的,那么本地就需求自行装置JDK11了,相同的,在运转如上咱们下载的SpringBoot工程时,相同需求挑选项目根据的JDK版别为11,然后才能正常运转。

二、Neo4jRepository介绍

Neo4jRepository是SpringData为咱们提供的用来操作Neo4j数据库的接口,咱们先来看看它的继承联系:

微服务SpringBoot+Neo4j搭建企业级分布式应用拓扑图

Neo4jRepository的继承联系

能够看到,通用的增删查改功能根本都有了,假如咱们的数据库操作也是些简单的操作,那根本就不必再增加办法了,直接运用Neo4jRepository提供的办法即可。当然也支撑咱们自定义办法进行操作,这个下面再信息讲述。

三、代码演示

这里的代码示例,仅仅展现体系节点的增加、相互之间联系的创立,其它增删查改操作,能够自行探索学习。

@Slf4j
@RestController
public class SystemController {
    @Autowired
    private SystemService systemService;
    public static final String SUCCESS_RESULT = "success";
    @GetMapping("/getAllSystemNode")
    public List<SystemEntity> getAllSystemNode(){
        return systemService.getAllSystemNode();
    }
    @GetMapping("/findSystemById/{id}")
    public SystemEntity findSystemById(@PathVariable("id") Long id){
        SystemEntity result = systemService.findSystemById(id);
        log.info("{}", result);
        return result;
    }
    @PostMapping("/addSystemNode")
    public String addSystemNode(@RequestBody SystemEntity systemEntity){
        systemService.addSystemNode(systemEntity);
        return SUCCESS_RESULT;
    }
    @GetMapping("addInvokeRelation/{from}/{to}")
    public String addInvokeRelation(@PathVariable("from") Long from, @PathVariable("to") Long to){
        systemService.addInvokeRelation(from, to);
        return SUCCESS_RESULT;
    }
    @GetMapping("addConsumeRelation/{from}/{to}")
    public String addConsumeRelation(@PathVariable("from") Long from, @PathVariable("to") Long to){
        systemService.addConsumeRelation(from, to);
        return SUCCESS_RESULT;
    }
    @GetMapping("addProduceRelation/{from}/{to}")
    public String addProduceRelation(@PathVariable("from") Long from, @PathVariable("to") Long to){
        systemService.addProduceRelation(from, to);
        return SUCCESS_RESULT;
    }
}
@Slf4j
@Service
public class SystemService {
    @Resource
    private SystemRepository systemRepository;
    public List<SystemEntity> getAllSystemNode(){
        List<SystemEntity> systemEntityList = systemRepository.findAll();
        log.info("查询一切的节点为:{}", systemEntityList);
        return systemEntityList;
    }
    public void addSystemNode(SystemEntity systemEntity){
        SystemEntity result = systemRepository.save(systemEntity);
        log.info("增加节点后的回来结果为:{}", result);
    }
    public void addInvokeRelation(Long from, Long to){
        systemRepository.addInvokeRelation(from, to);
    }
    public void addConsumeRelation(Long from, Long to){
        systemRepository.addConsumeRelation(from, to);
    }
    public void addProduceRelation(Long from, Long to){
        systemRepository.addProduceRelation(from, to);
    }
    public SystemEntity findSystemById(Long id){
        return systemRepository.findSystemById(id);
    }
}
/**
 * Neo4jRepository<T, ID>
 * T表明节点类,ID表明主键类型
 */
public interface SystemRepository extends Neo4jRepository<SystemEntity, Long> {
    @Query("MATCH (a),(b) WHERE id(a)=$from and id(b)=$to MERGE (a)-[:invoke]->(b)")
    void addInvokeRelation(@Param("from") Long from, @Param("to") Long to);
    @Query("MATCH (a),(b) WHERE id(a)=$from and id(b)=$to MERGE (a)-[:consume]->(b)")
    void addConsumeRelation(@Param("from") Long from, @Param("to") Long to);
    @Query("MATCH (a),(b) WHERE id(a)=$from and id(b)=$to MERGE (a)-[:produce]->(b)")
    void addProduceRelation(@Param("from") Long from, @Param("to") Long to);
    /**
     * 运用节点id时只能用id(n)这种写法,其它特点能够用n.name这样的写法
     * @param id
     * @return
     */
    @Query("MATCH (n) where id(n)=$id RETURN n")
    SystemEntity findSystemById(@Param("id") Long id);
    //等价写法@Query("MATCH (n:SystemEntity {leader: $leader}) RETURN n")
    @Query("MATCH (n) where n.leader=$leader RETURN n")
    SystemEntity findSystemByLeader(@Param("leader") String leader);
}

然后,运转如上SpringBoot项目后,咱们按照上一篇文章中的示例,顺次增加体系节点和联系之后,能够得到图如下:

微服务SpringBoot+Neo4j搭建企业级分布式应用拓扑图

实现的体系架构可视化

该比如和上一篇比如稍微有些不同,此处一切体系节点的类型都设置为了System,所以同一类型的节点色彩都是相同的。

四、待解决问题

可能是由于自己Cypher言语不熟悉,许多CRUD句子用的还不顺畅,比如为什么用到id时,不能运用n.id的写法,还有SystemRepository中调用联系的类型如何参数化,这样就不必为每一种调用联系创立办法了,假如有知道的朋友能够告知下