客户端连接

客户端连接逻辑涉及如下几个文件：

• connection.go
• peer_client.go
• group_client.go
• room_client.go
• client.go

Connection

type Connection struct {
	conn   interface{} //底层连接对象，两种可能：net.Conn 或 engineio.Conn
	closed int32 //客户端连接是否关闭
	
	forbidden int32 //是否被禁言
	notification_on bool //桌面在线时是否通知手机端
	online bool //是否在线

	sync_count int64 //单聊消息同步计数，用于判断是否是首次同步
	tc     int32 //write channel timeout/error count
	wt     chan *Message
	lwt    chan int
	pwt    chan []*Message //离线消息
	
	version int //客户端协议版本号

	tm     time.Time
	appid  int64
	uid    int64
	device_id string
	platform_id int8
	device_ID int64 //根据device_id和platform_id生成的唯一ID
	
	messages *list.List //待发送的消息队列 FIFO
	mutex  sync.Mutex
}

字段说明：

• conn：底层连接对象，有两种可能的类型net.Conn或engineio.Conn
• closed：客户端连接是否关闭
• forbidden：当前用户是否被禁言
• notification_on：桌面在线时是否通知手机端
• online：表示用户不再接受推送通知(apns, gcm)（online=!(notification_on&&!is_mobile)）
• sync_count：TODO
• tc：底层连接超时或失败的次数，只要出现一次超时或失败，不会再向该连接写入数据
• wt：消息发送通道
• pwt：消息列表发送通道
• lwt：异步发送消息通知通道
• version：客户端协议版本号
• tm：
• appid：应用ID
• uid：用户ID
• device_id：设备字符串
• platform_id：平台类型（1-iOS，2-Android，3-WEB）
• device_ID：根据device_id和platform_id生成的唯一ID
• messages：异步待写入的消息队列

主要方法：

• read：从客户端连接读取一条消息（Message）
• send：将消息（Message）写入到客户端
• close：关闭底层连接
• EnqueueMessage：将消息发送到wt通道
• EnqueueMessages：将消息列表发送到pwt通道
• EnqueueNonBlockMessage：将消息放入messages队列，如果队列长度超过1000，那么移除对头消息并插入该消息，同时通过lwt通道通知写入异步消息
• SendMessage：发送消息到除了自己以外的所有客户端
• SendGroupMessage：发送超级群消息

Client

type Client struct {
	Connection//必须放在结构体首部
	*PeerClient
	*GroupClient
	*RoomClient
	*CustomerClient
	public_ip int32
}

主要消息处理方法：HandleMessage

func (client *Client) HandleMessage(msg *Message) {
	switch msg.cmd {
	case MSG_AUTH_TOKEN:
		client.HandleAuthToken(msg.body.(*AuthenticationToken), msg.version)
	case MSG_ACK:
		client.HandleACK(msg.body.(*MessageACK))
	case MSG_PING:
		client.HandlePing()
	}
    //每种类型Client都会触发消息处理逻辑，是否对消息进行处理由对应的Client决定
	client.PeerClient.HandleMessage(msg)
	client.GroupClient.HandleMessage(msg)
	client.RoomClient.HandleMessage(msg)
	client.CustomerClient.HandleMessage(msg)
}

HandlePing

终端发送一个MSG_PING到IM终端服务器，IM再回复一个MSG_PONG类型消息给终端，没有其他任何逻辑。

HandleACK

终端发送一个MSG_ACK到IM终端服务器，IM只是简单的记录了一下日志，do nothing。

HandleAuthToken

TODO 终端认证登录，IM服务器在校验了终端的合法性后，为终端Client设置用户相关的属性，并加入到终端集合里。

Client重要方法

SendMessages

TODO 发送等待队列中的消息

func (client *Client) SendMessages(seq int) int {
	var messages *list.List
	client.mutex.Lock()
	if (client.messages.Len() == 0) {
		client.mutex.Unlock()		
		return seq
	}
	messages = client.messages
	client.messages = list.New()
	client.mutex.Unlock()

	e := messages.Front();	
	for e != nil {
		msg := e.Value.(*Message)
		if msg.cmd == MSG_RT || msg.cmd == MSG_IM || msg.cmd == MSG_GROUP_IM {
			atomic.AddInt64(&server_summary.out_message_count, 1)
		}
		seq++
		//以当前客户端所用版本号发送消息
		vmsg := &Message{msg.cmd, seq, client.version, msg.flag, msg.body}
		client.send(vmsg)
		
		e = e.Next()
	}
	return seq
}