今天就跟大家聊聊有關Go編寫的Socket服務器模塊解耦及基礎模塊的設計示例分析，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

為文圣等地區(qū)用戶提供了全套網(wǎng)頁設計制作服務，及文圣網(wǎng)站建設行業(yè)解決方案。主營業(yè)務為成都網(wǎng)站設計、成都網(wǎng)站建設、外貿(mào)網(wǎng)站建設、文圣網(wǎng)站設計，以傳統(tǒng)方式定制建設網(wǎng)站，并提供域名空間備案等一條龍服務，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務。我們深信只要達到每一位用戶的要求，就會得到認可，從而選擇與我們長期合作。這樣，我們也可以走得更遠！

Server的解耦—通過Router+Controller實現(xiàn)邏輯分發(fā)

在實際的系統(tǒng)項目工程中中，我們在寫代碼的時候要盡量避免不必要的耦合，否則你以后在更新和維護代碼的時候會發(fā)現(xiàn)如同深陷泥潭，隨便改點東西整個系統(tǒng)都要變動的酸爽會讓你深切后悔自己當初為什么非要把東西都寫到一塊去（我不會說我剛實習的時候就是這么干的。。。）
所以這一篇主要說說如何設計Sever的內(nèi)部邏輯，將Server處理Client發(fā)送信息的這部分邏輯與Sevrer處理Socket連接的邏輯進行解耦～
這一塊的實現(xiàn)靈感主要是在讀一個HTTP開源框架： Beego  的源代碼的時候產(chǎn)生的，Beego的整個架構就是高度解耦的，這里引用一下作者的介紹：
beego 是基于八大獨立的模塊構建的，是一個高度解耦的框架。當初設計 beego 的時候就是考慮功能模塊化，用戶即使不使用 beego 的 HTTP 邏輯，也依舊可以使用這些獨立模塊，例如：你可以使用 cache 模塊來做你的緩存邏輯；使用日志模塊來記錄你的操作信息；使用 config 模塊來解析你各種格式的文件。所以 beego 不僅可以用于 HTTP 類的應用開發(fā)，在你的 socket 游戲開發(fā)中也是很有用的模塊，這也是 beego 為什么受歡迎的一個原因。大家如果玩過樂高的話，應該知道很多高級的東西都是一塊一塊的積木搭建出來的，而設計 beego 的時候，這些模塊就是積木，高級機器人就是 beego。 
這里上一張Beego的架構圖：

  這是一個典型的MVC框架，可以看到，當用戶發(fā)送請求到beego后，Beego內(nèi)部在通過路由進行參數(shù)的過濾，然后路由根據(jù)用戶發(fā)來的參數(shù)判斷調用哪個Controller執(zhí)行相關的邏輯，并在controller里調用相關的模塊實現(xiàn)功能。通過這種方式，Beego成功的將所有模塊都獨立出來，也就是astaxie所說的“樂高積木化”。
       在這里，我們可以仿照Beego的架構，在Server內(nèi)部加入一層Router,通過Router對通過Socket發(fā)來的信息進通過我們設定的規(guī)則行的判斷后，調用相關的Controller進行任務的分發(fā)處理。在這個過程中不僅Controller彼此獨立，匹配規(guī)則和Controller之間也是相互獨立的。
       下面給出Router的實現(xiàn)代碼，其中Msg的結構對應的是Json字符串，當然考慮到實習公司現(xiàn)在也在用這個，修改了一部分，不過核心思路是一樣的哦：

復制代碼 代碼如下:

import ( 
    "utils" 
    "fmt" 
    "encoding/json" 
) 
 
type Msg struct { 
    Conditions   map[string]interface{} `json:"meta"` 
    Content interface{}            `json:"content"` 
} 
 
type Controller interface { 
    Excute(message Msg) []byte 
} 
 
var routers [][2]interface{} 
 
func Route(judge interface{} ,controller Controller) { 
    switch judge.(type) { 
    case func(entry Msg)bool:{ 
        var arr [2]interface{} 
        arr[0] = judge 
        arr[1] = controller 
        routers = append(routers,arr) 
    } 
    case map[string]interface{}:{ 
        defaultJudge:= func(entry Msg)bool{ 
            for keyjudge , valjudge := range judge.(map[string]interface{}){ 
                val, ok := entry.Meta[keyjudge] 
                if !ok { 
                    return false 
                } 
                if val != valjudge { 
                    return false 
                } 
            } 
            return true 
        } 
        var arr [2]interface{} 
        arr[0] = defaultjudge 
        arr[1] = controller 
        routers = append(routers,arr) 
        fmt.Println(routers) 
        } 
    default: 
        fmt.Println("Something is wrong in Router") 
    } 
} 

      通過自定義接口Router，我們將匹配規(guī)則judge和對應的controller封裝了進去，然后在Server端負責接收socket發(fā)送信息的函數(shù)handleConnection那里再實現(xiàn)Router內(nèi)部的遍歷即可：

復制代碼 代碼如下:

for _ ,v := range routers{ 
        pred := v[0] 
        act := v[1] 
        var message Msg 
        err := json.Unmarshal(postdata,&message) 
        if err != nil { 
            Log(err) 
        } 
        if pred.(func(entry Msg)bool)(message) { 
            result := act.(Controller).Excute(message) 
            conn.Write(result) 
            return 
        } 
    } 

       這樣Client每次發(fā)來信息，我們就可以讓Router自動跟現(xiàn)有的規(guī)則進行匹配，最后調用對應的Controller進行邏輯的實現(xiàn)啦，下面給出一個controller的編寫實例，這個Controll的作用是發(fā)來的json類型是mirror的時候，將Client發(fā)來的信息原樣返回：

