大型网站系统与Java中间件实践 02 Java中间件

简介: 01 认识分布式02 Java中间件03 分布式框架3 构建Java中间件3.1 什么事中间件?中间件不是最上层的应用也不是最底层的支撑系统,中间件在项目中起到桥梁作用,特定中间件是解决特定的场景问题的组件。

01 认识分布式
02 Java中间件
03 分布式框架

3 构建Java中间件

3.1 什么事中间件?

中间件不是最上层的应用也不是最底层的支撑系统,中间件在项目中起到桥梁作用,特定中间件是解决特定的场景问题的组件。让开发聚焦于自己的业务。

常用中间件的分类:

  1. 远程过程调用和对象访问中间件:主要解决分布式环境下应用的互相访问问题,
  2. 消息中间件:解决应用之间的消息传递,解耦,异步的问题。
  3. 数据访问中间件:主要解决应用访问数据库的共性问题的组件。

3.2 Java中间件的基础知识

3.2.1 JVM

Java源码通过编译器变成Java字节码

JVM加载Java字节码

3.2.2 垃圾回收与内存堆布局

Java通过虚拟机进行垃圾回收。

img_76d5b00c1a9539b5a672b4c4706a182e.png
Oracle Hotspot JVM堆

一般新的对象被分配在young的Eden区,也有可能直接分配在Tenured。

在进行垃圾回收的时候,Eden区中存活的对象会被复制到空的Survivor区,而下次新生代垃圾回收的时候,Eden区存活的对象和这个Survivor区中存活的对象会被复制到另外那个Survivor区域,并且清空当前的Survivor区域。经过多次新生代垃圾回收,还存活的对象被移动到年老代,而年老代的空间也会根据一定的条件进行垃圾回收。

新生代:

串行GC -- Serial Copying

并行GC -- ParNew

并行回收GC -- Parallel Scavenge

年老代:

串行GC -- Serial GC

并行MS -- Parallel MSC

并行Compacting GC -- Parallel Compacting GC

并发GC -- CMS

3.2.3 Java并发编程

  1. 线程池

  2. synchronized

任何两个线程之间调用互斥。 同步静态代码块。

同一对象之间的两个方法互斥。 同步代码块。

  1. ReentrantLock

tryLock:调用的时候,如果锁被其他线程占有返回false。

可以构造公平锁,公平锁的好处就是等待锁的线程不会饿死,但是整体效率低。

  1. volatile

可见性是指在一个线程中修改变量以后,在其他线程可以看得到这个数值。

volatile关键字保证了同一个变量在多线程中的可见性,所以它更是用于修饰作为开关状态的变量。

int  key1;
public int getKey1(){
    return key1;
}
对于调用getKey1获取当前线程中的副本,这个值不一定是最新的。
对于setKey1来说,操作的是当前线程中的副本,所以其他线程看不到最新的值。

volatile int key2;
public int getKey2(){
    return key2;
}
对于调用getKey2来说,volatile修饰保证这个变量没有线程副本,只会放在主存,所以得到的值是最新的值。
对于setKey2来说,直接操作主存,其他线程肯定会看到新值。

int key3;
public synchronized int getKey2(){
    return key3;
}

同步关键字保证线程主存与本地副本的同步,所以得到的值是最新的值。

  1. Atomics

提供了原子操作,计数器操作。

  1. wait,notify和nitifyAll

notify唤醒一个线程,noitfyAll唤醒所有线程。

对wait,notify和notifyAll调用都必须是在对象的synchronized快中。

  1. CountDownLatch

线程都到达了预期状态活完成预期工作时触发事件。

统计数据:分布计算 latch.countDown(),然后合并数据latch.await();

  1. CyclicBarrier

循环屏障,协同多个线程,让多个线程在这个屏障前等待,直到所有线程都到达了这个屏障的时候,在一起执行后面的计算。

可以循环使用。

  1. Semaphore

信号量:

  1. Exchanger

用于两个线程交互数据

线程会阻塞在exchange方法上,直到另一个线程也到了同一个Exchanger的exchange方法。

  1. Future和FutureTask
