剖析Go編寫的Socket服務(wù)器模塊解耦及基礎(chǔ)模塊的設(shè)計(jì)
Server的解耦—通過Router+Controller實(shí)現(xiàn)邏輯分發(fā)
在實(shí)際的系統(tǒng)項(xiàng)目工程中中，我們在寫代碼的時候要盡量避免不必要的耦合，否則你以后在更新和維護(hù)代碼的時候會發(fā)現(xiàn)如同深陷泥潭，隨便改點(diǎn)東西整個系統(tǒng)都要變動的酸爽會讓你深切后悔自己當(dāng)初為什么非要把東西都寫到一塊去（我不會說我剛實(shí)習(xí)的時候就是這么干的。。。）
所以這一篇主要說說如何設(shè)計(jì)Sever的內(nèi)部邏輯，將Server處理Client發(fā)送信息的這部分邏輯與Sevrer處理Socket連接的邏輯進(jìn)行解耦～
這一塊的實(shí)現(xiàn)靈感主要是在讀一個HTTP開源框架： Beego 的源代碼的時候產(chǎn)生的，Beego的整個架構(gòu)就是高度解耦的，這里引用一下作者的介紹：
beego 是基于八大獨(dú)立的模塊構(gòu)建的，是一個高度解耦的框架。當(dāng)初設(shè)計(jì) beego 的時候就是考慮功能模塊化，用戶即使不使用 beego 的 HTTP 邏輯，也依舊可以使用這些獨(dú)立模塊，例如：你可以使用 cache 模塊來做你的緩存邏輯；使用日志模塊來記錄你的操作信息；使用 config 模塊來解析你各種格式的文件。所以 beego 不僅可以用于 HTTP 類的應(yīng)用開發(fā)，在你的 socket 游戲開發(fā)中也是很有用的模塊，這也是 beego 為什么受歡迎的一個原因。大家如果玩過樂高的話，應(yīng)該知道很多高級的東西都是一塊一塊的積木搭建出來的，而設(shè)計(jì) beego 的時候，這些模塊就是積木，高級機(jī)器人就是 beego。
這里上一張Beego的架構(gòu)圖：
這是一個典型的MVC框架，可以看到，當(dāng)用戶發(fā)送請求到beego后，Beego內(nèi)部在通過路由進(jìn)行參數(shù)的過濾，然后路由根據(jù)用戶發(fā)來的參數(shù)判斷調(diào)用哪個Controller執(zhí)行相關(guān)的邏輯，并在controller里調(diào)用相關(guān)的模塊實(shí)現(xiàn)功能。通過這種方式，Beego成功的將所有模塊都獨(dú)立出來，也就是astaxie所說的“樂高積木化”。
在這里，我們可以仿照Beego的架構(gòu)，在Server內(nèi)部加入一層Router,通過Router對通過Socket發(fā)來的信息進(jìn)通過我們設(shè)定的規(guī)則行的判斷后，調(diào)用相關(guān)的Controller進(jìn)行任務(wù)的分發(fā)處理。在這個過程中不僅Controller彼此獨(dú)立，匹配規(guī)則和Controller之間也是相互獨(dú)立的。
下面給出Router的實(shí)現(xiàn)代碼，其中Msg的結(jié)構(gòu)對應(yīng)的是Json字符串，當(dāng)然考慮到實(shí)習(xí)公司現(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和對應(yīng)的controller封裝了進(jìn)去，然后在Server端負(fù)責(zé)接收socket發(fā)送信息的函數(shù)handleConnection那里再實(shí)現(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ī)則進(jìn)行匹配，最后調(diào)用對應(yīng)的Controller進(jìn)行邏輯的實(shí)現(xiàn)啦，下面給出一個controller的編寫實(shí)例，這個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)
}
日志模塊的設(shè)計(jì)與定時任務(wù)模塊模塊
作為一個Server，日志（Log）功能是必不可少的，一個設(shè)計(jì)良好的日志模塊，不論是開發(fā)Server時的調(diào)試，還是運(yùn)行時候的維護(hù)，都是非常有幫助的。
因?yàn)檫@里寫的是一個比較簡化的Server框架，因此我選擇對Golang本身的log庫進(jìn)行擴(kuò)充，從而實(shí)現(xiàn)一個簡單的Log模塊。
在這里，我將日志的等級大致分為Debug，Operating，Error 3個等級，Debug主要用于存放調(diào)試階段的日志信息，Operateing用于保存Server日常運(yùn)行時產(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，因?yàn)檫@樣在Server運(yùn)行的時候可以直接將log重定向到指定的位置，方便整個Server的部署。不過在日常開發(fā)的時候，為了方便調(diào)試代碼，我推薦將log輸出到指定文件位置下，這樣在調(diào)試的時候會方便很多（主要是因?yàn)間olang的調(diào)試實(shí)在太麻煩，很多時候都要依靠打log的時候進(jìn)行步進(jìn)。便于調(diào)試的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();
}
然后就是計(jì)時循環(huán)模塊啦，日常運(yùn)行中，Server經(jīng)常要執(zhí)行一些定時任務(wù)，比如隔一定時間刷新后臺，隔一段時間自動刷新爬蟲等等，在這里我設(shè)計(jì)了一個Task接口，通過類似于TaskList的的方式將所有定時任務(wù)注冊后統(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)
}
在這里以一個定時報時任務(wù)作為例子：
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的。。。
相關(guān)文章
函數(shù)是?Golang?中非常重要的組成部分之一，它們提供了代碼的可重用性和組織性。在本文中，我們將深入了解?Golang?函數(shù)的多個方面，希望對大家有所幫助2023-04-04
一個簡單的Golang實(shí)現(xiàn)的HTTP Proxy方法
今天小編就為大家分享一篇一個簡單的Golang實(shí)現(xiàn)的HTTP Proxy方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2019-08-08
這篇文章主要介紹了Golang 的defer執(zhí)行規(guī)則說明，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-04-04
本文主要介紹了Golang有類型常量和無類型常量的區(qū)別，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-04-04
golang操作連接數(shù)據(jù)庫實(shí)現(xiàn)mysql事務(wù)示例
這篇文章主要為大家介紹了golang操作連接數(shù)據(jù)庫實(shí)現(xiàn)mysql事務(wù)示例，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步早日升職加薪2022-04-04
淺談Golang 切片（slice）擴(kuò)容機(jī)制的原理
我們知道 Golang 切片在容量不足的情況下會進(jìn)行擴(kuò)容，擴(kuò)容的原理是怎樣的呢，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-06-06
gin自定義中間件解決requestBody不可重讀(請求體取值)
這篇文章主要介紹了gin自定義中間件解決requestBody不可重讀,確?？刂破髂軌颢@取請求體值,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-10-10
這篇文章主要詳細(xì)介紹了Golang中函數(shù)的使用方法，文中有詳細(xì)的示例代碼，對大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下2023-05-05
golang數(shù)組-----尋找數(shù)組中缺失的整數(shù)方法
這篇文章主要介紹了golang數(shù)組-----尋找數(shù)組中缺失的整數(shù)方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-12-12
這篇文章主要介紹了golang的基礎(chǔ)語法和常用開發(fā)工具,本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-12-12