Usage.md

使用示例

• 配置里的 subnets 决定了子节点的BUS ID范围，规则类似路由器。

比如 mask_bits=8,id_prefix=0x12345678, 则0x12345600-0x123456FF都是它的子节点，0x12345778则是它的兄弟节点

• 父子节点之间会自动断线重连
• 拥有相同父节点的兄弟节点之间会自动按需断线重连
• 没有相同父节点的兄弟节点之间不会自动断线重连。建议使用心跳或其他机制重新执行connectapi来维持在线信息

监听和连接的地址目前支持:

1. ipv4://IP地址:端口
2. ipv6://IP地址:端口
3. unix://Unix Socket地址（仅Unix like系统下有效）
4. dns://域名:端口
5. shm://共享内存Key（整数，仅本机通信有效，支持16进制或10进制表示，比如 shm://0x1234FF00 或 shm://305463040）
6. mem://内存地址（整数，仅本机通信有效，支持16进制或10进制表示，内存通道必须先分配好。比如 mem://0x1234FF00 或 mem://305463040）

最简单的完整代码流程如下：

#include <cstdlib>
#include <cstring>
#include <ctime>
#include <iomanip>
#include <iostream>
#include <string>


#include <atbus_node.h>
#include <libatbus_protocol.h>

int main() {
    // 初始化默认配置
    atbus::node::conf_t conf;
    atbus::node::default_conf(&conf);

    // 子域的范围设为16（后16位都是子节点）, id_prefix=0 等于使用endpoint自己的ID
    conf.subnets.push_back(atbus::endpoint_subnet_conf(0, 16));

    // 初始化libuv事件分发器
    uv_loop_t ev_loop;
    uv_loop_init(&ev_loop);

    // 指定事件分发器
    conf.ev_loop = &ev_loop;

    {
        // 创建两个通信节点
        atbus::node::ptr_t node1 = atbus::node::create();
        atbus::node::ptr_t node2 = atbus::node::create();

        // 初始化
        node1->init(0x12345678, &conf); // BUS ID=0x12345678, 0x1234XXXX 都是子节点
        node2->init(0x12356789, &conf); // BUS ID=0x12356789, 0x1235XXXX 都是子节点
        // 所以这两个都是兄弟节点

        // 各自监听地址
        node1->listen("ipv4://127.0.0.1:16387");
        node2->listen("ipv4://127.0.0.1:16388");

        // 启动初始化
        node1->start();
        node2->start();

        // 启动连接
        node1->connect("ipv4://127.0.0.1:16388");

        // 等待连接成功
        // 如果是拥有共同父节点的兄弟节点不能这么判定，因为在第一次发消息前是不会建立连接的
        for (int i = 0; i < 512; ++i) {
            if (node2->is_endpoint_available(node1->get_id()) && node1->is_endpoint_available(node2->get_id())) {
                break;
            }

            uv_run(conf.ev_loop, UV_RUN_ONCE);

            // 定期执行proc函数，用于处理内部定时器
            // 第一个参数是Unix时间戳（秒），第二个参数是微秒
            node1->proc(time(nullptr), 0);
            node2->proc(time(nullptr), 0);
        }

        // 设置接收到消息后的回调函数
        bool recved = false;
        node2->set_on_recv_handle([&recved](const atbus::node &n, const atbus::endpoint *ep, const atbus::connection *conn,
                                            const atbus::msg_t &m, const void *buffer, size_t len) {
            if (nullptr != ep && nullptr != conn) {
                std::cout << "atbus node 0x" << std::ios::hex << n.get_id() << " receive data from 0x" << std::ios::hex << ep->get_id()
                          << "(connection: " << conn->get_address().address << "): ";
            }
            std::cout.write(reinterpret_cast<const char *>(buffer), len);
            std::cout << std::endl;
            recved = true;
            return 0;
        });


        // 发送数据
        std::string send_data = "hello world!";
        node1->send_data(node2->get_id(), 0, send_data.data(), send_data.size());

        // 等待发送完成
        while (!recved) {
            uv_run(conf.ev_loop, UV_RUN_ONCE);

            // 定期执行proc函数，用于处理内部定时器
            // 第一个参数是Unix时间戳（秒），第二个参数是微秒
            node1->proc(time(nullptr), 0);
            node2->proc(time(nullptr), 0);
        }

        // 析构时会自动关闭所持有的资源
    }

    // 关闭libuv事件分发器
    while (UV_EBUSY == uv_loop_close(&ev_loop)) {
        uv_run(&ev_loop, UV_RUN_ONCE);
    }
    return 0;
}

编译时请包含msgpack、libuv和libatbus的include目录，链接atbus、atframe_utils和libuv