21ic电子技术开发论坛 › 软件应用 › 平台与系统开发 › 一起学go语言啦
123下一页
返回列表 发新帖我要提问

一起学go语言啦

[复制链接]
5311|42
 楼主| keer_zu 发表于 2016-11-30 10:45 | 显示全部楼层 |阅读模式
go, AC, 通信, ic
本帖最后由 keer_zu 于 2016-11-30 11:03 编辑

最近一个项目，需要go语言。
需要一个通信框架，可以并发处理多路链接和消息处理。

@21ic小喇叭 @yyy71cj @dong_abc

学go语言啦

学习 Go 语言(Golang).pdf (1.11 MB, 下载次数: 98)
回复

收藏1 举报

相关帖子
 楼主| keer_zu 发表于 2016-11-30 10:47 | 显示全部楼层
go语言开发速度快，容易学，支持并发
垃圾回收
编译型语言，效率高
语法有脚本语言的特点
适合做服务器开发

就选go语言啦
........
回复

收藏1 举报

 楼主| keer_zu 发表于 2016-11-30 10:55 | 显示全部楼层
首先在linux下安装go和sublime,其他组合也行，怎么习惯怎么来。网上大堆

如下图：
无标题.png
bei 011.jpg
回复

收藏1 举报

 楼主| keer_zu 发表于 2016-11-30 10:59 | 显示全部楼层
随便给一个demo，顺便了解一下go的interface概念和struct概念。
当然，所有环境可以很容易在windows环境下搭建。

代码：
复制
  1. package main
    


  2. 

  3. import (
    

  4.         "fmt"
    

  5.         "message"
    

  6.         "time"
    

  7. )
    


  8. 

  9. type S struct{ i int }
    


  10. 

  11. func (p *S) Get() int  { return p.i }
    

  12. func (p *S) Put(v int) { p.i = v }
    


  13. 

  14. type R struct{ i int }
    


  15. 

  16. func (p *R) Get() int  { return p.i }
    

  17. func (p *R) Put(v int) { p.i = v }
    


  18. 

  19. type I interface {
    

  20.         Get() int
    

  21.         Put(int)
    

  22. }
    


  23. 

  24. func f(p I) {
    

  25.         fmt.Println(p.Get())
    

  26.         p.Put(1)
    

  27. }
    


  28. 

  29. func f1(p I) {
    

  30.         switch p.(type) {
    


  31. 

  32.         case *S:
    

  33.                 fmt.Println("---- *S")
    

  34.                 break
    

  35.         case *R:
    

  36.                 fmt.Println("---- *R")
    

  37.                 break
    

  38.         default:
    

  39.                 fmt.Println("---- no thing")
    

  40.                 break
    

  41.         }
    

  42. }
    


  43. 

  44. var c chan int
    


  45. 

  46. func ready(w string, sec int) {
    

  47.         time.Sleep(time.Duration(sec) * time.Second)
    

  48.         fmt.Println(w, "is ready!")
    

  49.         c <- 1
    

  50. }
    

  51. func main() {
    

  52.         da := message.DmcMessageAnalyzer{}
    

  53.         da.OnNewFrame(nil, nil)
    

  54.         var s S
    

  55.         var r R
    

  56.         s.i = 5
    

  57.         r.i = 6
    

  58.         f(&r)
    

  59.         f(&s)
    

  60.         f1(&r)
    

  61.         f1(&s)
    

  62.         c = make(chan int)
    

  63.         go ready("Tea", 2)
    

  64.         go ready("Coffee", 1)
    

  65.         fmt.Println("I'm waiting, but not too long...")
    

  66.         //time.Sleep(5 * time.Second)
    

  67.         f1 := <-c
    

  68.         fmt.Println("recv f1: ", f1)
    

  69.         f2 := <-c
    

  70.         fmt.Println("recv f2: ", f2)
    

  71.         fmt.Println("bye")
    

  72. }



回复

收藏1 举报

 楼主| keer_zu 发表于 2016-11-30 11:01 | 显示全部楼层
上面代码被命名为：xxx.go
这里就叫test.go吧

然后使用go命令：
go build test.go

如果有错会提示，没有错误会得到可执行文件：test（windows下为test.exe）

就这么简单，玩起来吧。
回复

收藏1 举报

 楼主| keer_zu 发表于 2016-11-30 11:18 | 显示全部楼层
然后可以尝试一个go的“大”项目
首先确保你的环境已经安装好git，
然后使用 go get github.com/xxx 命令得到该项目源代码

比如我要用到一个go的通信库，
go get github.com/pojoin/golis

执行完毕后，在你的go目录下回有这个project的代码，我的在：
/root/go/src/github.com/pojoin/golis 下面。

用到这个库的地方，import进来（比如下面代码）：

复制
  1. package main
    


  2. 

  3. import (
    

  4.         "data_manager"
    

  5.         "fmt"
    

  6.         "github.com/pojoin/golis"
    

  7.         "message"
    

  8.         //        "time"
    

  9. )
    


  10. 

  11. func main() {
    

  12.         s := golis.NewServer()
    

  13.         s.FilterChain().AddLast("test", &filter{})
    

  14.         s.SetCodecer(&echoProtocalCodec{})
    

  15.         s.RunOnPort("tcp", ":9090")
    

  16. }
    


  17. 

  18. type echoProtocalCodec struct {
    

  19.         golis.ProtocalCodec
    

  20. }
    


  21. 

  22. type dmc struct {
    

  23.         data_manager.DmcInfo
    

  24. }
    


  25. 

  26. type stream struct {
    

  27.         data_manager.StreamInfo
    

  28. }
    


  29. 

  30. type room struct {
    

  31.         data_manager.RoomInfo
    

  32. }
    


  33. 

  34. type command struct {
    

  35.         message.Command
    

  36. }
    


  37. 

  38. func (*echoProtocalCodec) Decode(buffer *golis.Buffer, dataCh chan<- interface{}) error {
    

  39.         //var i int
    


  40. 

  41.         //length := buffer.GetWritePos()
    

  42.         fmt.Println("......Decode... len:", buffer.GetWritePos()-buffer.GetReadPos())
    

  43.         if buffer.GetWritePos()-buffer.GetReadPos() > 60 {
    

  44.                 fmt.Println("#################\n#######################\n#################\n#############\n")
    

  45.         }
    

  46.         /*
    

  47.                 for i = 0; i < length; i = i + 1 {
    

  48.                         fmt.Println(" ", buffer.GetBufItem(i))
    

  49.                         if buffer.GetBufItem(i) == 0x00 {
    

  50.                                 bs, _ := buffer.ReadBytes(i)
    

  51.                                 buffer.ResetRead()
    

  52.                                 buffer.ResetWrite()
    

  53.                                 if i < length-1 {
    

  54.                                         buffer.GetSlice(i+1, length-1)
    

  55.                                         dataCh <- bs
    

  56.                                         length = buffer.GetWritePos()
    

  57.                                         i = 0
    

  58.                                         continue
    

  59.                                 } else {
    

  60.                                         dataCh <- bs
    

  61.                                         break
    

  62.                                 }
    

  63.                         }
    

  64.                 }*/
    

  65.         bs, _ := buffer.ReadBytes(buffer.GetWritePos() - buffer.GetReadPos())
    

  66.         buffer.ResetRead()
    

  67.         buffer.ResetWrite()
    

  68.         dataCh <- bs
    


  69. 

  70.         return nil
    

  71. }
    


  72. 

  73. type filter struct{}
    


  74. 

  75. func (*filter) SessionOpened(session *golis.Iosession) bool {
    

  76.         fmt.Println("session opened,the client is ", session.Conn().RemoteAddr().String())
    

  77.         fmt.Println("+ session id: ", session.Id())
    

  78.         return true
    

  79. }
    


  80. 

  81. func (*filter) SessionClosed(session *golis.Iosession) bool {
    

  82.         fmt.Println("+ session closed, session id: ", session.Id())
    

  83.         return true
    

  84. }
    


  85. 

  86. func (*filter) MsgReceived(session *golis.Iosession, msg interface{}) bool {
    

  87.         ma := message.DmcMessageAnalyzer{}
    

  88.         if bs, ok := msg.([]byte); ok {
    

  89.                 fmt.Println(".....MsgReceived....")
    

  90.                 ma.OnNewFrame(session, "+++ new frame!!!")
    

  91.                 fmt.Println("+ received msg :", string(bs))
    

  92.                 fmt.Println("+ session id: ", session.Id())
    

  93.                 //if session.Id()%3 == 1 {
    

  94.                 //        fmt.Println("start sleeping...")
    

  95.                 //        time.Sleep(3 * time.Second)
    

  96.                 //        fmt.Println("end sleep.")
    

  97.                 //}
    

  98.                 //replayMsg := fmt.Sprintf("echoServer received msg : %v", string(bs))
    

  99.                 ma.OnNewFrame(session, bs)
    

  100.                 //session.Write([]byte(replayMsg))
    

  101.         }
    

  102.         return true
    

  103. }
    


  104. 

  105. func (*filter) MsgSend(session *golis.Iosession, message interface{}) bool {
    

  106.         fmt.Println("+ send msg, session id: ", session.Id())
    

  107.         return true
    

  108. }
    


  109. 

  110. func (*filter) ErrorCaught(session *golis.Iosession, err error) bool {
    

  111.         fmt.Println("+ ErrorCaught, session id: %d", session.Id())
    

  112.         return true
    

  113. }


