.netcore微服务——项目搭建

在.NET Core中,微服务是一种架构风格,它将应用程序构造为一组小型服务的集合,这些服务都通过HTTP-based API进行通信。每个服务都是独立部署的,可以用不同的编程语言编写,并且可以使用不同的数据存储技术。

微服务的主要优点包括:

  • 增强容错能力:一个服务的故障不会影响其他服务。

  • 增强弹性:可以根据需求增加或减少服务的实例。

  • 增加弹性:使用更适合的语言或工具。

  • 增加敏捷性:每个服务都可以独立于其他服务进行更新和迭代。

以下是一个简单的例子,展示如何在.NET Core中创建一个简单的微服务。

首先,创建一个ASP.NET Core Web 项目作为客户端,两个ASP.NET Core Web API项目作为服务(产品服务和订单服务),添加docker支持,为产品、订单服务添加一些基础代码,就简单的返回一下 服务名称,当前时间,服务的ip、端口

在Docker中运行服务

安装docker客户端

点击启用或关闭 windows 功能,然后勾选上 Hyper-V 以及适用于 Linux 的 Windows 子系统

 安装完客户端后报错:You are trying to start Docker Desktop but you don't have enough memory. Free some memory or change your settings.这是内存不足导致,可以修改docker的配置文件

 在项目根目录打开PowerShell窗口执行:docker build -t productapi -f ./Product.API/Dockerfile .

 运行容器:执行:docker run -d -p 9050:80 --name productservice productapi

查看运行的容器: 执行:docker ps

 产品服务部署成功。

 产品服务部署好了,下面部署一下订单服务,也是同样的流程:

build镜像:docker build -t orderapi -f ./Order.API/Dockerfile .
运行容器:docker run -d -p 9060:80 --name orderservice orderapi

 订单服务也部署完成了。

 在客户端调用

 客户端新建一个web用来测试,客户端需要http请求服务端接口,所以需要一个http请求客户端,这里使用RestSharp

 新建接口和实现IProductService.cs,IOrderService,ProductService,OrderService,并在program.cs里注入服务。

namespace ProjectCore.MVC.Services
{
    public interface IOrderService
    {
        /// <summary>
        /// 获取产品数据
        /// </summary>
        /// <returns></returns>
        Task<string> GetOrders();
    }
}
namespace ProjectCore.MVC.Services
{
    public interface IProductService
    {
        /// <summary>
        /// 获取产品数据
        /// </summary>
        /// <returns></returns>
        Task<string> GetProducts();
    }
}
using RestSharp;

namespace ProjectCore.MVC.Services
{
    public class OrderService : IOrderService
    {
        public async Task<string> GetOrders()
        {
            string serviceUrl = "http://localhost:9060";
            var Client = new RestClient(serviceUrl);
            var request = new RestRequest("/api/order", Method.Get);
            var reponse = await Client.ExecuteAsync(request);
            return reponse.Content;
        }
    }
}

using RestSharp;

namespace ProjectCore.MVC.Services
{
    public class ProductService : IProductService
    {
        public async Task<string> GetProducts()
        {
            string serviceUrl = "http://localhost:9050";
            var Client = new RestClient(serviceUrl);
            var request = new RestRequest("/api/product", Method.Get);

            var reponse = await Client.ExecuteAsync(request);
            return reponse.Content;
        }
    }
}
builder.Services.AddSingleton<IProductService, ProductService>();
builder.Services.AddSingleton<IOrderService, OrderService>();
//HomeController.cs

using Microsoft.AspNetCore.Mvc;
using ProjectCore.MVC.Models;
using ProjectCore.MVC.Services;
using System.Diagnostics;

namespace ProjectCore.MVC.Controllers
{
    public class HomeController : Controller
    {
        private readonly ILogger<HomeController> _logger;
        private readonly IProductService _productService;
        private readonly IOrderService _orderService;

