1 using System;
 2 using System.Collections.Generic;
 3 using System.Linq;
 4 using System.Net.Http;
 5 using Consul;
 6 using Microsoft.AspNetCore.Mvc;
 7 using Microsoft.Extensions.Logging;
 8 using PatrickLiu.MicroService.Interfaces;
 9 using PatrickLiu.MicroService.Models;
10 
11 namespace PatrickLiu.MicroService.Client.Controllers
12 {
13     public class HomeController : Controller
14     {
15         private readonly ILogger<HomeController> _logger;
16         private readonly IUserService _userService;
17         private static int index;
18 
19         /// <summary>
20         /// 初始化該類型的新實例。
21         /// </summary>
22         /// <param name="logger">注入日誌對象。</param>
23         /// <param name="userService">注入用戶服務對象。</param>
24         public HomeController(ILogger<HomeController> logger, IUserService userService)
25         {
26             _logger = logger;
27             _userService = userService;
28         }
29 
30         /// <summary>
31         /// 首頁。
32         /// </summary>
33         /// <returns></returns>
34         public IActionResult Index()
35         {
36 
37             #region 通過 Ocelot 網關訪問服務實例。
38 
39             string url = "//localhost:8080/gate/users/all";//Ocelot 集群的Nginx反向代理地址
40 
41             #endregion
42 
43             string content = InvokeAPI(url);
44             this.ViewBag.Users = Newtonsoft.Json.JsonConvert.DeserializeObject<IEnumerable<User>>(content);
45             Console.WriteLine($"This is {url} Invoke.");
46             
47             #endregion
48 
49             return View();
50         }
51 
52 
53         /// <summary>
54         /// 封裝 HttpClient 實例，提供 Http 調用。
55         /// </summary>
56         /// <param name="url">http url 的地址。</param>
57         /// <returns>返回結束數據，格式：JSON。</returns>
58         public static string InvokeAPI(string url)
59         {
60             using (HttpClient client = new HttpClient())
61             {
62                 HttpRequestMessage message = new HttpRequestMessage();
63                 message.Method = HttpMethod.Get;
64                 message.RequestUri = new Uri(url);
65                 var result = client.SendAsync(message).Result;
66                 string conent = result.Content.ReadAsStringAsync().Result;
67                 return conent;
68             }
69         }
70     }
71 }

 1 using PatrickLiu.MicroService.Models;
 2 using System.Collections.Generic;
 3 
 4 namespace PatrickLiu.MicroService.Interfaces
 5 {
 6     /// <summary>
 7     /// 用戶服務的介面定義。
 8     /// </summary>
 9     public interface IUserService
10     {
11         /// <summary>
12         /// 查找指定主鍵的用戶實例對象。
13         /// </summary>
14         /// <param name="id">用戶的主鍵。</param>
15         /// <returns>返回查找到的用戶實例對象。</returns>
16         User FindUser(int id);
17 
18         /// <summary>
19         /// 獲取所有用戶的實例集合。
20         /// </summary>
21         /// <returns>返回所有的用戶實例。</returns>
22         IEnumerable<User> UserAll();
23     }
24 }

 1 using System;
 2 
 3 namespace PatrickLiu.MicroService.Models
 4 {
 5     /// <summary>
 6     /// 用戶模型。
 7     /// </summary>
 8     public class User
 9     {
10         /// <summary>
11         /// 獲取或者設置用戶主鍵。
12         /// </summary>
13         public int ID { get; set; }
14 
15         /// <summary>
16         /// 獲取或者設置用戶姓名。
17         /// </summary>
18         public string Name { get; set; }
19 
20         /// <summary>
21         /// 獲取或者設置用戶帳號名稱。
22         /// </summary>
23         public string Account { get; set; }
24 
25         /// <summary>
26         /// 獲取或者設置用戶密碼。
27         /// </summary>
28         public string Password { get; set; }
29 
30         /// <summary>
31         /// 獲取或者設置用戶的電子郵箱地址。
32         /// </summary>
33         public string Email { get; set; }
34 
35         /// <summary>
36         /// 獲取或者設置用戶角色。
37         /// </summary>
38         public string Role { get; set; }
39 
40         /// <summary>
41         /// 獲取或者設置用戶的登錄時間。
42         /// </summary>
43         public DateTime LoginTime { get; set; }
44     }
45 }

 1 using PatrickLiu.MicroService.Interfaces;
 2 using PatrickLiu.MicroService.Models;
 3 using System;
 4 using System.Collections.Generic;
 5 using System.Linq;
 6 
 7 namespace PatrickLiu.MicroService.Services
 8 {
 9     /// <summary>
10     /// 實現用戶服務介面的實現類型。
11     /// </summary>
12     public class UserService : IUserService
13     {
14         private IList<User> dataList;
15 
16         /// <summary>
17         /// 初始化類型的實例
18         /// </summary>
19         public UserService()
20         {
21             dataList = new List<User>()
22             { new User {ID=1,Name="黃飛鴻",Account="HuangFeiHong",Password="HuangFeiHong123456",Email="[email protected]", Role="Admin", LoginTime=DateTime.Now },
23             new User {ID=2,Name="洪熙官",Account="HongXiGuan",Password="HongXiGuan54667",Email="[email protected]", Role="Admin", LoginTime=DateTime.Now.AddDays(-5) },
24             new User {ID=3,Name="方世玉",Account="FangShiYu",Password="FangShiYu112233",Email="[email protected]", Role="Admin", LoginTime=DateTime.Now.AddDays(-30) },
25             new User {ID=4,Name="苗翠花",Account="MiaoCuiHua",Password="MiaoCuiHua887766",Email="[email protected]", Role="Admin", LoginTime=DateTime.Now.AddDays(-90) },
26             new User {ID=5,Name="嚴詠春",Account="YanYongChun",Password="YanYongChun09392",Email="[email protected]", Role="Admin", LoginTime=DateTime.Now.AddMinutes(-50) }};
27         }
28 
29         /// <summary>
30         /// 查找指定主鍵的用戶實例對象。
31         /// </summary>
32         /// <param name="id">用戶的主鍵。</param>
33         /// <returns>返回查找到的用戶實例對象。</returns>
34         public User FindUser(int id)
35         {
36             return dataList.FirstOrDefault(user => user.ID == id);
37         }
38 
39         /// <summary>
40         /// 獲取所有用戶的實例集合。
41         /// </summary>
42         /// <returns>返回所有的用戶實例。</returns>
43         public IEnumerable<User> UserAll()
44         {
45             return dataList;
46         }
47     }
48 }

  1 using System;
  2 using System.Collections.Generic;
  3 using System.Linq;
  4 using System.Threading;
  5 using Microsoft.AspNetCore.Authorization;
  6 using Microsoft.AspNetCore.Mvc;
  7 using Microsoft.Extensions.Configuration;
  8 using Microsoft.Extensions.Logging;
  9 using PatrickLiu.MicroService.Interfaces;
 10 using PatrickLiu.MicroService.Models;
 11 
 12 namespace PatrickLiu.MicroService.ServiceInstance.Controllers
 13 {
 14     /// <summary>
 15     /// 用戶的 API 類型。
 16     /// </summary>
 17     [Route("api/[controller]")]
 18     [ApiController]    
 19     public class UsersController : ControllerBase
 20     {
 21         #region 私有欄位
 22 
 23         private readonly ILogger<UsersController> _logger;
 24         private readonly IUserService _userService;
 25         private IConfiguration _configuration;
 26 
 27         #endregion
 28 
 29         #region 構造函數
 30 
 31         /// <summary>
 32         /// 初始化該類型的新實例。
 33         /// </summary>
 34         /// <param name="logger">日誌記錄器。</param>
 35         /// <param name="userService">用戶服務介面。</param>
 36         /// <param name="configuration">配置服務。</param>
 37         public UsersController(ILogger<UsersController> logger, IUserService userService, IConfiguration configuration)
 38         {
 39             _logger = logger;
 40             _userService = userService;
 41             _configuration = configuration;
 42         }
 43 
 44         #endregion
 45 
 46         #region 實例方法
 47 
 48         /// <summary>
 49         /// 獲取一條記錄
 50         /// </summary>
 51         /// <param name="id"></param>
 52         /// <returns></returns>
 53         [HttpGet]
 54         [Route("Get")]
 55         public User Get(int id)
 56         {
 57             return _userService.FindUser(id);
 58         }
 59 
 60         /// <summary>
 61         /// 獲取所有記錄。
 62         /// </summary>
 63         /// <returns></returns>
 64         [HttpGet]
 65         [Route("All")]
 66         //[Authorize]
 67         public IEnumerable<User> Get()
 68         {
 69             Console.WriteLine($"This is UsersController {this._configuration["port"]} Invoke");
 70 
 71             return this._userService.UserAll().Select((user => new User
 72             {
 73                 ID = user.ID,
 74                 Name = user.Name,
 75                 Account = user.Account,
 76                 Password = user.Password,
 77                 Email = user.Email,
 78                 Role = $"{this._configuration["ip"]}：{this._configuration["port"]}",
 79                 LoginTime = user.LoginTime
 80             })); ;
 81         }
 82 
 83         /// <summary>
 84         /// 超時處理
 85         /// </summary>
 86         /// <returns></returns>
 87         [HttpGet]
 88         [Route("Timeout")]
 89         public IEnumerable<User> Timeout()
 90         {
 91             Console.WriteLine($"This is Timeout Start");
 92             //超時設置。
 93             Thread.Sleep(3000);
 94 
 95             Console.WriteLine($"This is Timeout End");
 96 
 97             return this._userService.UserAll().Select((user => new User
 98             {
 99                 ID = user.ID,
100                 Name = user.Name,
101                 Account = user.Account,
102                 Password = user.Password,
103                 Email = user.Email,
104                 Role = $"{this._configuration["ip"]}：{this._configuration["port"]}",
105                 LoginTime = user.LoginTime
106             })); ;
107         }
108 
109         #endregion
110     }
111 }

 1 using Consul;
 2 using Microsoft.Extensions.Configuration;
 3 using Microsoft.Extensions.Hosting;
 4 using System;
 5 
 6 namespace PatrickLiu.MicroService.ServiceInstance.Utilities
 7 {
 8     /// <summary>
 9     /// Consul 靜態擴展類。
10     /// </summary>
11     public static class ConsulExtension
12     {
13         /// <summary>
14         ///類型初始化器，初始化 Consul 網址和數據中心。
15         /// </summary>
16         static ConsulExtension()
17         {
18             Uri = new Uri("//localhost:8500");
19             DataCenter = "dc1";
20         }
21 
22         /// <summary>
23         /// 獲取或者設置 Consul 的網址。
24         /// </summary>
25         public static Uri Uri { get; set; }
26 
27         /// <summary>
28         /// 獲取或者設置數據中心。
29         /// </summary>
30         public static string DataCenter { get; set; }
31 
32         /// <summary>
33         /// 向 Consul 服務中心註冊服務實例。
34         /// </summary>
35         /// <param name="configuration">配置對象。</param>
36         /// <param name="consulServiceName">在 Consul 服務中心註冊的服務類別名稱，多個實例的 ID 可以屬於一個服務類別名稱。</param>
37         /// <param name="serviceID">服務實例的主鍵值，必須唯一。</param>
38         public static void ConsulRegist(this IConfiguration configuration,string consulServiceName, string serviceID)
39         {
40             if (string.IsNullOrEmpty(consulServiceName) || string.IsNullOrWhiteSpace(consulServiceName))
41             {
42                 throw new ArgumentNullException("consulServiceName is null");
43             }
44             if (string.IsNullOrEmpty(serviceID) || string.IsNullOrWhiteSpace(serviceID))
45             {
46                 throw new ArgumentNullException("serviceID is null.");
47             }
48 
49             using (ConsulClient client = new ConsulClient(config =>
50             {
51                 config.Address = Uri;
52                 config.Datacenter = DataCenter;
53             }))
54             {
55                 string ip = configuration["ip"];
56                 int port = int.Parse(configuration["port"]);
57                 int weight = string.IsNullOrWhiteSpace(configuration["weight"]) ? 1 : int.Parse(configuration["weight"]);
58 
59                 client.Agent.ServiceRegister(new AgentServiceRegistration()
60                 {
61                     ID = serviceID,
62                     Name = consulServiceName,
63                     Address = ip,
64                     Port = port,
65                     Tags = new string[] { weight.ToString() },
66                     Check = new AgentServiceCheck()
67                     {
68                         Interval = TimeSpan.FromSeconds(12),
69                         HTTP = $"//{ip}:{port}/API/Health/Index",
70                         Timeout = TimeSpan.FromSeconds(5),
71                         DeregisterCriticalServiceAfter = TimeSpan.FromSeconds(20)
72                     }
73                 }).Wait();
74                 Console.WriteLine($"註冊服務：{ip}:{port}--Weight:{weight}");
75             };                       
76         }
77 
78         /// <summary>
79         /// 向 Consul 服務中心註銷服務實例。
80         /// </summary>
81         /// <param name="applicationLifetime">配置對象。</param>
82         /// <param name="serviceID">服務實例的主鍵值，必須唯一。</param>
83         public static void ConsulDown(this IHostApplicationLifetime applicationLifetime, string serviceID)
84         {
85             if (string.IsNullOrEmpty(serviceID) || string.IsNullOrWhiteSpace(serviceID))
86             {
87                 throw new ArgumentNullException("serviceID is null");
88             }
89             applicationLifetime.ApplicationStopped.Register(() =>
90             {
91                 using (var consulClient = new ConsulClient(config => { config.Address = Uri; config.Datacenter = DataCenter; }))
92                 {
93                     Console.WriteLine("服務已經退出");
94                     consulClient.Agent.ServiceDeregister(serviceID);
95                 }
96             });
97         }
98     }
99 }

 1 using Consul;
 2 using Microsoft.AspNetCore.Builder;
 3 using Microsoft.AspNetCore.Hosting;
 4 using Microsoft.Extensions.Configuration;
 5 using Microsoft.Extensions.DependencyInjection;
 6 using Microsoft.Extensions.Hosting;
 7 using PatrickLiu.MicroService.Interfaces;
 8 using PatrickLiu.MicroService.ServiceInstance.Utilities;
 9 using PatrickLiu.MicroService.Services;
