zoukankan      html  css  js  c++  java
  • IM后端项目 Golang实现

    架构图示(截选IM部分)

    项目源代码示例

    调试示例(截选)

    示例一:消息存储调试

    示例二:gorpc消息调试代码

    package main
    
    import (
        "fmt"
        "github.com/valyala/gorpc"
        "time"
    )
    
    var server_summary *ServerSummary
    var storage *Storage
    var appid int64 = 0
    var device_id int64 = 0
    var master *Master
    var config *StorageConfig
    
    func main() {
        d := gorpc.NewDispatcher()
        d.AddFunc("SyncMessage", SyncMessage)
        d.AddFunc("SyncGroupMessage", SyncGroupMessage)
        d.AddFunc("SavePeerMessage", SavePeerMessage)
        c := gorpc.NewTCPClient("127.0.0.1:13333") //ims地址
        c.Start()
        defer c.Stop()
        dc := d.NewFuncClient(c)
    
        //-----------------测试核心代码/-----------------
        /*
            功能说明:模拟对IMS进行RPC调用,方法SavePeerMessage
            主要用作IMS端的调试
            需要注意:IMMessage,Message,PeerMessage三者的区别
        */
    
        im := &IMMessage{sender: 1, receiver: 1000, timestamp: int32(time.Now().Unix()), msgid: 5, content: "hello"}
        m := &Message{cmd: MSG_IM, seq: 5, version: 2, flag: 0, body: im}
    
        r, err := dc.Call("SavePeerMessage", &PeerMessage{
            0,
            1000,
            0,
            4,
            m.ToData(),
        })
        if err != nil {
            fmt.Println("调用错误")
        } else {
            fmt.Println(r)
        }
    }

    消息体定义

  • 相关阅读:
    SPOJ 149 FSHEEP Fencing in the Sheep ( 计算几何 + 二分 )
    UVa 11806
    UVa 1445
    HDU 4725 The Shortest Path in Nya Graph( 建图 + 最短路 )
    HDU 4661 Message Passing ( 树DP + 推公式 )
    从远程库克隆库
    添加远程库
    远程仓库
    删除文件
    撤销修改
  • 原文地址:https://www.cnblogs.com/tinaluo/p/15636304.html
Copyright © 2011-2022 走看看