首页
题库
公司真题
专项练习
面试题库
在线编程
面试
面试经验
AI 模拟面试
简历
求职
学习
基础学习课
实战项目课
求职辅导课
专栏&文章
竞赛
我要招人
发布职位
发布职位、邀约牛人
更多企业解决方案
AI面试、笔试、校招、雇品
HR免费试用AI面试
最新面试提效必备
登录
/
注册
每天都说我是过儿
2019-07-31 14:22
已编辑
西北大学 Java
关注
已关注
取消关注
java:生产者和消费者
消息队列的生产者消费者中消费者没有收到消息怎么办,消息有顺序比如1.2.3但是收到的却是1.3.2怎么办?消息发过来的过程中损坏或者出错怎么办?
提示
全部评论
推荐
最新
楼层
薛8
门头沟学院 Java
在生产者端保证顺序就好了,比如消息按顺序都放在一个队列,然后消费者端只用一个线程消费。
点赞
回复
分享
发布于 2019-07-31 13:06
Zwiebeln_Chan
南京理工大学 Java
生产者消费者模型据我所知好像不特别强调消息的有效性和顺序吧?主要是用来同步生产者和消费者之间的顺序的
点赞
回复
分享
发布于 2019-07-31 12:27
星雨诚
招商银行信用卡中心_信息技术部_应用开发
从生产者的角度看,消息队列通过常见的请求确认机制保障消息的可靠传输,因此,当生产者就消息传输到broker中时,需要注意正确处理broker返回的确认或者异常信息,以保证信息可靠传输,生产者一旦收到异常消息,便会重发消息。 从broker的角度看,只要broker正常运行,就不会丢失消息。但是broker进程或者是服务器宕机了,就可能丢失消息。如果可靠性要求较高,那么可以通过设置broker参数来避免因为宕机而丢失消息,例如刷盘和复制的配置项。 从消费者的角度看,也是通过请求确认的机制来保障消息的可靠传输,可以在消费者业务处理逻辑全部结束之后再将确认响应回复给broker,若broker没有收到确认响应,那么下次消费者再次拉取消息时,仍然会拉取未成功拉取的那条消息。
2
回复
分享
发布于 2019-08-01 13:05
星雨诚
招商银行信用卡中心_信息技术部_应用开发
另外,关于消息有序性的问题,如果broker用于接收消息的topic(承载真实数据的逻辑容器)是一个分区,那么有序性是可以得到保障,但是这就会丧失其消息队列高吞吐量的能力,因此topic可以进行多个分区,那么要想保证负载均衡,我们希望尽可能将数据均匀地分散到多个分区中,这个时候设置合适的分区策略也可以保证消息的有序性,例如Key-ordering。
点赞
回复
分享
发布于 2019-08-01 16:28
卑微搬砖工
西安交通大学 Java
听着咋感觉你在说tcp、
点赞
回复
分享
发布于 2019-07-31 14:21
暂无评论,快来抢首评~
相关推荐
06-26 08:54
中国地质大学 Java
北京京东一面,虽然问题常见但是有深度
最近由于三大外卖平台“打仗”,优惠券多到数不过来,一日三餐每个平台各点一单哈哈哈,正好最近组织内部还有朋友在北京的京东面试过,分享一下她的面经(Java岗):1. Kafka消息不丢失问题,Kafka本身会去保证消息的不丢失,为什么还需要存一个本地消息表来保证消息的不丢失呢?Kafka 本身通过副本机制、生产者确认(acks)、消费者手动提交等设计理论上可以实现消息不丢失,但在实际分布式系统中,由于业务逻辑复杂性、中间件与业务操作的原子性难以保障,仍需要引入“本地消息表”等额外机制。以下是具体原因及解决方案的对比分析:Kafka 消息不丢失的机制及其局限性生产者端acks=-1:要求所有 IS...
京东一面337人在聊
点赞
评论
收藏
分享
06-17 12:36
中国科学技术大学 Java
百度二面凉经
1. 介绍项目2. redis预检成功,数据库扣减失败怎么办3. 用过压测吗,有什么指标4. 分布式锁逻辑,底层原理5. 讲讲大模型相关6. 场景题:抖音消息推送架构设计的讨论(抖音大 V 更新视频,需设计架构让大量粉丝收到通知)推模式怎么优化,瓶颈在哪,压力在哪7. 上述生产者消息队列消费者瓶颈,消息积压相关8. 数据库写入压力大怎么优化
查看8道真题和解析
点赞
评论
收藏
分享
06-19 00:26
已编辑
门头沟学院 测试开发
【社招】百度一面
前文:①感觉她是不是在看着题库出题啊,每次我说完了等她的反应都很慢;②她是不是对我不感兴趣啊,业务和项目都没有深挖,我主要负责的也没有深挖1.自我介绍2.项目介绍(但不是我主要负责的,而是跟mt的)3.Java熟悉一些对吧?Java创建线程有哪些方式?4.Java的线程和进程的区别?5.HTTPS和HTTP的区别(心想:这是在校招?怎么全是计算机基础)6.equals和==的区别,什么时候用equals,可以举个例子吗==是地址,equals是值,往往需要重写hashCode方法7.场景题:百度app的搜索功能设计用例因为我没用过百度app,换成:安卓机下,抽奖功能如何设计测试用例8.做个题吧...
牛客创作赏金赛
点赞
评论
收藏
分享
06-10 09:36
中国地质大学 Java
字节还是那么喜欢考算法
今天分享的是训练营的朋友在字节跳动的面经,整个面试过程差不多一个小时,一半时间拷打八股,一半时间拷打算法,字节还是那么喜欢考算法。面经详解1 讲讲项目难易点常考的问题,对于自己的项目可以提前准备好话术2 kafka处理消息丢失和消息重复在分布式消息系统如Apache Kafka中,消息丢失和消息重复是两个常见的问题。为了解决这些问题,可以采取一系列的措施和技术手段。以下是一些处理Kafka消息丢失和消息重复的方法:消息丢失确认机制:确保消费者在成功处理完消息后才提交偏移量(offset),这可以通过设置enable.auto.commit=false并手动管理偏移量来实现。持久化配置:设置适当...
点赞
评论
收藏
分享
06-25 12:34
已编辑
门头沟学院 Java
didi社招一面凉贴
1、MySQL中3种log的作用是什么2、主从库是如何同步的,如果读从库读不到数据该怎么办?3、如果要将从库的读流量切换到主库需要考虑到哪些问题?4、消息如何保证顺序消费?5、Redis集群扩容的时候是否还能正常处理读写请求?6、Redis一共有多少个hash槽,扩容的过程是怎样的?7、Kafka reblance会不会影响顺序消费,为什么会影响?什么场景下会导致reblance8、线上的OOM导致的原因有哪些?怎么处理的,遇到过哪种是业务代码导致的9、哪些场景会FUll GC,线上出现会有哪些影响,该怎么排查处理?
查看9道真题和解析
点赞
评论
收藏
分享
评论
点赞成功,聊一聊 >
点赞
收藏
分享
评论
提到的真题
返回内容
全站热榜
更多
1
...
腾讯csig暑期一二三面
7019
2
...
为什么你很难找到工作
3888
3
...
可是,我脱了长衫也没人要啊...
3694
4
...
字节实习week6:听leader吐槽当前的应届生候选人们
3279
5
...
腾讯云智后台开发暑期面经
3175
6
...
友友们如何看待这个问题
3101
7
...
简历很差吗?
3054
8
...
作为实习生,我问薪无愧
3046
9
...
今天你举报室友ai作弊,明天可能被同事举报迟到
2920
10
...
原来在HR眼里我们应届生就是笨鸡蛋
2504
创作者周榜
更多
正在热议
更多
#
大家每天通勤多久?
#
45826次浏览
345人参与
#
银行笔面经互助
#
134111次浏览
1166人参与
#
现代汽车前瞻技术研发急速编程挑战赛
#
32786次浏览
257人参与
#
上班到公司第一件事做什么?
#
58447次浏览
498人参与
#
设计人如何选offer
#
119115次浏览
741人参与
#
CVTE求职进展汇总
#
16352次浏览
292人参与
#
上班苦还是上学苦呢?
#
229594次浏览
1357人参与
#
非技术投递记录
#
604357次浏览
6402人参与
#
90后北漂现状
#
24873次浏览
201人参与
#
百度工作体验
#
226725次浏览
1995人参与
#
机械人与华为的爱恨情仇
#
117817次浏览
951人参与
#
金融财会交流会
#
110503次浏览
380人参与
#
工作中,努力重要还是选择重要?
#
136870次浏览
1681人参与
#
发工资后,你做的第一件事是什么
#
68703次浏览
232人参与
#
机械人,你的秋招第一份简历被谁挂了
#
141645次浏览
1982人参与
#
Offer比较,你最看重什么?
#
186918次浏览
1287人参与
#
工作中哪个瞬间让你想离职
#
26400次浏览
179人参与
#
你觉得实习能学到东西吗
#
40442次浏览
777人参与
#
秋招什么时候开投比较合适?
#
28574次浏览
351人参与
#
联想求职进展汇总
#
270985次浏览
2053人参与
#
机械人集合!你是什么工程师?
#
16345次浏览
89人参与
牛客网
牛客网在线编程
牛客网题解
牛客企业服务