文件起名：golisTest.go

然后进入golisTest.go所在目录，执行：
    go build golisTest.go

编译器会自己在自己的/root/go/src目录下找到所依赖代码，最终生成可执行文件。
回复

收藏1 举报

baiyunpiapia 发表于 2016-11-30 11:56 | 显示全部楼层
这种语言第一次听说哦
回复

收藏1 举报

 楼主| keer_zu 发表于 2016-11-30 13:03 | 显示全部楼层
yyy71cj 发表于 2016-11-30 11:52
只要有用，语法倒是次要的
一看这风格，很好
多多分享 ...

编程风格是它自己调整的，你随便写，保存的一刹那就给你对齐了。
回复

收藏1 举报

 楼主| keer_zu 发表于 2016-11-30 15:06 来自手机 | 显示全部楼层
baiyunpiapia 发表于 2016-11-30 11:56
这种语言第一次听说哦

google出品，今年编程语言排行榜上升最快语言
回复

收藏1 举报

ddllxxrr 发表于 2016-11-30 18:22 | 显示全部楼层
go语言第一次听说，学习了
回复

收藏1 举报

评论

keer_zu
现在go语言是不是很火了  发表于 2021-3-10 23:25
 楼主| keer_zu 发表于 2016-11-30 19:07 | 显示全部楼层
ddllxxrr 发表于 2016-11-30 18:22
go语言第一次听说，学习了

比较擅长并发和分布式环境。很多云平台的选择
回复

收藏1 举报

 楼主| keer_zu 发表于 2016-11-30 20:10 | 显示全部楼层
命令部分：

复制
  1. package message
    


  2. 

  3. import (
    

  4.         //"fmt"
    

  5.         //"container/list"
    

  6.         "errors"
    

  7.         "github.com/pojoin/golis"
    

  8. )
    


  9. 

  10. type CommandProperty int
    


  11. 

  12. const (
    

  13.         ProvideResult CommandProperty = iota
    

  14.         NoProvideResult
    

  15. )
    


  16. 

  17. type Command interface {
    

  18.         BuildResponse(info interface{}) (string, error)
    

  19.         CommandHandle(session *golis.Iosession) error
    

  20. }
    


  21. 

  22. type CommandAttribute struct {
    

  23.         CommandName      string
    

  24.         MsgId            string
    

  25.         IsProvidedResult CommandProperty
    

  26. }
    


  27. 

  28. type DmcCommandRegist struct {
    

  29.         cmdAtt    CommandAttribute
    

  30.         RoomId    int32
    

  31.         SessionId int32
    

  32. }
    


  33. 

  34. func (dcr *DmcCommandRegist) BuildResponse(info interface{}) (string, error) {
    

  35.         return "abc", errors.New("cde")
    

  36. }
    


  37. 

  38. func (dcr *DmcCommandRegist) CommandHandle(session *golis.Iosession) error {
    

  39.         return errors.New("abc")
    

  40. }
    


  41. 

  42. type CommandPool struct {
    

  43.         WaitMap map[string]*Command
    

  44. }
    


  45. 

  46. func (cp *CommandPool) Add(cmd *Command, msgId string) {
    

  47.         cp.WaitMap[msgId] = cmd
    

  48. }
    


  49. 

  50. type CommandDb struct {
    

  51.         CommandMap map[string]*Command
    

  52. }
    


  53. 

  54. func (cdb *CommandDb) AddCommand(cmd *Command, cmdName string) {
    

  55.         cdb.CommandMap[cmdName] = cmd
    

  56. }
    


  57. 

  58. func (cdb *CommandDb) GetCommand(name string) (*Command, error) {
    


  59. 

  60.         if cdb.CommandMap[name] != nil {
    

  61.                 return cdb.CommandMap[name], nil
    

  62.         }
    


  63. 

  64.         err := errors.New("This command is not exist! ")
    


  65. 

  66.         return nil, err
    

  67. }
回复

收藏1 举报

 楼主| keer_zu 发表于 2016-12-1 10:27 | 显示全部楼层
本帖最后由 keer_zu 于 2016-12-1 10:29 编辑

对上贴中的command和task概念做了区分，放在两个文件里面：
command.go和task.go

分别对CommandDb和TaskPool（上贴中CommandPool）实现了单例模式，保证对象实例的唯一性，使用测试函数做了测试，三个文件代码如下：

command.go:

复制
  1. package message
    


  2. 

  3. import (
    

  4.         "errors"
    

  5.         "fmt"
    

  6.         "github.com/pojoin/golis"
    

  7.         "sync"
    

  8. )
    


  9. 

  10. var once sync.Once
    


  11. 

  12. type CommandProperty int
    


  13. 

  14. //const (
    

  15. //        ProvideResult CommandProperty = iota
    

  16. //        NoProvideResult
    

  17. //)
    


  18. 

  19. type Command interface {
    

  20.         BuildResponse(info interface{}) (string, error)
    

  21.         CommandHandle(session *golis.Iosession) error
    

  22.         GetCommandName() string
    

  23.         IsProvidedResult() bool
    

  24. }
    


  25. 

  26. type CommandAttribute struct {
    

  27.         CommandName string
    

  28.         //MsgId            string
    

  29.         IsProvidedResult bool //CommandProperty
    

  30. }
    


  31. 

  32. type DmcCommandRegist struct {
    

  33.         cmdAtt    CommandAttribute
    

  34.         RoomId    int32
    

  35.         SessionId int32
    

  36. }
    


  37. 

  38. func (dcr *DmcCommandRegist) BuildResponse(info interface{}) (string, error) {
    

  39.         return "abc", errors.New("cde")
    

  40. }
    


  41. 

  42. func (dcr *DmcCommandRegist) CommandHandle(session *golis.Iosession) error {
    

  43.         return errors.New("abc")
    

  44. }
    


  45. 

  46. func (dcr *DmcCommandRegist) GetCommandName() string {
    

  47.         return dcr.cmdAtt.CommandName
    

  48. }
    


  49. 

  50. func (dcr *DmcCommandRegist) IsProvidedResult() bool {
    

  51.         return dcr.cmdAtt.IsProvidedResult
    

  52. }
    


  53. 

  54. type CommandDb struct {
    

  55.         CommandMap map[string]*Command
    

  56. }
    


  57. 

  58. var commandDbInstance *CommandDb
    


  59. 

  60. func GetCommandDbInstance() *CommandDb {
    

  61.         once.Do(func() {
    

  62.                 fmt.Println("+++++++++++ commandDb instance +++++++")
    

  63.                 commandDbInstance = &CommandDb{}
    

  64.         })
    

  65.         return commandDbInstance
    

  66. }
    


  67. 

  68. func (cdb *CommandDb) AddCommand(cmd *Command, cmdName string) {
    

  69.         cdb.CommandMap[cmdName] = cmd
    

  70. }
    


  71. 

  72. func (cdb *CommandDb) GetCommand(name string) (*Command, error) {
    


  73. 

  74.         if cdb.CommandMap[name] != nil {
    

  75.                 return cdb.CommandMap[name], nil
    

  76.         }
    


  77. 

  78.         err := errors.New("This command is not exist!")
    


  79. 

  80.         return nil, err
    

  81. }




task.go:
复制
  1. package message
    


  2. 

  3. import (
    

  4.         "fmt"
    

  5.         //        "errors"
    

  6.         //        "github.com/pojoin/golis"
    

  7.         "sync"
    

  8. )
    


  9. 

  10. var taskPoolOnce sync.Once
    


  11. 

  12. type TaskInfo struct {
    

  13.         Cmd   *Command
    

  14.         MsgId string
    

  15. }
    


  16. 

  17. type TaskPool struct {
    

  18.         WaitMap map[string]*TaskInfo
    

  19. }
    


  20. 

  21. var taskPoolInstance *TaskPool
    


  22. 

  23. func GetTaskPoolInstance() *TaskPool {
    

  24.         taskPoolOnce.Do(func() {
    

  25.                 fmt.Println("+++++++++++ taskPool instance +++++++")
    

  26.                 taskPoolInstance = &TaskPool{}
    

  27.         })
    

  28.         return taskPoolInstance
    

  29. }
    


  30. 

  31. func (tp *TaskPool) Add(task *TaskInfo, msgId string) {
    

  32.         tp.WaitMap[msgId] = task
    

  33. }
    


  34. 

  35. func (tp *TaskPool) Del(msgId string) {
    

  36.         delete(tp.WaitMap, msgId)
    

  37. }


测试函数：
复制
  1. package main
    


  2. 

  3. import (
    

  4.         "fmt"
    

  5.         "message"
    

  6. )
    


  7. 

  8. func main() {
    

  9.         fmt.Println("message test")
    

  10.         var cmddb1, cmddb2, cmddb3 *message.CommandDb
    

  11.         cmddb1 = message.GetCommandDbInstance()
    

  12.         s1 := fmt.Sprintf(" %d", cmddb1)
    

  13.         fmt.Println("cmddb1: ", s1)
    

  14.         cmddb2 = message.GetCommandDbInstance()
    

  15.         s2 := fmt.Sprintf(" %d", cmddb2)
    

  16.         fmt.Println("cmddb2: ", s2)
    

  17.         cmddb3 = message.GetCommandDbInstance()
    

  18.         s3 := fmt.Sprintf(" %d", cmddb3)
    

  19.         fmt.Println("cmddb3: ", s3)
    


  20. 

  21.         var taskp1, taskp2, taskp3 *message.TaskPool
    

  22.         taskp1 = message.GetTaskPoolInstance()
    

  23.         t1 := fmt.Sprintf(" %d", taskp1)
    

  24.         fmt.Println("taskp1: ", t1)
    

  25.         taskp2 = message.GetTaskPoolInstance()
    

  26.         t2 := fmt.Sprintf(" %d", taskp2)
    

  27.         fmt.Println("taskp2: ", t2)
    

  28.         taskp3 = message.GetTaskPoolInstance()
    

  29.         t3 := fmt.Sprintf(" %d", taskp3)
    

  30.         fmt.Println("taskp3: ", t3)
    

  31. }



