当前位置：首页 > wzjs >正文

郑州网站设计制作广州中小企业seo推广运营

wzjs 2025/8/4 7:47:07

郑州网站设计制作,广州中小企业seo推广运营,众创空间那个网站做的好,wordpress商品管理registryMethod 函数详解： 函数目的 registryMethod 是 Provider 类的核心方法，用于向服务注册中心注册服务。注册成功后，服务注册中心会更新内部的服务映射表，建立服务名称到提供者地址的映射关系。执行流程示例场景: 多米…

registryMethod 函数详解：

函数目的

registryMethod 是 Provider 类的核心方法，用于向服务注册中心注册服务。注册成功后，服务注册中心会更新内部的服务映射表，建立服务名称到提供者地址的映射关系。

执行流程示例

场景: 多米诺注册芝士披萨服务

// 多米诺披萨店注册芝士披萨服务
Provider::ptr provider = std::make_shared<Provider>(requestor);
BaseConnection::ptr conn = ConnectionFactory::createConnection("127.0.0.1", 8000);
Address pizzaHost("192.168.1.101", 9001);
bool success = provider->registryMethod(conn, "芝士披萨", pizzaHost);

创建服务注册请求消息：

   auto msg_req = MessageFactory::create<ServiceRequest>();msg_req->setId(UUID::uuid());msg_req->setMType(MType::REQ_SERVICE);msg_req->setMethod("芝士披萨");msg_req->setHost({"192.168.1.101", 9001});msg_req->setOptype(ServiceOptype::SERVICE_REGISTRY);

发送请求并等待响应：

   BaseMessage::ptr msg_rsp;bool ret = _requestor->send(conn, msg_req, msg_rsp);

服务注册中心处理请求（内部过程，不在当前函数中）：

   // 服务注册中心内部的处理逻辑void PDManager::onServiceRequest(const BaseConnection::ptr &conn, const ServiceRequest::ptr &msg) {if (msg->optype() == ServiceOptype::SERVICE_REGISTRY) {std::string method = msg->method();Address host = msg->host();// 更新映射表：将服务方法与提供者关联_providers->addProvider(conn, host, method);// 映射表变化：// 之前: _method_providers["芝士披萨"] = [...]// 之后: _method_providers["芝士披萨"] = [..., {"192.168.1.101", 9001}]// 通知所有关注此服务的客户端_discoverers->onlineNotify(method, host);// 发送响应ServiceResponse::ptr rsp = MessageFactory::create<ServiceResponse>();rsp->setRcode(RCode::RCODE_OK);conn->sendMessage(rsp);}// ...其他操作类型处理...}

处理响应：

   auto service_rsp = std::dynamic_pointer_cast<ServiceResponse>(msg_rsp);if (service_rsp.get() == nullptr) {ELOG("响应类型向下转换失败！");return false;}

检查响应状态

   if (service_rsp->rcode() != RCode::RCODE_OK) {ELOG("服务注册失败，原因：%s", errReason(service_rsp->rcode()).c_str());return false;}

注册成功，映射表更新完成：

   return true;

映射表变化详解

注册前的映射表状态：

   _method_providers = {"夏威夷披萨": [{"192.168.1.102", 9001}],"素食披萨": [{"192.168.1.103", 9001}]}

