如何使用golang libp2p streams向多台主机发送数据？

Question

我的问题指的是golang中的libp2p库：https://github.com/libp2p/go-libp2p

这个视频解释了背景：https://www.youtube.com/watch?v=hP0hSZ7E7_Y

网络中的对等体通过缓冲流rw进行通信。对于每个新连接的对等体，都会创建一个新的流，该流使用地址将其连接到现有的对等体。这意味着有多个流，但并不是所有的对等点都直接相互连接。使用这些流，对等体可以通过以下方式读取和写入数据

rw := bufio.NewReadWriter(bufio.NewReader(stream),bufio.NewWriter(stream))

通过编写消息rw.WriteString("message")，`rw.Flush()

并通过message := rw.ReadString(rw)读取此消息。

由于对等体并不都是连接的，所以它们只接收来自直接连接的对等体的消息，如果有多个连接，甚至不会接收所有对等体的消息。

视频中正是提到了这个问题，大约在上午9点45分。视频的作者说，可以很容易地修改这一点，不仅可以向直接连接的对等设备发送消息，还可以向多台主机发送消息。但如何才能做到这一点呢？

我的目标是从一个对等点发送消息，并且网络中的所有其他对等点，以及非直接连接的对等点，都可以接收(并应答)它。

Answer 1

在libp2p中发送组播或广播消息的最好方式是使用PubSub，因此订阅topic的每个节点都会收到已发送消息的通知，而不是直接连接到发送方节点。

您可以找到使用Pubsub here的示例实现。它使用libp2p的gossibSub实现。