微服務(wù)間通信常見的兩種方式

由于微服務(wù)架構(gòu)慢慢被更多人使用后，迎面而來的問題是如何做好微服務(wù)間通信的方案。我們先分析下目前最常用的兩種服務(wù)間通信方案。

gRPC（rpc遠(yuǎn)程調(diào)用）

gRPC-微服務(wù)間通信實踐

• 場景：A服務(wù)主動發(fā)起請求到B服務(wù)，同步方式

• 范圍：只在微服務(wù)間通信應(yīng)用

EventBus（基于消息隊列的集成事件）

• 技術(shù)：NotNetCore.Cap + Rabbitmq + Database

• 場景：A服務(wù)要在B服務(wù)做某件事情后響應(yīng)，異步方式

• 實現(xiàn)：B服務(wù)在完成某件事情后發(fā)布消息，A服務(wù)訂閱此消息

• 范圍：只在微服務(wù)間通信應(yīng)用

通過對比，兩種方式完全不一樣。rpc是類似于http請求的及時響應(yīng)機制，但是比http更輕量、快捷，它更像以前的微軟的WCF，可以自動生成客戶端代碼，充分體現(xiàn)了面向?qū)嶓w對象的遠(yuǎn)程調(diào)用的思想；Eventbus是異步的消息機制，基于cap的思想，不關(guān)心下游訂閱方服務(wù)是否消費成功，保障了主服務(wù)業(yè)務(wù)的流暢性，同時也是一款分布式事務(wù)的實現(xiàn)方案，可以保障分布式架構(gòu)中的數(shù)據(jù)的最終一致性。

我們今天主要介紹CAP在微服務(wù)中的實踐案例。

搭建框架介紹

新建項目

新建解決方案 DotNetCore.Cap.Demo

新建項目 DotNetCore.Cap.Demo.Publisher 消息發(fā)布端

新建項目 DotNetCore.Cap.Demo.Subscriber 消息訂閱端

主要sdk

• 項目框架 netcoreapp 3.1

• 消息隊列選用RabbitMQ

• 數(shù)據(jù)庫存儲選用PostgreSql

根據(jù)實際情況選擇合適的消息隊列和數(shù)據(jù)庫存儲

CAP 支持 Kafka、RabbitMQ、AzureServiceBus 消息隊列：

PM> Install-Package DotNetCore.CAP.Kafka PM> Install-Package DotNetCore.CAP.RabbitMQ PM> Install-Package DotNetCore.CAP.AzureServiceBus

CAP 提供了 Sql Server, MySql, PostgreSQL，MongoDB 作為數(shù)據(jù)庫存儲：

PM> Install-Package DotNetCore.CAP.SqlServer PM> Install-Package DotNetCore.CAP.MySql PM> Install-Package DotNetCore.CAP.PostgreSql PM> Install-Package DotNetCore.CAP.MongoDB

本次demo使用的nuget包如下所示

$ dotnet list package 項目“DotNetCore.Cap.Demo.Publisher”具有以下包引用[netcoreapp3.1]: 頂級包 已請求 已解決 > DotNetCore.CAP 3.1.1 3.1.1> DotNetCore.CAP.PostgreSql 3.1.1 3.1.1> DotNetCore.CAP.RabbitMQ 3.1.1 3.1.1> Microsoft.VisualStudio.Azure.Containers.Tools.Targets 1.10.9 1.10.9> Npgsql.EntityFrameworkCore.PostgreSQL 3.1.4 3.1.4> Npgsql.EntityFrameworkCore.PostgreSQL.Design 1.1.0 1.1.0項目“DotNetCore.Cap.Demo.Subscriber”具有以下包引用[netcoreapp3.1]:頂級包 已請求 已解決> DotNetCore.CAP 3.1.1 3.1.1> DotNetCore.CAP.PostgreSql 3.1.1 3.1.1> DotNetCore.CAP.RabbitMQ 3.1.1 3.1.1> Microsoft.VisualStudio.Azure.Containers.Tools.Targets 1.10.9 1.10.9> Npgsql.EntityFrameworkCore.PostgreSQL 3.1.4 3.1.4> Npgsql.EntityFrameworkCore.PostgreSQL.Design 1.1.0 1.1.0

DotNetCore.Cap.Demo.Publisher 消息發(fā)布端

修改Startup文件

注入dotnetcore.cap組件及數(shù)據(jù)庫上下文

