在說明之前我先展示一下我的工程目錄層級，因為我連github有點慢，所以像protoc.exe這樣上了1M的檔案就不傳了。所以如果從github上獲取原始碼的同學可能還需要再去我的百度雲盤上獲取build.bat和protoc.exe。百度雲盤連結：http://pan.baidu.com/s/1dFebn25密碼：oq2h，當然用linux的同學需要自己再另外獲取protoc和自己寫build的shell指令碼，這裡對linux同學造成的小小不便請諒解

不過在git.oschina上有傳protoc.exe

這裡build.bat、protoc.exe和railgun這個工程的是處於同一個目錄下的

Go/workspace就是我的GoPath這個環境變數的值

就是說railgun工程所處的目錄是$GoPath/src

Build.bat是protoc.exe操作.proto檔案生成相應的.go原始檔的批處理命令，在linux下替換成相應.sh指令碼命令就行了（這裡要稍微注意點的是，如果你的GoPath環境變數有兩個以上的路徑，這個批處理命令是無法執行的，需要你把批處理裡面的%GOPATH%這個值替換成protoc-gen-go.exe所處的絕對路徑）

下面開始講解程式碼，以傳送LoginReq請求為例

執行GateApp.exe，RouterApp.exe, LoginApp.exe

1.在工程裡寫了一個很粗糙的客戶端測試用例

開始先建立與GateApp建立TCP連線

ch := make(chan proto.Message, 1000)
    session := DialManager.CreateClient("127.0.0.1:4101", ch)
    if session == nil {
        fmt.Println("連線gate失敗")
        return
    }

建立訊息接受協程

goReceiveMsg(ch)

將loginReq轉化為bs_tcp.TCPTransferMsg型別後向gateApp傳送報文

loginReq := new(bs_client.LoginReq)
loginReq.LoginAccount = "yourname"
loginReq.LoginPassword = "E10ADC3949BA59ABBE56E057F20F883E" //123456的MD5加密
tcpMsg := ChangeCommonMsgToTCPTransferMsg(loginReq)
if tcpMsg != nil {
        session.MsgWriteCh <- tcpMsg //向gate傳送訊息
}
 

2.通過TCP傳輸到了GateApp.exe:

2.1.從main()入口函式開始分析GateApp的程式碼

func main() {
    //先建立需要的變數
    quit := make(chan int)
    var myAppId uint32 = 101
    pNetAgent := PoolAndAgent.CreateNetAgent("0.0.0.0:4101") //監聽4101埠
    pLogicPool := PoolAndAgent.CreateMsgPool(quit, uint32(bs_types.EnumAppType_Gate), myAppId)
    pRouterAgent := PoolAndAgent.CreateRouterAgent("127.0.0.1:2001") //連線127.0.0.1:2001地址
    pGateLogic := CreateGateLogicInstance()
    //將他們都與Pool繫結起來
    pLogicPool.AddLogicProcess(pGateLogic)
    pLogicPool.BindNetAgent(pNetAgent)
    pLogicPool.BindRouterAgent(pRouterAgent)
    //執行
    ok := pLogicPool.InitAndRun(nil)
    if ok {
        fmt.Println("初始化完畢")
        pInitMsg := &PrivateInitMsg{
            pNetAgent:    pNetAgent,
            pRouterAgent: pRouterAgent,
            myAppId:      myAppId}
        //在初始化完畢後向邏輯層傳送初始化報文，帶著一些初始化資訊，比如自己的APPID等
        pLogicPool.PushMsg(pInitMsg, 0)
    }

    //阻塞直到收到quit請求
    for {
        select {
        case v := <-quit:
            if v == 1 { //只有在收到1時才退出主執行緒
                return
            }
        }
    }
}

這裡quit是通知整個GateApp.exe程序結束的channel

pNetAgent是監聽2001埠listenManager

pLogicPool是一個訊息佇列管理池將會與主邏輯繫結

pRouterAgent是去撥號連線RouterApp的DialManager

pGateLogic是業務邏輯GateLogic的一個單例，GateLogic實現了agent.go裡的typeILogicProcessinterface這個介面，GateLogic.go裡定義和實現了GateLogic

然後和這些變數都和pLogicPool繫結後，pLogicPool.InitAndRun來啟動執行，如果執行成功後向pLogicPool push私有的初始化用途報文PrivateInitMsg，把自己的APPId之類的資訊傳遞給主邏輯層。

2.2.下一步分析package PoolAndAgent的MsgPool.go的SingleMsgPool.InitAndRun:

這裡主要分3部分

