jvm-libp2p如何实现与go/js-ipfs同级的pubsub网络通信能力

jvm-libp2p默认配置与公共IPFS网络的pubsub路由规则不兼容，才会出现仅直连能收消息、公网节点不转发的现象，核心差异点有三个：

• 默认pubsub实现为Floodsub，而当前公共IPFS网络90%以上节点默认运行GossipSub v1.1协议，协议不匹配时公共节点不会处理你的订阅请求、也不会中转消息。
• 默认GossipSub配置关闭了节点交换、消息中继、mesh组网相关开关，就算协议匹配，节点也不会将你加入主题转发网络，不会主动推送同主题节点信息。
• 启动顺序错误：先订阅主题再连接公网节点时，订阅声明不会同步给后续连接的公网节点，导致公网节点不知道你需要对应主题的消息。

按照以下步骤配置即可达到和go-ipfs/js-ipfs一致的跨公网节点pubsub转发效果，无需节点直连。

1. 依赖引入 #

确保引入完整的jvm-libp2p模块，不要只引入核心包，Gradle依赖参考：

implementation 'io.libp2p:libp2p-core:0.12.0.RELEASE'
implementation 'io.libp2p:libp2p-pubsub:0.12.0.RELEASE'
implementation 'io.libp2p:libp2p-gossipsub:0.12.0.RELEASE'
implementation 'io.libp2p:libp2p-mplex:0.12.0.RELEASE'
implementation 'io.libp2p:libp2p-tcp:0.12.0.RELEASE'
implementation 'io.libp2p:libp2p-security-noise:0.12.0.RELEASE'

注意：不要使用0.10.0以下版本，低版本GossipSub不兼容v1.1协议，无法接入公网IPFS的pubsub网络。

2. 配置公网兼容的GossipSub实例 #

对齐go-ipfs默认的GossipSub参数，开启转发和节点交换能力：

GossipSubRouter router = new GossipSubRouter()
        .setEnableFloodPublish(true) // 兼容运行Floodsub的老节点
        .setPeerExchangeEnabled(true) // 允许公网节点推送同主题对等节点信息
        .setGossipEnabled(true); // 开启gossip消息转发

GossipSubParams params = GossipSubParams.defaults()
        .setD(6)
        .setDlow(5)
        .setDhigh(12)
        .setDlazy(6); // 以上参数与go-ipfs默认配置完全对齐

// 消息校验器默认返回通过即可，公网节点会做基础消息合法性校验
BiFunction<PubsubMessage, String, CompletableFuture<Boolean>> validator = 
        (msg, topic) -> CompletableFuture.completedFuture(true);

GossipSub gossipSub = new GossipSub(peerId, params, router, validator);

3. 构建兼容公网协议的Libp2p节点 #

构建Host时挂载公网通用的传输、加密、流多路复用协议，关闭仅本地生效的mDNS发现：

Host host = new HostBuilder()
        .addTransport(new TcpTransport())
        .addSecurityProtocol(Noise::new) // 公网节点已全面淘汰旧的Secio加密，必须用Noise
        .addMuxerProtocol(Mplex::new)
        .addProtocol(gossipSub) // 挂载配置好的GossipSub服务
        .disableMdnsDiscovery() // 关闭本地mDNS，避免依赖局域网发现
        .build();
host.start().get(5, TimeUnit.SECONDS);

4. 连接公网引导节点后再订阅主题 #

先连接IPFS官方引导节点，连接稳定后再发起主题订阅，保证订阅声明能同步到公网路由网络：

// IPFS官方引导节点地址
List<Multiaddr> bootstrapNodes = List.of(
        Multiaddr.fromString("/dnsaddr/bootstrap.libp2p.io/p2p/QmNnooDu7bfjPFoTZYxMNLWUQJyrVwtbZg5gBMjTezGAJN"),
        Multiaddr.fromString("/dnsaddr/bootstrap.libp2p.io/p2p/QmQCU2EcMqAqQPR2i9bChDtGNJchTbq5TbXJJ16u19uLTa"),
        Multiaddr.fromString("/dnsaddr/bootstrap.libp2p.io/p2p/QmbLHAnMoJPWSCR5Zhtx6BHJX9KiKNN6tpvbUcqanj75Nb")
);
// 建立引导节点连接
for (Multiaddr addr : bootstrapNodes) {
    try {
        host.getNetwork().connect(addr).get(10, TimeUnit.SECONDS);
    } catch (Exception e) {
        // 单个节点连接失败跳过即可，只要有1个节点连接成功就能接入pubsub网络
    }
}
// 等待3秒让连接状态稳定
Thread.sleep(3000);

// 订阅目标主题
gossipSub.subscribe("your-target-topic", msg -> {
    byte[] data = msg.getData();
    // 处理收到的跨节点转发消息
    System.out.println("收到消息: " + new String(data, StandardCharsets.UTF_8));
    return null;
});

• 节点启动后需要10~30秒完成GossipSub mesh组网，这段时间内消息可能出现丢失、延迟，组网完成后转发就会稳定。
• 节点位于NAT后无需手动配置端口映射，只要能主动向外发起TCP连接即可，公网节点会自动承担中继转发角色。
• 不要开启GossipSub的强制严格签名校验，公网部分节点的消息签名格式与jvm-libp2p默认校验逻辑不兼容，会导致合法消息被丢弃。
• 测试时不要用敏感、高频发送的测试消息，公网IPFS对pubsub消息有基础的限流规则，高频发送会被节点临时拉黑。

内容的提问来源于stack exchange，提问作者Sergei-Udris