首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

【问底】夏俊:深入网站服务端技术(一)——网站并发的问题

本文来自拥有十年IT从业经验、擅长网站架构设计、Web前端技术以及Java企业级开发的夏俊,此文也是《关于大型网站技术演进的思考》系列文章的最新出炉内容,首发于CSDN,各位技术人员不容错过。 以下为正文: 一、引子 《关于大型网站技术演进的思考》已经连载完了两个系列,它们分别是《存储的瓶颈》和《网站静态化的处理》,这两个系列对应到网站里的组件就是存储端和浏览器端,网站除了这两端外,还有一端那就是服务端了,服务端上接浏览器端,下承存储端,所以当我们想让网站的浏览器端或存储端性能更加优秀的时候,就不得不去考虑

08

基于HTTP请求的多线程实现类--视频讲解

上期将了定时和定量两种压测模式的虚拟类,本期分享一下基于单个HTTP请求对象HTTPrequestbase的两个压测模式的具体实现类。比较关键的就是GCThread的启动和结束,还有就是doing()方法的实现,就是把HTTPrequestbase对象发送请求然后解析响应,这里并没有去管响应结果的校验和断言,原因就是比较复杂,需要具体情况具体处理,难以通过一个通用的方法校验,还有一个原因就是很多时候没必要,可以通过监控服务端日志和其他统计方式统计相关业务数据来达到判断所有请求是否有报错和不成功的请求。其中应该着重注意就是对象拷贝,不管是多线程类对象还是HTTPrequestbase对象,如果不实现clone()方法,可能会有BUG。

01

消息批量写入Kafka(五)

在Kafka的生产者模式主要详细的介绍了作为生产者的中间价,把消息数据写入到Kafka,这样消费者才可以消费数据,以及针对这些数据进行其他的如数据分析等。但是在实际的应用中,会有大批量的实时数据需要写入到Kafka的系统里面,因此作为单线程的模式很难满足实时数据的写入,需要使用多线程的方式来进行大批量的数据写入,当然作为消费者也是写多线程的方式来接收这些实时的数据。比如举一个案例,需要把日志系统的信息写入到Kafka的系统里面,这就是一个实时的过程,因为在程序执行的过程中,日志系统在进行大量的IO的读写,也就意味着这些数据都需要写入到Kafka里面。

04

多线程的使用,避免ExecutorService 的创建处理

如果读者对Java 中的阻塞队列有所了解的话,看到这里或许就能够明白原 因了。 Java 中的BlockingQueue 主要有两种实现, 分别是ArrayBlockingQueue 和 LinkedBlockingQueue。 ArrayBlockingQueue 是一个用数组实现的有界阻塞队列,必须设置容量。 LinkedBlockingQueue 是一个用链表实现的有界阻塞队列,容量可以选择 进行设置,不设置的话,将是一个无边界的阻塞队列,最大长度为Integer.MAX_ VALUE。 这里的问题就出在:不设置的话,将是一个无边界的阻塞队列,最大长度为 为什么阿里巴巴禁止使用Executors 创建线程池? <  35 Integer.MAX_VALUE。也就是说,如果我们不设置LinkedBlockingQueue 的 容量的话,其默认容量将会是Integer.MAX_VALUE。 而newFixedThreadPool 中创建LinkedBlockingQueue 时,并未指定容 量。此时,LinkedBlockingQueue 就是一个无边界队列,对于一个无边界队列 来说,是可以不断的向队列中加入任务的,这种情况下就有可能因为任务过多而导 致内存溢出问题。 上面提到的问题主要体现在newFixedThreadPool 和newSingleThreadExecutor 两个工厂方法上,并不是说newCachedThreadPool 和newScheduledThreadPool 这两个方法就安全了,这两种方式创建的最大线程数可能是 Integer.MAX_VALUE,而创建这么多线程,必然就有可能导致OOM。

08
领券