復制代碼 代碼如下:

type MirrorController struct  { 
 
} 
 
func (this *MirrorController) Excute(message Msg)[]byte { 
    mirrormsg,err :=json.Marshal(message) 
    CheckError(err) 
    return mirrormsg 
} 
 
 
func init() { 
    var mirror  
    routers = make([][2]interface{} ,0 , 20) 
    Route(func(entry Msg)bool{ 
        if entry.Meta["msgtype"]=="mirror"{ 
        return true} 
        return  false 
    },&mirror) 
}

日志模塊的設計與定時任務模塊模塊
作為一個Server，日志（Log）功能是必不可少的，一個設計良好的日志模塊，不論是開發(fā)Server時的調試，還是運行時候的維護，都是非常有幫助的。
因為這里寫的是一個比較簡化的Server框架，因此我選擇對Golang本身的log庫進行擴充，從而實現(xiàn)一個簡單的Log模塊。
在這里，我將日志的等級大致分為Debug，Operating，Error 3個等級，Debug主要用于存放調試階段的日志信息，Operateing用于保存Server日常運行時產(chǎn)生的信息，Error則是保存報錯信息。
模塊代碼如下：

復制代碼 代碼如下:

func LogErr(v ...interface{}) { 
 
    logfile := os.Stdout 
    log.Println(v...) 
    logger := log.New(logfile,"\r\n",log.Llongfile|log.Ldate|log.Ltime); 
    logger.SetPrefix("[Error]") 
    logger.Println(v...) 
    defer logfile.Close(); 
} 
 
func Log(v ...interface{}) { 
 
    logfile := os.Stdout 
    log.Println(v...) 
    logger := log.New(logfile,"\r\n",log.Ldate|log.Ltime); 
    logger.SetPrefix("[Info]") 
    logger.Println(v...) 
    defer logfile.Close(); 
} 
 
func LogDebug(v ...interface{}) { 
    logfile := os.Stdout 
    log.Println(v...) 
    logger := log.New(logfile,"\r\n",log.Ldate|log.Ltime); 
    logger.SetPrefix("[Debug]") 
    logger.Println(v...) 
    defer logfile.Close(); 
} 
 
func CheckError(err error) { 
    if err != nil { 
        LogErr(os.Stderr, "Fatal error: %s", err.Error()) 
    } 
} 

注意這里log的輸出我使用的是stdout，因為這樣在Server運行的時候可以直接將log重定向到指定的位置，方便整個Server的部署。不過在日常開發(fā)的時候，為了方便調試代碼，我推薦將log輸出到指定文件位置下，這樣在調試的時候會方便很多（主要是因為golang的調試實在太麻煩，很多時候都要依靠打log的時候進行步進。便于調試的Log模塊代碼示意：

復制代碼 代碼如下:

func Log(v ...interface{}) { 
 
    logfile := os.OpenFile("server.log",os.O_RDWR|os.O_APPEND|os.O_CREATE,0); 
    if err != nil { 
        fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error()) 
        return    } 
    log.Println(v...) 
    logger := log.New(logfile,"\r\n",log.Ldate|log.Ltime); 
    logger.SetPrefix("[Info]") 
    logger.Println(v...) 
    defer logfile.Close(); 
} 

然后就是計時循環(huán)模塊啦，日常運行中，Server經(jīng)常要執(zhí)行一些定時任務，比如隔一定時間刷新后臺，隔一段時間自動刷新爬蟲等等，在這里我設計了一個Task接口，通過類似于TaskList的的方式將所有定時任務注冊后統(tǒng)一執(zhí)行，代碼如下：

復制代碼 代碼如下:

type DoTask interface { 
    Excute() 
} 
 
var tasklist []interface{} 
 
func AddTask(controller DoTask) { 
    var arr interface{} 
    arr = controller 
    tasklist = append(tasklist,arr) 
    fmt.Println(tasklist) 
    } 

在這里以一個定時報時任務作為例子：

復制代碼 代碼如下:

type Task1 struct {} 
 
func (this * Task1)Excute() { 
    timer := time.NewTicker(2 * time.Second) 
    for { 
        select { 
        case <-timer.C: 
            go func() { 
                Log(time.Now()) 
            }() 
        } 
    } 
} 
 
func init() { 
    var task1 Task1 
    tasklist = make([]interface{} ,0 , 20) 
    AddTask(&task1) 
        for _, v := range tasklist { 
            v.(DoTask).Excute() 
        } 
 
} 

注意這里的定時任務要做成非阻塞的，否則整個Server都會卡在tasklist的第一個task的。。。

看完上述內(nèi)容，你們對Go編寫的Socket服務器模塊解耦及基礎模塊的設計示例分析有進一步的了解嗎？如果還想了解更多知識或者相關內(nèi)容，請關注創(chuàng)新互聯(lián)成都網(wǎng)站設計公司行業(yè)資訊頻道，感謝大家的支持。

另外有需要云服務器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務器15元起步，三天無理由+7*72小時售后在線，公司持有idc許可證，提供“云服務器、裸金屬服務器、高防服務器、香港服務器、美國服務器、虛擬主機、免備案服務器”等云主機租用服務以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務可用性高、性價比高”等特點與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應用場景需求。

分享標題：Go編寫的Socket服務器模塊解耦及基礎模塊的設計示例分析-創(chuàng)新互聯(lián)
URL鏈接：http://chinadenli.net/article18/cojgdp.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站設計、虛擬主機、網(wǎng)站策劃、搜索引擎優(yōu)化、品牌網(wǎng)站制作、外貿(mào)建站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉載內(nèi)容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)