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

2022-07-29 14:05:03 浏览数 (1)

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

大型网站架构(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来设置锁,效率比前面的全部上锁更高。

0 人点赞