Messaging System（kafka/.NET）によるリクエスト/レスポンス戦略

Question

分散アーキテクチャをPythonから.NetCoreに移行しています。このアーキテクチャには、要求をサービスバス（KAFKA）にプッシュするゲートウェイAPIがあります。要求はマイクロサービスによって処理されます。これらのマイクロサービスは、要求オブジェクトに設定されているトピックについて、ゲートウェイ（クライアント）に応答します。 トピック名は、pythonアプリケーション（Flask/uwsgi）のprocess_idに基づいてビルドされています。

しかし、.NetCore Webapiアプリケーションでは、そのプロセスからトピックを取得する方法が見つかりませんでした（私は.NetCoreで始まります）。マイクロサービスの回答を待っている間にAsyncメソッドを使用してエントリポイントを解放すると、Assembly IDの種類に基づいてトピック名を生成するのが最適です。しかし、すべてのAsycメソッド呼び出しは、異なるトピックを生成するでしょう、そうですか？それは話題の数が多い...奇妙な種類...

他の方法はありますか？

私はMemoryCacheを使用してMicroservicesとゲートウェイプロセスからの回答を通信することを考えています。 （要求にはメモリキャッシュアクセスのキーとして使用されるGuidが含まれています）。どう思いますか？

Answer 1

このコードは同じ番号を出力するため、タスクはメインプロセスのprocess_idを継承します。おそらくthread_idは異なるでしょう。

また、process_idではなくGUIDの使用を検討することもできます。ちょっとした考え。

using System; 
using System.Threading.Tasks; 

namespace ConsoleApp1 
{ 
    class s 
    { 
     public s() { } 
     static void Main(string[] args) 
     { 
     Console.WriteLine(System.Diagnostics.Process.GetCurrentProcess().Id); 
     Task.Run(async() => { bool x = await Go(); }).GetAwaiter().GetResult(); ; 
     } 

     private static Task<bool> Go() 
     { 
     Console.WriteLine(System.Diagnostics.Process.GetCurrentProcess().Id); 
     return Task.FromResult<bool>(false); 
     } 
    } 
}