rnet_quickstart_node_setup_peer_connect_message_send.py

1import rnet
2
3# 1. Initialize the RNet client/node
4# In a real scenario, you would provide a configuration file or environment variables
5node = rnet.Node(node_id="node_01", listen_address="127.0.0.1:5000")
6
7# 2. Define a simple message handler for incoming data
8@node.on_message
9def handle_incoming(sender, message):
10    print(f"Received message from {sender}: {message}")
11
12# 3. Start the node's network listener
13node.start()
14
15# 4. Connect to a peer (e.g., another node running on a different port)
16# For this example, we assume node_02 is active
17node.connect_to("127.0.0.1:5001")
18
19# 5. Send a resilient message
20# The library automatically handles routing and retries if the path is interrupted
21node.send_message(
22    target_id="node_02", 
23    payload={"type": "greeting", "content": "Hello, Resilient Network!"}
24)
25
26# 6. Keep the script running to listen for responses
27try:
28    node.wait_forever()
29except KeyboardInterrupt:
30    node.stop()