开发工具:VS2017 如果下载不能打开,可能您的VS版本较低 C#完整代码,下载即可使用,在项目中可以直接使用。 自带客户与服务端心跳包验证。 客户端掉线,服务器自动响应。 所有均为事件与封装完全分享。代码高度简洁。 服务端断线与重启,客户端自动重新连接。 客户端消息异常,快速响应事件。 客户端与服务端,调用DOME完全分离。 不管是学习TCP/IP通信,还是项目中使用TCP/IP均为首选
2025-05-22 09:44:37 1003KB TCP/IP 异步通信 异步服务端 异步客户端
1
什么是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
基于paho mqtt c 版本的客户端SDK,采用异步模式,连接,订阅等采用回调模式。支持断网重连。
2022-06-16 15:05:06 1.08MB mqtt 客户端 异步模式 断网重连
1
1.Unity完整TCP、UDP服务器请查看NetworkServer资源。 2.完整TCP、UDP客户端,采用高效 ProtoBuf协议传送,包含完整的消息编解码、组装,UDP数据分包、组包处理。 3.完整心跳检测。 4.完整的数据接收缓冲区,发送队列,采用异步模型。 5.包含客户端登陆、管理。 6.支持外网,需做服务器映射。 7.支持UWP平台,HoloLens。
2022-04-19 13:09:05 106KB unity tcp/ip udp ProtoBuf
使用socket类做的一个客户端 一个服务器 可以开启多个客户端来连接服务器,对于刚学习网络编程的人来说是个好的例子 O(∩_∩)O~,在客户端里面还有个按钮叫做一直发送里面是tcp客户端用多线程同步发送1000条数据到服务器
2021-11-23 00:26:36 96KB socket TCP 异步 客户端
1
用于Swoole的Hprose简介Hprose是高性能的远程对象服务引擎。 它是用于Swoole的现代,轻便,跨语言,跨平台,面向对象,高性能,远程动态通信Hprose简介Hprose是高性能远程对象服务引擎。 它是一种现代,轻便,跨语言,跨平台,面向对象,高性能,远程动态通信中间件。 它不仅易于使用,而且功能强大。 您只需要一点时间来学习,然后就可以使用它轻松地构建跨语言跨平台的分布式应用程序系统。 Hprose支持多种编程语言,例如:AAuto Quicker ActionScrip
2021-11-04 11:45:59 39KB C/C++ Networking and Internet
1