前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Java中间件(1)--分布式系统&中间件从入门到精通(五)

Java中间件(1)--分布式系统&中间件从入门到精通(五)

作者头像
用户9919783
发布2022-07-29 14:05:03
4430
发布2022-07-29 14:05:03
举报
文章被收录于专栏:后端从入门到精通

上篇文章说了,当业务数据量大的时候,可以考虑业务和数据分离,当还解决不了的时候,可以考虑把数据库读写分离,缓存,还可以考虑把表垂直拆分,水平拆分。

大型网站架构(2)--分布式系统&中间件从入门到精通(四)

中间件为软件应用提供了操作系统所提供的服务之外的服务,中间件不是操作系统的一部分,也不是数据库的一部分,而是让软件开发者方便的处理通信输入和输出。

我的理解中间件主要分为三大类,当然这三大类肯定没有涵盖业内所有的中间件。

  1. 远程访问时候的中间件,只要解决分布式环境互相访问问题。
  2. 消息中间间:只要解决异步,解耦,削峰。
  3. 数据库访问的中间件,主要提升数据库读写性能。

构建java中间件

认识java中间件,我们要先谈下jvm—跨平台的java运行环境。Java诞生时候口号就是“write once,run anywhere”,能达到这个目标的关键点就是java虚拟机,不同的平台有不同的java虚拟机,但不同java虚拟机识别的是统一格式的中间代码,也就是我们常说的java字节码(java byte code)。

使用jvm就不得不说垃圾回收,java虚拟机是通过垃圾回收的方式进行内存回收的,而不是和c++那样通过代码进行释放,而在java虚拟机中,设置不同的垃圾回收方式和参数会影响垃圾回收的效果。

平时我们接触比较多的oracle hotspot jvm,这里主要分为Young/Tenured/Pren三块区域,也就是常说的新生代、老年代、持久代。一般新的对象会被分配在young的eden区,eden区中存活的对象会被copy到survivor区,survivor又分为form和to,当下次新生代垃圾回收的时候,会吧from里面的清空,copy到另一个survivor的to区域,经过多次回收,还存活的对象会到老年代Tenured,而老年代也会根据一定的条件进行垃圾回收。

Java并发编程

在多核时代下,多线程编程尤为重要,多线程首先要提到线程池,下面举个例子来看看使用线程池和不使用线程池的差别。

代码语言:javascript
复制
  long startTime = System.currentTimeMillis();
        final List<Integer> list = new LinkedList<>();
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 60, TimeUnit.SECONDS,
            new LinkedBlockingQueue<>(count));
        Random random = new Random();
        for (int i = 0; i < count; i++) {
            threadPoolExecutor.execute(new Runnable() {
                @Override
                public void run() {
                    list.add(random.nextInt());
                }
            });
        }
        threadPoolExecutor.shutdown();
 
        try{
            threadPoolExecutor.awaitTermination(1,TimeUnit.DAYS);
        }catch (Exception e){
 
        }
        System.out.println("耗费时间:" + (System.currentTimeMillis() - startTime));
        System.out.println("长度:" + list.size());
 
        System.out.println("=================================");
 
        long startTime1 = System.currentTimeMillis();
        final List<Integer> list1 = new LinkedList<>();
        Random random1 = new Random();
        for (int i = 0; i < count; i++) {
            Thread thread = new Thread(){
                @Override
                public void run(){
                    list1.add(random1.nextInt());
                }
            };
            thread.start();
            try{
                thread.join();
            }catch (Exception e){
 
            }
        }
        System.out.println("耗费时间:" + (System.currentTimeMillis() - startTime1));
        System.out.println("长度:" + list1.size());

线程池可以复用线程,而不需要冗余的创建线程,而线程池避免了频繁的创建和销毁线程,来统一处理。另外刚刚使用的是ThreadPoolExecutor,此外还有定时线程池ScheduledTheadPoolExecutor。

Synchronized可以用于声明方法,static,也可以声明代码块。当修饰static锁的是对象,所以虽然在同一个对象锁的是不同的方法,但是运行的时候,两个不同的方法是互斥的,但如果static没有修饰方法,只修饰了普通的方法,则不会出现锁对象的情况,只锁了方法。而最后一个锁代码块可以是this,也可以是任意对象,对比较前面的两个更加灵活。

reentrantLock与synchronized作用类似,但是需要自己手动释放锁,所以这时候需要注意,如果发生异常会释放锁失败,所以必须写在finally,另外提供了trylocal方法,当一个线程获取锁,另一个线程在一段时间内没有获取到锁则会返回false。reentrantlock构造器里有一个true和false的参数,默认是非公平的锁,公平锁则需要手动设置。

另外reentrantLock也有一个reentrantReadWriteLock,从名字可以看出是读写锁,主要业务场景使用在读多写少的和读不排斥的场景,这时候用readLock和writeLock来设置锁,效率比前面的全部上锁更高。

本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2022-01-19,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 后端从入门到精通 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 构建java中间件
  • Java并发编程
相关产品与服务
数据库
云数据库为企业提供了完善的关系型数据库、非关系型数据库、分析型数据库和数据库生态工具。您可以通过产品选择和组合搭建,轻松实现高可靠、高可用性、高性能等数据库需求。云数据库服务也可大幅减少您的运维工作量,更专注于业务发展,让企业一站式享受数据上云及分布式架构的技术红利!
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档