对于用户发送消息的方面，首先我们应该修改一下之前的UserMessage结构体，如下：
type UserMessage struct {
Type string `json:"type"`
UserId int `json:"user_id"`
FirstTopic int `json:"first_topic"`
SecondTopic int `json:"second_topic"`
MsgType int `json:"msg_type"`
MsgContent string `json:"msg_content"`
}
这里加入了一个MsgType和一个MsgContent。用户发送消息的类型和具体的消息内容。
然后我们就可以通过Type是否为Message来判断是否是用户发送的消息。
case "message":
messageContent:=common.MessageContent{
FirstTopic: umsg.FirstTopic,
SecondTopic: umsg.SecondTopic,
MsgType: umsg.MsgType,
MsgContent: umsg.MsgContent,
UserId: umsg.UserId,
}
fds:=new(user.UserService).GetFdByGroup(umsg.FirstTopic,umsg.SecondTopic)
fmt.Println("fds===================",fds)
PushToAllObj:=new(push.PushToAllMessage)
PushToAllObj.Status=0;
PushToAllObj.Data=messageContent
PushToAllObj.Fds=fds
messageservice:=new(message.MessageService)
messageservice.Add(PushToAllObj)
messageservice.Update()
break
这里我们新建了一个MessagService，这个Service只是为了继承一下PushEventGenerator，从而对用户发送通知。
OK，至此所有的发送消息的功能与之前Swoole_chat的功能都一致了。