// 远程调用回阻塞
1:HashMap<String,Object> map = rpc.getDataFromRemote();

doOther();

// 远程调用提交给线程池执行
2: Future<HahsMap<String,Object>> fuctur = rpc.getDataRemote();

doOther();

// 获取数据的时候阻塞
future.get();
  1. 并发容器

  2. 动态代理

控制在执行方法之前,方法之后能进行处理相关操作。

  1. 反射

常用操作库

Javassist

cglib

asm

bcel

  1. 网络通信实现

框架Mina,Netty

3.3 分布式系统与Java中间件

img_8648fea1cdb6a376427a56ff029c0a72.png
系统中的中间件

WebApp和Service中间引入服务框架,解决了集群之间的通信问题。

在应用和数据库之间,引入分布式数据层可以方便我们操作已被分库分表的数据库节点。

目录
相关文章
|
移动开发 监控 小程序
java家政平台源码,家政上门清洁系统源码,数据多端互通,可直接搭建使用
一款基于Java+SpringBoot+Vue+UniApp开发的家政上门系统,支持小程序、APP、H5、公众号多端互通。涵盖用户端、技工端与管理后台,支持多城市、服务分类、在线预约、微信支付、抢单派单、技能认证、钱包提现等功能,源码开源,可直接部署使用。
968 24
|
设计模式 消息中间件 传感器
Java 设计模式之观察者模式:构建松耦合的事件响应系统
观察者模式是Java中常用的行为型设计模式,用于构建松耦合的事件响应系统。当一个对象状态改变时,所有依赖它的观察者将自动收到通知并更新。该模式通过抽象耦合实现发布-订阅机制,广泛应用于GUI事件处理、消息通知、数据监控等场景,具有良好的可扩展性和维护性。
948 8
|
安全 前端开发 Java
使用Java编写UDP协议的简易群聊系统
通过这个基础框架,你可以进一步增加更多的功能,例如用户认证、消息格式化、更复杂的客户端界面等,来丰富你的群聊系统。
440 11
|
机器学习/深度学习 人工智能 自然语言处理
Java与生成式AI:构建内容生成与创意辅助系统
生成式AI正在重塑内容创作、软件开发和创意设计的方式。本文深入探讨如何在Java生态中构建支持文本、图像、代码等多种生成任务的创意辅助系统。我们将完整展示集成大型生成模型(如GPT、Stable Diffusion)、处理生成任务队列、优化生成结果以及构建企业级生成式AI应用的全流程,为Java开发者提供构建下一代创意辅助系统的完整技术方案。
588 10
|
人工智能 监控 Java
Java与AI智能体:构建自主决策与工具调用的智能系统
随着AI智能体技术的快速发展,构建能够自主理解任务、制定计划并执行复杂操作的智能系统已成为新的技术前沿。本文深入探讨如何在Java生态中构建具备工具调用、记忆管理和自主决策能力的AI智能体系统。我们将完整展示从智能体架构设计、工具生态系统、记忆机制到多智能体协作的全流程,为Java开发者提供构建下一代自主智能系统的完整技术方案。
1307 4
|
消息中间件 存储 负载均衡
消息中间件的选择:RabbitMQ是一个明智的选择
消息中间件的选择:RabbitMQ是一个明智的选择
461 0
|
消息中间件 存储 中间件
【消息中间件】详解三大MQ:RabbitMQ、RocketMQ、Kafka
【消息中间件】详解三大MQ:RabbitMQ、RocketMQ、Kafka
15355 1
|
消息中间件 编解码 Docker
Docker部署RabbitMQ消息中间件
【7月更文挑战第4天】Docker部署RabbitMQ消息中间件
757 3
|
消息中间件 数据库
消息中间件系列教程(18) -RabbitMQ-基于RabbitMQ解决分布式事务(思想)
消息中间件系列教程(18) -RabbitMQ-基于RabbitMQ解决分布式事务(思想)
596 0
|
消息中间件
消息中间件系列教程(17) -RabbitMQ-死信队列
消息中间件系列教程(17) -RabbitMQ-死信队列
490 0