NATS

NATS是一个简单、安全、高性能的数字系统、服务和设备通信系统。NATS 是 CNCF 的一部分。

Warning

CAP 5.2.0 以下的版本基于 Request/Response 实现, 现在我们已经基于 JetStream 实现。 查看 https://github.com/dotnetcore/CAP/issues/983 了解更多。

配置

要使用NATS 传输器，你需要安装下面的NuGet包：

PM> Install-Package DotNetCore.CAP.NATS

你可以通过在 Startup.cs 文件中配置 ConfigureServices 来添加配置：

public void ConfigureServices(IServiceCollection services)
{
    services.AddCap(capOptions =>
    {
        capOptions.UseNATS(natsOptions=>{
            //NATS Options
        });
    });
}

NATS 配置

CAP 直接提供的关于 NATS 的配置参数：

NAME	DESCRIPTION	TYPE	DEFAULT
Options	NATS 客户端配置	Options	Options
Servers	服务器Urls地址	string	NULL
ConnectionPoolSize	连接池数量	uint	10
DeliverPolicy	消费消息的策略点（⚠️在8.1.0版本移除，使用ConsumerOptions替代。）	enum	DeliverPolicy.New
StreamOptions	🆕 Stream 配置项	Action	NULL
ConsumerOptions	🆕 Consumer 配置项	Action	NULL

NATS ConfigurationOptions

如果你需要 更多 原生相关的配置项，可以通过 Options 配置项进行设定：

services.AddCap(capOptions => 
{
    capOptions.UseNATS(natsOptions=>
    {
        // NATS options.
        natsOptions.Options.Url="";
    });
});

Options 是 NATS.Client 客户端提供的配置， 你可以在这个链接找到更多详细信息。