mirror of
https://github.com/varun-r-mallya/py-libp2p.git
synced 2025-12-31 20:36:24 +00:00
65 lines
3.7 KiB
ReStructuredText
65 lines
3.7 KiB
ReStructuredText
|
|
PubSub Chat Demo
|
|
================
|
|
|
|
This example demonstrates how to create a chat application using libp2p's PubSub implementation with the GossipSub protocol.
|
|
|
|
.. code-block:: console
|
|
|
|
$ python -m pip install libp2p
|
|
Collecting libp2p
|
|
...
|
|
Successfully installed libp2p-x.x.x
|
|
$ pubsub-demo
|
|
2025-04-06 23:59:17,471 - pubsub-demo - INFO - Running pubsub chat example...
|
|
2025-04-06 23:59:17,471 - pubsub-demo - INFO - Your selected topic is: pubsub-chat
|
|
2025-04-06 23:59:17,472 - pubsub-demo - INFO - Using random available port: 33269
|
|
2025-04-06 23:59:17,490 - pubsub-demo - INFO - Node started with peer ID: QmcJnocH1d1tz3Zp4MotVDjNfNFawXHw2dpB9tMYGTXJp7
|
|
2025-04-06 23:59:17,490 - pubsub-demo - INFO - Listening on: /ip4/127.0.0.1/tcp/33269
|
|
2025-04-06 23:59:17,490 - pubsub-demo - INFO - Initializing PubSub and GossipSub...
|
|
2025-04-06 23:59:17,491 - pubsub-demo - INFO - Pubsub and GossipSub services started.
|
|
2025-04-06 23:59:17,491 - pubsub-demo - INFO - Pubsub ready.
|
|
2025-04-06 23:59:17,491 - pubsub-demo - INFO - Subscribed to topic: pubsub-chat
|
|
2025-04-06 23:59:17,491 - pubsub-demo - INFO - Run this script in another console with:
|
|
pubsub-demo -d /ip4/127.0.0.1/tcp/33269/p2p/QmcJnocH1d1tz3Zp4MotVDjNfNFawXHw2dpB9tMYGTXJp7
|
|
|
|
2025-04-06 23:59:17,491 - pubsub-demo - INFO - Waiting for peers...
|
|
Type messages to send (press Enter to send):
|
|
|
|
Copy the line that starts with ``pubsub-demo -d``, open a new terminal and paste it in:
|
|
|
|
.. code-block:: console
|
|
|
|
$ pubsub-demo -d /ip4/127.0.0.1/tcp/33269/p2p/QmcJnocH1d1tz3Zp4MotVDjNfNFawXHw2dpB9tMYGTXJp7
|
|
2025-04-07 00:00:59,845 - pubsub-demo - INFO - Running pubsub chat example...
|
|
2025-04-07 00:00:59,846 - pubsub-demo - INFO - Your selected topic is: pubsub-chat
|
|
2025-04-07 00:00:59,846 - pubsub-demo - INFO - Using random available port: 51977
|
|
2025-04-07 00:00:59,864 - pubsub-demo - INFO - Node started with peer ID: QmYQKCm95Ut1aXsjHmWVYqdaVbno1eKTYC8KbEVjqUaKaQ
|
|
2025-04-07 00:00:59,864 - pubsub-demo - INFO - Listening on: /ip4/127.0.0.1/tcp/51977
|
|
2025-04-07 00:00:59,864 - pubsub-demo - INFO - Initializing PubSub and GossipSub...
|
|
2025-04-07 00:00:59,864 - pubsub-demo - INFO - Pubsub and GossipSub services started.
|
|
2025-04-07 00:00:59,865 - pubsub-demo - INFO - Pubsub ready.
|
|
2025-04-07 00:00:59,865 - pubsub-demo - INFO - Subscribed to topic: pubsub-chat
|
|
2025-04-07 00:00:59,866 - pubsub-demo - INFO - Connecting to peer: QmcJnocH1d1tz3Zp4MotVDjNfNFawXHw2dpB9tMYGTXJp7 using protocols: MultiAddrKeys(<Multiaddr /ip4/127.0.0.1/tcp/33269/p2p/QmcJnocH1d1tz3Zp4MotVDjNfNFawXHw2dpB9tMYGTXJp7>)
|
|
2025-04-07 00:00:59,866 - pubsub-demo - INFO - Run this script in another console with:
|
|
pubsub-demo -d /ip4/127.0.0.1/tcp/51977/p2p/QmYQKCm95Ut1aXsjHmWVYqdaVbno1eKTYC8KbEVjqUaKaQ
|
|
|
|
2025-04-07 00:00:59,881 - pubsub-demo - INFO - Connected to peer: QmcJnocH1d1tz3Zp4MotVDjNfNFawXHw2dpB9tMYGTXJp7
|
|
Type messages to send (press Enter to send):
|
|
|
|
You can then start typing messages in either terminal and see them relayed to the other terminal. The messages will be distributed using the GossipSub protocol to all peers subscribed to the same topic. To exit the demo, type "quit" or send a keyboard interrupt (``Ctrl+C``) in either terminal.
|
|
|
|
Command Line Options
|
|
--------------------
|
|
|
|
- ``-t, --topic``: Specify the topic name to subscribe to (default: "pubsub-chat")
|
|
- ``-d, --destination``: Address of peer to connect to
|
|
- ``-p, --port``: Port to listen on (default: random available port)
|
|
- ``-v, --verbose``: Enable debug logging
|
|
|
|
The full source code for this example is below:
|
|
|
|
.. literalinclude:: ../examples/pubsub/pubsub.py
|
|
:language: python
|
|
:linenos:
|