【导读】本文介绍了一个 go 语言实现的简单 im 即时通信系统。
简介
纯go实现的im即时通讯系统,各层可单独部署,之间通过rpc通讯,支持集群,github地址 https://github.com/Terry-Ye/im_api , 学习于goim, 总分三层,
comet(用户连接层),可以直接部署多个节点,每个节点保证serverId 唯一,在配置文件comet.toml
logic(业务逻辑层),无状态,各层通过rpc通讯,容易扩展,支持http接口来接收消息
job(任务推送层)通过redsi 订阅发布功能进行推送到comet层。
时序图
以下Comet 层,Logic 层,Job层都可以灵活扩展机器
特性
分布式,可拓扑的架构
支持单个,房间推送
心跳支持(gorilla/websocket内置)
基于redis 做消息推送
轻量级
持续迭代。。.
部署
安装
goget-ugithub.com/Terry-Ye/im mv$GOPATH/src/github.com/Terry-Ye/im$GOPATH/src/im cd$GOPATH/src/im goget./...
golang.org 包拉不下来的情况,例
packagegolang.org/x/net/ipv4:unrecognizedimportpath"golang.org/x/net/ipv4"(httpsfetch:Gethttps:
从github 拉下来,再移动位置
gitclonehttps://github.com/golang/net.git mkdir-pgolang.org/x/ mvnet$GOPATH/src/golang.org/x/
- 部署im
安装comet、logic、job模块
cd$GOPATH/src/im/comet goinstall cd../logic/ goinstall cd../job goinstall nohup$GOPATH/bin/logic-d$GOPATH/src/im/logic/2>&1>/data/log/im/logic.log& nohup$GOPATH/bin/comet-d$GOPATH/src/im/comet/2>&1>/data/log/im/comet.log& nohup$GOPATH/bin/job-d$GOPATH/src/im/job/2>&1>/data/log/im/job.log&
- im_api 是im系统中使用的接口,需要像demo那样整体跑起来需要完整的部署
部署注意事项
- 部署服务器注意防火墙是否开放对应的端口(本地不需要,具体需要的端口在各层的配置文件)
demo
聊天室:http://www.texixi.com:1999/
使用的包
- log: github.com/sirupsen/logrus
- rpc: github.com/smallnest/rpcx
- websocket: github.com/gorilla/websocket
- 配置文件:github.com/spf13/viper
后续计划
- 在线列表
- 支持wss
- 聊天机器人
编辑:jq