微服務(wù)SpringBoot+Neo4j搭建企業(yè)級分布式應(yīng)用拓?fù)鋱D

一、環(huán)境搭建

最便捷的方式就是訪問start.spring.io纯路,新建一個(gè)項(xiàng)目,選擇的依賴有:

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

然后JDK需要選擇11版本寞忿,因?yàn)槲覀儺?dāng)前使用的Neo4j版本是4.4.7驰唬,可以在Neo4j的瀏覽器中左下角“About Neo4j”中看到使用的版本號,其對應(yīng)需要支持的JDK版本可以在官網(wǎng)中查到:

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鏡像安裝的,我們可以進(jìn)入鏡像內(nèi)部叫编,使用命令查看Neo4j運(yùn)行的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了,同樣的搓逾,在運(yùn)行如上我們下載的SpringBoot工程時(shí)卷谈,同樣需要選擇項(xiàng)目基于的JDK版本為11,然后才能正常運(yùn)行霞篡。

二世蔗、Neo4jRepository介紹

Neo4jRepository是SpringData為我們提供的用來操作Neo4j數(shù)據(jù)庫的接口,我們先來看看它的繼承關(guān)系:


Neo4jRepository的繼承關(guān)系

可以看到朗兵,通用的增刪查改功能基本都有了污淋,如果我們的數(shù)據(jù)庫操作也是些簡單的操作,那基本就不用再添加方法了余掖,直接使用Neo4jRepository提供的方法即可寸爆。當(dāng)然也支持我們自定義方法進(jìn)行操作,這個(gè)下面再信息講述盐欺。

三赁豆、代碼演示

這里的代碼示例,只是展示系統(tǒng)節(jié)點(diǎn)的增加冗美、相互之間關(guān)系的創(chuàng)建魔种,其它增刪查改操作,可以自行摸索學(xué)習(xí)墩衙。

@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("查詢所有的節(jié)點(diǎn)為:{}", systemEntityList);
        return systemEntityList;
    }

    public void addSystemNode(SystemEntity systemEntity){
        SystemEntity result = systemRepository.save(systemEntity);
        log.info("添加節(jié)點(diǎn)后的返回結(jié)果為:{}", 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表示節(jié)點(diǎn)類,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);

    /**
     * 使用節(jié)點(diǎn)id時(shí)只能用id(n)這種寫法甲抖,其它屬性可以用n.name這樣的寫法
     * @param id
     * @return
     */
    @Query("MATCH (n) where id(n)=$id RETURN n")
    SystemEntity findSystemById(@Param("id") Long id);

    //等價(jià)寫法@Query("MATCH (n:SystemEntity {leader: $leader}) RETURN n")
    @Query("MATCH (n) where n.leader=$leader RETURN n")
    SystemEntity findSystemByLeader(@Param("leader") String leader);

}

然后漆改,運(yùn)行如上SpringBoot項(xiàng)目后,我們按照上一篇文章中的示例准谚,依次增加系統(tǒng)節(jié)點(diǎn)和關(guān)系之后挫剑,可以得到圖如下:


實(shí)現(xiàn)的系統(tǒng)架構(gòu)可視化圖

該例子和上一篇例子稍微有些不同,此處所有系統(tǒng)節(jié)點(diǎn)的類型都設(shè)置為了System柱衔,所以同一類型的節(jié)點(diǎn)顏色都是相同的樊破。

四、待解決問題

可能是由于自己Cypher語言不熟悉唆铐,很多CRUD語句用的還不順暢哲戚,比如為什么用到id時(shí),不能使用n.id的寫法艾岂,還有SystemRepository中調(diào)用關(guān)系的類型如何參數(shù)化顺少,這樣就不用為每一種調(diào)用關(guān)系創(chuàng)建方法了,如果有知道的朋友可以告知下

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市脆炎,隨后出現(xiàn)的幾起案子梅猿,更是在濱河造成了極大的恐慌,老刑警劉巖秒裕,帶你破解...
    沈念sama閱讀 216,372評論 6 498
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件袱蚓,死亡現(xiàn)場離奇詭異,居然都是意外死亡几蜻,警方通過查閱死者的電腦和手機(jī)喇潘,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,368評論 3 392
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來入蛆,“玉大人响蓉,你說我怎么就攤上這事∩诨伲” “怎么了枫甲?”我有些...
    開封第一講書人閱讀 162,415評論 0 353
  • 文/不壞的土叔 我叫張陵,是天一觀的道長扼褪。 經(jīng)常有香客問我想幻,道長,這世上最難降的妖魔是什么话浇? 我笑而不...
    開封第一講書人閱讀 58,157評論 1 292
  • 正文 為了忘掉前任脏毯,我火速辦了婚禮,結(jié)果婚禮上幔崖,老公的妹妹穿的比我還像新娘食店。我一直安慰自己,他們只是感情好赏寇,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,171評論 6 388
  • 文/花漫 我一把揭開白布吉嫩。 她就那樣靜靜地躺著,像睡著了一般嗅定。 火紅的嫁衣襯著肌膚如雪自娩。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,125評論 1 297
  • 那天渠退,我揣著相機(jī)與錄音忙迁,去河邊找鬼。 笑死碎乃,一個(gè)胖子當(dāng)著我的面吹牛姊扔,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播梅誓,決...
    沈念sama閱讀 40,028評論 3 417
  • 文/蒼蘭香墨 我猛地睜開眼旱眯,長吁一口氣:“原來是場噩夢啊……” “哼晨川!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起删豺,我...
    開封第一講書人閱讀 38,887評論 0 274
  • 序言:老撾萬榮一對情侶失蹤共虑,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后呀页,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體妈拌,經(jīng)...
    沈念sama閱讀 45,310評論 1 310
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,533評論 2 332
  • 正文 我和宋清朗相戀三年蓬蝶,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了尘分。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 39,690評論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡丸氛,死狀恐怖培愁,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情缓窜,我是刑警寧澤定续,帶...
    沈念sama閱讀 35,411評論 5 343
  • 正文 年R本政府宣布,位于F島的核電站禾锤,受9級特大地震影響私股,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜恩掷,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,004評論 3 325
  • 文/蒙蒙 一倡鲸、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧黄娘,春花似錦峭状、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,659評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至氮凝,卻和暖如春羔巢,著一層夾襖步出監(jiān)牢的瞬間望忆,已是汗流浹背罩阵。 一陣腳步聲響...
    開封第一講書人閱讀 32,812評論 1 268
  • 我被黑心中介騙來泰國打工, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留启摄,地道東北人稿壁。 一個(gè)月前我還...
    沈念sama閱讀 47,693評論 2 368
  • 正文 我出身青樓,卻偏偏與公主長得像歉备,于是被迫代替她去往敵國和親傅是。 傳聞我的和親對象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,577評論 2 353

推薦閱讀更多精彩內(nèi)容