netcore 集成 CAP 使用 rabbitMQ集群

集成cap  cap可以简化使用消息中间件 这里使用的是 rabbitMQservices.AddCap(x =>{IConfigurationSection configurationSection = ConfigurationUtil.Configuration.GetSection("RabbitMQ");if (!String.IsNullOrEmpty(configurationSection["HostName"])){x.UseRabbitMQ(options =>{//上一篇中我创建的用户名密码 options.HostName = configurationSection["HostName"];options.UserName = configurationSection["userName"];options.Password = configurationSection["Password"];options.Port = String.IsNullOrEmpty(configurationSection["HostName"])? 5672: int.Parse(configurationSection["Port"]);});}var connectionString = ConfigurationUtil.Configuration.GetSection("ConnectionStrings")["CapMysqlConn"];if (String.IsNullOrEmpty(connectionString)){connectionString = ConfigurationUtil.Configuration.GetSection("ConnectionStrings")["MySqlConn"];}if (String.IsNullOrEmpty(connectionString)){throw new Exception("请配置Cap的数据库连接");}x.UseMySql(connectionString);x.FailedRetryCount = 2;x.FailedThresholdCallback = failed =>{var logger = failed.ServiceProvider.GetService<ILogger<ServiceInit>>();logger.LogError($@"A message of type {failed.MessageType} failed after executing {x.FailedRetryCount} several times, requiring manual troubleshooting. Message name: {failed.Message.GetName()}");};});

配置：

"RabbitMQ": {//单节点//"HostName": "XXX",//多节点"HostName": "XXX,XXX,192.168.XX.XX","Port": 5672,"UserName": "XXXX","Password": "XXX"}

netcore 集成 CAP 使用 rabbitMQ集群相关推荐

Rabbitmq集群，镜像队列和分布式原理
前言基于前两次的分享会,结合rabbitmq相关知识,做一个小结.说明一致性的设计思想,在此说明相关的基础理论. CAP定理: 在计算机科学里,CAP定理又被称作布鲁尔定理(Brewer theor ...
k8s集群搭建普若米修斯，监控rabbitmq集群
背景这几天在做关于容器化部署的工作,这里做一个简单的分享,给容器内的rabbitmq集群+一个普若米修斯监控服务先决条件: 拥有一个k8s集群(一主2从) k8s集群上已经搭建了rabbitmq集 ...
RabbitMQ集群
6. RabbitMQ集群 6.1 集群形式 RabbiMQ 是用 Erlang 开发的, 集群非常方便, 因为 Erlang 天生就是一门分布式语言, 但其本身并不支持负载均衡. RabbitMQ ...
RabbitMQ 学习（九）-- RabbitMQ 集群
RabbitMQ 集群最开始我们介绍了如何安装及运行 RabbitMQ 服务,不过这些是单机版的,无法满足目前真实应用的要求.如果 RabbitMQ 服务器遇到内存崩溃.机器掉电或者主板故障等情况, ...
RabbitMQ集群部署教程（Linux）
一.简介 Messaging that just works - RabbitMQ是一个开源的遵循AMQP协议实现的基于Erlang语言编写,支持多种客户端(语言),用于在分布式系统中存储消息,转发消 ...
hbase1.1.1 连接集群_除了HAProxy，RabbitMQ集群还可以这样用
全网最简单的安装手册 // 安装erlang wget https://packagecloud.io/install/repositories/rabbitmq/erlang/script.rpm. ...
Docker：搭建RabbitMQ集群
RabbitMQ原理介绍(一) RabbitMQ安装使用(二) RabbitMQ添加新用户并支持远程访问(三) RabbitMQ管理命令rabbitmqctl详解(四) RabbitMQ两种集群模式配 ...
CentOS7安装RabbitMQ集群
实验环境 RabbitMQ 集群 server1.example.com IP: 10.10.10.11 Node: disk server2.example.com IP: 10. ...
Ubuntu安装rabbitMQ及单机版rabbitMQ集群配置
安装过程 1.sudo vim /etc/apt/sources.list 打开sources.list添加下面的内容在结尾处 deb http://www.rabbitmq.com/debian/ ...

netcore 集成 CAP 使用 rabbitMQ集群

netcore 集成 CAP 使用 rabbitMQ集群相关推荐

最新文章

热门文章