Usage.md

使用示例

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

比如children_mask=8,BUS ID=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 <iostream>
#include <cstdlib>
#include <cstring>
#include <string>
#include <ctime>

#include <atbus_node.h>

#include "detail/libatbus_protocol.h"

int main () {
    // 初始化默认配置
    atbus::node::conf_t conf;
    atbus::node::default_conf(&conf);
    
    // 子域的范围设为16（后16位都是子节点）
    conf.children_mask = 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()) && NULL != node1->is_endpoint_available(node2->get_id())) {
                break;
            }

            uv_run(conf.ev_loop, UV_RUN_ONCE);
            
            // 定期执行proc函数，用于处理内部定时器
            // 第一个参数是Unix时间戳（秒），第二个参数是微秒
            node1->proc(time(NULL), 0);
            node2->proc(time(NULL), 0);
        }
        
        // 设置接收到消息后的回调函数
        bool recved = false;
        node2->set_on_recv_handle([&recved](const atbus::node& n, const atbus::endpoint* ep, const atbus::connection* conn, int status, const void* buffer, size_t len){
            std::cout<< reinterpret_cast<const char*>(buffer)<< 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(NULL), 0);
            node2->proc(time(NULL), 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