從零開始使用Dapr簡化微服務(wù)的示例
序言
現(xiàn)有的微服務(wù)模式需要再業(yè)務(wù)代碼中集成大量基礎(chǔ)設(shè)施模塊，比如注冊中心，服務(wù)發(fā)現(xiàn)，服務(wù)調(diào)用鏈路追蹤，請求熔斷，重試限流等等，使得系統(tǒng)過于臃腫重量級。
Dapr作為新一代微服務(wù)模式，使用sidecar模式，簡化了現(xiàn)有微服務(wù)系統(tǒng)代碼，將基礎(chǔ)設(shè)施層以sidecar模式分離，使得開發(fā)人員更集中于業(yè)務(wù)邏輯編寫。
本文以net6和dapr1.5為基礎(chǔ)，搭建一個dapr的簡單使用示例。
1、安裝Docker
Dapr的運行依賴于Docker環(huán)境。
作為學(xué)習(xí)環(huán)境，使用Centos 7系統(tǒng)安裝Docker。
安裝Docker推薦使用daocloud一鍵安裝命令：
curl -sSL https://get.daocloud.io/docker | sh
安裝完成后運行命令：
[root@localhost ~]# docker -v Docker version 20.10.11, build dea9396
顯示對應(yīng)的Docker版本即安裝成功。
2、安裝Dapr CLI
官方解釋：Dapr CLI 是您用于各種 Dapr 相關(guān)任務(wù)的主要工具。 您可以使用它來運行一個帶有Dapr sidecar的應(yīng)用程序， 以及查看sidecar日志、列出運行中的服務(wù)、運行 Dapr 儀表板。
下載Dapr CLI
wget -q https://raw.githubusercontent.com/dapr/cli/master/install/install.sh -O - | /bin/bash
驗證安裝情況
dapr -v
輸出以下內(nèi)容即安裝成功。
CLI version: 1.5.0 Runtime version: 1.5.0
由于國內(nèi)網(wǎng)絡(luò)問題，使用官方的Dapr安裝方法一般會遇到各種問題，因此把dapr下載下來，通過腳本進行安裝。
修改hosts文件
vi /etc/hosts 140.82.114.4 github.com 199.232.69.194 github.global.ssl.fastly.net 140.82.114.9 codeload.github.com
刷新緩存
yum install -y nscd service nscd restart
首先需要安裝Git，然后執(zhí)行以下命令：
git clone -v https://gitee.com/Two-Twoone/dapr-installer.git cd dapr-installer/ ./install.sh
雖然還是很慢，但是總比下不了好多了。
上面命令啟動了幾個容器，運行下列操作來驗證：
[root@localhost dapr-installer]# docker ps --format "table {{.ID}}\t{{.Names}}\t{{.Ports}}"
CONTAINER ID NAMES PORTS
a0565f609846 dapr_placement 0.0.0.0:50005->50005/tcp, :::50005->50005/tcp
c392f5cf7a18 dapr_redis 0.0.0.0:6379->6379/tcp, :::6379->6379/tcp
2ee68c450b29 dapr_zipkin 9410/tcp, 0.0.0.0:9411->9411/tcp, :::9411->9411/tcp
3、安裝Net6 SDK
rpm -Uvh https://packages.microsoft.com/config/rhel/7/packages-microsoft-prod.rpm yum update yum install dotnet-sdk-6.0
4、創(chuàng)建應(yīng)用程序
創(chuàng)建2個項目分別為 product，cart 引用Dapr
dotnet add package Dapr.AspNetCore
Program.cs中對 的 AddDapr 調(diào)用將 DaprClient 類注冊到 ASP.NET Core注入系統(tǒng)。 注冊客戶端后，現(xiàn)在可以將 的實例注入服務(wù)代碼， DaprClient 以與 Dapr sidecar、構(gòu)建基塊和組件進行通信。
builder.Services.AddControllers().AddDapr();
4.1、服務(wù)調(diào)用
在微服務(wù)系統(tǒng)中，服務(wù)與服務(wù)間的調(diào)用必不可少，難點主要集中在服務(wù)所在位置，發(fā)生錯誤時如何重試，負(fù)載均衡等問題。
Dapr中使用sidecar 作為服務(wù)的反向代理模塊來解決這些問題。
prodcut項目增加下列代碼
[Route("api/[controller]")]
[ApiController]
public class ProductController : ControllerBase
{
private ILogger<ProductController> _logger;
public ProductController(ILogger<ProductController> logger)
{
_logger = logger;
}
private static readonly List<string> products = new List<string> { "aa", "bb", "cc", "dd", "ee", "ff", "gg", "hh", "ii", "jj", "kk", "ll", "mm", "nn" };
[HttpGet]
public ActionResult Get()
{
_logger.LogInformation($"調(diào)用了獲取商品方法");
string[] temps = new string[5];
for (int i = 0; i < 5; i++)
{
Random random = new Random(Guid.NewGuid().GetHashCode());
temps[i] = products[random.Next(0, products.Count - 1)];
}
return Ok( temps);
}
}
# 啟動Product 項目 dapr run --app-id ProductDemo --app-port 5010 --dapr-http-port 7015 -- dotnet /root/www/product/Dapr.Product.Sample.dll --urls http://*:5010
cart項目增加下列代碼，dapr支持http，grpc調(diào)用方式，這里以常用的webapi為例，使用http方式調(diào)用。
InvokeMethodAsync方法中appid對應(yīng)的就是dapr run 中的appid，無需關(guān)系調(diào)用地址。
[Route("api/[controller]")]
[ApiController]
public class CartController : ControllerBase
{
private readonly DaprClient _daprClient;
private readonly ILogger<CartController> _logger;
public CartController(DaprClient daprClient, ILogger<CartController> logger)
{
_daprClient = daprClient;
_logger = logger;
}
[HttpGet]
[Route("GetProducts")]
public async Task<IActionResult> GetProducts()
{
_logger.LogInformation($" Cart 獲取商品");
var products = await _daprClient.InvokeMethodAsync<List<string>>(HttpMethod.Get, "ProductDemo", "/api/Product/GetAll");
return Ok(products);
}
}
將程序上傳到linux服務(wù)器，運行程序
# 啟動 Cart 項目 dapr run --app-id CartDemo --app-port 5020 --dapr-http-port 7025 -- dotnet /root/www/cart/Dapr.Cart.Sample.dll --urls http://*:5020
調(diào)用接口，可以看到Cart項目幾乎沒有代碼入侵就實現(xiàn)了接口調(diào)用。
[root@localhost ~]# curl -X 'GET' 'http://192.168.2.110:5020/api/Cart/GetProducts' ["aa","bb","cc","dd","ee","ff","gg","hh","ii","jj","kk","ll","mm","nn"]
Dapr內(nèi)部使用了mDns進行了服務(wù)注冊發(fā)現(xiàn)和負(fù)載均衡，部署多個product后調(diào)用，可以看到輪詢調(diào)用效果。
在自承載模式下，Dapr 使用 mDNS 查找它。在 Kubernetes 模式下運行時，Kubernetes DNS 服務(wù)確定地址。
在調(diào)用失敗和瞬態(tài)錯誤的情況下，服務(wù)調(diào)用會執(zhí)行自動重試，Dapr 默認(rèn)是開啟了重試，所以接口不支持冪等是十分危險的行為。
4.2、發(fā)布訂閱
? 發(fā)布訂閱模式，主要是用于微服務(wù)間基于消息進行相互通信。你可能也會說，這也要拿出來說，我搞個RabbitMQ/Kafka就是了，
原來我們都會根據(jù)使用的組件引入不同的sdk，不同的消息隊列監(jiān)聽、消費模式還不一樣。
? Dapr 提供了一個構(gòu)建基塊，可顯著簡化實現(xiàn)發(fā)布/訂閱功能，從而和底層基礎(chǔ)設(shè)施解耦，編寫業(yè)務(wù)邏輯時不需要關(guān)心是什么消息隊列。
再Program中添加發(fā)布訂閱支持
app.UseCloudEvents();
app.UseEndpoints(endpoints =>
{
endpoints.MapSubscribeHandler();
});
訂閱消息，使用Topic特性，傳遞pubsub和主題名稱
[Topic("pubsub", "newUser")]
public ActionResult subUserInfo(UserInfo us)
{
_logger.LogInformation($"接收到訂閱消息 id:{us.id} name:{us.name},age:{us.age},sex:{us.sex}");
return Ok("處理完畢");
}
發(fā)布消息，使用dapr公開方法PublishEventAsync，傳遞pubsub和主題名稱，以及消息體
[HttpPost]
public async Task<IActionResult> PubUserInfo(UserInfo us)
{
await _daprClient.PublishEventAsync("pubsub", "newUser", us);
return Ok();
}
消息發(fā)布訂閱組件支持RabbitMQ，Redis，Kafka等。
4.3、狀態(tài)管理
?Dapr 默認(rèn)使用 Redis 作為狀態(tài)存儲。它也支持MongoDB，PostgreSQL，SQL Server等。
它不會對上層暴露底層用的那個中間件，也就是說在不同環(huán)境下可以使用同一套代碼來使用不同的中間件。
[HttpPost]
[Route("SaveUserList")]
public async Task<IActionResult> SaveUserList()
{
var temps = new List<UserInfo>
{
new UserInfo("小紅",1,true,Guid.NewGuid().ToString()),
new UserInfo("小黃",1,true,Guid.NewGuid().ToString()),
new UserInfo("小藍",1,true,Guid.NewGuid().ToString())
};
await _daprClient.SaveStateAsync("statestore", "UserList", temps);
return Ok(1);
}
[HttpGet]
[Route("GetUserList")]
public async Task<IActionResult> GetUserList()
{
var list = await _daprClient.GetStateAsync<List<UserInfo>>("statestore", "UserList");
return Ok(list);
}
[HttpGet]
[Route("DeleteUserList")]
public async Task<IActionResult> DeleteUserList()
{
await _daprClient.DeleteStateAsync("statestore", "UserList");
return Ok(1);
}
public record UserInfo(string name, int age, bool sex, string id);
4.4、鏈路追蹤
傳統(tǒng)微服務(wù)中,要實現(xiàn)鏈路追蹤，對代碼的侵入強。
Dapr 在 Sidecar 中添加了一個 http/grpc中間件。攔截所有應(yīng)用程序流量，并自動注入關(guān)聯(lián) ID 以跟蹤分布式事務(wù)。
使用 Zipkin 協(xié)議進行分布式跟蹤，無需代碼檢測，使用可配置的跟蹤級別自動跟蹤所有流量。
5、總結(jié)
?本文只是對Dapr做了一個簡單示例，對各個組件具體的實現(xiàn)原理沒有做過多深入講解。
?Dapr區(qū)別于傳統(tǒng)微服務(wù)框架最大的優(yōu)點就是Sidecar 。以前的微服務(wù)框架都需要代碼項目引用微服務(wù)相關(guān)的一些類庫，無論是服務(wù)注冊發(fā)現(xiàn)、熔斷、配置等都是要調(diào)用對應(yīng)類庫實現(xiàn)，這些類庫是運行在微服務(wù)的進程中的，因此這些類庫都需要使用和業(yè)務(wù)代碼一樣（或者兼容）的語言來開發(fā)，因此是比較重的。
?而Sidecar 這種模式，把“注冊發(fā)現(xiàn)、熔斷、配置”等這些微服務(wù)的功能都剝離到一個和業(yè)務(wù)代碼的進程相伴而行的獨立進程中，業(yè)務(wù)代碼通過http或者grpc等方式和這個Sidecar 進程通訊來完成微服務(wù)的相關(guān)服務(wù)的調(diào)用。
?顯而易見，在Sidecar 這種模式中，業(yè)務(wù)代碼中只有極少數(shù)和Sidecar 進程通訊的代碼，因此非常輕量級。這樣Sidecar 進程中的服務(wù)可以獨立升級，模塊可以自由組合，不會干擾業(yè)務(wù)代碼。同時由于Sidecar 的進程是獨立的進程，業(yè)務(wù)代碼和Sidecar 進程通訊是采用http、grpc這樣語言無關(guān)的協(xié)議，因此業(yè)務(wù)代碼可以采用任何語言來進行開發(fā)。
到此這篇關(guān)于從零開始使用Dapr簡化微服務(wù)的文章就介紹到這了,更多相關(guān)Dapr簡化微服務(wù)內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
本文主要介紹了Nginx docker容器版部署訪問403的解決,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-12-12
Docker 安裝 Nginx 并掛載目錄的實現(xiàn)示例
本文介紹了如何使用Docker拉取Nginx鏡像、創(chuàng)建容器,并設(shè)置掛載目錄,掛載目錄用于將容器內(nèi)配置文件與主機關(guān)聯(lián),便于直接修改影響容器配置,感興趣的可以了解一下2024-10-10
這篇文章主要給大家介紹了關(guān)于CentOS7 Docker防火墻的簡單配置方法，以及總結(jié)了docker在centos7下的一些坑，文中通過示例代碼介紹的非常詳細，需要的朋友可以參考借鑒，下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧。2017-12-12
文章介紹了如何使用Docker搭建一個Samba共享文件系統(tǒng),首先安裝了Docker容器,然后下載并拉取了Samba鏡像,在本地創(chuàng)建了一個目錄用于掛載,啟動容器并添加了SMB用戶名和密碼,驗證掛載成功,最后總結(jié)了主要參數(shù)2025-03-03
Docker可以讓開發(fā)者打包他們的應(yīng)用以及依賴包到一個輕量級、可移植的容器中,然后發(fā)布到任何流行的 Linux 機器上,也可以實現(xiàn)虛擬化,下面這篇文章主要給大家介紹了關(guān)于docker安裝及部署的相關(guān)資料,需要的朋友可以參考下2022-08-08
Docker?Memcached?容器化部署的實現(xiàn)
memcached是一套分布式的高速緩存系統(tǒng)，本文主要介紹了Docker?Memcached?容器化部署的實現(xiàn)，具有一定的參考價值，感興趣的可以了解一下2024-03-03
Docker容器間通訊直接路由方式實現(xiàn)網(wǎng)絡(luò)通訊
今天小編就為大家分享一篇關(guān)于Docker容器間通訊直接路由方式實現(xiàn)網(wǎng)絡(luò)通訊，小編覺得內(nèi)容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2019-02-02
docker網(wǎng)絡(luò)及部署集群和打包鏡像問題
這篇文章主要介紹了docker網(wǎng)絡(luò)及部署集群和打包鏡像問題，本文給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2022-08-08
在本篇文章里我們給各位整理的是一篇關(guān)于Docker容器跨主機通信中直接路由方式詳解內(nèi)容，有需要的朋友們可以參考下。2019-10-10
Windows11上Docker Desktop鏡像源配置失效排查與解決方案
這篇文章主要介紹了Windows11上Docker Desktop鏡像源配置失效排查與解決方案,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2025-04-04