@yyy71cj @21ic小喇叭 @dong_abc @ayb_ice @Simon21ic



回复

收藏1 举报

 楼主| keer_zu 发表于 2016-12-2 20:03 | 显示全部楼层
复制
  1. package message
    


  2. 

  3. import (
    

  4.         "container/list"
    

  5.         "data_manager"
    

  6.         "encoding/json"
    

  7.         "errors"
    

  8.         "fmt"
    

  9.         "sync"
    


  10. 

  11.         "github.com/pojoin/golis"
    

  12. )
    


  13. 

  14. var once sync.Once
    


  15. 

  16. type CommandProperty int
    


  17. 

  18. type Command interface {
    

  19.         BuildResponse(info interface{}) (string, error)
    

  20.         CommandHandle(session *golis.Iosession, CmdInfo interface{}) error
    

  21.         GetCommandName() string
    

  22.         IsProvidedResult() bool
    

  23. }
    


  24. 

  25. type CommandAttribute struct {
    

  26.         CommandName      string
    

  27.         IsProvidedResult bool //CommandProperty
    

  28. }
    


  29. 

  30. ////////////////////////////dmc  command ////////////////////////////
    

  31. ////////////////////// dmc_register  /////////////////////
    

  32. type DmcRegist struct {
    

  33.         Command string `json:"command"`
    

  34.         MsgId   string `json:"msg_id"`
    

  35.         RoomId  int32  `json:"room_id"`
    

  36. }
    


  37. 

  38. type DmcCommandRegist struct {
    

  39.         cmdAtt CommandAttribute
    

  40. }
    


  41. 

  42. //////////////////////  dmc_heart_beat  //////////////////
    

  43. type DmcHeartBeat struct {
    

  44.         Command string `json:"command"`
    

  45.         MsgId   string `json:"msg_id"`
    

  46.         DmcId   int32  `json:"dmc_id"`
    

  47. }
    


  48. 

  49. type DmcCommandHeartBeat struct {
    

  50.         cmdAtt CommandAttribute
    

  51. }
    


  52. 

  53. ////////////////////// dmc_unregister //////////////////
    


  54. 

  55. type DmcUnregister struct {
    

  56.         Command string `json:"command"`
    

  57.         MsgId   string `json:"msg_id"`
    

  58.         DmcId   int32  `json:"dmc_id"`
    

  59. }
    


  60. 

  61. type DmcCommandUnregister struct {
    

  62.         cmdAtt CommandAttribute
    

  63. }
    


  64. 

  65. ////////////////////// dmc_stream_query //////////////////
    

  66. type DmcStreamQuery struct {
    

  67.         Command    string `json:"command"`
    

  68.         MsgId      string `json:"msg_id"`
    

  69.         DmcId      int32  `json:"dmc_id"`
    

  70.         StreamName string `json:"stream_name"`
    

  71. }
    


  72. 

  73. type DmcCommandStreamQuery struct {
    

  74.         cmdAtt CommandAttribute
    

  75. }
    


  76. 

  77. ////////////////// dmc _all_stream_update ////////////////
    

  78. type DmcAllStreamUpdate struct {
    

  79.         Command        string                          `json:"command"`
    

  80.         MsgId          string                          `json:"msg_id"`
    

  81.         DmcId          int32                           `json:"dmc_id"`
    

  82.         StreamInfoList []data_manager.StreamAttributes `json:"stream_info"`
    

  83. }
    


  84. 

  85. type DmcCommandAllStreamUpdate struct {
    

  86.         cmdAtt CommandAttribute
    

  87. }
    


  88. 

  89. ////////////////// dmc _capability_update ////////////////
    

  90. type DmcCapabilityUpdate struct {
    

  91.         Command string            `json:"command"`
    

  92.         MsgId   string            `json:"msg_id"`
    

  93.         DmcId   int32             `json:"dmc_id"`
    

  94.         Cap     Capability        `json:"capability"`
    

  95.         NCap    NetworkCapability `json:"network_capability"`
    

  96.         Ld      Load              `json:"load"`
    

  97.         NLd     NetworkLoad       `json:"network_load"`
    

  98. }
    


  99. 

  100. type DmcCommandCapabilityUpdate struct {
    

  101.         cmdAtt CommandAttribute
    

  102. }
    


  103. 

  104. //////////////////// dmc _stream_ update ////////////////
    

  105. type DmcStreamUpdate struct {
    

  106.         Command string `json:"command"`
    

  107.         MsgId   string `json:"msg_id"`
    

  108.         DmcId   int32  `json:"dmc_id"`
    

  109.         ////////////////// StreamAttributes /////////////////
    

  110.         Name       string                       `json:"stream_name"`
    

  111.         Operate    data_manager.StreamOperate   `json:"operate"`
    

  112.         Status     data_manager.StreamState     `json:"status"`
    

  113.         Attributes data_manager.StreamAttribute `json:"attributes"`
    

  114.         Type       data_manager.StreamType      `json:"type"`
    

  115.         DmsInfo    []string                     `json:"dms_info"`
    

  116. }
    


  117. 

  118. type DmcCommandStreamUpdate struct {
    

  119.         cmdAtt CommandAttribute
    

  120. }
    


  121. 

  122. //////////////////// dmc_get_dms_request ////////////////
    

  123. type DmcGetDmsRequest struct {
    

  124.         Command string `json:"command"`
    

  125.         MsgId   string `json:"msg_id"`
    

  126.         DmcId   int32  `json:"dmc_id"`
    

  127. }
    


  128. 

  129. type DmcCommandGetDmsRequest struct {
    

  130.         cmdAtt CommandAttribute
    

  131. }
    


  132. 

  133. //////////////////////////////////////////////////////////////////
    


  134. 

  135. //////////////////////////   gmc request & response   /////////////////////////////
    


  136. 

  137. type GmcRegResponse struct {
    

  138.         Command string `json:"command"`
    

  139.         MsgId   string `json:"msg_id"`
    

  140.         DmcId   int32  `json:"dmc_id"`
    

  141. }
    


  142. 

  143. type GmcResponse struct {
    

  144.         Command string `json:"command"`
    

  145.         MsgId   string `json:"msg_id"`
    

  146. }
    


  147. 

  148. type GmcStreamQueryResult struct {
    

  149.         Command    string     `json:"command"`
    

  150.         MsgId      string     `json:"msg_id"`
    

  151.         Result     string     `json:"result"`
    

  152.         StreamName string     `json:"stream_name"`
    

  153.         DmsInfo    *list.List `json:"dms_info"`
    

  154. }
    


  155. 

  156. ///////////////////////////////////////////////////////////////////////////////////
    


  157. 

  158. func (dcr *DmcCommandRegist) BuildResponse(info interface{}) (string, error) {
    


  159. 

  160.         return "abc", errors.New("cde")
    

  161. }
    


  162. 

  163. func (dcr *DmcCommandRegist) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  164.         fmt.Println("register command handle ........ ")
    

  165.         cmd := CmdInfo.(*DmcRegist)
    

  166.         fmt.Println("cmd:", cmd.Command, " msgid:", cmd.MsgId, " roomid:", cmd.RoomId)
    

  167.         dmc_instance := data_manager.GetDmcInstance()
    

  168.         dmc_id := dmc_instance.GetDmcId()
    

  169.         dmc_info := data_manager.DmcInfo{dmc_id, list.New(), list.New(), cmd.RoomId}
    

  170.         dmc_instance.AddDmcInfo(dmc_id, dmc_info)
    

  171.         gmcResponse := &GmcRegResponse{"gmc_reg_response", cmd.MsgId, dmc_id}
    


  172. 

  173.         b, err := json.Marshal(gmcResponse)
    

  174.         if err != nil {
    

  175.                 fmt.Println("encoding faild")
    

  176.                 return errors.New("encoding faild")
    

  177.         } else {
    

  178.                 fmt.Println("encoded data : ")
    

  179.                 //fmt.Println(b)
    

  180.                 fmt.Println(string(b))
    

  181.         }
    


  182. 

  183.         buf := make([]byte, len(b)+1)
    

  184.         copy(buf, b[:])
    

  185.         buf[len(b)] = 0x00
    


  186. 

  187.         fmt.Println("------------- Session write frame: ---")
    


  188. 

  189.         session.Write(buf)
    


  190. 

  191.         return nil
    

  192. }
    


  193. 

  194. func (dcr *DmcCommandRegist) GetCommandName() string {
    

  195.         return dcr.cmdAtt.CommandName
    

  196. }
    


  197. 

  198. func (dcr *DmcCommandRegist) IsProvidedResult() bool {
    

  199.         return dcr.cmdAtt.IsProvidedResult
    

  200. }
    


  201. 

  202. ///////////////////// dmc_heart_beat ////////////////////////
    


  203. 

  204. func (dcr *DmcCommandHeartBeat) BuildResponse(info interface{}) (string, error) {
    


  205. 

  206.         return "abc", errors.New("cde")
    

  207. }
    


  208. 

  209. func (dcr *DmcCommandHeartBeat) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  210.         fmt.Println("heart beat command handle ........ ")
    

  211.         return nil
    

  212. }
    


  213. 

  214. func (dcr *DmcCommandHeartBeat) GetCommandName() string {
    

  215.         return dcr.cmdAtt.CommandName
    

  216. }
    


  217. 

  218. func (dcr *DmcCommandHeartBeat) IsProvidedResult() bool {
    

  219.         return dcr.cmdAtt.IsProvidedResult
    

  220. }
    


  221. 

  222. ////////////////////// dmc_unregister //////////////////
    

  223. func (dcr *DmcCommandUnregister) BuildResponse(info interface{}) (string, error) {
    


  224. 

  225.         return "abc", errors.New("cde")
    

  226. }
    


  227. 

  228. func (dcr *DmcCommandUnregister) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  229.         fmt.Println("unregister command handle ........ ")
    

  230.         cmd := CmdInfo.(*DmcUnregister)
    

  231.         fmt.Println("cmd:", cmd.Command, " msgid:", cmd.MsgId, " dmcid:", cmd.DmcId)
    

  232.         dmc_instance := data_manager.GetDmcInstance()
    


  233. 

  234.         dmc_instance.DelDmcInfo(cmd.DmcId)
    

  235.         gmcResponse := &GmcResponse{"gmc_response", cmd.MsgId}
    


  236. 

  237.         b, err := json.Marshal(gmcResponse)
    

  238.         if err != nil {
    

  239.                 fmt.Println("encoding faild")
    

  240.                 return errors.New("encoding faild")
    

  241.         } else {
    

  242.                 fmt.Println("encoded data : ")
    

  243.                 //fmt.Println(b)
    

  244.                 fmt.Println(string(b))
    

  245.         }
    


  246. 

  247.         buf := make([]byte, len(b)+1)
    

  248.         copy(buf, b[:])
    

  249.         buf[len(b)] = 0x00
    


  250. 

  251.         fmt.Println("------------- Session write frame: ---")
    


  252. 

  253.         session.Write(buf)
    

  254.         return nil
    

  255. }
    


  256. 

  257. func (dcr *DmcCommandUnregister) GetCommandName() string {
    

  258.         return dcr.cmdAtt.CommandName
    

  259. }
    


  260. 

  261. func (dcr *DmcCommandUnregister) IsProvidedResult() bool {
    

  262.         return dcr.cmdAtt.IsProvidedResult
    

  263. }
    


  264. 

  265. ////////////////////// dmc_stream_query //////////////////
    

  266. func (dcr *DmcCommandStreamQuery) BuildResponse(info interface{}) (string, error) {
    


  267. 

  268.         return "abc", errors.New("cde")
    

  269. }
    


  270. 

  271. func (dcr *DmcCommandStreamQuery) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  272.         fmt.Println("stream query command handle ........ ")
    

  273.         cmd := CmdInfo.(*DmcStreamQuery)
    

  274.         fmt.Println("cmd:", cmd.Command, " msgid:", cmd.MsgId, " dmcid:", cmd.DmcId, "streamname:", cmd.StreamName)
    

  275.         stream_instance := data_manager.GetStreamInstance()
    

  276.         stream_info, result := stream_instance.GetStreamInfo(cmd.StreamName)
    

  277.         var queryresponse *GmcStreamQueryResult
    

  278.         if result == true {
    

  279.                 queryresponse = &GmcStreamQueryResult{"gmc_stream_query_result", cmd.MsgId, "Found", cmd.StreamName, stream_info.DmsInfo}
    

  280.         } else {
    

  281.                 queryresponse = &GmcStreamQueryResult{"gmc_stream_query_result", cmd.MsgId, "Not Found", cmd.StreamName, nil}
    

  282.         }
    


  283. 

  284.         b, err := json.Marshal(queryresponse)
    

  285.         if err != nil {
    

  286.                 fmt.Println("encoding faild")
    

  287.                 return errors.New("encoding faild")
    

  288.         } else {
    

  289.                 fmt.Println("encoded data : ")
    

  290.                 //fmt.Println(b)
    

  291.                 fmt.Println(string(b))
    

  292.         }
    


  293. 

  294.         buf := make([]byte, len(b)+1)
    

  295.         copy(buf, b[:])
    

  296.         buf[len(b)] = 0x00
    


  297. 

  298.         fmt.Println("------------- Session write frame: ---")
    


  299. 

  300.         session.Write(buf)
    

  301.         return nil
    

  302. }
    


  303. 

  304. func (dcr *DmcCommandStreamQuery) GetCommandName() string {
    

  305.         return dcr.cmdAtt.CommandName
    

  306. }
    


  307. 

  308. func (dcr *DmcCommandStreamQuery) IsProvidedResult() bool {
    

  309.         return dcr.cmdAtt.IsProvidedResult
    

  310. }
    


  311. 

  312. ////////////////// dmc_all_stream_update ////////////////
    

  313. func (dcr *DmcCommandAllStreamUpdate) BuildResponse(info interface{}) (string, error) {
    


  314. 

  315.         return "abc", errors.New("cde")
    

  316. }
    


  317. 

  318. func (dcr *DmcCommandAllStreamUpdate) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  319.         fmt.Println("all stream  update command handle ........ ")
    

  320.         cmd := CmdInfo.(*DmcAllStreamUpdate)
    

  321.         fmt.Printf("------------------ len=%d cap=%d slice=%v\n", len(cmd.StreamInfoList), cap(cmd.StreamInfoList), cmd.StreamInfoList)
    


  322. 

  323.         return nil
    

  324. }
    


  325. 

  326. func (dcr *DmcCommandAllStreamUpdate) GetCommandName() string {
    

  327.         return dcr.cmdAtt.CommandName
    

  328. }
    


  329. 

  330. func (dcr *DmcCommandAllStreamUpdate) IsProvidedResult() bool {
    

  331.         return dcr.cmdAtt.IsProvidedResult
    

  332. }
    


  333. 

  334. ////////////////// dmc_capability_update ////////////////
    

  335. func (dcr *DmcCommandCapabilityUpdate) BuildResponse(info interface{}) (string, error) {
    


  336. 

  337.         return "abc", errors.New("cde")
    

  338. }
    


  339. 

  340. func (dcr *DmcCommandCapabilityUpdate) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  341.         fmt.Println("capability  update command handle ........ ")
    

  342.         return nil
    

  343. }
    


  344. 

  345. func (dcr *DmcCommandCapabilityUpdate) GetCommandName() string {
    

  346.         return dcr.cmdAtt.CommandName
    

  347. }
    


  348. 

  349. func (dcr *DmcCommandCapabilityUpdate) IsProvidedResult() bool {
    

  350.         return dcr.cmdAtt.IsProvidedResult
    

  351. }
    


  352. 

  353. //////////////////// dmc_stream_update ////////////////
    

  354. func (dcr *DmcCommandStreamUpdate) BuildResponse(info interface{}) (string, error) {
    


  355. 

  356.         return "abc", errors.New("cde")
    

  357. }
    


  358. 

  359. func (dcr *DmcCommandStreamUpdate) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  360.         fmt.Println("stream  update command handle ........ ")
    

  361.         return nil
    

  362. }
    


  363. 

  364. func (dcr *DmcCommandStreamUpdate) GetCommandName() string {
    

  365.         return dcr.cmdAtt.CommandName
    

  366. }
    


  367. 

  368. func (dcr *DmcCommandStreamUpdate) IsProvidedResult() bool {
    

  369.         return dcr.cmdAtt.IsProvidedResult
    

  370. }
    


  371. 

  372. //////////////////// dmc_get_dms_request ////////////////
    

  373. func (dcr *DmcCommandGetDmsRequest) BuildResponse(info interface{}) (string, error) {
    


  374. 

  375.         return "abc", errors.New("cde")
    

  376. }
    


  377. 

  378. func (dcr *DmcCommandGetDmsRequest) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  379.         fmt.Println("get dms request command handle ........ ")
    

  380.         return nil
    

  381. }
    


  382. 

  383. func (dcr *DmcCommandGetDmsRequest) GetCommandName() string {
    

  384.         return dcr.cmdAtt.CommandName
    

  385. }
    


  386. 

  387. func (dcr *DmcCommandGetDmsRequest) IsProvidedResult() bool {
    

  388.         return dcr.cmdAtt.IsProvidedResult
    

  389. }
    


  390. 

  391. ////////////////////////////////////////////////// CommandDb /////////////////////////////////////////////////////////
    

  392. type CommandDb struct {
    

  393.         CommandMap  map[string]Command
    

  394.         JsonReflect *JsonReflectMap
    

  395. }
    


  396. 

  397. var commandDbInstance *CommandDb
    


  398. 

  399. func GetCommandDbInstance() *CommandDb {
    

  400.         once.Do(func() {
    

  401.                 commandDbInstance = &CommandDb{}
    

  402.                 commandDbInstance.CommandMap = make(map[string]Command)
    

  403.                 commandDbInstance.JsonReflect = Json()
    

  404.                 //////////////////////////////////////// add command /////////////////////////////////////////
    


  405. 

  406.                 /////////////////////////////////////// dmc_register /////////////////////////////
    

  407.                 commandDbInstance.JsonReflect.RegisterName("dmc_register", DmcRegist{})
    

  408.                 commandDbInstance.AddCommand(&DmcCommandRegist{cmdAtt: CommandAttribute{CommandName: "dmc_register", IsProvidedResult: false}}, "dmc_register")
    


  409. 

  410.                 ///////////////////////////////////// dmc_heart_beat /////////////////////////////
    

  411.                 commandDbInstance.JsonReflect.RegisterName("dmc_heart_beat", DmcHeartBeat{})
    

  412.                 commandDbInstance.AddCommand(&DmcCommandHeartBeat{cmdAtt: CommandAttribute{CommandName: "dmc_heart_beat", IsProvidedResult: false}}, "dmc_heart_beat")
    


  413. 

  414.                 ///////////////////////////////////// dmc_unregister /////////////////////////////
    

  415.                 commandDbInstance.JsonReflect.RegisterName("dmc_unregister", DmcUnregister{})
    

  416.                 commandDbInstance.AddCommand(&DmcCommandUnregister{cmdAtt: CommandAttribute{CommandName: "dmc_unregister", IsProvidedResult: false}}, "dmc_unregister")
    


  417. 

  418.                 ///////////////////////////////////// dmc_stream_query /////////////////////////////
    

  419.                 commandDbInstance.JsonReflect.RegisterName("dmc_stream_query", DmcStreamQuery{})
    

  420.                 commandDbInstance.AddCommand(&DmcCommandStreamQuery{cmdAtt: CommandAttribute{CommandName: "dmc_stream_query", IsProvidedResult: false}}, "dmc_stream_query")
    


  421. 

  422.                 ///////////////////////////////////// dmc_all_stream_update /////////////////////////////
    

  423.                 commandDbInstance.JsonReflect.RegisterName("dmc_all_stream_update", DmcAllStreamUpdate{})
    

  424.                 commandDbInstance.AddCommand(&DmcCommandAllStreamUpdate{cmdAtt: CommandAttribute{CommandName: "dmc_all_stream_update", IsProvidedResult: false}}, "dmc_all_stream_update")
    


  425. 

  426.                 ///////////////////////////////////// dmc_capability_update /////////////////////////////
    

  427.                 commandDbInstance.JsonReflect.RegisterName("dmc_capability_update", DmcCapabilityUpdate{})
    

  428.                 commandDbInstance.AddCommand(&DmcCommandCapabilityUpdate{cmdAtt: CommandAttribute{CommandName: "dmc_capability_update", IsProvidedResult: false}}, "dmc_capability_update")
    


  429. 

  430.                 ///////////////////////////////////// dmc_stream_update /////////////////////////////
    

  431.                 commandDbInstance.JsonReflect.RegisterName("dmc_stream_update", DmcStreamUpdate{})
    

  432.                 commandDbInstance.AddCommand(&DmcCommandStreamUpdate{cmdAtt: CommandAttribute{CommandName: "dmc_stream_update", IsProvidedResult: false}}, "dmc_stream_update")
    


  433. 

  434.                 ///////////////////////////////////// dmc_get_dms_request /////////////////////////////
    

  435.                 commandDbInstance.JsonReflect.RegisterName("dmc_get_dms_request", DmcGetDmsRequest{})
    

  436.                 commandDbInstance.AddCommand(&DmcCommandGetDmsRequest{cmdAtt: CommandAttribute{CommandName: "dmc_get_dms_request", IsProvidedResult: true}}, "dmc_get_dms_request")
    


  437. 

  438.         })
    

  439.         return commandDbInstance
    

  440. }
    


  441. 

  442. func (cdb *CommandDb) AddCommand(cmd Command, cmdName string) {
    

  443.         cdb.CommandMap[cmdName] = cmd
    

  444. }
    


  445. 

  446. func (cdb *CommandDb) GetCommand(name string) (Command, error) {
    


  447. 

  448.         if cdb.CommandMap[name] != nil {
    

  449.                 return cdb.CommandMap[name], nil
    

  450.         }
    


  451. 

  452.         err := errors.New("This command is not exist!")
    


  453. 

  454.         return nil, err
    

  455. }


