Go編寫的Socket服務器模塊解耦及基礎模塊的設計示例分析

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

在田東等地區(qū)，都構建了全面的區(qū)域性戰(zhàn)略布局，加強發(fā)展的系統(tǒng)性、市場前瞻性、產品創(chuàng)新能力，以專注、極致的服務理念，為客戶提供成都網站建設、網站制作 網站設計制作定制制作,公司網站建設,企業(yè)網站建設,品牌網站制作,成都全網營銷推廣,成都外貿網站建設公司,田東網站建設費用合理。

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

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

Go編寫的Socket服務器模塊解耦及基礎模塊的設計示例分析

  這是一個典型的MVC框架，可以看到，當用戶發(fā)送請求到beego后，Beego內部在通過路由進行參數的過濾，然后路由根據用戶發(fā)來的參數判斷調用哪個Controller執(zhí)行相關的邏輯，并在controller里調用相關的模塊實現(xiàn)功能。通過這種方式，Beego成功的將所有模塊都獨立出來，也就是astaxie所說的“樂高積木化”。
       在這里，我們可以仿照Beego的架構，在Server內部加入一層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ā)送信息的函數handleConnection那里再實現(xiàn)Router內部的遍歷即可：

復制代碼 代碼如下:


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日常運行時產生的信息，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經常要執(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的。。。

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

文章名稱：Go編寫的Socket服務器模塊解耦及基礎模塊的設計示例分析
標題URL：http://muchs.cn/article2/ihedic.html

成都網站建設公司_創(chuàng)新互聯(lián)，為您提供微信公眾號、網站導航、ChatGPT、自適應網站、手機網站建設、做網站

廣告

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

網站優(yōu)化排名