标签:
前面几篇基本已经实现了大部分即时通讯功能:聊天,群聊,发送文件,图片,消息。不过这些业务都是比较粗犷的。下面我们就把业务细化,之前用的是死数据,那我们就从加好友开始吧。加好友,首先你得知道你要加谁。Layim界面右下角有个+号,点击它之后就会弹出查找好友的界面,不过那个界面需要自定义。由于前端不是我的强项,勉强凑了个页面。不过不要在意这些细节。这些都不重要,今天主要介绍一下ElasticSearch搜索解决方案。它是一个基于Lucene的搜索服务器。它提供了一个分布式多用户能力的全文搜索引擎,基于RESTful web接口。不熟悉Elastic的也不要紧,本篇的搜索查找好友用关系数据库一样实现。(不想对ES做深入研究的可以简单看一下思路即可)
首先安装好ES环境。安装步骤可以参考 http://www.cnblogs.com/panzi/p/5659697.html。
OK,先看一下成型效果图,第一张是用户,第二个是群。
好的,界面就是这样。当然要绑定什么数据可以自己定义,比如绑定签名,男女或者其他信息等,都可以,在高级一点,把是否在线信息加上。既然用了layui,那顺带着绑定插件我就直接用laytpl了。前端模板如下:(一个用户模板,一个群模板)。
再说数据源,既然我用到了ElasticSearch(下文用ES代替),但是数据库(MSSQL)也保存了相应的信息。这就需要,当一个用户注册进来之后,我们还需要将该搜索信息保存到ES中。伪代码如下:
var dt = UserRegister(); if(dt){
//如果用户注册成功,返回了相应的信息,我们就把他在加到ES中去。 AdduserInfoToElastic(dt); }
下图就是ES中保存的用户信息,这些用户信息是和数据库中的数据同步的,因此,修改用户信息的时候,此表中的数据也要同步。当然有延迟也没问题。
用ES的一个好处呢就是快,他能帮你做缓存,帮你分词查询。我们做练习用数据库搜索几十条没问题。如果数据量大了,搜索条件复杂了,ES就能体现出他的优势了。现在我用的搜索条件很简单,一个是IM号,类似QQ,一个就是昵称。对接ES的客户端是PlainElastic.Net,用nuget安装即可。 install-package PlainElastic.Net.
ES有自己的查询语法,又复杂的也有简单点的,我就用一些简单的,毕竟我也没太深入研究。正如前文所说,它提供了Restful api。我们查询的路径就是:127.0.0.1:9200/layim/layim_user/_search POST方法,POST的参数如下:
{ "query": { "match_all": {}//没有条件的时候就是match_all相当于查询所有 }, "from": 0,//分页开始 "size": 50,//每页条数 "sort": { //排序,根据 province 正序排序 "province": { "order": "asc" } } }
上边的是查询所有的情况,当用户输入了查询条件时候,比如精确查询IM号为 288186 的用户,搜索条件如下:
{ "query": { "filtered": { "filter": { "or": [ //or 查询,下面的条件符合一个即可 { "term": { "im": 288186 //im =288186 } }, { "query": { "match_phrase": { //短语查询 "nickname": { "query": "288186", //或者昵称中有288186 "slop": 0 } } } } ] } } }, "from": 0, "size": 50 }
不熟悉语法的同学可能看不太懂,总之上边这些参数的意思就是 select top 50 * from layim_user where im=288186 or nickname like ‘%288186%‘
查询结果他会把查询到的总数和耗时(ms)返回,像几万条数据的话大部分就是几十毫秒甚至不到十毫秒。相对于从数据用查,速度还是可以的。
基于PlainElastic.NET我又封装了一层查询的核心方法:
public BaseQueryEntity<T> QueryBayConditions(string query) { try { string cmd = CreateSearchCommand();//构造查询命令 OperationResult result = Client.Post(cmd, query);//Post query参数查询 var data = serializer.ToSearchResult<T>(result.Result); //返回结果转换 return GetResults(data); } catch (Exception ex) { ESLog.WriteLogException(MethodBase.GetCurrentMethod(), "查询条件:" + query); ESLog.WriteLogException(MethodBase.GetCurrentMethod(), ex); return new BaseQueryEntity<T>(); } }
public class BaseQueryEntity<T> where T :BaseEntity { /// <summary> /// 命中条数 /// </summary> public long hits { get; set; } /// <summary> /// 花费时间(单位ms) /// </summary> public long took { get; set; } public IEnumerable<T> list { get; set; } }
查询结果json:
总共有3883个用户,ES查询用了5ms,加上http请求耗时,总共耗时为45毫秒。
写到这里呢,就暂时对ES做个简单的总结,其实如果做练习的话也没必要用他来查,直接查数据库就可以了,如果再配合缓存的话速度也不慢,而且今天讲的业务逻辑也不复杂。说白了,本篇就讲了个CRUD的 Retrieve。(R)还有聊天记录顺便说一下,也是用ES查的,不过到时候会增加一些小的效果。我也不卖关子了,就是模糊查询的关键字高亮效果。
下面继续说加好友流程,首先,如果你想吧一个用户加为好友首先,得发送加好友请求吧,类似QQ。当然,如果那个人设置了任何人都可以加好友,是不是就可以直接加上了。如果那个人设置了不允许任何人加好友,那么你也没法加他的,所以,简单的一个加好友也可以设计的很复杂。本篇就介绍普通的申请流程。点击加好友之后,弹出框,填写附加消息:(我们搜索出288186的用户添加)
当我们点击发送之后要考虑什么呢?先不要看下文,仔细思考一下。5 ,4, 3 ,2, 1。。。
没错,就是如果对方恰好在线的处理,和对方不在线的处理、如果对方在线,保存到数据库并且即时提醒。不在线,保存到数据库,等下次登录提醒用户。详细做法下一篇再写吧。先贴一个预告图:
本篇贴的图比较多,讲了一些业务上的东西和ES的简单使用,场景和使用方式等。本篇就到这里吧。
下篇预告:【中级】ASP.NET SignalR 与 LayIM2.0 配合轻松实现Web聊天室(五) 之 加好友,加群消息提示,Hub中的User用法。
想要学习的小伙伴,可以关注我的博客哦,我的QQ:645857874,Email:fanpan26@126.com
ASP.NET SignalR 与 LayIM2.0 配合轻松实现Web聊天室(四) 之 用户搜索(Elasticsearch),加好友流程(1)。
标签:
原文地址:http://www.cnblogs.com/panzi/p/5759368.html