        public HomeController(ILogger<HomeController> logger, IProductService productService, IOrderService orderService)
        {
            _logger = logger;
            _productService = productService;
            _orderService = orderService;
        }

        public async Task<IActionResult> Index()
        {
            ViewBag.OrderData = await _orderService.GetOrders();
            ViewBag.ProductData = await _productService.GetProducts();
            return View();
        }

        public IActionResult Privacy()
        {
            return View();
        }

        [ResponseCache(Duration = 0, Location = ResponseCacheLocation.None, NoStore = true)]
        public IActionResult Error()
        {
            return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });
        }
    }
}
//Index.cshtml
@{
    ViewData["Title"] = "Home Page";
}

<div class="text-center">
    <h1 class="display-4">Welcome</h1>
    <p>
        @ViewBag.OrderData
    </p>
    <p>
        @ViewBag.ProductData
    </p>
</div>

 F5启动项目:

 将订单服务停止:

 客户端无法获取订单数据了。

这样可以通过简单的集群来解决,部署多个订单实例

docker run -d -p 9061:80 --name orderservice1 orderapi
docker run -d -p 9062:80 --name orderservice2 orderapi
docker run -d -p 9051:80 --name productservice1 productapi
docker run -d -p 9052:80 --name productservice2 productapi

 然后客户端中做个随机访问服务实例:


using RestSharp;

namespace ProjectCore.MVC.Services
{
    public class ProductService : IProductService
    {
        public async Task<string> GetProducts()
        {
            string[] serviceUrl = { "http://localhost:9050","http://localhost:9051", "http://localhost:9052" };
            var Client = new RestClient(serviceUrl[new Random().Next(0, 3)]);
            var request = new RestRequest("/api/product", Method.Get);

            var reponse = await Client.ExecuteAsync(request);
            return reponse.Content;
        }
    }
}
using RestSharp;

namespace ProjectCore.MVC.Services
{
    public class OrderService : IOrderService
    {
        public async Task<string> GetOrders()
        {
            string[] serviceUrl = { "http://localhost:9060", "http://localhost:9061", "http://localhost:9062" };
            //随机访问一个实例
            var Client = new RestClient(serviceUrl[new Random().Next(0, 3)]);
            var request = new RestRequest("/api/order", Method.Get);
            var reponse = await Client.ExecuteAsync(request);
            return reponse.Content;
        }
    }
}

 但是这样也会存在一个问题,如果正好随机到停止的服务就会导致客户端读不到数据。所以将使用Consul来进行服务的注册与发现。

相关推荐

最近更新

  1. Vue3替代vue2就好比自动驾驶代替出租网约车

    2024-07-09 22:00:08       0 阅读
  2. 如何学习计算机

    2024-07-09 22:00:08       0 阅读
  3. 【大数据面试题】38 说说 Hive 怎么行转列

    2024-07-09 22:00:08       0 阅读
  4. 10步职业进阶:全新霍兰德自我提升计划

    2024-07-09 22:00:08       0 阅读
  5. Nginx系列-4 proxy_pass使用和路径拼接问题

    2024-07-09 22:00:08       0 阅读
  6. ASPICE在汽车软件开发中的作用

    2024-07-09 22:00:08       0 阅读

热门阅读

  1. 【Tools】了解人工通用智能 (AGI):未来的智能体

    2024-07-09 22:00:08       5 阅读
  2. HTML最快速最简单

    2024-07-09 22:00:08       5 阅读
  3. 等保测评推动黑龙江数字化转型中的安全保障

    2024-07-09 22:00:08       5 阅读
  4. 嵌入式硬件电路常用设计软件

    2024-07-09 22:00:08       7 阅读
  5. [终端安全]-2 移动终端之硬件安全(SE)

    2024-07-09 22:00:08       6 阅读
  6. Kafka 典型问题与排查以及相关优化

    2024-07-09 22:00:08       6 阅读