一、單元測試
通過Nebula提供的Java Client完成代碼開發后,使用JUnit對其進行單元測試,需要注意幾點:
1.1 坑
1.Nebula創建圖空間是異步實現的,Nebula將在下一個心跳周期內(默認是10s)完成圖空間的創建
如果單元測試代碼中有動態創建、刪除圖空間的語句,單元測試結果可能是不確定的,時好時壞
2.如果單元測試中有動態創建Tag、EdgeType,單元測試結果可能是不確定的,時好時壞
1.2 解決方案
1.基於前面的兩種不確定性,建議提前手動創建好:
圖空間(相當於關系數據庫)、Tag(相當於關系數據庫中的表)、EdgeType(相當於關系數據庫中的表)
只對Vertex以及Edge進行動態插入刪除操作,這樣單元測試的結果是穩定的,不會出現時好時壞的現象
2.如果使用JUnit5進行單元測試,建議:
在@BeforeAll注解的方法里進行Vertex及Edge的初始化
在@AfterAll注解的方法里進行Vertex及Edge的清除、Nebula會話的釋放、連接池的關閉等操作
二、Java Client線程不安全
2.1 坑
Nebula提供的Java Client是線程不安全的,當多個線程同時跑時,會出現IO異常:
com.vesoft.nebula.client.graph.exception.IOErrorException: java.net.SocketException: Broken pipe (Write failed)
所以使用Java Client的,只能用一個線程跑,沒有充分利用多線程優勢,這真是Nebula Java Client最大的坑!
2.2 解決方案
1.將Java Client封裝為單例
2.如果Nebula與Flink等流計算框架相結合,則需要設置並行度為1