如何使用Neo4j可视化Spring Integration图？

Spring Integration框架能够以JSON图的形式给出所有EIP组件及其关系的当前状态。学习和调试似乎很方便，但是可惜的是，没有一种Google工具（其中只有一次 / 两次）为显示和分析这种图形提供了足够的灵活性。在本文中，我将展示如何通过将图形导入Neo4j图形DBMS来解决此问题，首先要实现这种灵活性。

更短（tl; dr）

简而言之，这是您需要做的：

1. 在已知URL处以JSON形式提供图的返回。
2. 在Neo4j浏览器中运行此 Cypher请求，替换那里的URL。

好吧，如果它还没有开始或细节变得有趣，那么欢迎您。

如何在JSON中获取图形描述？

有两种非互斥方式：

1. 如果使用一个spring-integration-http（或spring-integration-webflux）模块，则可以通过拉出“ 积分图控制器”来获得该图。
2. 如果该模块与Spring Boot Actuator spring-integration-core 一起使用，则可以通过称为积分图的端点获取该图（默认情况下无法通过Web访问该图）。

在这两种情况下，答案都将如下所示：

{
  "contentDescriptor": {
    "providerVersion": "5.2.4.RELEASE",
    "providerFormatVersion": 1.1,
    "provider": "spring-integration",
    "name": "analog"
  },
  "nodes": [
    {
      "nodeId": 3,
      "componentType": "ExecutorSubscribableChannel",
      "name": "brokerChannel"
    },
    // ...
  ],
  "links": [
    {
      "from": 19,
      "to": 8,
      "type": "output"
    },
    // ...
  ]
}

3 :

• contentDescriptor – ; name ( spring.application.name).
• nodes – EIP-, . name, componentType nodeId, , .
• links , .. EIP-. from to nodeId . type , 5: input, output, route, error, discard.

( EIP) !
, , , componentType channel.

Spring Integration.

Neo4j, - , , , http://localhost:8080/actuator/integrationgraph ( Spring Boot Actuator). JSON, , .

CORS, . Spring Boot (+Actuator) , :

management:
  endpoints:
    web:
      exposure:
        include: '*'
      cors:
        allowed-origins: '*'
        allowed-methods: '*'

( production!)

Spring Integration, . .

Neo4j?

Neo4j, 2 :

1. Neo4j (, ?)
   :

   
   
   • Neo4j Desktop
   • Neo4j Community Server
   • Neo4j Sandbox
     
   
   

2. Cypher- APOC

   
   

   - Neo4j, . Neo4j Sandbox .

   
   

Neo4j 4.0.1, , . APOC , 2 Neo4j.

1:

Spring Integration, JSON-, , “ ” : – , – , – . : nodeId, nodeName componentType. org.springframework.integration.graph.IntegrationNode, ( ).

, Neo4j - :

JSON URL, .

Cypher :

// (1) load JSON from URL:
WITH "http://localhost:8080/actuator/integrationgraph" AS url
CALL apoc.load.json(url) YIELD value      
WITH value AS json, value.contentDescriptor AS jsonDescriptor
// (2) descriptor:
MERGE (descriptor:Descriptor {name: jsonDescriptor.name})
    ON CREATE SET
    descriptor.providerVersion = jsonDescriptor.providerVersion,
    descriptor.providerFormatVersion = jsonDescriptor.providerFormatVersion,
    descriptor.provider = jsonDescriptor.provider
// (3) nodes:
WITH json, descriptor
UNWIND json.nodes AS jsonNode
MERGE (node:Node {nodeId: jsonNode.nodeId})
    ON CREATE SET
    node.componentType = jsonNode.componentType,
    node.name = jsonNode.name
// (4) links:
WITH json, descriptor, node
UNWIND json.links AS jsonLink
MATCH (a:Node {nodeId: jsonLink.from}), (b:Node {nodeId: jsonLink.to})
MERGE (a)-[link:Link {type: jsonLink.type}]->(b)
// (5) result:
RETURN descriptor, node, link

Cypher, ( ):

1. APOC- apoc.load.json(url) JSON- json, – jsonDescriptor.
2. Descriptor, jsonDescriptor.
   MERGE, , . , MERGE CREATE.
3. JSON- ( nodes) UNWIND Node, name componentType.
4. ( links), Link MATCH, .
5. , : , .

Neo4j Browser JSON-, :

-, : EIP- , , Neo4j Browser, , Cypher-:

“” ( ) , . , .

