请求 - 通过消息系统（kafka/.NET）的响应策略

Question

我正在将分布式架构从 Python 迁移到 .NetCore。此架构具有将请求推送到服务总线 (KAFKA) 的网关 API。请求由微服务处理。这些微服务在请求对象中设置的主题上回答网关（然后是客户端）。 主题名是根据python应用程序的process_id构建的（Flask/uwsgi）。

但是对于 .NetCore Webapi 应用程序，我找不到从其进程中获取“主题”的方法（我从 .NetCore 开始）。使用 Async 方法在等待微服务应答时释放入口点，最好是根据 Assembly ID 的种类生成主题名称。但是每个 Asyc 方法调用都会产生不同的主题，对吧？这会引发大量话题……有点奇怪……

您还有其他方法可以继续吗？

我正在考虑使用 MemoryCache 来包装来自微服务和网关进程的答案之间的通信。 （请求将包含一个 Guid，用作内存缓存访问的键）。你怎么看？

Answer 1

此代码输出相同的数字，因此任务确实继承了主进程的 process_id。 thread_id 可能不同。

您也可以考虑使用 GUID，而不是 process_id。只是一个想法。

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);
        }
   }
}