RocketMQ的长轮询消费方式

RocketMQ的长轮询消费方式1.Push推送方式(即Server端推送消息给client):当Server收到消息发送者发送过来的消息后,Server端主动把消息推送给client,这个方式实时性比较好,但是增加了Server的工作负担,对Server的性能造成影响;另外Client如果不能够及时处理Server推送的消息,也是很大的问题。2.Pull拉取方式(即Client从Server拉取消息):Client…

大家好,又见面了,我是你们的朋友全栈君。

1.Push推送方式(即Server端推送消息给client):

当Server收到消息发送者发送过来的消息后,Server端主动把消息推送给client,这个方式实时性比较好,但是增加了Server的工作负担,对Server的性能造成影响;另外Client如果不能够及时处理Server推送的消息,也是很大的问题。

2.Pull拉取方式(即Client从Server拉取消息):

Client循环的从Server拉取消息,由client控制着主动权。弊端:拉取消息的时间间隔不好设定,间隔太短循环空拉取造成资源浪费,间隔时间太长,就会增加消息消费的延迟,影响业务使用。另外需要Client拉取消息时维护offset,代码比较麻烦。

3.长轮询的消费方式

RocketMQ的消息消费方式,采用了“长轮询”方式,兼具了Push和Pull的有点,不过需要Server和Client的配合才能够实现。
即Client发送消息请求,Server端接受请求,如果发现Server队列里没有新消息,Server端不立即返回,而是持有这个请求一段时间(通过设置超时时间来实现),在这段时间内轮询Server队列内是否有新的消息,如果有新消息,就利用现有的连接返回消息给消费者;如果这段时间内没有新消息进入队列,则返回空。
这样消费消息的主动权既保留在Client端,也不会出现Server积压大量消息后,短时间内推送给Client大量消息使client因为性能问题出现消费不及时的情况。
长轮询的弊端:在持有消费者请求的这段时间,占用了系统资源,因此长轮询适合客户端连接数可控的业务场景中。

参考资料:《RocketMQ实战与原理解析》

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/149529.html原文链接:https://javaforall.net

(0)
上一篇 2022年6月24日 下午7:00
下一篇 2022年6月24日 下午7:00


相关推荐

  • 2025年最新 Claude 国内注册与订阅全攻略

    2025年最新 Claude 国内注册与订阅全攻略

    2026年3月16日
    2
  • oracle怎么测试包,用ORACLE自带包测试FUSIONIO的IOPS「建议收藏」

    oracle怎么测试包,用ORACLE自带包测试FUSIONIO的IOPS「建议收藏」settimingonserveroutputondeclarev_max_iopsBINARY_INTEGER;v_max_mbpsBINARY_INTEGER;v_act_latBINARY_INTEGER;begindbms_resource_manager.CALIBRATE_IO(num_physical_disks=>1,max_latency…

    2025年5月22日
    10
  • 414 Request-URI Too Long 15ms[通俗易懂]

    414 Request-URI Too Long 15ms[通俗易懂]这个问题是使用get请求后面跟的参数太多,造成的,解决办法是把get请求换成POST请求@POST@Path(“/poststate”)@Consumes(“application/x-www-form-urlencoded”)@Produces(MediaType.APPLICATION_JSON)publicList<UserState>getPostUserState(@FormParam(“type”)Stringtype,…

    2022年5月2日
    60
  • 视频直播技术_直播如何实现低延迟

    视频直播技术_直播如何实现低延迟借《让子弹飞》中姜文的名言作为开场白:让子弹飞一会儿。某名人吐槽说:还要飞一会儿哪?这子弹的延迟也忒大了。 该名人就是鄙人。为什么低延迟很重要?低延迟的子弹可以击杀敌军千米之外,低延迟的直播技术可以秒杀粉丝千里之外。互动直播技术已经成为直播平台的标配。没有互动直播技术的直播平台无法跻身直播行业第一梯队。而要获得互动直播技术,实现低延迟

    2022年7月21日
    18
  • 经典欧美电影推荐

    经典欧美电影推荐

    2021年5月4日
    96
  • 逻辑回归原理_逻辑回归代码

    逻辑回归原理_逻辑回归代码此文章为初学机器学习时,对AndrewNG《机器学习》课程整理所写,也参考了其他CSDN同学的笔记,写的较为粗糙,很多网友帮助我指正了问题,现在重新更新向量化部分,并加入实践篇。什么是逻辑回归?Logistic回归与多重线性回归实际上有很多相同之处,最大的区别就在于它们的因变量不同,其他的基本都差不多。正是因为如此,这两种回归可以归于同一个家族,即广义线性模型(generalizedli…

    2025年6月19日
    4

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号