Corda V2.0节点与RAFT公证节点通信问题及测试方法咨询

问题解答 #

1. 通过RPC端口ping通无法确保节点间消息通信正常

首先明确：Corda节点间的交易消息通信依赖P2P端口（默认是10002），而RPC端口（默认10003）是给外部应用（比如客户端、监控工具）连接节点用的，这是两个完全独立的端口。你ping通RPC端口只能证明外部应用能和节点的RPC服务建立连接，但完全无法验证节点之间的P2P消息通路是否正常——这也是为什么你ping通了RPC但还是出现消息重试失败的核心原因。

2. 测试普通节点与公证节点间消息收发的方法

这里给你几个从网络层到应用层的实用验证手段，逐步排查问题：

• 第一步：验证P2P端口的网络连通性
  直接用网络工具测试普通节点到每个公证节点的P2P端口是否能连通：

  • 用telnet：telnet <公证节点IP> <P2P端口>，如果能建立连接说明网络层是通的；
  • 用nc（netcat）：nc -zv <公证节点IP> <P2P端口>，会直接返回端口是否可达。
    如果这一步失败，大概率是防火墙、安全组或者网络路由限制了P2P端口的流量，需要先打通网络链路。

• 第二步：用Corda内置的pingPeer命令验证P2P通信
  Corda节点自带了专门测试节点间P2P连通性的RPC命令，你可以通过Corda Shell或者自定义RPC客户端执行：

  run pingPeer peerAddress="<公证节点IP>:<P2P端口>"
  

  如果命令返回Success，说明两个节点之间的P2P消息通道完全正常，能正常收发消息；如果失败，日志里会给出具体的错误原因（比如身份验证失败、连接超时等）。

• 第三步：自定义简单测试Flow验证端到端消息收发
  写一个极简的测试Flow，直接验证普通节点和公证节点之间的消息交互：

  • 在普通节点的CorDapp里添加发起Flow：

    @InitiatingFlow
    class NotaryPingFlow(val notaryParty: Party) : FlowLogic<String>() {
        @Suspendable
        override fun call(): String {
            val session = initiateFlow(notaryParty)
            // 发送测试消息
            session.send("Test ping from regular node")
            // 接收回复
            return session.receive<String>().unwrap { it }
        }
    }
    

  • 在公证节点的CorDapp里添加响应Flow：

    @InitiatedBy(NotaryPingFlow::class)
    class NotaryPingResponder(val session: FlowSession) : FlowLogic<Unit>() {
        @Suspendable
        override fun call() {
            val receivedMsg = session.receive<String>().unwrap { it }
            println("[Notary] Received test message: $receivedMsg")
            // 返回回复消息
            session.send("Test pong from notary")
        }
    }
    

  部署这两个Flow到对应节点后，通过RPC启动NotaryPingFlow，如果能成功收到"Test pong from notary"的回复，就证明端到端的消息收发完全正常。

• 第四步：检查节点P2P相关日志
  在普通节点的日志里搜索P2P、messaging关键词，比如找有没有Failed to send message to peer或者Connection to peer <公证节点信息> closed这类条目；同时在公证节点日志里找Incoming connection from peer或者Received message from peer的记录，这些日志能帮你定位是连接建立失败、消息发送失败还是其他问题。

结合你的场景来看，公证节点日志没有报错，大概率是普通节点没成功和公证节点建立P2P连接，或者消息在网络链路中丢失了，建议从第一步开始逐步排查。

内容的提问来源于stack exchange，提问作者Jiachuan Li