Orleans解决并发之痛(三):集群
Orleans本身的设计是一个分布式的框架,多个Silo构成集群,Grains分布在多个Silo中。一旦一个Silo挂了,原来归属这个Silo的Grains会自动在其他Silo中激活。生产环境下还是需要以集群方式来部署。
cluster
在Orleans解决并发之痛(二):Grain状态文章中提到内存存储State是不靠谱的,同样,以内存方式存储集群中Silo的成员关系也是不靠谱的,所以本文使用SQL Server来做Silo的成员关系存储,以内存方式存储成员关系存在主节点之说,其他节点的启动必须依赖主节点的启动状态,但以Azure Table、SQL Server 、ZooKeeper、Consul 等存储成员关系,所有的Silo都是平等的,不需要等待谁。
之前在Orleans解决并发之痛(一):单线程Demo中是以内存存储集群成员关系的,有兴趣可以返回查看。
这篇文章的Demo是Orleans解决并发之痛(二):Grain状态的基础上完成的,所以在原来代码的基础上做一些调整即可。我们会启动3个Silo,构建成一个集群环境。实际上提供3个配置文件即可,配置文件稍做修改就可实现。
Silo配置文件
OrleansConfiguration1.xml:
<?xml version="1.0" encoding="utf-8" ?>
<OrleansConfiguration xmlns="urn:orleans"><Globals><SystemStore SystemStoreType="SqlServer" DeploymentId="OrleansTest" DataConnectionString="Server=.;Database=OrleansStorage;User ID=sa;Password=123456;"/><StorageProviders><Provider Type="Orleans.Storage.AdoNetStorageProvider"Name="OrleansStorage"AdoInvariant="System.Data.SqlClient"DataConnectionString="Server=.;Database=OrleansStorage;User ID=sa;Password=123456;"/></StorageProviders></Globals><Defaults><Networking Address="localhost" Port="11111" /><ProxyingGateway Address="localhost" Port="30000" /></Defaults>
</OrleansConfiguration>
OrleansConfiguration2.xml和OrleansConfiguration3.xml除了Networking 、ProxyingGateway 配置有所区别,其他完全一样。
OrleansConfiguration2.xml:
<Networking Address="localhost" Port="11112" />
<ProxyingGateway Address="localhost" Port="30001" />
OrleansConfiguration3.xml:
<Networking Address="localhost" Port="11113" />
<ProxyingGateway Address="localhost" Port="30002" />
这次配置文件中引入了一个SystemStore节点:
SystemStoreType:存储的类型;如:AzureTable、SqlServer、ZooKeeper等;
DeploymentId:部署的唯一Id标识,具有相同的DeploymentId的Silo会加入一个集群中;
DataConnectionString:连接字符串;
3台Silo启动成功后,在OrleansStorage库的OrleansMembershipTable表中会记录下成员关系:
systemStore
Client配置文件
ClientConfiguration.xml:
<?xml version="1.0" encoding="utf-8" ?>
<ClientConfiguration xmlns="urn:orleans"><SystemStore SystemStoreType ="SqlServer"DeploymentId="OrleansTest"DataConnectionString="Data Source=.;Database=OrleansStorage;User ID=sa;Password=123456;" AdoInvariant="System.Data.SqlClient" />
</ClientConfiguration>
Client通过DeploymentId标识连接Silo集群。具体最终调用那个Silo完成方法的调用,由其内部调配。当某一台Silo挂了,Grain会重新在另一个Silo上激活,达到高可用状态。
Client的测试代码:
我们用一个死循环,创建很多Grain,来观察Silo控制台的输出效果
var random = new Random();
while (true)
{Thread.Sleep(1000);var grainId = random.Next().ToString();var grain = GrainClient.GrainFactory.GetGrain<IPersonGrain>("Test-" + grainId);grain.SayHelloAsync();
}
测试结果:
从控制台输出结果来开,每台Silo上Grain的分配还是比较均匀的
Test Result
当杀掉一个Silo后,服务依然是正常运行,具体Grain是否重新被分配有兴趣可以测试一下:
Test Result2
参考链接:
Actor模型
Orleans
案例Demo-OrleansCluster
关文章:
.NET的Actor模型:Orleans
微软分布式云计算框架Orleans(1):Hello World
微软分布式云计算框架Orleans(2):容灾与集群(1)
Aaron Stannard谈Akka.NET 1.1
使用Akka.net开发第一个分布式应用
Orleans入门例子
Orleans例子再进一步
Orleans稍微复杂的例子—互动
Orleans简单配置
Orleans配置---持久化
Orleans—一些概念
Orleans的集群构建
Oleans集群之Consul再解释
Orleans解决并发之痛(一):单线程
Orleans解决并发之痛(二):Grain状态
原文地址:http://www.jianshu.com/p/fdf4b3456039
.NET社区新闻,深度好文,微信中搜索dotNET跨平台或扫描二维码关注
Orleans解决并发之痛(三):集群相关推荐
- Orleans解决并发之痛(五):Web API
通过前面几篇文章的介绍,可能会疑问怎么在实际开发中调用Grain,之前Demo的Client都是基于控制台应用程序,实际开发下可能是基于Web Form.Web API.MVC......,由于一时短 ...
- Orleans解决并发之痛(四):Streams
Orleans 提供了 Stream扩展编程模型.此模型提供了一套API,使处理流更简单和更健壮.Stream默认提供了两种Provider,不同的流类型可能使用不同的Provider来处理,Simp ...
- Orleans解决并发之痛(二):Grain状态
Grains是Orleans应用程序的构建块,它们是彼此孤立的原子单位,分布的,持久的, 一个典型的Grain是有状态和行为的一个单实例,每个Grain实例的在单线程内执行,Grain之间共享数据通过 ...
- Orleans解决并发之痛(一):单线程
程序在运行过程中有时会莫名其妙出现代码的某些约束或者执行结果和理想状况不一样,正常逻辑怎么会出现这样的情况?到底发生了什么?好像见了鬼!瞬间好无助. 谁来救救我 大多数出现正常逻辑很难解释的时候,我们 ...
- 【Flnik】解决提交程序到flink集群的异常:Could not complete snapshot 3 for operator Source...
一. 情况描述 之前一直在IDEA中运行Flink程序,程序也都很顺利的跑通.但是当把程序打包发布到集群上运行便遇到了一些情况: bin/flink run -m hadoop102:8081 -c ...
- 解决sentinel结合nacos实现集群限流(嵌入式)
本文将为您介绍什么是集群流控,如何使用阿里的开源项目 Sentinel实现动态配置的集群流控的详细内容,以下是详情内容,希望我们能共同学习进步 Why? 为什么要用集群流控? 相对于单机流控而言,我们 ...
- 三 Ceph集群搭建
Ceph集群 集群组件 Ceph集群包括Ceph OSD,Ceph Monitor两种守护进程. Ceph OSD(Object Storage Device): 功能是存储数据,处理数据的复制.恢复 ...
- Nacos2.0.3版本线上bug导致整个集群挂掉从而导致业务系统挂掉的解决办法
文章目录 @[toc] 一.问题 二.解决办法 三.项目升级demo及项目nacos配置 3.1 dubbo-demo-producer生产者端项目POM配置 3.2 dubbo-demo-consu ...
- Orleans的集群构建
听闻一周前,微软公布了.net core2.0,以及各种各样的其他core2.0.大家都很兴奋.微妈的诚意真是满满的.这次开源势头让我感觉到了微妈的技术实力之雄厚.我在这里祝福C#越来越好.细心的人似 ...
最新文章
- 增加CentOS File Descriptors
- python详细安装教程linux-Linux下python3.7.0安装教程
- MySQL中int、char、varchar的性能浅谈
- vue从入门到精通之进阶篇(三)axios
- JavaScript | JSON基本格式
- 李国杰院士:国内开源社区的崛起需要一个过程
- 如何将Springboot项目成功部署到linux服务器上?
- 2019沙雕失误瞬间!哈哈哈哈笑出猪叫...
- 解决 jupyter-lab 安装插件后无法使用的问题(重新安装插件无法使用)
- Java从零开始(4)——入门项目
- navicat for mysql 数据传输_如何利用Navicat for MySQL数据库进行数据传输
- oracle怎么下载安装,Oracle数据库下载与安装的完整步骤
- PHPWAMP强行脱离依赖,在系统缺失必备组件或DLL受损的情况下依然能正常运行
- Intel SGX远程认证【SGX手册截图】
- 山东标梵讲解如何在HTML文档中使用CSS样式表?
- 序贯蒙特卡洛的粒子简并性问题
- C# CAD操作之定位实体位置(视图操作缩放)
- php显示汉字,在php中如何显示汉字?
- 计算机组成原理试题和答案2017,20177自考计算机组成原理试题及答案.doc
- ArcGIS Pro基于遥感影像使用深度学习地物识别评估植被健康情况(教程)