services.AddDbContext<PgDbContext>(p => p.UseNpgsql("數(shù)據(jù)庫連接字符串"));services.AddCap(x =>{//rabbitmq在docker運行時，需要映射兩個端口：5672和15672//5672供程序集訪問//15672供web訪問//默認(rèn)用戶名和密碼為：guest/guestx.UseRabbitMQ(p =>{p.HostName = "localhost";p.Port = 5672;p.UserName = "guest";p.Password = "guest";});x.UseEntityFramework<PgDbContext>();//x.FailedRetryCount = 1;//x.UseDashboard();});

新建Controller作為Publisher

• 構(gòu)造函數(shù)注入DotNetCore.CAP.ICapPublisher

提供了同步和異步的消息發(fā)布方法

• 發(fā)布字符串消息

await _capPublisher.PublishAsync("消息名稱", "消息內(nèi)容");

[HttpGet("string")]public async Task<IActionResult> PublishString(){await _capPublisher.PublishAsync("sample.rabbitmq.demo.string", "this is text!");return Ok();}

• 發(fā)布對象

await _capPublisher.PublishAsync("消息名稱", "消息對象");

[HttpGet("dynamic")]public async Task<IActionResult> PublishDynamic(){await _capPublisher.PublishAsync("sample.rabbitmq.demo.dynamic", new{Name = "xiao gou",Age = 18});return Ok();}

• 分布式事務(wù)場景

當(dāng)需要在數(shù)據(jù)庫操作后，發(fā)布消息出去，DotNetCore.Cap也提供了分布式事務(wù)的解決方案。它擴展的transcation能保證只有在數(shù)據(jù)庫操作和消息發(fā)送都完成后，才提交Commit

[HttpGet("transcation")]public async Task<IActionResult> PublishWithTranscation(){using (var trans = _pgDbContext.Database.BeginTransaction(_capPublisher)){var apiConfig = new ApiConfig{ApiName = "111122",ApiDesc = "223",ReturnType = "1",ReturnExpect = "1",IsAsync = true,OperCode = "999",OperTime = DateTime.Now};await _pgDbContext.ApiConfig.AddAsync(apiConfig);await _pgDbContext.SaveChangesAsync();_capPublisher.Publish("sample.rabbitmq.demo.transcation", apiConfig);trans.Commit();return Ok();}}

DotNetCore.Cap.Demo.Subscriber 消息訂閱端

修改Startup文件

注入dotnetcore.cap組件及數(shù)據(jù)庫上下文

services.AddDbContext<PgDbContext>(p => p.UseNpgsql("數(shù)據(jù)庫連接字符串"));services.AddCap(x =>{//rabbitmq在docker運行時，需要映射兩個端口：5672和15672//5672供程序集訪問//15672供web訪問//默認(rèn)用戶名和密碼為：guest/guestx.UseRabbitMQ(p =>{p.HostName = "localhost";p.Port = 5672;p.UserName = "guest";p.Password = "guest";});x.UseEntityFramework<PgDbContext>();//x.FailedRetryCount = 1;//x.UseDashboard();});

新建Controller作為Subscriber

• 訂閱字符串消息

[NonAction] 標(biāo)簽：Indicates that a controller method is not an action method.

[CapSubscribe] 標(biāo)簽：標(biāo)志此方法為訂閱方法，并以消息名稱匹配發(fā)布端的消息事件

[NonAction][CapSubscribe("sample.rabbitmq.demo.string")]public void SubscriberString(string text){Console.WriteLine($"【SubscriberString】Subscriber invoked, Info: {text}");}

• 訂閱對象消息

方法入?yún)erson即為消息體

[NonAction][CapSubscribe("sample.rabbitmq.demo.dynamic")]public void SubscriberDynamic(dynamic person){Console.WriteLine($"【SubscriberDynamic】Subscriber invoked, Info: {person.Name} {person.Age}");}

新建Service作為Subscriber

• 除了Controller可以作為消息訂閱端外，也可以用繼承自DotNetCore.CAP.ICapSubscribe接口的Service作為訂閱端

• Controller作為訂閱者時，不用繼承ICapSubscribe；Service作為訂閱者時，必須繼承ICapSubscribe

• Controller和Service同時訂閱了一個消息時，只觸發(fā)了Service的消費；若要多個消費，需要在不同的Group下

using DotNetCore.CAP; using System;namespace DotNetCore.Cap.Demo.Subscriber.Services {/// <summary>/// 消費訂閱服務(wù)/// </summary>public class SubscriberService : ICapSubscribe{[CapSubscribe("sample.rabbitmq.demo.string")]public void SubscriberString(string text){Console.WriteLine($"【SubscriberString】Subscriber invoked, Info: {text}");}[CapSubscribe("sample.rabbitmq.demo.dynamic")]public void SubscriberDynamic(dynamic person){Console.WriteLine($"【SubscriberDynamic】Subscriber invoked, Info: {person.Name} {person.Age}");}[CapSubscribe("sample.rabbitmq.demo.object")]public void SubscriberObject(Person person){Console.WriteLine($"【SubscriberObject】Subscriber invoked, Info: {person.Name} {person.Age}");}[CapSubscribe("sample.rabbitmq.demo.trans")]public void SubscriberTrans(ApiConfig apiConfig){Console.WriteLine($"【SubscriberTrans】Subscriber invoked, Info: {apiConfig.Id}");}} }

總結(jié)

• DotNetCore.Cap 是一種異步消息的通信，可以作為微服務(wù)間通信的一種方式

• DotNetCore.Cap 為微服務(wù)架構(gòu)提供了分布式事務(wù)的解決方案，保障了數(shù)據(jù)的最終一致性

• 開發(fā)中，應(yīng)根據(jù)實際業(yè)務(wù)需求和場景，選擇合適可靠的微服務(wù)間通信方案

參考

https://github.com/dotnetcore/CAP/blob/master/README.md
https://book.douban.com/subject/33425123/

Demo 代碼

https://github.com/cailin0630/DotNetCore.Cap.Demo

原文地址：https://www.cnblogs.com/jiangyihz/p/13864245.html

總結(jié)

以上是生活随笔為你收集整理的CAP-微服务间通信实践的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。