10 using System;
11 using System.Security.Policy;
12 
13 namespace PatrickLiu.MicroService.ServiceInstance
14 {
15     /// <summary>
16     /// 應用程式啟動配置
17     /// </summary>
18     public class Startup
19     {
20         /// <summary>
21         /// 構造函數注入配置對象
22         /// </summary>
23         /// <param name="configuration">配置實例</param>
24         public Startup(IConfiguration configuration)
25         {
26             Configuration = configuration;
27         }
28 
29         /// <summary>
30         /// 獲取配置實例。
31         /// </summary>
32         public IConfiguration Configuration { get; }
33 
34         /// <summary>
35         /// 配置注入對象。
36         /// </summary>
37         /// <param name="services"></param>
38         public void ConfigureServices(IServiceCollection services)
39         {
40             //其他程式碼省略
41             services.AddSingleton<IUserService, UserService>();
42         }
43 
44         /// <summary>
45         /// 配置 HTTP 處理管道。
46         /// </summary>
47         /// <param name="app">應用程式對象。</param>
48         /// <param name="env">環境對象。</param>
49         /// <param name="applicationLifetime">應用程式生命周期的對象。</param>
50         public void Configure(IApplicationBuilder app, IWebHostEnvironment env,IHostApplicationLifetime applicationLifetime)
51         {
52             //其他程式碼省略
53             #region Consul 註冊
54 
55             string serviceID = $"Service:{Configuration["ip"]}:{Configuration["port"]}---{Guid.NewGuid()}";
56             string consuleServiceName = "PatrickLiuService";
57             
58             //註冊服務。
59             Configuration.ConsulRegist(consuleServiceName,serviceID);
60 
61             //註銷服務
62             applicationLifetime.ConsulDown(serviceID);
63 
64             #endregion
65         }
66     }
67 }