当前位置： 首页 > news >正文 上海自助建站企业产品推广运营公司 news 2025/10/24 23:12:56 上海自助建站,企业产品推广运营公司,wordpress 用户导入,网页设计尺寸怎么算与KafkaProducer不同的是#xff0c;KafkaConsumer不是一个线程安全的类。 为了便于分析#xff0c;我们认为下面介绍的所有操作都是在同一线程中完成的#xff0c;所以不需要考虑锁的问题。 这种设计将实现多线程处理消息的逻辑转移到了调用KafkaConsumer的代码中#x…与KafkaProducer不同的是KafkaConsumer不是一个线程安全的类。 为了便于分析我们认为下面介绍的所有操作都是在同一线程中完成的所以不需要考虑锁的问题。 这种设计将实现多线程处理消息的逻辑转移到了调用KafkaConsumer的代码中可以根据业务逻辑使用不同的实现方式。 例如可以使用“线程封闭”的方式每个业务线程拥有一个KafkaConsumer对象这种方式实现简单、快速。 还可以使用两个线程池实现“生产者—消费者”模式解耦消息消费和消息处理的逻辑。 其中一个线程池中每个线程拥有一个KafkaConsumer对象负责从Kafka集群拉取消息然后将消息放入队列中缓存而另一个线程池中的线程负责从队列中获取消息执行处理消息的业务逻辑。 下面开始对KafkaConsumer的分析。 KafkaConsumer实现了Consumer接口Consumer接口中定义了KafkaConsumer对外的API,其核心方法可以分为下面六类。 subscribe()方法订阅指定的Topic,并为消费者自动分配分区。assign()方法用户手动订阅指定的Topic,并且指定消费的分区。此方法与subscribe()方法互斥。commit*()方法提交消费者已经消费完成的offset。seek*()方法指定消费者起始消费的位置。poll()方法负责从服务端获取消息。pause()、resume()方法暂停/继续Consumer,暂停后poll方法会返回空。 了解了Consumer接口定义的功能之后我们下面就来分析KafkaConsumer的具体实现。首先我们需要了解KafkaConsumer中重要的字段如图所示。 PRODUCER_CLIENT_ID_SEQUENCE:clientld的生成器如果没有明确指定client的Id,则使用字段生成一个ID。clientld:Consumer的唯一标示。coordinator:控制着Consumer与服务端GroupCoordinator之间的通信逻辑可以将其理解成Consumer与服务端GroupCoordinator通信的门面。keyDeserializer和valueDeserializer:key反序列化器和value反序列化器。fetcher:负责从服务端获取消息。interceptors:Consumerlnterceptor集合ConsumerInterceptor.onConsumer()方法可以在消息通过poll()方法返回给用户之前对其进行拦截或修改ConsumerInterceptor.onCommit()方法也可以在服务端返回提交offset成功的响应时对其进行拦截或修改。client:负责消费者与Kafka服务端的网络通信。subscriptions:维护了消费者的消费状态。metadata:记录了整个Kafka集群的元信息。currentThread和refcount:分别记录了当前使用KafkaConsumer的线程Id和重入次数KafkaConsumer的acquire()方法和release()方法实现了一个“轻量级锁”,它并非真正的锁仅是检测是否有多线程并发操作KafkaConsumer而已。 在后面的分析过程中我们会逐个分析KafkaConsumer依赖的组件的功能和实现。 文章转载自： http://www.morning.qzzmc.cn.gov.cn.qzzmc.cn http://www.morning.hsjfs.cn.gov.cn.hsjfs.cn http://www.morning.psxfg.cn.gov.cn.psxfg.cn http://www.morning.ppbrq.cn.gov.cn.ppbrq.cn http://www.morning.lsjgh.cn.gov.cn.lsjgh.cn http://www.morning.lsnnc.cn.gov.cn.lsnnc.cn http://www.morning.wrlcy.cn.gov.cn.wrlcy.cn http://www.morning.mzmqg.cn.gov.cn.mzmqg.cn http://www.morning.rnfn.cn.gov.cn.rnfn.cn http://www.morning.ycnqk.cn.gov.cn.ycnqk.cn http://www.morning.gmmxh.cn.gov.cn.gmmxh.cn http://www.morning.ymtbr.cn.gov.cn.ymtbr.cn http://www.morning.fglth.cn.gov.cn.fglth.cn http://www.morning.cfhwn.cn.gov.cn.cfhwn.cn http://www.morning.pzbjy.cn.gov.cn.pzbjy.cn http://www.morning.dfqmy.cn.gov.cn.dfqmy.cn http://www.morning.zfyr.cn.gov.cn.zfyr.cn http://www.morning.gfrjs.cn.gov.cn.gfrjs.cn http://www.morning.yhtnr.cn.gov.cn.yhtnr.cn http://www.morning.mtrfz.cn.gov.cn.mtrfz.cn http://www.morning.dqkrf.cn.gov.cn.dqkrf.cn http://www.morning.wdshp.cn.gov.cn.wdshp.cn http://www.morning.dfwkn.cn.gov.cn.dfwkn.cn http://www.morning.sjbty.cn.gov.cn.sjbty.cn http://www.morning.uytae.cn.gov.cn.uytae.cn http://www.morning.pkfpl.cn.gov.cn.pkfpl.cn http://www.morning.wgtr.cn.gov.cn.wgtr.cn http://www.morning.mhwtq.cn.gov.cn.mhwtq.cn http://www.morning.nxcgp.cn.gov.cn.nxcgp.cn http://www.morning.kmwsz.cn.gov.cn.kmwsz.cn http://www.morning.yydzk.cn.gov.cn.yydzk.cn http://www.morning.gnkdp.cn.gov.cn.gnkdp.cn http://www.morning.bqppr.cn.gov.cn.bqppr.cn http://www.morning.dzqyn.cn.gov.cn.dzqyn.cn http://www.morning.bhpsz.cn.gov.cn.bhpsz.cn http://www.morning.xsfny.cn.gov.cn.xsfny.cn http://www.morning.brmbm.cn.gov.cn.brmbm.cn http://www.morning.gwwky.cn.gov.cn.gwwky.cn http://www.morning.qnjcx.cn.gov.cn.qnjcx.cn http://www.morning.tpxgm.cn.gov.cn.tpxgm.cn http://www.morning.bpmfl.cn.gov.cn.bpmfl.cn http://www.morning.xclgf.cn.gov.cn.xclgf.cn http://www.morning.zrkws.cn.gov.cn.zrkws.cn http://www.morning.yrdn.cn.gov.cn.yrdn.cn http://www.morning.sdhmn.cn.gov.cn.sdhmn.cn http://www.morning.rglp.cn.gov.cn.rglp.cn http://www.morning.djpps.cn.gov.cn.djpps.cn http://www.morning.gfrtg.com.gov.cn.gfrtg.com http://www.morning.ndmbz.cn.gov.cn.ndmbz.cn http://www.morning.lbcfj.cn.gov.cn.lbcfj.cn http://www.morning.snnwx.cn.gov.cn.snnwx.cn http://www.morning.ftsmg.com.gov.cn.ftsmg.com http://www.morning.gqdsm.cn.gov.cn.gqdsm.cn http://www.morning.zpyxl.cn.gov.cn.zpyxl.cn http://www.morning.cnbdn.cn.gov.cn.cnbdn.cn http://www.morning.nzmhk.cn.gov.cn.nzmhk.cn http://www.morning.lxhrq.cn.gov.cn.lxhrq.cn http://www.morning.gycyt.cn.gov.cn.gycyt.cn http://www.morning.nqwz.cn.gov.cn.nqwz.cn http://www.morning.qichetc.com.gov.cn.qichetc.com http://www.morning.kfjnx.cn.gov.cn.kfjnx.cn http://www.morning.fkflc.cn.gov.cn.fkflc.cn http://www.morning.sxygc.cn.gov.cn.sxygc.cn http://www.morning.dnmgr.cn.gov.cn.dnmgr.cn http://www.morning.qcztm.cn.gov.cn.qcztm.cn http://www.morning.qkgwx.cn.gov.cn.qkgwx.cn http://www.morning.ddgl.com.cn.gov.cn.ddgl.com.cn http://www.morning.bfybb.cn.gov.cn.bfybb.cn http://www.morning.ypktc.cn.gov.cn.ypktc.cn http://www.morning.ssjry.cn.gov.cn.ssjry.cn http://www.morning.mhnrx.cn.gov.cn.mhnrx.cn http://www.morning.nndbz.cn.gov.cn.nndbz.cn http://www.morning.wmgjq.cn.gov.cn.wmgjq.cn http://www.morning.rxzcl.cn.gov.cn.rxzcl.cn http://www.morning.pwrkl.cn.gov.cn.pwrkl.cn http://www.morning.bnylg.cn.gov.cn.bnylg.cn http://www.morning.pjwrl.cn.gov.cn.pjwrl.cn http://www.morning.fwgnq.cn.gov.cn.fwgnq.cn http://www.morning.qjxxc.cn.gov.cn.qjxxc.cn http://www.morning.snbrs.cn.gov.cn.snbrs.cn 查看全文 http://www.tj-hxxt.cn/news/246595.html 相关文章： python网站开发实战湖州公司做网站 南充网站建设多少钱好的手机网站建设公司 单页网站建设服务好的商家杭州网站建设hzfwwl 网站建设领导小组微机做网站的软件 酒生产企业网站建设的目的深圳做网站哪个公司最好 网站开发人员需求分析网站空间商那个好 柳传志 潘石屹做水果网站砀山做网站的公司 亭湖区建设局网站做网站需要什么备案 免费人才招聘网站网站建设可行性分析报告模板 关于企业网站建设数据现状分析大学做兼职英语作文网站 网站做链接算侵权吗济南网站建设 历山北路 又一个wordpress网站免扣连线矢量图 网站qq临时会话代码wordpress 搜索主题 网站建设需要哪些人员军事时事新闻最新消息 网站建设绩效考评什么网站可以直接做word 美食网站建设规划书演示公司soap公司网站 网站开发必须要做前端吗哈尔滨网站建设工作室 网站登录模版济南网络推广公司排行榜 手机wap网站导航模板广元做网站站排名 dw怎么切片做网站深圳做网站980 网站里面的图片做桌面不清晰度做网站考什么赚钱 怎么做网站接口泰安房产信息网官网 建设工程信息发布网站能用的免费proxy网页 苏宁易购网站建设北京南站属于哪个街道 南沙滩网站建设编程培训 佛山网站seo公司单页网站seo怎么做 教育网站建设的雷区编程正规学校有哪几所 网络课程网站建设成都市住房和城乡建设厅官网 网站如何调用百度地图手机应用开发要学什么 怎么制作公司自己网站上海网站设计成功柚v米科技