1.判斷有沒有bindingNetAgent，就是是否需要建立網路監聽例項，如果需要那麼就建立新的協程，用於一直select case阻塞讀取NetToLogicChannel這個channel

2.判斷有沒有RouterToLogicChannel，就是是否需要建立去連線RouterApp的網路撥號例項（除了RouterApp自身都需要）

3.遍歷bindingLogicProcesses這個slice,如果是主邏輯業務的ILogicProcess建議只需要一個就夠了，因為主邏輯業務會不可避免的要儲存各種資料，那麼如果是多協程可能就會涉及到全域性資料加鎖的情況，反覆加鎖解鎖說效率不一定比單協程要高。（當然如果你要主邏輯多協程我也不反對，只是按照我的經驗來說不建議這麼做）。像資料庫操作就這種IO速度較慢不可避免需要多協程的來處理的情況，那麼實際上操作資料庫的協程之間是沒有相互通訊的。都是在獲取好資料後直接傳給主邏輯協程來處理，這樣程式結構上顯得清楚點。後面講到LoginApp.exe時會舉例。

在遍歷迴圈中為每個bindingLogicProcesses建立RunLogicProcess(pLogicILogicProcess,pDataBase*CADODatabase,InitMsgproto.Message)

協程pLogic就是業務邏輯的單例，pDataBase是資料庫，如果不需要操作資料庫傳nil，InitMsg是需要傳入的初始化報文，不需要也傳nil

RunLogicProcess()函式裡每當收到一個報文就呼叫pLogic.ProcessReq來處理這個報文，和定時呼叫pLogic.OnPulse(nMs)函式，每次OnPulse的時間間隔ONPULSE_INTERVAL由程式猿根據實際需求調整

OK，這裡當上文中來自ClientForTest.exe的TCPTransferMsg報文由網路層收到以後就丟給SingleMsgPool,SingleMsgPool收到後再丟給自己的成員變PoolToLogicChannel

，然後RunLogicProcess()協程一直在阻塞讀取PoolToLogicChannel在收到TCPTransferMsg報文後呼叫pLogic.ProcessReq函式來處理這個報文

2.3.下一步分析GateLogic.go裡的ProcessReq：

開始需要呼叫Gate_CreateCommonMsgByTCPTransferMsg函式來過濾掉不需要的報文，並轉化成自己需要的報文。ClientForTest.exe發來的報文到這裡變為了bs_gate.GateTransferData，然後Gate_GateTransferData()函式裡把GateTransferData轉為RouterTransferData發往RouterApp.exe

3.GateApp.exe通過TCP傳輸到了RouterApp.exe:

Main()，SingleMsgPool.InitAndRun()和GateApp.exe部分大同小異，區別部分就是GateApp.exe是有RouterAgent模組的，RouterApp.exe是沒有RouterAgent模組的

講一下RouterLogic.go檔案的ProcessReq():

在收到RouterTransferData報文後，根據dest_apptype和dest_appid的值向目標APP傳送（其實這裡就是LoginApp）

4.RouterApp.exe通過TCP傳輸到了LoginApp.exe:

4.1 這裡要說一下Main()：

