这段时间项目不忙，想着搞点事情.于是花了大概一个月时间，写了一套聊天系统。前端是用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];
}
