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

Question

我正在将分布式架构从Python移动到。网络核心。此体系结构具有将请求推送到服务总线（KAFKA）的网关API。请求由微服务处理。这些微服务在请求对象中设置的主题上响应网关（然后响应客户端）。主题名称是基于python Application（Flask/uwsgi）的process_id构建的。

但是用。NetCore Webapi应用程序，我无法找到从其过程中获取主题的方法（我开始在.NetCore）。使用Async方法在等待微服务回答时释放切入点，最好是根据程序集ID的类型生成主题名称。但是每个Asyc方法调用都会产生不同的主题，对吗？这将导致大量的话题...有点奇怪...

你认为还有别的办法吗？

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

Answer 1

此代码输出相同的数字，因此任务确实继承了主进程的进程id。线程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);
        }
   }
}