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

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

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

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

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

復(fù)制代碼 代碼如下:

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和對應(yīng)的controller封裝了進去，然后在Server端負(fù)責(zé)接收socket發(fā)送信息的函數(shù)handleConnection那里再實現(xiàn)Router內(nèi)部的遍歷即可：

復(fù)制代碼 代碼如下:

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ī)則進行匹配，最后調(diào)用對應(yīng)的Controller進行邏輯的實現(xiàn)啦，下面給出一個controller的編寫實例，這個Controll的作用是發(fā)來的json類型是mirror的時候，將Client發(fā)來的信息原樣返回：

復(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) 
}

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

復(fù)制代碼 代碼如下:

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ā)的時候，為了方便調(diào)試代碼，我推薦將log輸出到指定文件位置下，這樣在調(diào)試的時候會方便很多（主要是因為golang的調(diào)試實在太麻煩，很多時候都要依靠打log的時候進行步進。便于調(diào)試的Log模塊代碼示意：

復(fù)制代碼 代碼如下:

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í)行一些定時任務(wù)，比如隔一定時間刷新后臺，隔一段時間自動刷新爬蟲等等，在這里我設(shè)計了一個Task接口，通過類似于TaskList的的方式將所有定時任務(wù)注冊后統(tǒng)一執(zhí)行，代碼如下：

復(fù)制代碼 代碼如下:

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

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

復(fù)制代碼 代碼如下:

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() 
        } 
 
} 

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

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

文章名稱：Go編寫的Socket服務(wù)器模塊解耦及基礎(chǔ)模塊的設(shè)計示例分析
標(biāo)題URL：http://sd-ha.com/article2/ihedic.html

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

廣告

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