skynet cluster集群笔记
- 前言
- 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 downnode2 = "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(未完待续)