一、由来

　　最近，公司需要一个即时聊天功能。为此，曾尝试，，重点研究了下mars项目，该项目支持Android，iOS端通信，并能对网络进行优化处理，是微信内部运行架构。服务端是基于Netty框架通信，数据通过protobuf封装，并自定义了一套通信协议。客户端通信，通过封装好的类库进行调用。因此，对于项目较急的，上线快速，此方案研究耗时较长，不满足现状。因此，在此先试用简单长连接，并设置好接口，以备后续直接切换成成熟框架。

作为研究学习记录，对简单长连接做一番记录。

二、实现原理

　　客户端发起请求，当有可用消息时，直接返回所请求的消息。如果没有可用消息，则等待30秒。请求超时后，继续发起请求。

三、实例

1.服务端，主要基于.net core api，实现Send（发送消息），Receive（接收消息）业务

服务端主要实现逻辑：

1 [HttpPost] 2 public IActionResult Send([FromBody] Message message) 3 { 4     if (message == null) 5         return Content(""); 9     lock (_messages)10     {11         _messages.Add(new Message12         {13             QueueID = _messages.Count > 0 ? _messages.Max(q => q.QueueID) + 1 : 1,14             From = message.From,15             FromName = _users.FirstOrDefault(u => u.Id == message.From).UserName,16             To = message.To,17             ToName = _users.FirstOrDefault(u => u.Id == message.To).UserName,18             Content = message.Content19         });20     }21     return Content("");22 }23 24 public IActionResult Receive(long userId, long queueId)25 {26     Message retMsg = null;27     int seconds = 0;28     do29     {30         lock (_messages)31         {32             retMsg = _messages.Where(m => (m.To == userId || m.To == 0) && m.From != userId && queueId < m.QueueID).FirstOrDefault();33         }34         if (retMsg == null)35         {36             Thread.Sleep(1000); // 5s37             seconds += 1;38         }39     } while (retMsg == null && seconds < 30);40     return Json(retMsg);41 }