func main() {
    //先建立需要的變數
    quit := make(chan int)
    var myAppId uint32 = 30
    pLogicPool := PoolAndAgent.CreateMsgPool(quit, uint32(bs_types.EnumAppType_Login), myAppId)
    pRouterAgent := PoolAndAgent.CreateRouterAgent("127.0.0.1:2001") //連線127.0.0.1:2001地址
    pMainLoginLogic := CreateLoginLogicInstance()
    //將他們都與Pool繫結起來
    pLogicPool.AddLogicProcess(pMainLoginLogic)
    pLogicPool.BindRouterAgent(pRouterAgent)
    //建立資料庫協程,只有主執行緒pLogicPool需要繫結RouterAgent，資料庫協程是不需要的,所以退出quit也不需要建立，因為程式退出又邏輯主執行緒來控制
    //先建立需要的變數
    pDBPool := PoolAndAgent.CreateMsgPool(nil, uint32(bs_types.EnumAppType_Login), myAppId)
    for i := 0; i < 10; i++ {
        //建立10個數據庫協程，因為資料庫IO速度比較慢會存在阻塞時間，所以要多開幾個，
        //資料庫邏輯協程間最好不要有資料通訊，都應該通過主邏輯POOL與主邏輯進行通訊
        //相對的主邏輯最好只用一個協程，這樣寫業務邏輯也好寫，
        pDBLogic := CreateLoginDBInstance()
        pDBProcess := PoolAndAgent.CreateADODatabase("root:[email protected](localhost:3306)/gotest?charset=utf8")
        //將他們都與Pool繫結起來
        pDBPool.AddLogicProcess(pDBLogic)
        pDBPool.AddDataBaseProcess(pDBProcess)
    }

    //執行主邏輯執行緒pool
    ok := pLogicPool.InitAndRun(nil)
    if ok {
        fmt.Println("主邏輯POOL初始化完畢")
        //這裡要在初始化完畢後把DBPool和MainPool的指標傳過去，這樣才能兩個Pool之間才可以相互傳遞資料
        pInitMsg := &PrivateInitMsg{
            pNetAgent:    nil,
            pRouterAgent: pRouterAgent,
            myAppId:      myAppId,
            pMainPool:    pLogicPool,
            pDBPool:      pDBPool}
        //在初始化完畢後向邏輯層傳送初始化報文，帶著一些初始化資訊，比如自己的APPID等
        pLogicPool.PushMsg(pInitMsg, 0)
    } else {
        return
    }
    //執行資料庫協程pool
    pInitMsg := &PrivateInitMsg{
        pNetAgent:    nil,
        pRouterAgent: pRouterAgent,
        myAppId:      myAppId,
        pMainPool:    pLogicPool,
        pDBPool:      pDBPool}
    ok = pDBPool.InitAndRun(pInitMsg)
    if ok {
        fmt.Println("資料庫邏輯POOL初始化完畢")
    } else {
        return
    }
    //阻塞直到收到quit請求
    for {
        select {
        case v := <-quit:
            if v == 1 { //只有在收到1時才退出主執行緒
                return
            }
        }
    }
}

在main()函式裡建立了兩個SingleMsgPool,一個是繫結主邏輯業務協程的Pool，另一個是繫結多個數據庫邏輯業務協程的Pool。

而且在繫結資料庫協程的pDBPool.InitAndRun(pInitMsg)的時候引數不是nil而是pInitMsg。為什麼呢？因為如果不在InitAndRun的時候就傳進去，在初始化完成後再向pDBPool傳送，那麼多個數據庫業務邏輯協程實際上是對PoolToLogicChannel是處於共同讀取狀態，如果哪個協程空閒或者說正處於管道讀取阻塞狀態，就會去處理這個報文。就是說就算髮送多個初始化報文仍然有可能存在有些資料庫邏輯沒有收到初始化報文的情況，造成初始化不完全的情況。

綁定了資料庫邏輯業務協程的Pool實際上是沒有繫結RouterAgent的，只有主邏輯Pool才綁定了RouterAgent，就是說LoginApp和RouterApp通訊是通過主邏輯Pool,資料庫的pDBPool並不直接與RouterApp通訊

4.2.LoginMainLogic.go裡的ProcessReq：

在收到TCPTransferMsg時，RouterAgent會將其轉為RouterTransferData再讓ProcessReq來處理。ProcessReq先將RouterTransferData轉為LoginReq,

Client_OnLoginReq()函式中列印後就呼叫this.PushToDBPool(req) push給資料庫的DBPool。

DBPool收到後就讓空閒的資料庫業務協程來處理

4.3.LoginDBLogic.go裡的ProcessReq：

在LoginDBLogic收到的直接就是LoginReq,直接呼叫Client_OnDBLoginReq來處理

這裡我對資料庫sql.DB做了簡單的封裝，如果你不喜歡我的封裝直接操作CADODatabase

.TheDB也是可以的，或者重新封裝也沒問題。

在從資料庫裡獲取了資料後new了一個bs_client.LoginRsp登入回覆報文丟給主邏輯業務Pool

接下來LoginRsp從LoginApp最終返回到客戶端，就是上述過程的逆過程，這裡就不再贅述了。需要簡單注意一下的是，在GateApp收到LoginRsp時，如果是登入成功則會記錄下這個userId並和對應的會話關聯起來，以後其他APP向某個使用者客戶端傳送報文時就可以用userId作為標識傳送了，不一定要gateConnId，因為用userId通常比較方便，因為gateConnId使用者客戶端每當重新連線時都會變更。

5.說明和小結：每當根據業務需求新寫一個業務App時，需要手寫的原始檔有

package main的main.go、PrivateMsg.go（這個如果沒有需要新增私有報文就直接複製過來就行了）、XXXMsgFilter.go、XXXMainLogic.go、XXXDBLogic.go（如果需要操作資料庫的話）

Package bs_proto的SetBaseInfo.go中的SetBaseKindAndSubId函式，要根據proto資料型別對其new Base並對Base.KindId和SubId賦值