注册后的映射表状态：

   _method_providers = {"夏威夷披萨": [{"192.168.1.102", 9001}],"素食披萨": [{"192.168.1.103", 9001}],"芝士披萨": [{"192.168.1.101", 9001}]  // 新增映射}

如果是已有服务新增提供者：

   // 如果另一家披萨店也注册提供芝士披萨_method_providers = {"夏威夷披萨": [{"192.168.1.102", 9001}],"素食披萨": [{"192.168.1.103", 9001}],"芝士披萨": [{"192.168.1.101", 9001}, {"192.168.1.104", 9002}]  // 添加新提供者}

注册成功后，服务注册中心还会通过 onlineNotify 通知所有关注"芝士披萨"服务的客户端，有新的服务提供者上线，客户端的 Discoverer 会更新本地缓存的服务提供者列表。

生活中的类比

新餐厅在美食外卖平台注册

想象一下，registryMethod 就像一家新开的餐厅（服务提供者）在美团或饿了么这样的外卖平台（服务注册中心）上注册自己的特色菜品（服务）。

场景：小王的川菜馆注册麻婆豆腐服务

现实生活中的流程：

小王开了一家川菜馆，想在外卖平台上注册提供麻婆豆腐。

小王登录外卖平台商家端，填写注册表单：

店铺名称：小王川菜馆

地址：北京市海淀区中关村大街128号

特色菜品：麻婆豆腐

联系电话：010-12345678

小王提交注册申请，等待平台审核。

外卖平台处理注册请求：

验证小王提供的信息

将"麻婆豆腐"与"小王川菜馆"关联起来

注册成功，平台向小王发送确认消息。

平台更新用户端，现在用户搜索"麻婆豆腐"时，可以看到小王川菜馆。

代码中对应的流程

// 小王川菜馆注册麻婆豆腐服务
Provider::ptr provider = std::make_shared<Provider>(requestor);
BaseConnection::ptr conn = ConnectionFactory::createConnection("delivery-platform.com", 8000);
Address restaurantAddress("北京市海淀区中关村大街128号", 12345678); // 地址和电话
bool success = provider->registryMethod(conn, "麻婆豆腐", restaurantAddress);

映射表变化：

注册前的外卖平台菜品目录：

   菜品目录 = {"宫保鸡丁": ["老张川菜馆", "蜀香小馆"],"水煮鱼": ["蜀香小馆", "渝味轩"]}

注册后的外卖平台菜品目录

   菜品目录 = {"宫保鸡丁": ["老张川菜馆", "蜀香小馆"],"水煮鱼": ["蜀香小馆", "渝味轩"],"麻婆豆腐": ["小王川菜馆"]  // 新增映射}

用户体验变化：

之前用户搜索"麻婆豆腐"时，找不到提供这道菜的餐厅

注册成功后，用户搜索"麻婆豆腐"时，会看到"小王川菜馆"

平台会向已经收藏"麻婆豆腐"的用户推送通知："小王川菜馆现在提供麻婆豆腐啦！"

MethodHost 类详解：

类目的

MethodHost 类是一个服务地址管理器，负责存储和管理能够提供特定服务的所有主机地址，并提供负载均衡功能。它是服务发现机制中的核心组件，用于维护服务提供者列表并支持动态更新。

方法详解与执行流程

场景1: 麻辣烫服务新增提供者

当"老王麻辣烫"店铺上线，开始提供麻辣烫服务：

// 服务注册中心收到上线通知后
MethodHost::ptr methodHost = _method_hosts["麻辣烫"];
methodHost->appendHost({"192.168.1.105", 8080});  // 老王麻辣烫的地址

执行步骤：

获取互斥锁保护共享数据：std::unique_lock<std::mutex> lock(_mutex)

添加新主机到列表：_hosts.push_back({"192.168.1.105", 8080})

映射表变化

   之前: _hosts = [{"192.168.1.101", 8080}]  // 只有小李麻辣烫之后: _hosts = [{"192.168.1.101", 8080}, {"192.168.1.105", 8080}]  // 增加了老王麻辣烫

场景2: 麻辣烫服务提供者下线

当"小李麻辣烫"暂停营业，需要从服务列表中移除：

// 服务注册中心检测到连接断开后
MethodHost::ptr methodHost = _method_hosts["麻辣烫"];
methodHost->removeHost({"192.168.1.101", 8080});  // 小李麻辣烫的地址

执行步骤：

获取互斥锁保护共享数据：std::unique_lock<std::mutex> lock(_mutex)

遍历主机列表查找匹配地址：

   for (auto it = _hosts.begin(); it != _hosts.end(); ++it) {if (*it == {"192.168.1.101", 8080}) {_hosts.erase(it);break;}}

映射表变化：

   之前: _hosts = [{"192.168.1.101", 8080}, {"192.168.1.105", 8080}]之后: _hosts = [{"192.168.1.105", 8080}]  // 只剩下老王麻辣烫

现在客户端调用chooseHost()时，只会返回老王麻辣烫的地址

生活中的例子

想象一个外卖平台的"麻辣烫"分类页面：

初始状态：

页面显示3家麻辣烫店铺：小李、老王、小张

平台后台维护一个麻辣烫店铺列表：[小李, 老王, 小张]

新店开业（appendHost）：

小赵开了一家新麻辣烫店并在平台注册

平台将小赵的店添加到列表：[小李, 老王, 小张, 小赵]

用户刷新页面，现在能看到4家麻辣烫店铺

店铺暂停营业（removeHost）：

小张的店因装修暂停营业

平台将小张的店从列表移除：[小李, 老王, 小赵]

用户刷新页面，现在只能看到3家麻辣烫店铺

负载均衡（chooseHost）：

当用户点击"随机推荐一家"按钮时

平台会轮流推荐列表中的店铺，确保每家店获得平等的展示机会

MethodHost类就像这个平台的后台管理系统，动态维护服务提供者列表，并在客户端请求时提供负载均衡的选择。

Discoverer 类详解：

类目的

Discoverer 类是RPC框架中的服务发现组件，负责查找和管理可用的服务提供者。它的主要职责是：

发现并获取能提供特定服务的主机地址
缓存服务提供者信息，提高查询效率
处理服务上线和下线通知，动态更新服务提供者列表
提供负载均衡功能，在多个服务提供者之间分配请求

核心功能

服务发现（serviceDiscovery方法）：

查找能提供特定服务的主机

先检查本地缓存，如无则向服务注册中心查询

将查询结果缓存起来供后续使用

服务状态变更处理（onServiceRequest方法）：

处理服务上线通知，添加新的服务提供者

处理服务下线通知，移除不可用的服务提供者

调用下线回调函数处理相关资源清理

生活中的例子

Discoverer类就像一个智能外卖APP：

查找服务（serviceDiscovery）：

用户想点一份特定菜品（如"麻辣香锅"）

APP先检查缓存，看是否有最近浏览过的提供该菜品的餐厅

如果没有，则向服务器查询提供"麻辣香锅"的餐厅列表

获取列表后，选择一家餐厅（负载均衡）并缓存整个列表

处理餐厅状态变更（onServiceRequest）：

新餐厅上线：APP收到通知"新餐厅'川香阁'开始提供麻辣香锅"，更新列表

餐厅下线：APP收到通知"'香辣坊'暂停营业"，从列表中移除并取消相关订单

关键组件

_method_hosts：服务方法到主机列表的映射表

键：服务方法名（如"用户认证"、"支付处理"）

值：提供该服务的主机列表（MethodHost对象）

_requestor：负责发送请求和接收响应的组件

_offline_callback：服务下线时的回调函数，用于处理资源清理

_mutex：互斥锁，保护在多线程环境下对共享数据的访问

总结

Discoverer类是分布式系统中服务发现的核心组件，它使客户端能够：

动态发现可用的服务提供者
在多个提供者之间实现负载均衡
实时感知服务提供者的变化
通过本地缓存提高查询效率

这使得系统具有高可用性、可扩展性和弹性，服务提供者可以动态加入或离开系统，而客户端能够自动适应这些变化。

serviceDiscovery 方法详解：

方法目的

serviceDiscovery 是 Discoverer 类的核心方法，用于发现和获取能提供特定服务的主机地址。它首先检查本地缓存，如果没有找到则向服务注册中心发起查询，并将结果缓存起来以供后续使用。

执行流程示例

场景: 用户查找附近的奶茶店

想象一个用户想要点一杯奶茶，使用APP查找附近提供奶茶服务的店铺：

// 用户APP初始化
Discoverer::ptr discoverer = std::make_shared<Discoverer>(requestor, offlineCallback);
BaseConnection::ptr conn = ConnectionFactory::createConnection("service-center.com", 8000);
Address milkTeaShop;
bool found = discoverer->serviceDiscovery(conn, "奶茶", milkTeaShop);

执行步骤：

检查本地缓存：

   {std::unique_lock<std::mutex> lock(_mutex);auto it = _method_hosts.find("奶茶");if (it != _method_hosts.end()) {if (it->second->empty() == false) {milkTeaShop = it->second->chooseHost();return true;  // 成功找到缓存的奶茶店地址}}}

如果APP之前已经查询过奶茶店，会直接从缓存返回一个地址

类似用户打开APP时，显示上次浏览过的奶茶店

缓存未命中，创建服务发现请求：

   auto msg_req = MessageFactory::create<ServiceRequest>();msg_req->setId(UUID::uuid());msg_req->setMType(MType::REQ_SERVICE);msg_req->setMethod("奶茶");msg_req->setOptype(ServiceOptype::SERVICE_DISCOVERY);

类似用户在APP搜索框输入"奶茶"并点击搜索

APP向服务器发送查询请求

发送请求并等待响应：

   BaseMessage::ptr msg_rsp;bool ret = _requestor->send(conn, msg_req, msg_rsp);if (ret == false) {ELOG("服务发现失败！");return false;}

APP向服务中心发送请求

如果网络问题导致请求失败，显示"搜索失败，请检查网络"

处理响应：

   auto service_rsp = std::dynamic_pointer_cast<ServiceResponse>(msg_rsp);if (!service_rsp) {ELOG("服务发现失败！响应类型转换失败！");return false;}if (service_rsp->rcode() != RCode::RCODE_OK) {ELOG("服务发现失败！%s", errReason(service_rsp->rcode()).c_str());return false;}

检查服务器返回的响应是否有效

类似APP收到服务器响应后检查数据格式是否正确

更新本地缓存并返回结果：

   std::unique_lock<std::mutex> lock(_mutex);auto method_host = std::make_shared<MethodHost>(service_rsp->hosts());if (method_host->empty()) {ELOG("%s 服务发现失败！没有能够提供服务的主机！", method.c_str());return false;}milkTeaShop = method_host->chooseHost();_method_hosts["奶茶"] = method_host;return true;

将服务器返回的奶茶店列表保存到本地缓存

从列表中选择一家奶茶店返回给用户

下次用户再查询奶茶店时可以直接从缓存获取

生活中的例子

想象小明想喝奶茶，但不知道附近有哪些奶茶店：

小明先检查记忆（检查本地缓存）：

小明回忆上次是在"一点点"买的奶茶

如果记得路线，他可以直接去那里（缓存命中）

如果忘记了或想尝试新店，需要查询（缓存未命中）

小明问路人（发送服务发现请求）：

"请问附近有奶茶店吗？"

等待路人回答（等待响应）

路人回答（处理响应）：

"有啊，附近有'一点点'、'CoCo'和'喜茶'"

小明记下这些店的位置（更新缓存）

选择一家店（chooseHost）：

小明决定去"CoCo"（负载均衡选择）

下次想喝奶茶时，他已经知道三家店的位置（缓存有效）

这个方法通过本地缓存优化了服务发现的效率，避免了每次都需要向服务中心查询，同时通过动态更新保证了服务信息的及时性。

onServiceRequest 方法详解：

方法目的

onServiceRequest 是 Discoverer 类的方法，用于处理服务状态变更通知，包括服务上线和下线。它是服务动态发现机制的核心，确保客户端能够及时感知服务提供者的变化。

执行流程示例

场景1: 新的披萨店开始提供服务

想象一个新的披萨店"意式风情"开业，开始提供披萨服务：

// 服务注册中心向所有关注披萨服务的客户端发送通知
ServiceRequest::ptr msg = MessageFactory::create<ServiceRequest>();
msg->setMethod("披萨");
msg->setHost({"192.168.1.110", 8080});  // 意式风情披萨店地址
msg->setOptype(ServiceOptype::SERVICE_ONLINE);// 对每个关注披萨服务的客户端
discoverer->onServiceRequest(conn, msg);

执行步骤：

判断操作类型：

   auto optype = msg->optype();  // SERVICE_ONLINEstd::string method = msg->method();  // "披萨"

确认这是一个服务上线通知

获取服务方法名称为"披萨"

加锁保护共享数据：

   std::unique_lock<std::mutex> lock(_mutex);

确保在多线程环境下安全访问和修改数据

处理上线通知：

   if (optype == ServiceOptype::SERVICE_ONLINE) {auto it = _method_hosts.find("披萨");if (it == _method_hosts.end()) {// 如果这是第一家提供披萨服务的店auto method_host = std::make_shared<MethodHost>();method_host->appendHost({"192.168.1.110", 8080});_method_hosts["披萨"] = method_host;} else {// 如果已有其他披萨店，将新店添加到列表it->second->appendHost({"192.168.1.110", 8080});}}

检查是否已有披萨服务的提供者列表

如果没有，创建新列表并添加"意式风情"披萨店

如果已有，将"意式风情"披萨店添加到现有列表

更新后的映射表：

   _method_hosts = {"汉堡": [...],"披萨": [..., {"192.168.1.110", 8080}]  // 添加了新的披萨店}

场景2: 披萨店暂停营业

想象"意式风情"披萨店因设备故障暂停营业：

// 服务注册中心向所有关注披萨服务的客户端发送通知
ServiceRequest::ptr msg = MessageFactory::create<ServiceRequest>();
msg->setMethod("披萨");
msg->setHost({"192.168.1.110", 8080});
msg->setOptype(ServiceOptype::SERVICE_OFFLINE);// 对每个关注披萨服务的客户端
discoverer->onServiceRequest(conn, msg);

执行步骤：

判断操作类型：

   auto optype = msg->optype();  // SERVICE_OFFLINEstd::string method = msg->method();  // "披萨"

确认这是一个服务下线通知

获取服务方法名称为"披萨"

加锁保护共享数据：

   std::unique_lock<std::mutex> lock(_mutex);

处理下线通知：

   if (optype == ServiceOptype::SERVICE_OFFLINE) {auto it = _method_hosts.find("披萨");if (it == _method_hosts.end()) {return;  // 没有找到披萨服务提供者列表，直接返回}it->second->removeHost({"192.168.1.110", 8080});  // 从列表中移除_offline_callback({"192.168.1.110", 8080});  // 调用下线回调}

查找披萨服务的提供者列表

从列表中移除"意式风情"披萨店

调用下线回调函数，可能用于清理与该店相关的连接或缓存

   _method_hosts = {"汉堡": [...],"披萨": [...]  // 移除了"意式风情"披萨店}

生活中的例子

想象一个使用外卖APP的用户：

新餐厅上线通知（SERVICE_ONLINE）：

用户订阅了披萨类别的推送

一家新的披萨店"意式风情"在APP上线

APP推送通知："新店上线！意式风情披萨店开业啦"

APP更新披萨分类页面，添加新店信息

用户下次浏览披萨分类时，能看到这家新店

餐厅下线通知（SERVICE_OFFLINE）：

"意式风情"披萨店因设备故障暂停营业

APP收到下线通知

APP更新披萨分类页面，移除该店或标记为"暂停营业"

如果用户之前有未完成的订单，APP可能会通知用户："您的订单餐厅暂停营业，建议取消订单"（类似_offline_callback的功能）

这个方法确保了客户端能够实时感知服务提供者的变化，提供了动态服务发现的能力，使系统更加灵活和可靠。

查看全文

http://www.dtcms.com/wzjs/213044.html

自己怎么设置网站石家庄抖音seo

建设哪里看卡号seo tdk

设计师常去的素材网站今日军事新闻最新消息

广告设计与制作工作内容青岛seo百科

设计软件网站推荐百度2022年版本下载

平顶山做网站优化培训网站模板

论文网站最经典最常用的网站推广方式

微商城网站建设策划方案关键词挖掘工具有哪些

上海企业网站制作方法湖南百度seo排名点击软件

自己做的网站给人攻击了怎么办友情链接平台站长资源

国外优秀的网站自助建站免费搭建个人网站

网站虚拟机可以自己做吗免费二级域名分发

做菠菜网站代理犯法吗2345网址导航怎么样

官方网站建设案例软文营销的步骤

建设银行网站上的的研究报告班级优化大师下载安装最新版

有趣的网站大全搜索引擎网站提交入口

做视频解析网站犯法吗百度直播间

wordpress cname优化网站seo

厦门工程网站建设个人介绍网页制作

怎么做网站跟域名app推广30元一单平台

平潭综合实验区建设局网站女教师遭网课入侵视频大全

涂料网站建设如何进行网站的宣传和推广

网站asp文件只读做网站公司

电商类网站怎么做 seosaas建站

网站开发哪家公司百度快照什么意思

英文成品网站模板下载创建网站

中企动力做网站的价格网站模板下载

php大型网站开发视频百度指数支持数据下载吗

厦门网站建设哪家专业百度网站的网址

注册账号自建网站危机公关

registryMethod 函数详解：

场景: 多米诺注册芝士披萨服务

映射表变化详解

生活中的类比

MethodHost 类详解：

场景1: 麻辣烫服务新增提供者

场景2: 麻辣烫服务提供者下线

生活中的例子

Discoverer 类详解：

serviceDiscovery 方法详解：

场景: 用户查找附近的奶茶店

onServiceRequest 方法详解：

场景1: 新的披萨店开始提供服务

场景2: 披萨店暂停营业

相关文章：