(更新时间)2021年6月2日 商城高并发秒杀系统(.NET Core版) 23-性能优化-Consul优化

一：Consul性能瓶颈

Consul主要的性能出现在服务发现，网络IO是很耗性能的。

二：Consul性能优化

1. 使用单例全局共享
2. 使用数据缓存(进程：字典，集合，redis)
3. 使用连接池

下面以本地缓存为案例

/// <summary>
/// consul服务发现实现
/// </summary>
public class ConsulServiceDiscovery : AbstractServiceDiscovery
{
    public ConsulServiceDiscovery(IOptions<ServiceDiscoveryOptions> options) : base(options)
    {
    }

    protected override CatalogService[] RemoteDiscovery(string serviceName)
    {
        // 1、创建consul客户端连接 2s 1、使用单例全局共享 2、使用数据缓存(进程：字典，集合) 3、使用连接池
        var consulClient = new ConsulClient(configuration =>
        {
            //1.1 建立客户端和服务端连接
            configuration.Address = new Uri(serviceDiscoveryOptions.DiscoveryAddress);
        });

        // 2、consul查询服务,根据具体的服务名称查询
        var queryResult = consulClient.Catalog.Service(serviceName).Result;
        // 3、判断请求是否失败
        if (!queryResult.StatusCode.Equals(HttpStatusCode.OK))
        {
            throw new FrameException($"consul连接失败:{queryResult.StatusCode}");
        }

        return queryResult.Response;
    }

}

  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
  
20
  
21
  
22
  
23
  
24
  
25
  
26
  
27
  
28
  
29
  
30
 

/// <summary>
/// 抽象服务发现，主要是缓存功能
/// </summary>
public abstract class AbstractServiceDiscovery : IServiceDiscovery
{
    // 字典缓存
    private readonly Dictionary<string, List<ServiceNode>> CacheConsulResult = new Dictionary<string, List<ServiceNode>>();
    protected readonly ServiceDiscoveryOptions serviceDiscoveryOptions;
    public AbstractServiceDiscovery(IOptions<ServiceDiscoveryOptions> options)
    {
        this.serviceDiscoveryOptions = options.Value;

        // 1、创建consul客户端连接
        var consulClient = new ConsulClient(configuration =>
        {
            //1.1 建立客户端和服务端连接
            configuration.Address = new Uri(serviceDiscoveryOptions.DiscoveryAddress);
        });

        // 2、consul 先查询服务
        var queryResult = consulClient.Catalog.Services().Result;
        if (!queryResult.StatusCode.Equals(HttpStatusCode.OK))
        {
            throw new FrameException($"consul连接失败:{queryResult.StatusCode}");
        }

        // 3、获取服务下的所有实例
        foreach (var item in queryResult.Response)
        {
            QueryResult<CatalogService[]> result = consulClient.Catalog.Service(item.Key).Result;
            if (!queryResult.StatusCode.Equals(HttpStatusCode.OK))
            {
                throw new FrameException($"consul连接失败:{queryResult.StatusCode}");
            }
            var list = new List<ServiceNode>();
            foreach (var service in result.Response)
            {
                list.Add(new ServiceNode { Url = service.ServiceAddress + ":" + service.ServicePort });
            }
            CacheConsulResult.Add(item.Key, list);
        }
    }


    public List<ServiceNode> Discovery(string serviceName)
    {
        // 1、从缓存中查询consulj结果
        if (CacheConsulResult.ContainsKey(serviceName))
        {
            return CacheConsulResult[serviceName];
        }
        else
        {
            // 1.2、从远程服务器取
            CatalogService[] queryResult = RemoteDiscovery(serviceName);

            var list = new List<ServiceNode>();
            foreach (var service in queryResult)
            {
                list.Add(new ServiceNode { Url = service.ServiceAddress + ":" + service.ServicePort });
            }

            // 1.3 将结果添加到缓存
            CacheConsulResult.Add(serviceName, list);

            return list;
        }
    }

    /// <summary>
    /// 远程服务发现
    /// </summary>
    /// <param name="serviceName"></param>
    /// <returns></returns>
    protected abstract CatalogService[] RemoteDiscovery(string serviceName);
}

  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
  
20
  
21
  
22
  
23
  
24
  
25
  
26
  
27
  
28
  
29
  
30
  
31
  
32
  
33
  
34
  
35
  
36
  
37
  
38
  
39
  
40
  
41
  
42
  
43
  
44
  
45
  
46
  
47
  
48
  
49
  
50
  
51
  
52
  
53
  
54
  
55
  
56
  
57
  
58
  
59
  
60
  
61
  
62
  
63
  
64
  
65
  
66
  
67
  
68
  
69
  
70
  
71
  
72
  
73
  
74
  
75
  
76
 

三：优化效果

原本一个接口是3秒的响应时间，通过缓存可以在0.1秒内响应。

文章来源: codeboy.blog.csdn.net，作者：愚公搬代码，版权归原作者所有，如需转载，请联系作者。

原文链接：codeboy.blog.csdn.net/article/details/117483510