zoukankan      html  css  js  c++  java
  • (转)NEST.net Client For Elasticsearch简单应用

    由于最近的一个项目中的搜索部分要用到 Elasticsearch 来实现搜索功能,苦于英文差及该方面的系统性资料不好找,在实现时碰到了不少问题,现把整个处理过程的代码分享下,给同样摸索的人一些借鉴,同时希望有经验的大牛发现有问题的地方不吝斧正!
     
     

    查询入口

    webapi 的部分代码,把查询条件封装到 eJobQueryPosition 中
    var param = new eJobQueryPosition
                {
                    IndustryPost = industryPost,
                    Region = region,
                    MinSalary = minSalary,
                };
    //调用搜索
    var gl = await _queryBusiness.QueryPositionsAsync(param, skip, top, string.Empty);
     
    //处理结果
    if (gl.IsError)
                return FailActionRequest(gl.webapi_error);
                if (gl.total <= 0)
                {
                    return OkActionRequest(gl);
                }
               
                return OkListActionRequest(gl);
     

    QueryPositionsAsync 部分代码

    var resultData = await _queryPostion.QueryAsync(condition, skip, top, searchText);

                //查看搜索语句
                //var temp= Encoding.UTF8.GetString(resultData.RequestInformation.Request).Trim();

                if (!resultData.Hits.Any())
                {
                    return new GListResult<eJobPositionSimple>(new eJobPositionSimple[0]);
                }
                var result = resultData.Documents;

                var g1 = result.Select(position => new eJobPositionSimple
                {
                    Pstn_Id = position._id,
                    ...
                    Phone = position.Phone, 
                    Name = position.BrandName,
                }).ToList();
                
                return new GListResult<eJobPositionSimple>(g1, (int) resultData.Total);

    QueryAsync部分代码

    /// <summary>
            /// 生成搜索客户端
            /// </summary>
            /// <returns></returns>
            private static ElasticClient GetSearchClient()
            {
                var connectString = ConfigurationManager.ConnectionStrings["ElasticSearch"].ConnectionString;
                var nodesStr = connectString.Split('|');
                var nodes = nodesStr.Select(s => new Uri(s)).ToList();
                var connectionPool = new SniffingConnectionPool(nodes);
                var settings = new ConnectionSettings(connectionPool).SetDefaultIndex("position");
                settings.SetDefaultPropertyNameInferrer(p => p.ToString());
                var client = new ElasticClient(settings);
                return client;
            }
     
    //web.config 中 ElasticSearch 的设置  <add name="ElasticSearch" connectionString="http://192.168.1.7:7200" />  //默认为9200端口

            public async Task<ISearchResponse<QPosition>> QueryAsync(eJobQueryPosition condition, int skip, int top, string searchText = "")
            {
                var client = GetSearchClient();

                var resultData = await client.SearchAsync<QPosition>(s =>
                    s.Index("position").Type("tbJobPosition").
                        Query(
                            q => QueryContainerPosition(condition, searchText, q)).
                        SortDescending(f => f.UpdateTime).Skip(skip).Take(top));
                return resultData;
            }
     
            /// <summary>
            /// 生成职位查询表达式
            /// </summary>
            /// <param name="condition">职位条件</param>
            /// <param name="searchText">查询的关键字</param>
            /// <param name="q">用于返回的查询表达式</param>
            /// <returns>返回用于搜索的表达式</returns>
            private static QueryContainer QueryContainerPosition(eJobQueryPosition condition, string searchText, QueryDescriptor<QPosition> q)
            {
                var query = new QueryContainer();
                //未过有效期
                query &= q.Range(rr => rr.OnField(ff => ff.ExpireTime).GreaterOrEquals(DateTime.UtcNow.Date));

                if (!string.IsNullOrWhiteSpace(searchText))
                {
                    query &= QueryText(searchText, q, query);    
                }  
                return query;
     
       //该部分补充说明 在这里可以构造多个搜索条件 如下
                /*
                var query1 = new QueryContainer();
                query1 = q.Term(s => s.OnField(ff => ff.BrandName).Value("szbrandname1"));

                var query2 = new QueryContainer();
                query2 = q.Term(s => s.OnField(ff => ff.BrandName).Value("szbrandname2"));

                var query3 = new QueryContainer();
                query2 = q.Term(s => s.OnField(ff => ff.BrandName).Value("szbrandname3"));
                query = query1 || query2 || query3;
                // or  query = (query1 || query2) && query3;
                //说明 各条件 || 等同 query 中的should; && 等同 must 
               //部分搜索条件可改用filter性能会更好,略
              */
            }
     
            /// <summary>
            /// 搜索文本表达式,一定要放在所有表达式的最后
            /// </summary>
            /// <param name="searchText">搜索文本</param>
            /// <param name="q">搜索表达式</param>
            /// <param name="query">要返回的搜索表达式类</param>
            /// <returns></returns>
            private static QueryContainer QueryText(string searchText, QueryDescriptor<QPosition> q, QueryContainer query)
            {
                if (!string.IsNullOrWhiteSpace(searchText))
                {
                    query = q.MatchPhrase(p => p.OnField(o => o.Descript).Query(searchText));
                }
                return query;
            }
     
    以上代码分别放到相应的cs文件中即可实现postion的搜索功能
    部分应用要加哦
    using System;
    using System.Configuration;
    using System.Linq;
    using System.Threading.Tasks;
    using **.Entity;
    using Elasticsearch.Net.ConnectionPool;
    using Nest;

    参考资料网址

    http://nest.azurewebsites.net/nest/core/
  • 相关阅读:
    LeetCode212. Word Search II
    LeetCode132. Palindrome Partitioning II
    LeetCode239. Sliding Window Maximum
    LeetCode解题报告—— Interleaving String
    LeetCode解题报告—— Maximal Rectangle
    LeetCode解题报告—— Minimum Window Substring && Largest Rectangle in Histogram
    LeetCode解题报告—— N-Queens && Edit Distance
    LeetCode解题报告—— Trapping Rain Water
    在CentOS上安装第三方软件库EPEL
    lunix存取windows共享文件夹
  • 原文地址:https://www.cnblogs.com/ywcz060/p/6028797.html
Copyright © 2011-2022 走看看