什么是ZooKeeper ? ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。 ZooKeeper的目标就是封装好复杂易出错的关键服务,将简单易用的接口和性能高效、功能稳定的系统提供给用户。 Rabbit ZooKeeper Extensions 该项目使用了 Apache ZooKeeper .NET async Client 组件,除提供了基本的zk操作,还额外封装了常用的功能以便让.net开发者更好的使用zookeeper。 提供的功能 session过期重连 永久watcher 递归删除节点 递归创建节点 跨平台(支持.net core) 使用说明 创建连接 IZookeeperClient client = new ZookeeperClient(new ZookeeperClientOptions         {             ConnectionString = "172.18.20.132:2181",             BasePath = "/", //default value             ConnectionTimeout = TimeSpan.FromSeconds(10), //default value             SessionTimeout = TimeSpan.FromSeconds(20), //default value             OperatingTimeout = TimeSpan.FromSeconds(60), //default value             ReadOnly = false, //default value             SessionId = 0, //default value             SessionPasswd = null //default value         }); 创建节点 var data = Encoding.UTF8.GetBytes("2016"); //快速创建临时节点 await client.CreateEphemeralAsync("/year", data); await client.CreateEphemeralAsync("/year", data, ZooDefs.Ids.OPEN_ACL_UNSAFE); //快速创建永久节点 await client.CreatePersistentAsync("/year", data); await client.CreatePersistentAsync("/year", data, ZooDefs.Ids.OPEN_ACL_UNSAFE); //完整调用 await client.CreateAsync("/year", data, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT_SEQUENTIAL); //递归创建 await client.CreateRecursiveAsync("/microsoft/netcore/aspnet", data, CreateMode.PERSISTENT); 获取节点数据 IEnumerable data = await client.GetDataAsync("/year"); Encoding.UTF8.GetString(data.ToArray()); 获取子节点 IEnumerable children= await client.GetChildrenAsync("/microsoft"); 判断节点是否存在 bool exists = await client.ExistsAsync("/year"); 删除节点 await client.DeleteAsync("/year"); //递归删除 bool success = await client.DeleteRecursiveAsync("/microsoft"); 更新数据 Stat stat = await client.SetDataAsync("/year", Encoding.UTF8.GetBytes("2017")); 订阅数据变化 await client.SubscribeDataChange("/year", (ct, args) => {     IEnumerable currentData = args.CurrentData;     string path = args.Path;     Watcher.Event.EventType eventType = args.Type;     return Task.CompletedTask; }); 订阅子节点变化 await client.SubscribeChildrenChange("/microsoft", (ct, args) => {     IEnumerable currentChildrens = args.CurrentChildrens;     string path = args.Path;     Watcher.Event.EventType eventType = args.Type;     return Task.CompletedTask; }); FAQ 什么时候会触发 "SubscribeDataChange" 事件 ? 在以下情况下会触发通过 "SubscribeDataChange" 方法订阅的事件: 节点被创建 节点被删除 节点数据发生改变 zk连接重连成功 什么时候会触发 "SubscribeChildrenChange" 事件 ? 在以下情况下会触发通过 "SubscribeChildrenChange" 方法订阅的事件: 节点被创建 节点被删除 节点子节点发生改变 zk连接重连成功 如何在 "xxxxChange" 事件中区分节点的状态 ? 在事件触发参数会有个类型为 "EventType" 的属性 "Type",通过该属性可以清楚的区分出节点变更的原因。 为什么要写这个程序,它与 "ZooKeeperEx" 有什么区别 ? 官方提供的组件,只提供了基本的api,在正常的zk使用情景中需要做非常复杂的事情,滋生出很多额外的代码并且不能保证其执行的正确性。 在java语言中也有对官方zk进行封装的包 ZKClient,当前组件也是参考了这个项目。具体组件包提供了什么功能请参考 "提供的功能" 这一节。   更新介绍,详见作者博客:http://www.cnblogs.com/ants/p/6209773.html    标签:.net
2024-04-24 09:19:55 29KB 开源项目
1
使用教程 百度一下 有很多
2022-12-04 16:21:58 438KB unity excel
1
VMProtectUltimate3.5.0 新版的vm壳工具,已和谐!支技asp.net,C#.net等,强壳。很好的保护自己的软件
2021-11-30 01:36:27 39.54MB vmprotect 加壳 3.5 支持net
1
本版本是根据最新更新的de4do4源码生成的,亲测可脱更多的Net Reactor5.0 的壳。 不一定保证一定能成功,但是测试了两个 .NET Reactor(4.8-4.9)[-]的壳,都成功了。介意者慎入。
2021-07-23 22:43:14 2.25MB [.NET] 最新版de4dot
1
html转pdf,支持大型html转pdf,内存消耗少,转换速度快,IronPdf.Core_2019.6.5.0破解版 支持net core 2.0及以上。
2021-07-11 23:46:14 107.68MB Html Pdf
1
C#调用SAP RFC(Remote Function Call)是企业级应用程序集成中的常见需求,尤其是在.NET框架下进行SAP系统交互时。NCO(.NET Connector for SAP)是SAP提供的一个.NET接口,允许C#等.NET语言直接与SAP系统进行通信。在“C#调用SAP RFC的nco库文件,支持Net.4.0”这个主题中,我们将深入探讨如何使用NCO库来实现这一功能。 NCO库是SAP NetWeaver RFC SDK的一个.NET封装,它提供了丰富的API,使得开发人员可以方便地在.NET环境中调用SAP的RFC函数。这个库文件特别强调对.NET Framework 4.0的支持,这意味着它可以运行在更现代的开发环境中,同时享受.NET 4.0带来的性能优化和新特性。 在提供的压缩包中,通常会有两个版本的安装包,一个是X86(32位),另一个是X64(64位)。这是由于不同的操作系统和.NET环境可能需要对应位数的库。在安装这两个包时,你需要根据你的系统和项目配置选择合适的版本。安装完成后,会在指定的安装目录下找到四个重要的DLL文件,它们是NCO库的核心组件,包括: 1. `sapnco.dll`:这是SAP的RFC客户端库,用于连接到SAP系统并执行RFC调用。 2. `sapnco_utils.dll`:包含了辅助工具函数,如日志记录和错误处理。 3. `sapnwrfc.dll`:这是SAP的RFC服务器端库,但在这个上下文中,它可能是为了模拟或测试环境而提供。 4. `sapnwo.dll`:这是Web服务客户端库,如果需要通过SOAP接口与SAP交互,可能需要用到。 要将这些库文件整合到你的C#项目中,你需要按照以下步骤操作: 1. 将这四个DLL文件添加到你的项目引用中。右键点击项目,选择“添加引用”,然后浏览到安装目录找到这些文件。 2. 引用SAP命名空间,例如: ```csharp using SAP.Middleware.Connector; ``` 3. 创建一个RFC连接配置,并初始化RfcRepository对象: ```csharp IRfcConfiguration config = RfcConfigParameters.GetDefault(); config.ApplicationServer = "your_server"; config.SystemNumber = "your_system_number"; config.Client = "your_client"; config.User = "your_user"; config.Password = "your_password"; config.Language = "your_language"; RfcRepository repo = new RfcRepository(config); ``` 4. 加载需要调用的RFC函数,例如: ```csharp IRfcFunction function = repo.CreateFunction("BAPI_USER_GET_DETAIL"); ``` 5. 设置函数参数,执行调用,并获取结果: ```csharp function.SetValue("USERNAME", "your_username"); IRfcStructure userDetail = function.Invoke(repo).GetTable("USERDETAIL"); ``` 通过以上步骤,你可以成功地在C#中使用NCO库调用SAP的RFC函数。不过,实际应用中还需要考虑异常处理、连接池管理、事务控制等复杂情况,以及可能的性能优化策略。在进行SAP系统集成时,确保遵循最佳实践,同时注意SAP系统的安全性和稳定性。
2019-12-21 22:12:51 8.04MB
1
Aspose.Cells for.net是一款可扩展并且功能丰富的组件。有了它,开发人员能导出数据,格式化电子表格到最精细的水平,导入图像、图表,创建图表、应用和计算复杂公式,保存为各种格式 没测试过,好用不好用.请给留言.
2019-12-21 20:39:50 3.15MB Aspose 破解版 net co
1