回复

收藏1 举报

dong_abc 发表于 2016-12-3 16:40 | 显示全部楼层
其实go语言应用很普遍。
回复

收藏1 举报

dong_abc 发表于 2016-12-4 00:01 | 显示全部楼层
我觉得楼主没必要在这里讨论这个，你想把梳子卖给和尚，这很励志，但没什么意义！
回复

收藏1 举报

 楼主| keer_zu 发表于 2016-12-5 08:23 | 显示全部楼层
dong_abc 发表于 2016-12-4 00:01
我觉得楼主没必要在这里讨论这个，你想把梳子卖给和尚，这很励志，但没什么意义！ ...

回复

收藏1 举报

 楼主| keer_zu 发表于 2016-12-5 08:23 | 显示全部楼层
dong_abc 发表于 2016-12-3 16:40
其实go语言应用很普遍。

是的
回复

收藏1 举报

 楼主| keer_zu 发表于 2016-12-5 16:05 | 显示全部楼层
继续完善  command.go
Part 1:

复制
  1. package message
    


  2. 

  3. import (
    

  4.         "container/list"
    

  5.         "data_manager"
    

  6.         "encoding/json"
    

  7.         "errors"
    

  8.         "fmt"
    

  9.         "sync"
    


  10. 

  11.         "github.com/pojoin/golis"
    

  12. )
    


  13. 

  14. var once sync.Once
    


  15. 

  16. type CommandProperty int
    


  17. 

  18. type Command interface {
    

  19.         //BuildResponse(info interface{}) (string, error)
    

  20.         CommandHandle(session *golis.Iosession, CmdInfo interface{}) error
    

  21.         GetCommandName() string
    

  22.         IsProvidedResult() bool
    

  23. }
    


  24. 

  25. type CommandAttribute struct {
    

  26.         CommandName      string
    

  27.         IsProvidedResult bool //CommandProperty
    

  28. }
    


  29. 

  30. ////////////////////////////dmc  command ////////////////////////////
    

  31. ////////////////////// dmc_register  /////////////////////
    

  32. type DmcRegist struct {
    

  33.         Command string `json:"command"`
    

  34.         MsgId   string `json:"msg_id"`
    

  35.         RoomId  int32  `json:"room_id"`
    

  36. }
    


  37. 

  38. type DmcCommandRegist struct {
    

  39.         cmdAtt CommandAttribute
    

  40. }
    


  41. 

  42. //////////////////////  dmc_heart_beat  //////////////////
    

  43. type DmcHeartBeat struct {
    

  44.         Command string `json:"command"`
    

  45.         MsgId   string `json:"msg_id"`
    

  46.         DmcId   int32  `json:"dmc_id"`
    

  47. }
    


  48. 

  49. type DmcCommandHeartBeat struct {
    

  50.         cmdAtt CommandAttribute
    

  51. }
    


  52. 

  53. ////////////////////// dmc_unregister //////////////////
    


  54. 

  55. type DmcUnregister struct {
    

  56.         Command string `json:"command"`
    

  57.         MsgId   string `json:"msg_id"`
    

  58.         DmcId   int32  `json:"dmc_id"`
    

  59. }
    


  60. 

  61. type DmcCommandUnregister struct {
    

  62.         cmdAtt CommandAttribute
    

  63. }
    


  64. 

  65. ////////////////////// dmc_stream_query //////////////////
    

  66. type DmcStreamQuery struct {
    

  67.         Command    string `json:"command"`
    

  68.         MsgId      string `json:"msg_id"`
    

  69.         DmcId      int32  `json:"dmc_id"`
    

  70.         StreamName string `json:"stream_name"`
    

  71. }
    


  72. 

  73. type DmcCommandStreamQuery struct {
    

  74.         cmdAtt CommandAttribute
    

  75. }
    


  76. 

  77. ////////////////// dmc _all_stream_update ////////////////
    

  78. type DmcAllStreamUpdate struct {
    

  79.         Command        string                          `json:"command"`
    

  80.         MsgId          string                          `json:"msg_id"`
    

  81.         DmcId          int32                           `json:"dmc_id"`
    

  82.         StreamInfoList []data_manager.StreamAttributes `json:"stream_info"`
    

  83. }
    


  84. 

  85. type DmcCommandAllStreamUpdate struct {
    

  86.         cmdAtt CommandAttribute
    

  87. }
    


  88. 

  89. ////////////////// dmc _capability_update ////////////////
    

  90. type DmcCapabilityUpdate struct {
    

  91.         Command string            `json:"command"`
    

  92.         MsgId   string            `json:"msg_id"`
    

  93.         DmcId   int32             `json:"dmc_id"`
    

  94.         Cap     Capability        `json:"capability"`
    

  95.         NCap    NetworkCapability `json:"network_capability"`
    

  96.         Ld      Load              `json:"load"`
    

  97.         NLd     NetworkLoad       `json:"network_load"`
    

  98. }
    


  99. 

  100. type DmcCommandCapabilityUpdate struct {
    

  101.         cmdAtt CommandAttribute
    

  102. }
    


  103. 

  104. //////////////////// dmc _stream_ update ////////////////
    

  105. type DmcStreamUpdate struct {
    

  106.         Command string `json:"command"`
    

  107.         MsgId   string `json:"msg_id"`
    

  108.         DmcId   int32  `json:"dmc_id"`
    

  109.         ////////////////// StreamAttributes /////////////////
    

  110.         Operate    data_manager.StreamOperate   `json:"operate"`
    

  111.         Name       string                       `json:"stream_name"`
    

  112.         Status     data_manager.StreamState     `json:"status"`
    

  113.         Attributes data_manager.StreamAttribute `json:"attributes"`
    

  114.         Type       data_manager.StreamType      `json:"type"`
    

  115.         DmsInfo    []string                     `json:"dms_info"`
    

  116. }
    


  117. 

  118. type DmcCommandStreamUpdate struct {
    

  119.         cmdAtt CommandAttribute
    

  120. }
    


  121. 

  122. //////////////////// dmc_get_dms_request ////////////////
    

  123. type DmcGetDmsRequest struct {
    

  124.         Command string                  `json:"command"`
    

  125.         MsgId   string                  `json:"msg_id"`
    

  126.         DmcId   int32                   `json:"dmc_id"`
    

  127.         Type    data_manager.StreamType `json:"type"`
    

  128. }
    


  129. 

  130. type DmcCommandGetDmsRequest struct {
    

  131.         cmdAtt CommandAttribute
    

  132. }
    


  133. 

  134. ////////// dmc_get_dms_response /////////////
    

  135. type DmcGetDmsResponse struct {
    

  136.         Command string   `json:"command"`
    

  137.         MsgId   string   `json:"msg_id"`
    

  138.         DmcId   int32    `json:"dmc_id"`
    

  139.         DmsInfo []string `json:"dms_info"`
    

  140. }
    


  141. 

  142. type DmcCommandGetDmsResponse struct {
    

  143.         cmdAtt CommandAttribute
    

  144. }
    


  145. 

  146. //////////////////////////////////////////////////////////////////
    


  147. 

  148. //////////////////////////   gmc request & response   /////////////////////////////
    


  149. 

  150. func AddFrameTail(input []byte) []byte {
    

  151.         buf := make([]byte, len(input)+1)
    

  152.         copy(buf, input[:])
    

  153.         buf[len(input)] = 0x00
    


  154. 

  155.         return buf
    

  156. }
    


  157. 

  158. func JsonMarshal(msgStruct interface{}) ([]byte, error) {
    

  159.         b, err := json.Marshal(msgStruct)
    

  160.         if err != nil {
    

  161.                 fmt.Println("encoding faild")
    

  162.                 return nil, errors.New("encoding faild")
    

  163.         } else {
    

  164.                 fmt.Println("encoded data : ")
    

  165.                 //fmt.Println(b)
    

  166.                 fmt.Println(string(b))
    

  167.         }
    


  168. 

  169.         return b, err
    

  170. }
    


  171. 

  172. type GmcMessage interface {
    

  173.         BuildMessage() ([]byte, error)
    

  174. }
    


  175. 

  176. /////// gmc_reg_response ///////
    

  177. type GmcRegResponse struct {
    

  178.         Command string `json:"command"`
    

  179.         MsgId   string `json:"msg_id"`
    

  180.         DmcId   int32  `json:"dmc_id"`
    

  181. }
    


  182. 

  183. func (gm *GmcRegResponse) BuildMessage() ([]byte, error) {
    


  184. 

  185.         //gmcRegResponse := &GmcRegResponse{"gmc_reg_response", gm.MsgId, gm.DmcId}
    


  186. 

  187.         b, err := JsonMarshal(*gm)
    

  188.         if b == nil {
    

  189.                 return b, err
    


  190. 

  191.         }
    


  192. 

  193.         buf := AddFrameTail(b)
    


  194. 

  195.         return buf, nil
    

  196. }
    


  197. 

  198. /////// gmc_response ///////
    

  199. type GmcResponse struct {
    

  200.         Command string `json:"command"`
    

  201.         MsgId   string `json:"msg_id"`
    

  202. }
    


  203. 

  204. func (gm *GmcResponse) BuildMessage() ([]byte, error) {
    

  205.         //gmcResponse := &GmcResponse{"gmc_response", gm.MsgId}
    


  206. 

  207.         b, err := JsonMarshal(*gm)
    

  208.         if b == nil {
    

  209.                 return b, err
    


  210. 

  211.         }
    


  212. 

  213.         buf := AddFrameTail(b)
    


  214. 

  215.         return buf, nil
    

  216. }
    


  217. 

  218. /////// gmc_stream_query_result ///////
    


  219. 

  220. type GmcStreamQueryResult struct {
    

  221.         Command    string     `json:"command"`
    

  222.         MsgId      string     `json:"msg_id"`
    

  223.         Result     string     `json:"result"`
    

  224.         StreamName string     `json:"stream_name"`
    

  225.         DmsInfo    *list.List `json:"dms_info"`
    

  226. }
    


  227. 

  228. func (gm *GmcStreamQueryResult) BuildMessage() ([]byte, error) {
    


  229. 

  230.         b, err := JsonMarshal(*gm)
    

  231.         if b == nil {
    

  232.                 return b, err
    


  233. 

  234.         }
    


  235. 

  236.         buf := AddFrameTail(b)
    


  237. 

  238.         return buf, nil
    

  239. }
    


  240. 

  241. //////// gmc_get_dms_request //////////
    


  242. 

  243. type GmcGetDmsRequest struct {
    

  244.         Command string `json:"command"`
    

  245.         MsgId   string `json:"msg_id"`
    

  246. }
    


  247. 

  248. func (gm *GmcGetDmsRequest) BuildMessage() ([]byte, error) {
    

  249.         //gmcResponse := &GmcGetDmsRequest{"gmc_get_dms_request", gm.MsgId}
    


  250. 

  251.         b, err := JsonMarshal(*gm)
    

  252.         if b == nil {
    

  253.                 return b, err
    


  254. 

  255.         }
    


  256. 

  257.         buf := AddFrameTail(b)
    


  258. 

  259.         return buf, nil
    

  260. }
    


  261. 

  262. /////////// gmc_get_dms_response /////////
    

  263. type GmcGetDmsResponse struct {
    

  264.         Command string   `json:"command"`
    

  265.         MsgId   string   `json:"msg_id"`
    

  266.         DmcId   int32    `json:"dmc_id"`
    

  267.         DmsInfo []string `json:"dms_info"`
    

  268. }
    


  269. 

  270. func (gm *GmcGetDmsResponse) BuildMessage() ([]byte, error) {
    


  271. 

  272.         b, err := JsonMarshal(*gm)
    

  273.         if b == nil {
    

  274.                 return b, err
    


  275. 

  276.         }
    


  277. 

  278.         buf := AddFrameTail(b)
    


  279. 

  280.         return buf, nil
    

  281. }
    


  282. 

  283. /////// gmc_stream_published_notify //////
    


  284. 

  285. type GmcStreamPublishedNotify struct {
    

  286.         Command    string   `json:"command"`
    

  287.         MsgId      string   `json:"msg_id"`
    

  288.         StreamName string   `json:"stream_name"`
    

  289.         DmsInfo    []string `json:"dms_info"`
    

  290. }
    


  291. 

  292. func (gm *GmcStreamPublishedNotify) BuildMessage() ([]byte, error) {
    


  293. 

  294.         b, err := JsonMarshal(*gm)
    

  295.         if b == nil {
    

  296.                 return b, err
    


  297. 

  298.         }
    


  299. 

  300.         buf := AddFrameTail(b)
    


  301. 

  302.         return buf, nil
    

  303. }
    


  304. 

  305. /////////// func BuildGmcMessage ////////////
    

  306. func BuildGmcMessage(gmcMsg GmcMessage) ([]byte, error) {
    


  307. 

  308.         msg, err := gmcMsg.BuildMessage()
    

  309.         if err != nil {
    

  310.                 return nil, err
    

  311.         }
    

  312.         return msg, nil
    

  313. }
    


  314. 

  315. ///////////////////////////////////////////////////////////////////////////////////
    


  316. 

  317. func (dcr *DmcCommandRegist) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  318.         fmt.Println("register command handle ........ ")
    

  319.         cmd := CmdInfo.(*DmcRegist)
    


  320. 

  321.         fmt.Println("cmd:", cmd.Command, " msgid:", cmd.MsgId, " roomid:", cmd.RoomId)
    

  322.         dmc_instance := data_manager.GetDmcInstance()
    

  323.         dmc_id := dmc_instance.GetDmcId()
    


  324. 

  325.         dmc_info := data_manager.DmcInfo{dmc_id, list.New(), list.New(), cmd.RoomId, session}
    

  326.         dmc_instance.AddDmcInfo(dmc_id, dmc_info)
    


  327. 

  328.         gmcResponse := &GmcRegResponse{"gmc_reg_response", cmd.MsgId, dmc_id}
    


  329. 

  330.         buf, err := BuildGmcMessage(gmcResponse)
    

  331.         if err != nil {
    

  332.                 return err
    

  333.         }
    

  334.         fmt.Println("------------- Session write frame: ---")
    


  335. 

  336.         session.Write(buf)
    


  337. 

  338.         return nil
    

  339. }
    


  340. 

  341. func (dcr *DmcCommandRegist) GetCommandName() string {
    

  342.         return dcr.cmdAtt.CommandName
    

  343. }
    


  344. 

  345. func (dcr *DmcCommandRegist) IsProvidedResult() bool {
    

  346.         return dcr.cmdAtt.IsProvidedResult
    

  347. }
    


  348. 

  349. ///////////////////// dmc_heart_beat ////////////////////////
    


  350. 

  351. func (dcr *DmcCommandHeartBeat) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  352.         fmt.Println("heart beat command handle ........ ")
    

  353.         cmd := CmdInfo.(*DmcHeartBeat)
    

  354.         fmt.Println("cmd:", cmd.Command, " msgid:", cmd.MsgId, " dmcid:", cmd.DmcId)
    


  355. 

  356.         return nil
    

  357. }
    


  358. 

  359. func (dcr *DmcCommandHeartBeat) GetCommandName() string {
    

  360.         return dcr.cmdAtt.CommandName
    

  361. }
    


  362. 

  363. func (dcr *DmcCommandHeartBeat) IsProvidedResult() bool {
    

  364.         return dcr.cmdAtt.IsProvidedResult
    

  365. }
    


  366. 

  367. ////////////////////// dmc_unregister //////////////////
    


  368. 

  369. func (dcr *DmcCommandUnregister) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  370.         fmt.Println("unregister command handle ........ ")
    

  371.         cmd := CmdInfo.(*DmcUnregister)
    

  372.         fmt.Println("cmd:", cmd.Command, " msgid:", cmd.MsgId, " dmcid:", cmd.DmcId)
    

  373.         dmc_instance := data_manager.GetDmcInstance()
    


  374. 

  375.         dmc_instance.DelDmcInfo(cmd.DmcId)
    

  376.         gmcResponse := &GmcResponse{"gmc_response", cmd.MsgId}
    


  377. 

  378.         buf, err := BuildGmcMessage(gmcResponse)
    

  379.         if err != nil {
    

  380.                 return err
    

  381.         }
    

  382.         fmt.Println("------------- Session write frame: ---")
    


  383. 

  384.         session.Write(buf)
    

  385.         return nil
    

  386. }
    


  387. 

  388. func (dcr *DmcCommandUnregister) GetCommandName() string {
    

  389.         return dcr.cmdAtt.CommandName
    

  390. }
    


  391. 

  392. func (dcr *DmcCommandUnregister) IsProvidedResult() bool {
    

  393.         return dcr.cmdAtt.IsProvidedResult
    

  394. }
    


  395. 

  396. ////////////////////// dmc_stream_query //////////////////
    


  397. 

  398. func (dcr *DmcCommandStreamQuery) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  399.         fmt.Println("stream query command handle ........ ")
    

  400.         cmd := CmdInfo.(*DmcStreamQuery)
    

  401.         fmt.Println("cmd:", cmd.Command, " msgid:", cmd.MsgId, " dmcid:", cmd.DmcId, "streamname:", cmd.StreamName)
    

  402.         stream_instance := data_manager.GetStreamInstance()
    

  403.         stream_info, result := stream_instance.GetStreamInfo(cmd.StreamName)
    

  404.         var queryresponse *GmcStreamQueryResult
    

  405.         if result == true {
    

  406.                 queryresponse = &GmcStreamQueryResult{"gmc_stream_query_result", cmd.MsgId, "Found", cmd.StreamName, stream_info.DmsInfo}
    

  407.         } else {
    

  408.                 queryresponse = &GmcStreamQueryResult{"gmc_stream_query_result", cmd.MsgId, "Not Found", cmd.StreamName, nil}
    

  409.         }
    


  410. 

  411.         b, err := json.Marshal(queryresponse)
    

  412.         if err != nil {
    

  413.                 fmt.Println("encoding faild")
    

  414.                 return errors.New("encoding faild")
    

  415.         } else {
    

  416.                 fmt.Println("encoded data : ")
    

  417.                 //fmt.Println(b)
    

  418.                 fmt.Println(string(b))
    

  419.         }
    


  420. 

  421.         buf := make([]byte, len(b)+1)
    

  422.         copy(buf, b[:])
    

  423.         buf[len(b)] = 0x00
    


  424. 

  425.         fmt.Println("------------- Session write frame: ---")
    


  426. 

  427.         session.Write(buf)
    

  428.         return nil
    

  429. }
    


  430. 

  431. func (dcr *DmcCommandStreamQuery) GetCommandName() string {
    

  432.         return dcr.cmdAtt.CommandName
    

  433. }
    


  434. 

  435. func (dcr *DmcCommandStreamQuery) IsProvidedResult() bool {
    

  436.         return dcr.cmdAtt.IsProvidedResult
    

  437. }
    


  438. 

  439. ////////////////// dmc_all_stream_update ////////////////
    


  440. 

  441. func (dcr *DmcCommandAllStreamUpdate) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  442.         fmt.Println("all stream  update command handle ........ ")
    

  443.         cmd := CmdInfo.(*DmcAllStreamUpdate)
    

  444.         fmt.Printf("------------------ len=%d cap=%d slice=%v\n", len(cmd.StreamInfoList), cap(cmd.StreamInfoList), cmd.StreamInfoList)
    

  445.         fmt.Println("cmd:", cmd.Command, " dmc id:", cmd.DmcId, " msg id:", cmd.MsgId)
    

  446.         stream_instance := data_manager.GetStreamInstance()
    

  447.         stream_lst := cmd.StreamInfoList
    

  448.         for _, stream_info := range stream_lst {
    

  449.                 temp_stream_info := data_manager.NewStreamInfo(stream_info.Name, cmd.DmcId, stream_info.State, stream_info.Attributes, stream_info.Type, list.New())
    

  450.                 stream_instance.AddStreamInfo(stream_info.Name, temp_stream_info)
    

  451.         }
    


  452. 

  453.         gmcResponse := &GmcResponse{"gmc_response", cmd.MsgId}
    


  454. 

  455.         buf, err := BuildGmcMessage(gmcResponse)
    

  456.         if err != nil {
    

  457.                 return err
    

  458.         }
    

  459.         fmt.Println("------------- Session write frame: ---")
    


  460. 

  461.         session.Write(buf)
    

  462.         return nil
    

  463. }
    


  464. 

  465. func (dcr *DmcCommandAllStreamUpdate) GetCommandName() string {
    

  466.         return dcr.cmdAtt.CommandName
    

  467. }
    


  468. 

  469. func (dcr *DmcCommandAllStreamUpdate) IsProvidedResult() bool {
    

  470.         return dcr.cmdAtt.IsProvidedResult
    

  471. }
    


  472. 

  473. ////////////////// dmc_capability_update ////////////////
    


  474. 

  475. func (dcr *DmcCommandCapabilityUpdate) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  476.         fmt.Println("capability  update command handle ........ ")
    

  477.         cmd := CmdInfo.(*DmcCapabilityUpdate)
    

  478.         fmt.Println("cmd:", cmd.Command, " msgid:", cmd.MsgId, " dmcid:", cmd.DmcId, " cap item:", cmd.Cap.Item, " ld item", cmd.Ld.Item, " nld item:", cmd.NLd.Item)
    


  479. 

  480.         return nil
    

  481. }
    


  482. 

  483. func (dcr *DmcCommandCapabilityUpdate) GetCommandName() string {
    

  484.         return dcr.cmdAtt.CommandName
    

  485. }
    


  486. 

  487. func (dcr *DmcCommandCapabilityUpdate) IsProvidedResult() bool {
    

  488.         return dcr.cmdAtt.IsProvidedResult
    

  489. }
    


  490. 

  491. //////////////////// dmc_stream_update ////////////////
    


  492. 

  493. func (dcr *DmcCommandStreamUpdate) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  494.         fmt.Println("stream  update command handle ........ ")
    

  495.         cmd := CmdInfo.(*DmcStreamUpdate)
    

  496.         fmt.Println(" cmd:", cmd.Command, " dmc id:", cmd.DmcId, " msg id:", cmd.MsgId, " stream name:", cmd.Name)
    

  497.         stream_instance := data_manager.GetStreamInstance()
    

  498.         if cmd.Operate == data_manager.ADDStream {
    

  499.                 temp_stream_info := data_manager.NewStreamInfo(cmd.Name, cmd.DmcId, cmd.Status, cmd.Attributes, cmd.Type, list.New())
    

  500.                 stream_instance.AddStreamInfo(cmd.Name, temp_stream_info)
    

  501.         } else if cmd.Operate == data_manager.DELStream {
    

  502.                 stream_instance.DelStreamInfo(cmd.Name)
    


  503. 

  504.         } else {
    

  505.                 temp_stream_info := data_manager.NewStreamInfo(cmd.Name, cmd.DmcId, cmd.Status, cmd.Attributes, cmd.Type, list.New())
    

  506.                 stream_instance.ModStreamInfo(cmd.Name, temp_stream_info)
    

  507.         }
    


  508. 

  509.         gmcResponse := &GmcResponse{"gmc_response", cmd.MsgId}
    


  510. 

  511.         buf, err := BuildGmcMessage(gmcResponse)
    

  512.         if err != nil {
    

  513.                 return err
    

  514.         }
    

  515.         fmt.Println("------------- Session write frame: ---")
    


  516. 

  517.         session.Write(buf)
    


  518. 

  519.         return nil
    

  520. }
    


  521. 

  522. func (dcr *DmcCommandStreamUpdate) GetCommandName() string {
    

  523.         return dcr.cmdAtt.CommandName
    

  524. }
    


  525. 

  526. func (dcr *DmcCommandStreamUpdate) IsProvidedResult() bool {
    

  527.         return dcr.cmdAtt.IsProvidedResult
    

  528. }
    


  529. 

  530. //////////////////// dmc_get_dms_request ////////////////
    


  531. 

  532. func (dcr *DmcCommandGetDmsRequest) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  533.         fmt.Println("get dms request command handle ........ ")
    

  534.         cmd := CmdInfo.(*DmcGetDmsRequest)
    

  535.         fmt.Println(" cmd:", cmd.Command, " msg id:", cmd.MsgId, " dmc id:", cmd.DmcId)
    


  536. 

  537.         dmcManager := data_manager.GetDmcInstance()
    

  538.         dmc, err1 := dmcManager.GetDmc(data_manager.GET_A_USEFUL_DMS)
    

  539.         if err1 != nil {
    

  540.                 return errors.New("source dmc session is nil")
    

  541.         }
    


  542. 

  543.         session_source_dmc := dmc.Session
    


  544. 

  545.         gmcGetDmsRequest := &GmcGetDmsRequest{"gmc_get_dms_request", cmd.MsgId}
    

  546.         buf, err := BuildGmcMessage(gmcGetDmsRequest)
    

  547.         if err != nil {
    

  548.                 return err
    

  549.         }
    

  550.         fmt.Println("------------- Session write gmcGetDmsRequest frame: ---")
    


  551. 

  552.         session_source_dmc.Write(buf)
    


  553. 

  554.         return nil
    

  555. }
    


  556. 

  557. func (dcr *DmcCommandGetDmsRequest) GetCommandName() string {
    

  558.         return dcr.cmdAtt.CommandName
    

  559. }
    


  560. 

  561. func (dcr *DmcCommandGetDmsRequest) IsProvidedResult() bool {
    

  562.         return dcr.cmdAtt.IsProvidedResult
    

  563. }
    


  564. 


  565.
