From c928ef8c96067890ae8d16d6473f91318c3d06f3 Mon Sep 17 00:00:00 2001 From: boyce Date: Fri, 1 Mar 2019 17:12:49 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BC=96=E8=BE=91=E6=95=99=E7=A8=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 190 ++++++++++++++++++++++++------------------------------ 1 file changed, 86 insertions(+), 104 deletions(-) diff --git a/README.md b/README.md index 17d4255..9e97e40 100644 --- a/README.md +++ b/README.md @@ -1,122 +1,104 @@ -# Origin -全分布式服务器引擎 -1.添加服务 -Test.go - -package Test - -import ( - "fmt" - "os" - "time" - - "github.com/duanhf2012/origin/cluster" - "github.com/duanhf2012/origin/service" -) - -type CTest struct { - service.BaseService - tmp int -} - -type TestModule struct { - service.BaseModule -} - -func (ws *TestModule) OnInit() error { - return nil -} - -func (ws *TestModule) OnRun() error { - return nil -} - -func (ws *CTest) OnInit() error { - - //添加模块 - test := &TestModule{} - ws.AddModule(test, true) - - //获取模块 - pModule := ws.GetModule("TestModule") - fmt.Print(pModule) - return nil -} +orgin 游戏服务器引擎简介 +================== -type CTestData struct { - Bbbb int64 - Cccc int - Ddd string -} +orgin 是一个由 Go 语言（golang）编写的分布式开源游戏服务器引擎。Leaf 适用于各类游戏服务器的开发，包括 H5（HTML5）游戏服务器。 -func (ws *CTest) RPC_LogTicker2(args *CTestData, quo *CTestData) error { +orgin 解决的问题： +* orgin总体设计如go语言设计一样，总是尽可能的提供简洁和易用的模式，快速开发。 +* 能够根据业务需求快速并灵活的制定服务器架构，甚至做到上线后根据负载需求动态调整。 +* 利用多核优势，将不同的service配置到不同的node，并能高效的协同工作。 +* 将整个引擎抽象三大对象，node,service,module。通过统一的组合模式管理游戏中各功能模块的关系。 +* 有丰富并健壮的工具库。 - *quo = *args - return nil -} - -func (ws *CTest) OnRun() error { - - ws.tmp = ws.tmp + 1 - time.Sleep(1 * time.Second) - if ws.tmp%10 == 0 { - var test CTestData - test.Bbbb = 1111 - test.Cccc = 111 - test.Ddd = "1111" - err := cluster.Go("collectTickLogService.RPC_LogTicker2", &test) - fmt.Print(err) - } - - return nil -} - -func NewCTest(servicetype int) *CTest { - wss := new(CTest) - wss.Init(wss, servicetype) - return wss -} - -func checkFileIsExist(filename string) bool { - var exist = true - if _, err := os.Stat(filename); os.IsNotExist(err) { - exist = false - } - return exist -} - -func (ws *CTest) OnDestory() error { - return nil -} -2.使用服务 -main.go +Hello world! +--------------- +下面我们来一步步的建立orgin服务器,先下载[orgin引擎](github.com/duanhf2012/origin),或者使用如下命令： +```go +go get -v -u github.com/duanhf2012/origin +``` +于是下载到GOPATH环境目录中,在src中加入main.go,内容如下： +```go package main import ( - "Test" - "bytes" - "compress/flate" - "fmt" - "io/ioutil" - - "github.com/duanhf2012/origin/server" - "github.com/duanhf2012/origin/sysmodule" + "github.com/duanhf2012/origin/originnode" ) - func main() { - server := server.NewServer() - if server == nil { + node := originnode.NewOrginNode() + if node == nil { return } - test := Test.NewCTest(1000) - server.SetupService(test) + node.Init() + node.Start() +} +``` +一个orgin服务器需要创建一个node对象，然后必需有Init和Start的流程。 - server.Init() - server.Start() +orgin引擎三大对象关系 +--------------- +* Node: 可以认为每一个Node代表着一个orgin进程 +* Service:一个独立的服务可以认为是一个大的功能模块，他是Node的子集，创建完成并安装Node对象中。服务可以支持外部RPC和HTTP接口对外功能。 +* Module: 这是orgin最小对象单元，非常建议所有的业务模块都划分成各个小的Module组合。Module可以建立树状关系。Service也是Module的类型。 + +orgin集群核心配置文件config/cluser.json如下: +--------------- +``` +{ +"PublicServiceList":["logiclog"], + +"NodeList":[ + +{ + "NodeID":1, + "NodeName":"N_Node1", + "ServerAddr":"127.0.0.1:8080", + + "ServiceList":["CTestService1"], + "ClusterNode":["N_Node2"] +}, + +{ + "NodeID":2, + "NodeName":"N_Node2", + "ServerAddr":"127.0.0.1:8081", + "ServiceList":["CTestService2","CTestService3"], + "ClusterNode":[] } +] +} +``` +orgin所有的结点与服务通过配置进行关联，配置文件分为两大配置结点： +* PublicServiceList：用于公共服务配置，所有的结点默认会加载该服务列表。 +* NodeList：Node所有的列表 + * NodeId: Node编号，用于标识唯一的进程id + * NodeName: Node名称，用于区分Node结点功能。例如，可以是GameServer + * ServerAddr: 结点监听的地址与端口 + * ServiceList:结点中允许开启的服务列表 + * ClusterNode:将与列表中的Node产生集群关系。允许访问这些结点中所有的服务。 + +orgin第一个服务: +--------------- +我们准备新建两个服务，分别是CTestService1与CTestService2。 +* config/cluster.json内容如下 +``` +{ +"NodeList":[ +{ + "NodeID":1, + "NodeName":"N_Node1", + "ServerAddr":"127.0.0.1:8080", + + "ServiceList":["CTestService1","CTestService2"], + "ClusterNode":[] +} +] +} +``` + +