in client/Apache.ShenYu.Client/Registers/ShenyuZookeeperRegister.cs [126:139]
private async Task RegisterURIAsync(string contextPath, URIRegisterDTO registerDTO)
{
string uriNodeName = BuildURINodeName(registerDTO);
string uriPath = RegisterPathConstants.BuildURIParentPath(registerDTO.rpcType, contextPath);
string realNode = RegisterPathConstants.BuildRealNode(uriPath, uriNodeName);
await _zkClient.CreateWithParentAsync(uriPath, null, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
string nodeData = JsonConvert.SerializeObject(registerDTO, Formatting.None, new JsonSerializerSettings
{
NullValueHandling = NullValueHandling.Ignore
});
_nodeDataMap[realNode] = nodeData;
await _zkClient.CreateOrUpdateAsync(realNode, Encoding.UTF8.GetBytes(nodeData), ZooDefs.Ids.OPEN_ACL_UNSAFE,
CreateMode.EPHEMERAL);
}