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

网站试用模块网络营销的概念与含义

网站试用模块,网络营销的概念与含义,装饰公司在哪个网站上接活,做网站的项目开发计划书背景 某项目封装了 Kafka 消费者 API,根据传递的消费者线程数,创建 N 个消费者线程同时消费对应 topic 的数据,并在线程启动后收集到全局列表中,方便在程序调用 stop 流程时逐个停止。 主控类在创建 Kafka 消费线程时使用了 Cou…

背景

某项目封装了 Kafka 消费者 API,根据传递的消费者线程数,创建 N 个消费者线程同时消费对应 topic 的数据,并在线程启动后收集到全局列表中,方便在程序调用 stop 流程时逐个停止。

主控类在创建 Kafka 消费线程时使用了 CountDownLatch ,将启动的线程收集到全局列表,并阻塞等待所有线程初始化完成;消费者线程指定 Kafka 订阅方法后对计数器减一,然后轮询消费 Kafka 的数据。

近日因某场景下不想消费某类 topic 数据而将 topic 设置为空,预想其他几类的 topic 数据应该正常消费,结果发现第一个 topic 设置为空后,其他几类消费线程都没有正常启动。

封装逻辑

程序封装了一个 KafkaConsumerThread 类,根据配置的线程数启动 N 个线程消费目标 topic 数据,基本代码如下:
在这里插入图片描述
用 CountDownLatch 控制消费者线程的初始化,本意是在 run 方法执行的时候就对计数器减一,标识本消费线程初始化完成的。

  1. 根据线程数创建 CountDownLatch 计数器。
  2. 订阅 Kafka topic。
  3. 计数器减一。
  4. 记录启动的线程对象。
  5. 主程序阻塞等待消费线程 run 方法执行到计数器减一。

问题排查

有一个 topic 设置为空后,对应的消费者线程启动报异常了:

java.lang.IllegalArgumentException: 
Topic collection to subscribe to 
cannot contain null or empty topic

一个消费异常,但其他消费者没有启动,为什么呢?理论上它们并不相干才对。

打印程序堆栈信息,发现程序阻塞了:
在这里插入图片描述

封装的 Kafka API 是顺次启动几类 topic 消费线程的,因为启动第一个 topic 消费线程时,因 topic 设置为空,consumer.subscribe(config.getTopics()) 这句代码异常了,其后面的 countDown 未执行而引发阻塞

第一个 topic 消费启动异常后,程序因调用了 countDownLatch.await() 而阻塞了,因此后面代码就不执行了,继而程序呈现异常状态。

基础巩固

CountDownLatch 是 JUC 包同步工具类,用于协调多个线程。它允许一个或多个线程等待,直到其他线程中执行的一组操作完成。CountDownLatch 通过一个计数器来实现,该计数器由线程递减,计数器值到达零后,所有调用过 await 方法的线程将解除阻塞状态。

  • 创建:new CountDownLatch 对象时,指定计数器的初始值。
  • 阻塞:一个或多个线程调用 await 方法,进入阻塞等待状态,直到计数器的值变为零。
  • 倒计数:其他线程在完成各自任务后调用 countDown 方法,将计数器的值减一。当计数器的值减到零时,所有在 await 上等待的线程会被唤醒,继续执行。

启示录

同步锁使用不当容易引发死锁问题,阿里开发者规范在 countDown() 方法处有一个提示:
在这里插入图片描述
这个提示也不准确,因为这个是一个 Kafka 消费线程,它以线程中断状态为标识,循环从 Kafka 中 poll 数据处理的,所以不能在 finally 中调用。但是也不能在 subscribe 之后调用,因为该语句会异常。

到底应该在哪里对计数器减一才能保证即使异常,也能正常减一呢?有两个方法:

  1. 简化处理,在线程的 run 方法第一行调用。
  2. 稍微复杂一点,添加一个开关,在 countDown 后面设置为 true,然后再 finally 里面判断,如果这个开关的代码没有走到,说明后面异常了,就在对计数器再补充减一:在这里插入图片描述
    其实这个问题产生的根源是没有对 topic 进行判空,如果源头控制了,就不会出现这种异常了。

PS:真心再推荐一下 utools 工具,整理本文时堆栈信息是从七天前的剪切板里面找出来的:
在这里插入图片描述
对我这种一天不知道复制粘贴多少次的人来说,这个工具真的很好用啊!

http://www.ritt.cn/news/20311.html

相关文章:

  • 代做施组 方案的网站网络营销平台
  • 网站如何做一张轮播图免费自助建站
  • 网站建设报价表廊坊百度推广seo
  • 校园文化设计公司公司排名优化排名
  • 做网站改版的nba排名2021最新排名
  • 专业制作网站图片友情链接发布网
  • 电商培训类网站模板下载平谷头条新闻
  • 网站文件服务器抖音推广怎么收费
  • 给网站写教案做课件一节课多少钱免费建立个人网站凡科
  • 100款夜间必备软件app优化关键词排名外包
  • 网站建设制作报价方案网推渠道
  • angular网站模板下载百度竞价推广开户价格
  • 免费建站软件哪个最好如何制作一个自己的网页网站
  • 做网站的中文名字标题优化怎样选关键词
  • 电子商务网站建设规划方案seo测试工具
  • 不花钱做推广的网站百度自动搜索关键词软件
  • 南京浦口做网站每日财经要闻
  • 动态网站开发组合2024的新闻有哪些
  • 万网虚拟服务器怎么做网站内容seo关键词是什么
  • 富阳网站建设找哪家qq群引流推广网站
  • 类似站酷的设计网站网络推广引流是做什么的
  • 昆山靠谱的网站建设公司 豆瓣长沙百度推广公司电话
  • 北京网站营销seo方案百度网盘网址是多少
  • 武汉网站建设公司 排名代写文案的软件
  • 广西网站建设性价比高nba最新消息球员交易
  • 网站对企业的好处seo概念的理解
  • 眉县做网站百度竞价推广开户多少钱
  • 分类目录网站程序大数据比较好的培训机构
  • cf刷枪网站怎么做的百度seo 优化
  • 北京好的做网站的公司哪家好怎么把网站排名到百度前三名