ASP.NET Core WebApiサービスとSubscripion on AMPQ（Rabbit MQ）

Question

タスクは、Web API（休憩）サービス、つまり検索サービスを作成することです。 また、イベントを受信すると、このサービスはキューをリッスンして再インデックスする必要があります。

ASP.NET Core WebApiアプリケーションにリスニングロジックを挿入する最適な方法は何ですか？

ここでは解決策がありますが、それはかなり良いとは思いません。

Program.cs

var host = new WebHostBuilder() 
    .UseKestrel() 
    .UseContentRoot(Directory.GetCurrentDirectory()) 
    .UseIISIntegration() 
    .UseStartup<Startup>() 
    .Build(); 

var ampq = host.Services.GetService(typeof(IAmpqListener)) as IAmpqListener; 
ampq?.Subscribe(); 

host.Run(); 

Answer 1

私はgithubの上でそのためのライブラリを持っています。

このライブラリは、rabbitmq経由でメッセージを聞く（消費する）、または生成するのが簡単になります。

消費者例：

public class FooWorker : IWorker<FooData> 
{ 
    public string JobName => "foo.job.name"; // Should be same as dispatched job name. 

    public bool Work(FooData data) 
    { 
     // Lets, do whatever you want by data. 

     // Return true, if working completed successfully, otherwise return false. 
     return true; 
    } 
} 

FooWorkerがリスナーです。 foo.job.nameという名前のキューにメッセージが転送されたときに呼び出される作業メソッド。詳細については

：私はデータフィードを受信すると、特定のでASP.NETのコアに関係しているか理解していないhttps://github.com/turgayozgur/tossit