.netcore 分布式事务CAP2.6之控制台使用
上一编讲了cap2.6的快速入门,这次我们来讲讲在控制台中如何使用cap2.6。因为cap2.6的内存模式目前已经可以使用了,相关组件已经更新,所以这次我们以简单的内存模式为例。
1:创建项目
创建一个名叫CAPConsoleDemo的 “控制台应用(.NET Core)” 程序,.netcore版本要求在2.2或以上。
2:添加相关引用
在nuget中添加 DotNetCore.CAP DotNetCore.CAP.InMemoryStorage Savorboard.CAP.InMemoryMessageQueue Microsoft.Extensions.Hosting 等组件的引用。
3:构建常规Host主机
常规host主机是.net core 2.1中引入的,本质是移除了web功能的webhost,以前webhost的所有依赖注入,生命周期管理,日志管理等都可以在控制台程序中使用。以后webhost都会是基于常规host来实现的。
实现方式也很简单,只要将Programe.cs中改成下面这样就好了
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Savorboard.CAP.InMemoryMessageQueue;
using System; namespace CAPConsoleDemo
{
class Program
{
static void Main(string[] args)
{
CreateHostBuilder(args).Build().Run(); //构建一个常规Host
}
static IHostBuilder CreateHostBuilder(string[] args)
{
var build = new HostBuilder();
build.ConfigureServices((hostContext, services) =>
{
services.AddCap(option => //添加CAP框架
{
option.UseInMemoryStorage(); //使用内存存储
option.UseInMemoryMessageQueue(); //使用内存队列
option.UseDashboard(); //添加监控仪表盘
});
});
return build;
}
}
}
4:添加推送程序
4.1: 添加一个继承自IHostedService的Publish类,并在里面创建一个定时器,每秒推送一次事件。
using DotNetCore.CAP;
using Microsoft.Extensions.Hosting;
using System;
using System.Threading;
using System.Threading.Tasks; namespace CAPConsoleDemo
{
public class Publish : IHostedService
{
private ICapPublisher capPublish; //CAP发布程序
private Timer _timer; //定时器 public Publish(ICapPublisher capPublish) //自动注入CAP程序
{
this.capPublish = capPublish;
} public Task StartAsync(CancellationToken cancellationToken)
{
_timer = new Timer(work, null, TimeSpan.Zero, TimeSpan.FromSeconds()); //每秒运行一次推送任务
return Task.CompletedTask;
}
private void work(object state)
{
capPublish.Publish<string>("Order.Created", DateTime.Now.ToString()); //推送Order.Created事件
Console.WriteLine("推送:" + DateTime.Now.ToString());
} public Task StopAsync(CancellationToken cancellationToken)
{
return Task.CompletedTask;
}
}
}
4.2:在Programe.CreateHostBuilder方法中添加推送服务 services.AddHostedService<Publish>();
4.3:f5运行程序,此时是已经可以正常推送消息了。
5:添加监听服务
5.1:创建一个承继自ICapSubscribe接口的类Events,并监听Order.Created事件,代码如下:
using DotNetCore.CAP;
using System;
using System.Threading.Tasks; namespace ConsoleApp2
{
public class Events : ICapSubscribe
{ [CapSubscribe("Order.Created")] //监听Order.Created事件
public async Task OrderCreatedEventHand(string msg)
{
Console.WriteLine("--接收:"+ msg);
} }
}
5.2: 在在Programe.CreateHostBuilder方法中添加监听服务 services.AddSingleton<ICapSubscribe, Events>();
6:大功造成
F5运行程序,可以看到程序在一边推送一边接收。
7:同一事件,多个服务监听处理。
默认情况下,一个事件只会被一个监听者处理,即使我们创建了多个服务来监听同一事件,也只会有一个服务收到此事件,其它服务是收不到的。那么怎么让多个服务同时处理同一事件呢?答案是使用分组,在添加监听器时使用不同的分组名称。
7.1:我们将Events类中的代码,稍微改动一下,使用两个都监听Order.Created事件的方法,但命名成不同的分组。
using DotNetCore.CAP;
using System;
using System.Threading.Tasks; namespace CAPConsoleDemo
{
public class Events : ICapSubscribe
{ [CapSubscribe("Order.Created", Group = "Group1")] //监听Order.Created事件,并命名为Group1
public async Task OrderCreatedEventHand(string msg)
{
Console.WriteLine("--Group1接收:" + msg);
} [CapSubscribe("Order.Created", Group = "Group2")] //监听Order.Created事件,并命名为Group2
public async Task Group2(string msg)
{
Console.WriteLine("--Group2接收:" + msg);
}
}
}
7.2:F5运行,如下图所示,一次推送事件,两个监听服务都处理了此事件。
示例代码下载:https://pan.baidu.com/s/1X2uCvcLjQ9AiqxMD3CtTcA
最新文章
- Python之路,Day9, 进程、线程、协程篇
- The conversion of a varchar data type to a datetime data type resulted in an out-of-range value
- SSH实例(2)
- pom中定义某jar包的依赖,但并不使用该jar包,那最后部署的应用中会有这个jar包么?
- libc abi.dylib: terminate_handler unexpectedly threw an exception
- druid的安装
- haskell io模块
- Golang的iota的特性
- C++ CheckMenuItem
- java中IO流的操作
- 页面中引入带中文的JS文件乱码问题
- IS---InstallShield第二天
- UITableViewCell性能优化
- next()方法 执行下一个中间件 类似than
- 强联通分量-tarjan算法
- 四十二、Linux 线程——线程同步之条件变量之线程状态转换
- Spring表单验证(Spring Validation)
- log4Net辅助类
- 【 HDU1081 】 To The Max (最大子矩阵和)
- 获取docker容器的ip地址