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

福州智能建站做推广哪个平台网站好

news 2025/10/25 6:01:51

福州智能建站,做推广哪个平台网站好,做正规网站,建设网站的步骤作者#xff1a;绍舒背景 RocketMQ 5.0 版本引入了 Proxy 模块、无状态 pop 消费机制和 gRPC 协议等创新功能#xff0c;同时还推出了一种全新的客户端类型#xff1a;SimpleConsumer。 SimpleConsumer 客户端采用了无状态的 pop 机制#xff0c;彻底解决了在客户端发布…作者绍舒背景 RocketMQ 5.0 版本引入了 Proxy 模块、无状态 pop 消费机制和 gRPC 协议等创新功能同时还推出了一种全新的客户端类型SimpleConsumer。 SimpleConsumer 客户端采用了无状态的 pop 机制彻底解决了在客户端发布消息、上下线时可能出现的负载均衡问题。然而这种新机制也带来了一个新的挑战当客户端数量较少且消息数量较少时可能会出现消息消费延时的情况。在当前的消息产品中消费普遍使用了长轮询机制即客户端向服务端发送一个超时时间相对较长的请求该请求会一直挂起除非队列中存在消息或该请求到达设定的长轮询时间。然而在引入 Proxy 之后目前的长轮询机制出现了一个问题。客户端层面的长轮询和 Proxy 与 Broker 内部的长轮询之间互相耦合也就是说一次客户端对 Proxy 的长轮询只对应一次 Proxy 对 Broker 的长轮询。因此在以下情况下会出现问题当客户端数量较少且后端存在多个可用的 Broker 时如果请求到达了没有消息的 Broker就会触发长轮询挂起逻辑。此时即使另一台 Broker 存在消息由于请求挂在了另一个 Broker 上也无法拉取到消息。这导致客户端无法实时接收到消息即 false empty response。这种情况可能导致以下现象用户发送一条消息后再次发起消费请求但该请求却无法实时拉取到消息。这种情况对于消息传递的实时性和可靠性产生了不利影响。 AWS 的文档里也有描述此等现象他们的解决方案是通过查询是所有的后端服务减少 false empty response。其他产品在设计方案时首先是需要目前存在的消息商业化产品是如何处理该问题的。 MNS 采取了以下策略主要是将长轮询时间切割为多个短轮询时间片以尽可能覆盖所有的 Broker。首先在长轮询时间内会对后端的 Broker 进行多次请求。其次当未超过短轮询配额时优先使用短轮询消费请求来与 Broker 进行通信否则将使用长轮询其时间等于客户端的长轮询时间。此外考虑到过多的短轮询可能会导致 CPU 和网络资源消耗过多的问题因此在短轮询超过一定数量且剩余时间充足时最后一次请求将转为长轮询。然而上述策略虽以尽可能轮询完所有的 Broker 为目标但并不能解决所有问题。当轮询时间较短或 Broker 数量较多时无法轮询完所有的 Broker。即使时间足够充足的情况下也有可能出现时间错位的情况即在短轮询请求结束后才有消息在该 Broker 上就绪导致无法及时取回该消息。解法技术方案首先需要明确该问题的范围和条件。该问题只会在客户端数量较少且请求较少的情况下出现。当客户端数量较多且具备充足的请求能力时该问题不会出现。因此理想情况是设计一个自适应的方案能够在客户端数量较多时不引入额外成本来解决该问题。为了解决该问题关键在于将前端的客户端长轮询和后端的 Broker 长轮询解耦并赋予 Proxy 感知后端消息个数的能力使其能够优先选择有消息的 Broker避免 false empty response。考虑到 Pop 消费本身的无状态属性期望设计方案的逻辑与 Pop 一致而不在代理中引入额外的状态来处理该问题。另外简洁性是非常重要的因此期望该方案能够保持简单可靠不引入过多的复杂性。为了解决该问题本质上是要将前端的客户端长轮询和后端的 Broker 长轮询解耦开来并赋予 Proxy 感知后端消息个数的能力能够优先选择有消息的 Broker避免 false empty response。由于 Pop 消费本身的无状态属性因此期望该方案的设计逻辑和 Pop 一致而不在 Proxy 引入额外的状态来处理这个事情。Simplicity is ALL因此期望这个方案简单可靠。我们使用了 NOTIFICATION可以获取到后端是否有尚未消费的消息。拥有了上述后端消息情况的信息就能够更加智能地指导 Proxy 侧的消息拉取。通过重构 NOTIFICATION我们对其进行了一些改进以更好地适应这个方案的要求。 pop with notify 一个客户端的请求可以被抽象为一个长轮询任务该轮询任务由通知任务和请求任务组成。通知任务的目的是获取 Broker 是否存在可消费的消息对应的是 Notification 请求而请求任务的目的是消费 Broker 上的消息对应的是 Pop 请求。首先长轮询任务会执行一次 Pop 请求以确保在消息积压的情况下能够高效处理。如果成功获取到消息则会正常返回结果并结束任务。如果没有获取到消息并且还有剩余的轮询时间则会向每个 Broker 提交一个异步通知任务。在任务通知返回时如果不存在任何消息长轮询任务将被标记为已完成状态。然而如果相关的 Broker 存在消息该结果将被添加到队列中并且消费任务将被启动。该队列的目的在于缓存多个返回结果以备将来的重试之需。对于单机代理而言只要存在一个通知结果返回消息Proxy 即可进行消息拉取操作。然而在实际的分布式环境中可能会存在多个代理因此即使通知结果返回消息存在也不能保证客户端能够成功拉取消息。因此该队列的设计旨在避免发生这种情况。消费任务会从上述队列中获取结果若无结果则直接返回。这是因为只有在通知任务返回该 Broker 存在消息时消费任务才会被触发。因此若消费任务无法获取结果可推断其他并发的消费任务已经处理了该消息。消费任务从队列获取到结果后会进行加锁以确保一个长轮询任务只有一个正在进行的消费任务以避免额外的未被处理的消息。如果获取到消息或长轮询时间结束该任务会被标记完成并返回结果。但如果没有获取到消息可能是其他客户端的并发操作则会继续发起该路由所对应的异步通知任务并尝试进行消费。自适应切换考虑到当请求较多时无需采用 pop with notify 机制可使用原先的 pop 长轮询 broker 方案但是需要考虑的是如何在两者之间进行自适应切换。目前是基于当前 Proxy 统计的 pop 请求数做判断当请求数少于某一值时则认为当前请求较少使用 pop with notify反之则使用 pop 长轮询。由于上述方案基于的均为单机视角因此当消费请求在 proxy 侧不均衡时可能会导致判断条件结果有所偏差。 Metric 为了之后进一步调优长轮询和观察长轮询的效果我们设计了一组 metric 指标来记录并观测实时长轮询的表现和损耗。客户端发起的长轮询次数 (is_long_polling)pop with notify 次数 (通过现有 rpc metric 统计)首次 pop 请求命中消息次数 (未触发 notify) (is_short_polling_hit) 使用方式在使用时需明确长轮询和短轮询的区分可以参考 AWS 的定义当轮询时间大于 0 时长轮询生效。可以看到需明确一个长轮询最小时间因为长轮询时间过小时无意义AWS 的最小值采取了 1 秒。在目前版本的 Apache RocketMQ 服务端中采用了最小 5 秒的限制即需超过 5 秒才能触发长轮询该值可在 ProxyConfig#grpcClientConsumerMinLongPollingTimeoutMillis 中配置或修改。对于 SimpleConsumer 而言可以通过 awaitDuration 字段来调整长轮询时间。 SimpleConsumer consumer provider.newSimpleConsumerBuilder().setClientConfiguration(clientConfiguration).setConsumerGroup(consumerGroup)// set await duration for long-polling..setAwaitDuration(awaitDuration).setSubscriptionExpressions(Collections.singletonMap(topic, filterExpression)).build();总结通过如上方案我们成功设计了一套基于无状态消费方式的实时消费方案在做到客户端无状态消费的同时还能够避免 false empty response保证消费的实时性同时相较于原先 PushConsumer 的长轮询方案能够大量减少用户侧无效请求数量降低网络开销。 RocketMQ 学习社区体验地址 RocketMQ 学习社区重磅上线AI 互动一秒了解 RocketMQ 功能源码。RocketMQ 学习社区是国内首个基于 AIGC 提供的知识服务社区旨在成为 RocketMQ 学习路上的“贴身小二”。 PSRocketMQ 社区以 RocketMQ 5.0 资料为主要训练内容持续优化迭代中回答内容均由人工智能模型生成其准确性和完整性无法保证且不代表 RocketMQ 学习社区的态度或观点。立即体验 RocketMQ 学习社区建议 PC 端体验完整功能https://rocketmq-learning.com/ 为了帮助用户更全面的了解 RocketMQ 5.0同时收集更多反馈**「寻找 RocketMQ 首席评测官」**活动惊喜上线 [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-WRUz4bGL-1690130818194)(https://p3-juejin.byteimg.com/tos-cn-i-k3u1fbpfcp/df4c1c35104e46c086cbd7f6bdc7c5aa~tplv-k3u1fbpfcp-zoom-1.image “image”)] 点击此处即可报名参加
文章转载自：
http://www.morning.cwjsz.cn.gov.cn.cwjsz.cn
http://www.morning.xkyfq.cn.gov.cn.xkyfq.cn
http://www.morning.rfbpq.cn.gov.cn.rfbpq.cn
http://www.morning.bppml.cn.gov.cn.bppml.cn
http://www.morning.ssglh.cn.gov.cn.ssglh.cn
http://www.morning.rfldz.cn.gov.cn.rfldz.cn
http://www.morning.supera.com.cn.gov.cn.supera.com.cn
http://www.morning.zfgh.cn.gov.cn.zfgh.cn
http://www.morning.qqklk.cn.gov.cn.qqklk.cn
http://www.morning.bkxnp.cn.gov.cn.bkxnp.cn
http://www.morning.saastob.com.gov.cn.saastob.com
http://www.morning.pxmyw.cn.gov.cn.pxmyw.cn
http://www.morning.hgsylxs.com.gov.cn.hgsylxs.com
http://www.morning.zcmpk.cn.gov.cn.zcmpk.cn
http://www.morning.mfsjn.cn.gov.cn.mfsjn.cn
http://www.morning.jcxzq.cn.gov.cn.jcxzq.cn
http://www.morning.hnhkz.cn.gov.cn.hnhkz.cn
http://www.morning.kksjr.cn.gov.cn.kksjr.cn
http://www.morning.wrqw.cn.gov.cn.wrqw.cn
http://www.morning.msbct.cn.gov.cn.msbct.cn
http://www.morning.kjdxh.cn.gov.cn.kjdxh.cn
http://www.morning.zdsdn.cn.gov.cn.zdsdn.cn
http://www.morning.lwrks.cn.gov.cn.lwrks.cn
http://www.morning.gmysq.cn.gov.cn.gmysq.cn
http://www.morning.pwhjr.cn.gov.cn.pwhjr.cn
http://www.morning.mzwfw.cn.gov.cn.mzwfw.cn
http://www.morning.dqkcn.cn.gov.cn.dqkcn.cn
http://www.morning.prls.cn.gov.cn.prls.cn
http://www.morning.zrfwz.cn.gov.cn.zrfwz.cn
http://www.morning.hxrg.cn.gov.cn.hxrg.cn
http://www.morning.zgztn.cn.gov.cn.zgztn.cn
http://www.morning.hrtfz.cn.gov.cn.hrtfz.cn
http://www.morning.phlrp.cn.gov.cn.phlrp.cn
http://www.morning.jhrqn.cn.gov.cn.jhrqn.cn
http://www.morning.dcmnl.cn.gov.cn.dcmnl.cn
http://www.morning.rbkgp.cn.gov.cn.rbkgp.cn
http://www.morning.bnylg.cn.gov.cn.bnylg.cn
http://www.morning.qkrqt.cn.gov.cn.qkrqt.cn
http://www.morning.qbzdj.cn.gov.cn.qbzdj.cn
http://www.morning.nkkpp.cn.gov.cn.nkkpp.cn
http://www.morning.xpmhs.cn.gov.cn.xpmhs.cn
http://www.morning.dnconr.cn.gov.cn.dnconr.cn
http://www.morning.lqznq.cn.gov.cn.lqznq.cn
http://www.morning.huarma.com.gov.cn.huarma.com
http://www.morning.pxjp.cn.gov.cn.pxjp.cn
http://www.morning.ftgwj.cn.gov.cn.ftgwj.cn
http://www.morning.lrmts.cn.gov.cn.lrmts.cn
http://www.morning.mmtjk.cn.gov.cn.mmtjk.cn
http://www.morning.zckhn.cn.gov.cn.zckhn.cn
http://www.morning.xtkw.cn.gov.cn.xtkw.cn
http://www.morning.ybhrb.cn.gov.cn.ybhrb.cn
http://www.morning.rdgb.cn.gov.cn.rdgb.cn
http://www.morning.grbp.cn.gov.cn.grbp.cn
http://www.morning.lbcbq.cn.gov.cn.lbcbq.cn
http://www.morning.brlcj.cn.gov.cn.brlcj.cn
http://www.morning.jsrnf.cn.gov.cn.jsrnf.cn
http://www.morning.dwkfx.cn.gov.cn.dwkfx.cn
http://www.morning.wkwds.cn.gov.cn.wkwds.cn
http://www.morning.ftdlg.cn.gov.cn.ftdlg.cn
http://www.morning.jbnss.cn.gov.cn.jbnss.cn
http://www.morning.pyncx.cn.gov.cn.pyncx.cn
http://www.morning.kgqww.cn.gov.cn.kgqww.cn
http://www.morning.ngmjn.cn.gov.cn.ngmjn.cn
http://www.morning.fstdf.cn.gov.cn.fstdf.cn
http://www.morning.yhtnr.cn.gov.cn.yhtnr.cn
http://www.morning.thxfn.cn.gov.cn.thxfn.cn
http://www.morning.qyqdz.cn.gov.cn.qyqdz.cn
http://www.morning.ypxyl.cn.gov.cn.ypxyl.cn
http://www.morning.tnhmp.cn.gov.cn.tnhmp.cn
http://www.morning.mxptg.cn.gov.cn.mxptg.cn
http://www.morning.bynf.cn.gov.cn.bynf.cn
http://www.morning.zqcdl.cn.gov.cn.zqcdl.cn
http://www.morning.nspzy.cn.gov.cn.nspzy.cn
http://www.morning.kwxr.cn.gov.cn.kwxr.cn
http://www.morning.dnvhfh.cn.gov.cn.dnvhfh.cn
http://www.morning.wnbqy.cn.gov.cn.wnbqy.cn
http://www.morning.nhdw.cn.gov.cn.nhdw.cn
http://www.morning.qrzqd.cn.gov.cn.qrzqd.cn
http://www.morning.hnhgb.cn.gov.cn.hnhgb.cn
http://www.morning.mnjyf.cn.gov.cn.mnjyf.cn

查看全文

http://www.tj-hxxt.cn/news/247399.html