我们正在开发一个由多个不同服务组成的服务结构应用程序,我们的应用程序工作方式的一个关键部分是这些服务需要大量相互调用。
直到最近我们增加了应用程序的负载并发现它的速度大大减慢时,我们才遇到任何问题。经过大量调查和对各种事情进行计时后,我们发现问题似乎是,当我们对一种类型的服务(其中我们有多个实例)进行大量调用时,调用似乎在我们调用服务之间存在一些延迟,并且服务实际上开始处理请求。
我们正在按照 Microsoft 的描述在服务之间进行调用here https://learn.microsoft.com/en-us/azure/service-fabric/service-fabric-reliable-services-communication-remoting
更清楚地说:ServiceA 获取对 ServiceB 的引用,然后调用 ServiceB.GetResult(),我们记录在 ServiceA 中调用此方法的时间,而我们在 GetResult() 中做的第一件事是记录处理开始的时间。当没有负载时,只有几毫秒,一旦我们增加负载,我们发现有一个4-5秒这些时间之间的延迟。
这是服务结构的某种限制吗?我们有多个 ServiceB 实例,集群上的资源占用基本上没有什么,所有节点上 CPU 徘徊在 10% 左右,内存占用约为 1/4,但服务的吞吐量非常低,因为它在这里等待。
为什么要等?对于服务一次可以处理的不同调用的数量是否存在某种定义的限制?我们的沟通方式是否出了问题?
谢谢。
MaxConcurrentCalls 设置似乎正是我所需要的。
连接到服务时:
FabricTransportSettings transportSettings = new FabricTransportSettings
{
MaxConcurrentCalls = 32
};
ServiceProxyFactory serviceProxyFactory = new ServiceProxyFactory(
(c) => new FabricTransportServiceRemotingClientFactory(transportSettings));
service = serviceProxyFactory.CreateServiceProxy<T>(serviceUri);
创建服务监听器:
protected override IEnumerable<ServiceInstanceListener> CreateServiceInstanceListeners()
{
FabricTransportListenerSettings listenerSettings = new FabricTransportListenerSettings
{
MaxConcurrentCalls = 32
};
return new[]
{
new ServiceInstanceListener(
(context) => new FabricTransportServiceRemotingListener(context,this,listenerSettings))
};
}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)