1.用rocketmq消息中间来提高吞吐量。会造成消息积压的情况,如何提高消费者的并发消费?
2.问题:用rocketmq做中间件,客户端往中间件发送拨打消息,消费者就行消费,需要及时回应。如果大量的客户端进行拨打电话,会造成消息积压
rocketmq消息积压,能处理实时消息传递消费吗
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
- 邀请回答
-
5条回答 默认 最新
- 燕少༒江湖 2023-02-27 10:23关注
1、增加队列,一个主题可以有多个队列,消费的时候,通用新增对应数量的消费线程数量,即队列数 = 消费线程数;要不然浪费资源;
2、根据broker的数量,现在消费者,即有3个broker,那就起3个消费者(这里跟消费线程不是一回事儿);
3、可同时批量处理多条消息,比如一次拉去20条消息,异步处理这20条信息;
4、优化处理消息的业务逻辑,尽量减少不必要的时间损耗。本回答被题主选为最佳回答 , 对您是否有帮助呢?解决 无用评论 打赏 举报
悬赏问题
- ¥15 微信会员卡等级和折扣规则
- ¥15 微信公众平台自制会员卡可以通过收款码收款码收款进行自动积分吗
- ¥15 随身WiFi网络灯亮但是没有网络,如何解决?
- ¥15 gdf格式的脑电数据如何处理matlab
- ¥20 重新写的代码替换了之后运行hbuliderx就这样了
- ¥100 监控抖音用户作品更新可以微信公众号提醒
- ¥15 UE5 如何可以不渲染HDRIBackdrop背景
- ¥70 2048小游戏毕设项目
- ¥20 mysql架构,按照姓名分表
- ¥15 MATLAB实现区间[a,b]上的Gauss-Legendre积分