zhusenlin/Yi.Admin
1
0
Fork 0
mirror of https://gitee.com/ccnetcore/Yi synced 2026-04-03 07:36:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

添加es服务

Browse Source
This commit is contained in:
橙子
2021-11-09 18:55:11 +08:00
parent d9fe0895bc
commit bf9c86f7b7
2 changed files with 17 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
Yi.Framework/Yi.Framework.ElasticSearchProcessor/InitESIndexWorker.cs
View File

@@ -49,16 +49,16 @@ namespace Yi.Framework.ElasticSearchProcessor
//【判断增删改，es进行相应的操作】 //【判断增删改，es进行相应的操作】
//switch (spuCQRSQueueModel.CQRSType) //switch (spuCQRSQueueModel.CQRSType)
//{ //{
//case (int)SPUCQRSQueueModelType.Insert: // case (int)SPUCQRSQueueModelType.Insert:
//case (int)SPUCQRSQueueModelType.Update: // case (int)SPUCQRSQueueModelType.Update:
// { // {
// Goods goods = this._ISearchService.GetGoodsBySpuId(spuCQRSQueueModel.SpuId); // Goods goods = this._ISearchService.GetGoodsBySpuId(spuCQRSQueueModel.SpuId);
// this._IElasticSearchService.InsertOrUpdata<Goods>(goods); // this._IElasticSearchService.InsertOrUpdata<Goods>(goods);
// break; // break;
// } // }
//case (int)SPUCQRSQueueModelType.Delete: // case (int)SPUCQRSQueueModelType.Delete:
// this._IElasticSearchService.Delete<Goods>(spuCQRSQueueModel.SpuId.ToString()); // this._IElasticSearchService.Delete<Goods>(spuCQRSQueueModel.SpuId.ToString());
// break; // break;
// default: // default:
// throw new Exception("wrong spuCQRSQueueModel.CQRSType"); // throw new Exception("wrong spuCQRSQueueModel.CQRSType");
//} //}

10
Yi.Framework/Yi.Framework.ElasticSearchProcessor/WarmupESIndexWorker.cs
View File

@@ -13,7 +13,9 @@ using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
using Yi.Framework.Common.IOCOptions; using Yi.Framework.Common.IOCOptions;
using Yi.Framework.Common.Models; using Yi.Framework.Common.Models;
using Yi.Framework.Common.QueueModel;
using Yi.Framework.Core; using Yi.Framework.Core;
using Yi.Framework.Interface;
namespace Yi.Framework.ElasticSearchProcessor namespace Yi.Framework.ElasticSearchProcessor
{ {
@@ -25,13 +27,15 @@ namespace Yi.Framework.ElasticSearchProcessor
private readonly ElasticSearchInvoker _elasticSearchInvoker; private readonly ElasticSearchInvoker _elasticSearchInvoker;
private readonly IOptionsMonitor<ElasticSearchOptions> _ElasticSearchOptions = null; private readonly IOptionsMonitor<ElasticSearchOptions> _ElasticSearchOptions = null;
public WarmupESIndexWorker(ILogger<WarmupESIndexWorker> logger, RabbitMQInvoker rabbitMQInvoker, IConfiguration configuration, ElasticSearchInvoker elasticSearchInvoker, IOptionsMonitor<ElasticSearchOptions> optionsMonitor) private readonly ISearchService _searchService;
public WarmupESIndexWorker(ILogger<WarmupESIndexWorker> logger, RabbitMQInvoker rabbitMQInvoker, IConfiguration configuration, ElasticSearchInvoker elasticSearchInvoker, IOptionsMonitor<ElasticSearchOptions> optionsMonitor, ISearchService searchService)
{ {
this._logger = logger; this._logger = logger;
this._RabbitMQInvoker = rabbitMQInvoker; this._RabbitMQInvoker = rabbitMQInvoker;
this._configuration = configuration; this._configuration = configuration;
this._elasticSearchInvoker = elasticSearchInvoker; this._elasticSearchInvoker = elasticSearchInvoker;
this._ElasticSearchOptions = optionsMonitor; this._ElasticSearchOptions = optionsMonitor;
this._searchService=searchService;
} }
protected override async Task ExecuteAsync(CancellationToken stoppingToken) protected override async Task ExecuteAsync(CancellationToken stoppingToken)
@@ -44,14 +48,14 @@ namespace Yi.Framework.ElasticSearchProcessor
HttpClient _HttpClient = new HttpClient(); HttpClient _HttpClient = new HttpClient();
this._RabbitMQInvoker.RegistReciveAction(rabbitMQConsumerModel, message => this._RabbitMQInvoker.RegistReciveAction(rabbitMQConsumerModel, message =>
{ {
//SKUWarmupQueueModel skuWarmupQueueModel = JsonConvert.DeserializeObject<SKUWarmupQueueModel>(message); SKUWarmupQueueModel skuWarmupQueueModel = JsonConvert.DeserializeObject<SKUWarmupQueueModel>(message);
//【得到消息队列模型】 //【得到消息队列模型】
#region 先删除Index---新建Index---再建立全部数据索引 #region 先删除Index---新建Index---再建立全部数据索引
{ {
try try
{ {
this._elasticSearchInvoker.DropIndex(this._ElasticSearchOptions.CurrentValue.IndexName); this._elasticSearchInvoker.DropIndex(this._ElasticSearchOptions.CurrentValue.IndexName);
//this._ISearchService.ImpDataBySpu(); this._searchService.ImpDataBySpu();
//【触发es数据导入服务】 //【触发es数据导入服务】
this._logger.LogInformation($"{nameof(WarmupESIndexWorker)}.InitAll succeed"); this._logger.LogInformation($"{nameof(WarmupESIndexWorker)}.InitAll succeed");
return true; return true;