devbox
你好赵伟
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

.Net6中使用Nacos做服务和配置_net6 nacos

作者：你好赵伟 | 2024-07-24 19:20:57

赞

踩

net6 nacos

1、添加api项目并注册到服务中心

        nacos服务端需要自己下载安装，请参照官方文档

        地址：什么是 Nacos

        下载完成后，按照文档提示启动Nacos，在浏览器查看控制台:Nacos本地链接

        1.1、根据需要安装nuget

  1. dotnet add package nacos-sdk-csharp
  2. dotnet add package nacos-sdk-csharp.AspNetCore
  3. dotnet add package nacos-sdk-csharp.Extensions.Configuration
  4. dotnet add package nacos-sdk-csharp.YamlParser
  5. dotnet add package nacos-sdk-csharp.IniParser

        1.2、在program.cs中添加服务

  1.  
  2. //builder
  3. using Nacos.AspNetCore.V2;
  4.  
  5.  
  6. var builder = WebApplication.CreateBuilder(args);
  7. {
  8.     // Add services to the container.
  9.     // Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
  10.     builder.Services.AddEndpointsApiExplorer();
  11.     builder.Services.AddSwaggerGen();
  12.     builder.Services.AddMvc(option => { option.EnableEndpointRouting = false; });
  13.  
  14.     // nacos server v1.x or v2.x
  15.     builder.Services.AddNacosAspNet(builder.Configuration);
  16.  
  17. }
  18.  
  19.  
  20.  
  21. //app
  22. var app = builder.Build();
  23. {
  24.     // Configure the HTTP request pipeline.
  25.     if (app.Environment.IsDevelopment())
  26.     {
  27.         app.UseSwagger();
  28.         app.UseSwaggerUI();
  29.     }
  30.  
  31.     app.UseMvcWithDefaultRoute();
  32.     app.Run();
  33. }

        1.3、在appsettings.json中添加nacos节点

  1.   "nacos": {
  2.     "EndPoint": "",
  3.     "ServerAddresses": [ "http://localhost:8848" ],
  4.     "DefaultTimeOut": 15000,
  5.     "Namespace": "public",
  6.     "ListenInterval": 1000,
  7.     "ServiceName": "BaseApi", // your service name
  8.     "GroupName": "DEFAULT_GROUP",
  9.     "ClusterName": "DEFAULT",
  10.     "Ip": "",
  11.     "PreferredNetworks": "", // select an IP that matches the prefix as the service registration IP
  12.     "Port": 0,
  13.     "Weight": 100,
  14.     "RegisterEnabled": true,
  15.     "InstanceEnabled": true,
  16.     "Ephemeral": true,
  17.     "Secure": false,
  18.     "AccessKey": "",
  19.     "SecretKey": "",
  20.     "UserName": "",
  21.     "Password": "",
  22.     "ConfigUseRpc": true,
  23.     "NamingUseRpc": false,
  24.     "NamingLoadCacheAtStart": "",
  25.     "LBStrategy": "WeightRandom", //WeightRandom WeightRoundRobin
  26.     "Metadata": {
  27.       "aa": "bb",
  28.       "cc": "dd"
  29.     }

        1.4、添加你的api控制器

  1. using Microsoft.AspNetCore.Mvc;
  2.  
  3. namespace BaseApi
  4. {
  5.     [Route("api/[controller]")]
  6.     [ApiController]
  7.     public class ValuesController : ControllerBase
  8.     {
  9.         private readonly Nacos.V2.INacosNamingService _svc;
  10.  
  11.         public ValuesController(Nacos.V2.INacosNamingService svc)
  12.         {
  13.             _svc = svc;
  14.         }
  15.  
  16.         [HttpGet]
  17.         public string Get()
  18.         {
  19.             return "Ok~" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:ffff");
  20.         }
  21.  
  22.         /// <summary>
  23.         /// 从nacos中获取服务并选一个调用
  24.         /// </summary>
  25.         /// <returns></returns>
  26.         [HttpGet("test")]
  27.         public async Task<string> Test()
  28.         {
  29.             // 这里需要知道被调用方的服务名
  30.             var instance = await _svc.SelectOneHealthyInstance("BaseApi", "DEFAULT_GROUP");
  31.             var host = $"{instance.Ip}:{instance.Port}";
  32.  
  33.             var baseUrl = instance.Metadata.TryGetValue("secure", out _)
  34.                 ? $"https://{host}"
  35.                 : $"http://{host}";
  36.  
  37.             if (string.IsNullOrWhiteSpace(baseUrl))
  38.             {
  39.                 return "empty";
  40.             }
  41.  
  42.             var url = $"{baseUrl}/api/values";
  43.  
  44.             using var client = new HttpClient();
  45.             var result = await client.GetAsync(url);
  46.             return await result.Content.ReadAsStringAsync();
  47.         }
  48.     }
  49. }

        1.5、启动你的Net6服务，可以启动多个(本地的话用不同的端口)

        1.6、打开Nacos服务端，查看服务注册的服务

                nacos服务地址：Nacos本地链接

        可以看到已注册到服务中心

        1.7、测试服务调用

 2、配置管理和手动注册服务

        2.1、配置管理

        2.1.1、添加配置服务

  1.  //用于管理Nacos的配置的信息
  2.     builder.Services.AddNacosV2Config(x =>
  3.     {
  4.         x.ServerAddresses = new System.Collections.Generic.List<string> { "http://localhost:8848/" };
  5.         x.EndPoint = "";
  6.         x.Namespace = "public";
  7.         x.UserName = "nacos";
  8.         x.Password = "nacos";
  9.  
  10.         // this sample will add the filter to encrypt the config with AES.
  11.         x.ConfigFilterAssemblies = new System.Collections.Generic.List<string> { "BaseApi" };
  12.  
  13.         // swich to use http or rpc
  14.         x.ConfigUseRpc = false;
  15.     });

        2.1.2添加配置管理控制器

  1. using Microsoft.AspNetCore.Mvc;
  2. using Nacos.V2;
  3.  
  4. namespace UpService
  5. {
  6.  
  7.     /// <summary>
  8.     /// 操作配置信息
  9.     /// </summary>
  10.     [ApiController]
  11.     [Route("api/[controller]")]
  12.     public class ConfigController : ControllerBase
  13.     {
  14.         private readonly IConfiguration _configuration;
  15.         private readonly INacosConfigService _svc;
  16.  
  17.         public ConfigController(IConfiguration configuration, INacosConfigService svc)
  18.         {
  19.             _configuration = configuration;
  20.             _svc = svc;
  21.         }
  22.  
  23.         [HttpGet("get")]
  24.         public async Task<string> Get(string dataId= "default-dev.yaml")
  25.         {
  26.             var res = await _svc.GetConfig(dataId, "DEFAULT_GROUP", 3000).ConfigureAwait(false);
  27.  
  28.             return res ?? "empty config";
  29.         }
  30.  
  31.         [HttpGet("set")]
  32.         public async Task<bool> Put(string dataId = "default-dev.yaml")
  33.         {
  34.             var res = await _svc.PublishConfig(dataId, "DEFAULT_GROUP", "test:demo-0001").ConfigureAwait(false);
  35.  
  36.             return res; 
  37.         }
  38.  
  39.         [HttpGet("listener")]
  40.         public async Task<string> Listen(string dataId = "default-dev.yaml")
  41.         {
  42.             await _svc.AddListener(dataId, "DEFAULT_GROUP", _configListen).ConfigureAwait(false);
  43.             return "ok";
  44.         }
  45.  
  46.         [HttpGet("unlistener")]
  47.         public async Task<string> UnListen(string dataId = "default-dev.yaml")
  48.         {
  49.             await _svc.RemoveListener(dataId, "DEFAULT_GROUP", _configListen).ConfigureAwait(false);
  50.  
  51.             return "ok";
  52.         }
  53.  
  54.         private static readonly CusConfigListen _configListen = new ();
  55.  
  56.         public class CusConfigListen : Nacos.V2.IListener
  57.         {
  58.             public void ReceiveConfigInfo(string configInfo)
  59.             {
  60.                 System.Console.WriteLine("config updating " + configInfo);
  61.             }
  62.         }
  63.     }
  64. }

        2.2手动注册服务管理服务

        2.2.1、添加手动注册服务管理服务

  1.  //用于添加临时服务
  2.     builder.Services.AddNacosV2Naming(x =>
  3.     {
  4.         x.ServerAddresses = new System.Collections.Generic.List<string> { "http://localhost:8848/" };
  5.         x.EndPoint = "";
  6.         x.Namespace = "public";
  7.  
  8.         // swich to use http or rpc
  9.         x.NamingUseRpc = false;
  10.     });

        2.2.2、添加手动注册服务控制器

  1. using Microsoft.AspNetCore.Mvc;
  2. using Nacos.V2.Utils;
  3.  
  4. namespace UpService
  5. {
  6.  
  7.     /// <summary>
  8.     /// 手动操作服务实例-增删监听
  9.     /// </summary>
  10.     public class NamingController : Controller
  11.     {
  12.  
  13.         private readonly Nacos.V2.INacosNamingService _client;
  14.  
  15.         public NamingController(Nacos.V2.INacosNamingService client)
  16.         {
  17.             _client = client;
  18.         }
  19.  
  20.         // GET n/g
  21.         [HttpGet("GetAllInstances")]
  22.         public async Task<string> GetAllInstances()
  23.         {
  24.             var list = await _client.GetAllInstances("MyService1", false).ConfigureAwait(false);
  25.  
  26.             var res = list.ToJsonString();
  27.  
  28.             return res ?? "GetAllInstances";
  29.         }
  30.  
  31.         // GET n/r
  32.         [HttpGet("RegisterInstance")]
  33.         public async Task<string> RegisterInstance()
  34.         {
  35.             // await _client.RegisterInstance("mysvc", "127.0.0.1", 9635);
  36.             var instance = new Nacos.V2.Naming.Dtos.Instance
  37.             {
  38.                 Ip = "127.0.0.1",
  39.                 Ephemeral = true,
  40.                 Port = 5088,
  41.                 ServiceName = "mysvc2"
  42.             };
  43.  
  44.             await _client.RegisterInstance("MyService1", instance).ConfigureAwait(false);
  45.  
  46.             return "RegisterInstance ok";
  47.         }
  48.  
  49.         // GET n/r2
  50.         [HttpGet("RegisterInstance2")]
  51.         public async Task<string> RegisterInstance2()
  52.         {
  53.             // await _client.RegisterInstance("mysvc", "127.0.0.1", 9635);
  54.             var instance = new Nacos.V2.Naming.Dtos.Instance
  55.             {
  56.                 Ip = "127.0.0.1",
  57.                 Ephemeral = true,
  58.                 Port = 5089,
  59.                 ServiceName = "MyService1"
  60.             };
  61.  
  62.             await _client.RegisterInstance("MyService1", instance).ConfigureAwait(false);
  63.  
  64.             return "RegisterInstance ok";
  65.         }
  66.  
  67.         // GET n/dr
  68.         [HttpGet("DeregisterInstance")]
  69.         public async Task<string> DeregisterInstance()
  70.         {
  71.             // await _client.RegisterInstance("mysvc", "127.0.0.1", 9635);
  72.             var instance = new Nacos.V2.Naming.Dtos.Instance
  73.             {
  74.                 Ip = "127.0.0.1",
  75.                 Ephemeral = true,
  76.                 Port = 9562,
  77.                 ServiceName = "mysvc2"
  78.             };
  79.  
  80.             await _client.DeregisterInstance("mysvc2", instance).ConfigureAwait(false);
  81.  
  82.             return "DeregisterInstance ok";
  83.         }
  84.  
  85.         // GET n/si
  86.         [HttpGet("SelectInstances")]
  87.         public async Task<string> SelectInstances()
  88.         {
  89.             var list = await _client.SelectInstances("mysvc2", true, false).ConfigureAwait(false);
  90.  
  91.             var res = list.ToJsonString();
  92.  
  93.             return res ?? "SelectInstances ok";
  94.         }
  95.  
  96.         // GET n/gs
  97.         [HttpGet("GetServicesOfServer")]
  98.         public async Task<string> GetServicesOfServer()
  99.         {
  100.             var list = await _client.GetServicesOfServer(1, 10).ConfigureAwait(false);
  101.  
  102.             var res = list.ToJsonString();
  103.  
  104.             return res ?? "GetServicesOfServer";
  105.         }
  106.  
  107.         // GET n/sub
  108.         [HttpGet("Subscribe")]
  109.         public async Task<string> Subscribe()
  110.         {
  111.             await _client.Subscribe("mysvc2", listener).ConfigureAwait(false);
  112.             return "Subscribe";
  113.         }
  114.  
  115.         // GET n/unsub
  116.         [HttpGet("Unsubscribe")]
  117.         public async Task<string> Unsubscribe()
  118.         {
  119.             await _client.Unsubscribe("mysvc2", listener).ConfigureAwait(false);
  120.             return "UnSubscribe";
  121.         }
  122.  
  123.         // NOTE: MUST keep Subscribe and Unsubscribe to use one instance of the listener!!!
  124.         // DO NOT create new instance for each opreation!!!
  125.         private static readonly CusListener listener = new ();
  126.  
  127.         public class CusListener : Nacos.V2.IEventListener
  128.         {
  129.             public Task OnEvent(Nacos.V2.IEvent @event)
  130.             {
  131.                 if (@event is Nacos.V2.Naming.Event.InstancesChangeEvent e)
  132.                 {
  133.                     System.Console.WriteLine("CusListener");
  134.                     System.Console.WriteLine("ServiceName" + e.ServiceName);
  135.                     System.Console.WriteLine("GroupName" + e.GroupName);
  136.                     System.Console.WriteLine("Clusters" + e.Clusters);
  137.                     System.Console.WriteLine("Hosts" + e.Hosts.ToJsonString());
  138.                 }
  139.  
  140.                 return Task.CompletedTask;
  141.             }
  142.         }
  143.     }
  144. }

官方地址：Nacos快速开始

更多信息请查看 博客 或者关注公众号：Z技术

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/你好赵伟/article/detail/876409
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号