skynet cluster集群笔记

前言

skynet 是一个基于事件驱动的分布式游戏服务器框架，支持构建高性能、高并发的网络程序。在 skynet中，集群是指将多个节点连接在一起，共同协作完成任务的一个系统，一个skynet集群架构中涉及的一些名词如下：

1. 节点： skynet 中的节点是指运行着 skynet 实例的独立服务器。每个节点都有自己的地址和唯一标识符，可以运行不同的服务。节点之间通过网络连接进行通信和协作。
2. 服务： 在 skynet 中，服务是指运行在节点上的具体功能模块。每个服务都有一个唯一的服务名标识符，可以通过该标识符进行访问和通信。服务可以在同一节点上运行，也可以跨节点部署。
3. 集群： skynet 中的集群是指多个节点连接在一起，共同组成一个分布式系统。集群中的节点可以相互通信，共享资源，协同完成任务。集群可以通过网络连接，也可以根据配置在同一台物理机器上运行多个节点。
4. 节点发现： 节点发现是指节点之间相互发现和连接的过程。skynet 提供了节点发现的功能，可以通过配置文件(例如clustername)或者其他方式指定节点的地址和端口，使节点能够找到彼此并建立连接。
5. 服务发现： 集群中的服务发现是指服务之间相互发现和通信的过程。通过服务发现，可以在集群中查找和访问指定的服务，实现分布式系统中的模块化和协作。

cluster相关方法说明

cluster.call： 用于在集群中向指定节点的服务发送请求并等待其回应。它可以用于远程调用其他节点上的服务。

-- 调用名为 "testservice" (也可以是address)的服务的 "hello" 函数，并传递参数 "arg1" 和 "arg2"，等待返回结果
local ret = cluster.call("node1", ".testservice", "hello", "arg1", "arg2")
print(ret) 

cluster.send： 用于在集群中向指定节点的服务发送消息，不等待回应。它通常用于异步通信或者发送不需要返回结果的消息。

-- 向名为 "testservice" (也可以是address)的服务发送消息通知，传递参数 "message"
cluster.send("node2", ".testservice", "notify", "message")

cluster.open： 打开节点端口, 通知网关监听节点端口。用于节点发现，这个节点中的服务可以被其他节点调用（前提需要使用cluster.register或cluster.proxy获取到服务句柄）。

-- 在当前节点中打开一个名为 "node1" 的服务，并指定处理函数
cluster.open("node1")

cluster.reload： 用于加载集群节点配置

-- 加载node2，用于集群中的节点发现（node1配置关闭状态）
-- __nowaiting设置true，表示使用cluster.call时是阻塞等待，若设置为false,cluster.call不等待加载完成，而立即返回
-- __nowaiting默认为true
cluster.reload {
            __nowaiting = true,
            node1 = false, -- node1 is down
            node2 = "127.0.0.1:2529"
        }

cluster.proxy： 用于在当前节点中创建一个代理对象，代理指定节点上的服务。这样可以方便地通过代理对象调用远程服务。（可以直接使用skynet.call代替使用cluster.call直接调用远端服务地址）

-- 将远程节点node2上的db1服务在本地创建一个代理对象
local proxy = cluster.proxy "node2@db1"   -- cluster.proxy("node2", "@.db1")
-- 使用代理对象调用远程服务的方法
skynet.call(proxy, "lua", ...)

cluster.snax： 用于在当前节点中创建一个 SNAX 服务实例，该实例可以管理指定节点上的 SNAX 服务。

-- 创建一个 SNAX 服务实例，管理名为 "testservice" 的 SNAX 服务，位于 "node1" 节点上
local instance = cluster.snax("node1", "testservice")

cluster.register： 用于将addr注册为在cluster中可见的字符串名字name，如果不传addr，如默认将自身注册为name

-- 在集群中注册当前节点的db1服务
cluster.register(".db1")

cluster.unregister： 用于取消cluster.register的注册。

cluster.unregister(".db1")

cluster.query： 用于查询指定节点上注册的服务名字，返回该名字对应的服务数字地址。若不存在，则抛出error

-- 查询节点node1上的.db1服务的address，并返回其对应的服务地址
local address = cluster.query("node1", ".db1")
print(address)  -- 打印查询结果

源方法使用的注意点：
cluster.call、cluster.send、cluser.proxy接口可以使用@加字符串的方式来调用通过cluster.register注册的服务（官方推荐用法）

集群设计方案：

-- TODO(未完待续)

集群中常遇到的问题：

-- TODO (未完待续)

注意事项：

-- TODO(未完待续)