当互联网不可用：几种实用的替代通信方案

# 安装 Meshtastic CLI（Python 包）
pip install meshtastic

# 查看已连接设备的当前配置
meshtastic --info

# 发送一条文本消息到默认频道
meshtastic --sendtext "所有人集合，坐标 N39.9 E116.3"

# 设置节点名称，方便 mesh 内识别
meshtastic --set-owner "救援A组-01"

# 查看 mesh 内可见的其他节点
meshtastic --nodes

import meshtastic
import meshtastic.tcp_interface

# 通过 TCP 连接到本地 Meshtastic 设备（设备先通过 USB 或 WiFi 连到主机）
interface = meshtastic.tcp_interface.TCPInterface(hostname="localhost")

# 发送消息
interface.sendText("传感器读数: 温度22°C 湿度65%", channelIndex=0)

# 获取节点列表
nodes = interface.nodes
for node_id, node_info in nodes.items():
    print(f"节点: {node_info.get('user', {}).get('longName', '未知')}  "
          f"SNR: {node_info.get('snr', 'N/A')}  "
          f"距离: 约 {node_info.get('distance', '未知')}m")

interface.close()

# Linux 上安装 Yggdrasil
sudo apt install yggdrasil-go   # Debian/Ubuntu
# 或从 GitHub Releases 下载二进制

# 生成配置文件
sudo yggdrasil -genconf > /etc/yggdrasil/yggdrasil.conf

# 启动（默认会自动发现局域网内的其他节点）
sudo yggdrasil -useconffile /etc/yggdrasil/yggdrasil.conf

# 查看自己的 Yggdrasil IPv6 地址
yggdrasil -getaddress
# 输出类似: 200:5e22:943e:e1f2:fd5e:892:3b4a:7c

# 测试连通性——ping 另一个 Yggdrasil 节点
ping6 200:abcd:1234:5678:9abc:def0:1234:5678

# /etc/yggdrasil/yggdrasil.conf 关键配置片段
# 如果有公网节点可做中继，填入 Peers；纯局域网场景则留空，节点会自动发现同网段邻居
Peers: []
#  或指定已知的中继节点:
#  Peers:
#    - tls://1.2.3.4:1234

Listen: []
#  如果想让其他节点通过 WiFi 局域网连入:
#  Listen:
#    - tcp://0.0.0.0:12345

IfName: "auto"
#  auto 会自动创建虚拟网卡；也可指定如 "ygg0"

"""
离线消息中继服务器 + 客户端
同一局域网内运行 server，其他设备用 client 发送/接收消息
无需公网，无需注册
"""

import socket
import json
import threading
import time

SERVER_HOST = "0.0.0.0"   # 本机所有网卡
SERVER_PORT = 9900
MSG_FILE = "messages.json"  # 本地持久化

def load_messages():
    try:
        with open(MSG_FILE, "r") as f:
            return json.load(f)
    except FileNotFoundError:
        return []

def save_messages(msgs):
    with open(MSG_FILE, "w") as f:
        json.dump(msgs, f, ensure_ascii=False)

# ---------- 服务器 ----------
def handle_client(conn, addr):
    data = conn.recv(4096).decode()
    req = json.loads(data)
    if req["action"] == "send":
        msgs = load_messages()
        msgs.append({"from": req["name"], "text": req["text"], "ts": time.time()})
        save_messages(msgs)
        conn.sendall(json.dumps({"status": "ok", "count": len(msgs)}).encode())
    elif req["action"] == "recv":
        since = req.get("since", 0)
        msgs = load_messages()
        new = [m for m in msgs if m["ts"] > since]
        conn.sendall(json.dumps({"messages": new}).encode())
    conn.close()

def run_server():
    srv = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    srv.bind((SERVER_HOST, SERVER_PORT))
    srv.listen(5)
    print(f"中继服务器启动于 {SERVER_PORT}，局域网内设备可连接")
    while True:
        conn, addr = srv.accept()
        threading.Thread(target=handle_client, args=(conn, addr), daemon=True).start()

# ---------- 客户端 ----------
def send_message(name, text, server_ip):
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.connect((server_ip, SERVER_PORT))
    s.sendall(json.dumps({"action": "send", "name": name, "text": text}).encode())
    resp = json.loads(s.recv(4096).decode())
    print(f"发送成功，服务器当前共 {resp['count']} 条消息")
    s.close()

def fetch_messages(since_ts, server_ip):
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.connect((server_ip, SERVER_PORT))
    s.sendall(json.dumps({"action": "recv", "since": since_ts}).encode())
    resp = json.loads(s.recv(8192).decode())
    for m in resp["messages"]:
        print(f"[{m['from']}] {m['text']}")
    s.close()
    return max((m["ts"] for m in resp["messages"]), default=since_ts)

# 使用方式:
#   在一台机器上: run_server()
#   其他机器上:   send_message("张三", "集合点在北门", "192.168.1.100")
#                 fetch_messages(0, "192.168.1.100")
if __name__ == "__main__":
    import sys
    if len(sys.argv) < 2:
        print("用法: python relay.py server | client <server_ip> send <名字> <消息> | client <server_ip> recv")
        sys.exit(1)
    mode = sys.argv[1]
    if mode == "server":
        run_server()
    elif mode == "client":
        sip = sys.argv[2]
        action = sys.argv[3]
        if action == "send":
            send_message(sys.argv[4], sys.argv[5], sip)
        elif action == "recv":
            fetch_messages(0, sip)