回复

收藏1 举报

 楼主| keer_zu 发表于 2016-12-5 16:06 | 显示全部楼层
继续完善 command.go

Part 2:
复制
  1. ////////// dmc_get_dms_response /////////////
    


  2. 

  3. func (dcr *DmcCommandGetDmsResponse) CommandHandle(session *golis.Iosession, CmdInfo interface{}) error {
    

  4.         fmt.Println("get DmcGetDmsResponse  command handle ........ ")
    

  5.         cmd := CmdInfo.(*DmcGetDmsResponse)
    

  6.         fmt.Println(" cmd:", cmd.Command, " msg id:", cmd.MsgId, " dmc id:", cmd.DmcId)
    


  7. 

  8.         taskPool := GetTaskPoolInstance()
    


  9. 

  10.         defer taskPool.Del(cmd.MsgId)
    


  11. 

  12.         taskInfo, ok := taskPool.GetTaskInfo(cmd.MsgId)
    

  13.         if !ok {
    

  14.                 return errors.New("can not fand this task!")
    

  15.         }
    


  16. 

  17.         gmcGetDmsReponse := &GmcGetDmsResponse{"gmc_get_dms_response", cmd.MsgId, cmd.DmcId, cmd.DmsInfo}
    

  18.         buf, err := BuildGmcMessage(gmcGetDmsReponse)
    

  19.         if err != nil {
    

  20.                 return err
    

  21.         }
    

  22.         fmt.Println("------------- Session write GmcGetDmsResponse frame: ---")
    


  23. 

  24.         session_dms_request := taskInfo.Session
    

  25.         session_dms_request.Write(buf)
    


  26. 

  27.         return nil
    

  28. }
    


  29. 

  30. func (dcr *DmcCommandGetDmsResponse) GetCommandName() string {
    

  31.         return dcr.cmdAtt.CommandName
    

  32. }
    


  33. 

  34. func (dcr *DmcCommandGetDmsResponse) IsProvidedResult() bool {
    

  35.         return dcr.cmdAtt.IsProvidedResult
    

  36. }
    


  37. 

  38. ////////////////////////////////////////////////// CommandDb /////////////////////////////////////////////////////////
    

  39. type CommandDb struct {
    

  40.         CommandMap  map[string]Command
    

  41.         JsonReflect *JsonReflectMap
    

  42. }
    


  43. 

  44. var commandDbInstance *CommandDb
    


  45. 

  46. func GetCommandDbInstance() *CommandDb {
    

  47.         once.Do(func() {
    

  48.                 commandDbInstance = &CommandDb{}
    

  49.                 commandDbInstance.CommandMap = make(map[string]Command)
    

  50.                 commandDbInstance.JsonReflect = Json()
    

  51.                 //////////////////////////////////////// add command /////////////////////////////////////////
    


  52. 

  53.                 /////////////////////////////////////// dmc_register /////////////////////////////
    

  54.                 commandDbInstance.JsonReflect.RegisterName("dmc_register", DmcRegist{})
    

  55.                 commandDbInstance.AddCommand(&DmcCommandRegist{cmdAtt: CommandAttribute{CommandName: "dmc_register", IsProvidedResult: false}}, "dmc_register")
    


  56. 

  57.                 ///////////////////////////////////// dmc_heart_beat /////////////////////////////
    

  58.                 commandDbInstance.JsonReflect.RegisterName("dmc_heart_beat", DmcHeartBeat{})
    

  59.                 commandDbInstance.AddCommand(&DmcCommandHeartBeat{cmdAtt: CommandAttribute{CommandName: "dmc_heart_beat", IsProvidedResult: false}}, "dmc_heart_beat")
    


  60. 

  61.                 ///////////////////////////////////// dmc_unregister /////////////////////////////
    

  62.                 commandDbInstance.JsonReflect.RegisterName("dmc_unregister", DmcUnregister{})
    

  63.                 commandDbInstance.AddCommand(&DmcCommandUnregister{cmdAtt: CommandAttribute{CommandName: "dmc_unregister", IsProvidedResult: false}}, "dmc_unregister")
    


  64. 

  65.                 ///////////////////////////////////// dmc_stream_query /////////////////////////////
    

  66.                 commandDbInstance.JsonReflect.RegisterName("dmc_stream_query", DmcStreamQuery{})
    

  67.                 commandDbInstance.AddCommand(&DmcCommandStreamQuery{cmdAtt: CommandAttribute{CommandName: "dmc_stream_query", IsProvidedResult: false}}, "dmc_stream_query")
    


  68. 

  69.                 ///////////////////////////////////// dmc_all_stream_update /////////////////////////////
    

  70.                 commandDbInstance.JsonReflect.RegisterName("dmc_all_stream_update", DmcAllStreamUpdate{})
    

  71.                 commandDbInstance.AddCommand(&DmcCommandAllStreamUpdate{cmdAtt: CommandAttribute{CommandName: "dmc_all_stream_update", IsProvidedResult: false}}, "dmc_all_stream_update")
    


  72. 

  73.                 ///////////////////////////////////// dmc_capability_update /////////////////////////////
    

  74.                 commandDbInstance.JsonReflect.RegisterName("dmc_capability_update", DmcCapabilityUpdate{})
    

  75.                 commandDbInstance.AddCommand(&DmcCommandCapabilityUpdate{cmdAtt: CommandAttribute{CommandName: "dmc_capability_update", IsProvidedResult: false}}, "dmc_capability_update")
    


  76. 

  77.                 ///////////////////////////////////// dmc_stream_update /////////////////////////////
    

  78.                 commandDbInstance.JsonReflect.RegisterName("dmc_stream_update", DmcStreamUpdate{})
    

  79.                 commandDbInstance.AddCommand(&DmcCommandStreamUpdate{cmdAtt: CommandAttribute{CommandName: "dmc_stream_update", IsProvidedResult: false}}, "dmc_stream_update")
    


  80. 

  81.                 ///////////////////////////////////// dmc_get_dms_request /////////////////////////////
    

  82.                 commandDbInstance.JsonReflect.RegisterName("dmc_get_dms_request", DmcGetDmsRequest{})
    

  83.                 commandDbInstance.AddCommand(&DmcCommandGetDmsRequest{cmdAtt: CommandAttribute{CommandName: "dmc_get_dms_request", IsProvidedResult: true}}, "dmc_get_dms_request")
    


  84. 

  85.                 ///////////////////////////////////// dmc_get_dms_response ////////////////////////////
    

  86.                 commandDbInstance.JsonReflect.RegisterName("dmc_get_dms_response", DmcGetDmsResponse{})
    

  87.                 commandDbInstance.AddCommand(&DmcCommandGetDmsResponse{cmdAtt: CommandAttribute{CommandName: "dmc_get_dms_response", IsProvidedResult: false}}, "dmc_get_dms_response")
    

  88.         })
    

  89.         return commandDbInstance
    

  90. }
    


  91. 

  92. func (cdb *CommandDb) AddCommand(cmd Command, cmdName string) {
    

  93.         cdb.CommandMap[cmdName] = cmd
    

  94. }
    


  95. 

  96. func (cdb *CommandDb) GetCommand(name string) (Command, error) {
    


  97. 

  98.         if cdb.CommandMap[name] != nil {
    

  99.                 return cdb.CommandMap[name], nil
    

  100.         }
    


  101. 

  102.         err := errors.New("This command is not exist!")
    


  103. 

  104.         return nil, err
    

  105. }
回复

收藏1 举报

下一页 »
123下一页
返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则

keer_zu

1488

主题

12953

帖子

55

粉丝
快速回复 在线客服 返回列表 返回顶部