这段时间项目不忙，想着搞点事情.于是花了大概一个月时间，写了一套聊天系统。前端是用flutter写的，后台服务用的go写的。目前支持ios和安卓双端运行.前后端通讯采用的websocket.目前支持发送接收。

服务端用到的技术
数据库：MySQL+Redis
通讯框架：GRPC
长连接通讯协议：Protocol Buffers
日志框架：Zap
ORM框架：GORM

目前支持文字.语音.图片.视频消息.（语音图片视频存储在阿里云oss服务器上）支持单聊。群聊以及上线拉取未读离线消息。下面说说我整套设计思路（主要是服务端）以及其中遇到的难点。

设计框架.png

已经实现的功能

• 登陆
• 注册
• 单聊
• 群聊
• 发送文字
• 发送语音
• 发送图片
• 发送视频
• 离线消息获取
• 添加好友
• 删除好友
• 加入群聊
• 语音实时通话
• 视频实时通话
• 群拉人（后台接口已经做好，剩余前台）
• 群踢人（后台接口已经做好，剩余前台）
• 创建群
• 消息已读未读回执

安卓端真机运行效果

安卓端.gif

ios模拟器运行效果

ios.gif

中间遇到的难点是如何获取离线消息，当用户端websocket处于离线状态时，其他用户发送的消息都不会收到，后来查阅资料，目前的解决办法是每次会话的message都增加自增seq的字段，客户端上线后从本地数据库查询每一条会话的最大的seq值上报给后端，后端查询服务端数据，将所有这个对象的每一个会话大于对于seq值的消息返回给客户端。下面是服务端代码

服务端处理离线消息的代码

//接受客户端最后一次的seq参数查询离线消息
func (ctx *ConnContext) Sync(input defs.Input) {
    var sync defs.SyncInput
    err := json.Unmarshal([]byte(input.Data), &sync)
    if err != nil {
        log.Print(err)
        ctx.Release()
        return
    }
    seq, _ := strconv.ParseInt(sync.Seq, 10, 64)

    messageList, err := service.MessageService.ListByUserIdAndSeq(ctx.AppId, ctx.UserId, seq)
    var syncOutput defs.SyncOutput
    if err == nil {
        messageItems := make([]defs.MessageItem, 0, 5)
        for _, v := range *messageList {
            var messageItem defs.MessageItem
            messageItem.SenderId = strconv.FormatInt(v.SenderId, 10)
            messageItem.ReceiverId = strconv.FormatInt(v.ReceiverId, 10)
            messageItem.SendTime = util.FormatDatetime(v.SendTime, util.YYYYMMDDHHMMSS)
            messageItem.Type = defs.MessageType(v.Type)
            messageItem.Content = v.Content
            messageItem.Seq = strconv.FormatInt(v.Seq, 10)
            messageItem.Avatar = v.Avatar
            messageItems = append(messageItems, messageItem)
        }
        syncOutput = defs.SyncOutput{Messages: messageItems}
    }
    ctx.Output(defs.PackageType_SYNC, input.RequestId, err, &syncOutput)
}

func (ctx *ConnContext) Heartbeat(input defs.Input) {
    ctx.Output(defs.PackageType_HEARTBEAT, input.RequestId, nil, "PONG")
    log.Print("device_id：", ctx.DeviceId, " PING")
}

// 根据seq去查询消息
func (*messageService) ListByUserIdAndSeq(appId, userId, seq int64) (*[]model.Message, error) {
    var err error
    if seq == 0 {
        seq, err = DeviceAckService.GetMaxByUserId(appId, userId)
        if err != nil {
            return nil, err
        }
    }
    messages, err := dao.MessageDao.ListBySeq(appId, model.MessageObjectTypeUser, userId, seq)
    if err != nil {
        return nil, err
    }
    return messages, nil
}

用户端处理离线消息的代码

  //从服务端获取离线消息
  void getUnreadMessageFromServe(){
    DBService().queryLastMessageSeq().then((value){
      Map param = {
        "seq":value == null?"0":value["Seq"]
      };
      Map sendParam = {
        "type":2,
        "requestId":0,
        "data":convert.jsonEncode(param)
      };
      String sendParamString= convert.jsonEncode(sendParam);
      WebSocketUtility().sendMessage(sendParamString);
    });
  }
//DBService
  Future<Map> queryLastMessageSeq() async{
    await dbUtil.open();
    List<Map> data = await dbUtil.queryList("SELECT * FROM chat_flutter order by id desc");
    print('数据库查询的data：$data');
    await dbUtil.close();
    return data.length == 0?null:data[0];
  }