, :

• , EIP- , , , , , serverR... , , , .
• , Link, type. , Cypher, “ ” .
• , , , – , .

, , , …

2:

, : , , . Neo4j Browser ( , ), GraSS (Graph Style Sheet), Neo4j Browser’. , , :style ( ):

. Neo4j Browser , , ( ) Node. Neo4j Browser, , . “” EIP-: , , .. , , , Cypher- - “ ” . , Cypher “ ” : – , . APOC. apoc.merge.node, / , :

merge nodes with dynamic labels, with support for setting properties ON CREATE or ON MATCH

: , /, – , . , Cypher- , “” , , channel. CASE.

: -, , -, JSON- Cypher MERGE, APOC – apoc.merge.relationship:

merge relationship with dynamic type, with support for setting properties ON CREATE or ON MATCH

, - “” , , , , , – , . , , , . , “” . DESCRIBES - .

, , :

// (1) load JSON from URL:
WITH "http://localhost:8080/actuator/integrationgraph" AS url
CALL apoc.load.json(url) YIELD value
WITH value AS json, value.contentDescriptor AS jsonDesc
// (2) descriptor:
MERGE (descriptor:Descriptor {name: jsonDesc.name})
  ON CREATE SET
    descriptor.providerVersion = jsonDesc.providerVersion,
    descriptor.providerFormatVersion = jsonDesc.providerFormatVersion,
    descriptor.provider = jsonDesc.provider,
    descriptor.updated = localdatetime()
  ON MATCH SET
    descriptor.updated = localdatetime()
// (3) nodes:
WITH json, descriptor
UNWIND json.nodes AS jsonNode
CALL apoc.merge.node(
  /*labels*/ ['Node',
    CASE
      WHEN jsonNode.componentType IS NULL THEN "<unknown>"
      WHEN toLower(jsonNode.componentType) ENDS WITH "channel" THEN "channel"
      WHEN toLower(jsonNode.componentType) ENDS WITH "adapter" THEN "adapter"
      WHEN jsonNode.componentType CONTAINS '$' THEN "<other>"
      ELSE jsonNode.componentType
    END],
  /*identProps*/   {nodeId: jsonNode.nodeId, appName: descriptor.name},
  /*onCreateProps*/{name: jsonNode.name, componentType: jsonNode.componentType},
  /*onMatchProps*/ {}
) YIELD node
MERGE (descriptor)-[:DESCRIBES]->(node)
// (4) links:
WITH json, descriptor, node
UNWIND json.links AS jsonLink
MATCH (a:Node {nodeId: jsonLink.from})<-[:DESCRIBES]-(descriptor)-[:DESCRIBES]->(b:Node {nodeId: jsonLink.to})
CALL apoc.merge.relationship(a, toUpper(jsonLink.type), {}, {}, b, {}) YIELD rel
// (5) result:
RETURN descriptor

, - 5 ( ):

1. JSON ;
2. / , ;

3. / , Node ( - ), :

   
   
   • <unknown>, (, , , , , UnzipTransformer);
   • channel, channel, , ExecutorSubscribableChannel;
   • adapter, adapter, , inbound-channel-adapter;
   • <other>, $, ( ) , , ServerConfig$$Lambda$994/0x00000008010fd440;
   • , , , "componentType": "gateway".
     componentType . DESCRIBES.
   
   
4. / , type JSON- .
   . , , nodeId. , appName .
5. .
   , , - . .

Spring Integration, ( 350+ 330+ , . ). Neo4j , , , :

Neo4j , . , Neo4j bin/neo4j-admin, memrec , , .

, GraSS- (, ) Neo4j Browser’, :style.

, MATCH (a) RETURN a, - . , , , . ( name):

WITH "analog" AS appName
MATCH (:Descriptor {name: appName})-[:DESCRIBES]->(n:Node)-[l*0..1]-(:Node)
RETURN n, l

, , ( ). , .

:

, . Cypher- (. .4 ), style.grass, componentType Node. , . , GraSS- EIP- :

node.Node {
  defaultCaption: "<id>";
  caption: "{name}";
}

Neo4j Browser – :

. , , Neo4j Browser, . .

, Neo4j Spring Integration. , , , :

, JSON- EIP- Spring Integration. Neo4j . Cypher “ ” , . . , ( ) Cypher-, .

– Neo4j Browser. , ; , . , – . Cypher , . , //, / , , / / , / .. , .

原始的Cypher语法重点文章在这里。