Vector(基于JDK1.8)

Vector

• 底层是由数组存储的
• 是java早期 list接口的 线程安全的 实现类

依赖关系

1 2 3

public class Vector<E> extends AbstractList<E> implements List<E>, RandomAccess, Cloneable, java.io.Serializable

• 实现了list
• 实现了RandomAccess 可以快速访问
• 可以使用Object的clone方法
• 和ArrayList一样继承了AbstractList

类注释说明

1. 底层是个动态数组存储
2. Vector底层使用 容量 和 容量增量(capacityIncrement) 来优化存储管理 容量大于等于Vector的size Vector的存储以 容量增量大小增加 可以在插入大量组件前增加 size的容量 减少了增量重新分配的数量
3. since：1.2

LinkedList(基于JDK1.8)

LinkedList

• 是list接口 最常用的实现类 之一
• LinkedList 底层是 双向链表
• LinkedlList 可以应用在 “先进先出” “先进后出”的场景 在队列源码中被频繁使用

依赖关系

1 2 3

public class LinkedList<E> extends AbstractSequentialList<E> implements List<E>, Deque<E>, Cloneable, java.io.Serializable

• 实现了 list 双向队列 可克隆 以及序列化接口
• 每个节点 叫做 Node Node有prev 代表前一个节点位置 next 代表后一个节点位置
• first 代表头结点 last代表尾节点
• 当链表为空是 两个节点是一个节点
• 链表 是 数据结构中 最简单的 动态数据结构
• 链表 引入了 指针（或者 引用）的概念

类注释说明

• 双向链表实现list 和deque 并且可以操作 null
• LinkedList 是线程不安全的 如果多个线程池并发地访问一个链表 至少其中一个线程在 结构上修改链表 它必须外部同步（链表修改可以是任意操作：添加，删除一个或多个元素 但是 设置元素的值 不是结构修改）通常通过对链表进行封装来完成的
• 推荐使用 Collections.synchronizedList 访问非同步链表 例子：List list = Collections.synchronizedList(new LinkedList(…));
• since：1.2

ArrayList （基于JDK1.8）

ArrayList

• 实现了 list 接口 是 list下 最常用的实现类之一
• 实现了 RandomAccess 接口 RandomAccess是一个声明式接口 拥有此接口 意味着 可以快速访问
• 实现了 Cloneable 接口 Cloneable 是一个声明式接口 拥有此接口 意味着 可以使用Object的clone方法复制副本
• 实现了 Serializable 接口 Serializable是一个声明式接口 拥有此接口 意味着 可以序列化以及反序列化

ArrayList 依赖关系：

1 2	public class ArrayList<E> extends AbstractList<E> implements List<E>, RandomAccess, Cloneable, java.io.Serializable

类注释说明：

1. ArrayList 提供操作数组的方法 与 Vector 相似 但是ArrayList 线程不安全
2. add() 时间复杂度O(n)
3. 容量大于等于size
4. 线程不安全 如果想要用线程安全的 推荐使用Collections.synchronizedList 例子：List list = Collections.synchronizedList(new ArrayList(…))
5. since：1.2

ArrayList的一些默认属性值

1 2	// 初始容量大小 默认为10 private static final int DEFAULT_CAPACITY = 10;

1 2	// 基于空数组的实例 private static final Object[] EMPTY_ELEMENTDATA = {};

1 2 3

// 共享空数组实例，用于默认大小的空实例 // 将其与EMPTY_ELEMENTDATA区分开来，以了解添加第一个元素时需要膨胀多少。 private static final Object[] DEFAULTCAPACITY_EMPTY_ELEMENTDATA = {};

1 2 3 4 5

// 默认的元素数据 // 如果初始化是没有设置 默认值元素数据为 DEFAULTCAPACITY_EMPTY_ELEMENTDATA // 源码中 注释 不使用private 是为了能用于 简化 嵌套访问 // non-private to simplify nested class access transient Object[] elementData;

1 2	// 数组大小 ArrayList中包含多少数据 private int size;

为什么？

单一架构 演变到 分布式集群项目 需要解决session共享问题

SSO（Single Sign On）模式

CAS单点登录、OAuth2

• 如图所示 图中有三个系统 分别为业务A B 和SSO
• 业务A 和 B 没有登录模块
• 只有SSO有登录模块 没有其他的业务模块

一般过程：

• 当业务A B 需要登录的时候 跳转到 SSO系统
• SSO从用户信息数据库中 获取用户信息 并且 校验 校验通过 SSO完成登录
• 将校验的用户信息存入缓存（如：redis）
• 当用户访问其他业务时 如果需要登录 将跳转到SSO系统中 进行用户身份认证 SSO判断缓存中是否存在用户身份信息
• 只要在其中一个业务中 完成了 用户登录 其他的应用系统 都不需要登录

优点：

用户身份信息独立管理，更好的分布式管理。可以自己扩展安全策略

缺点：

认证服务器访问压力较大。

线程定制化通讯问题

1 2 3 4 5

题目 定制化线程间通讯 线程A 循环五次 调用B 线程B 循环十次 调用C 线程C 循环十五次 调用A

生产者/消费者 问题

生产者 / 消费者 问题 是线程模型中的经典问题

问题概述（为什么？）：

​ 生产者 和 消费者 在同一时间段内 共用 同一个存储空间 如果不加以协调 可能出现以下情况 存储空间已满 而生产者占用着它 消费者等待着 生产者 让出资源 从而去除产品 而 生产者 等待着 消费者 去消费产品 从而向空间中 新增产品 相互等待 产生死锁

产什么死锁的四个必要条件：

• 互斥条件 ： 一个资源一次只能被一个线程使用
• 请求与保持条件： 一个线程因请求资源 而 阻塞时 对已经获得的资源 保持 不放
• 不剥夺条件： 线程已经获得资源 在未使用完后之前 不能强行剥夺
• 循环等待条件：若干线程之间 形成一种 头尾相接的 循环等待资源关系
• 上述问题简而言之：同一时刻 统一资源 被两个线程(多个线程)使用 并且 两个线程相互等待对方执行结束 从而释放资源 另一方 接着使用 共享资源

文本 主要是记录一些 有关于ElasticSearch的DSL语句的使用

上一篇 说明了 文档操作 请求体查询(基本查询 结果过滤) 本文将继续说明其他的语法

具体操作

1. 请求体查询（高级查询）

1.1 布尔组合（bool）

bool 把 各种 其他查询 通过 must ，must_not ， should 的方式进行组合

发送请求

GET /shopping/_search
{
“query”: {
“bool”: {
“must”: [
{“match”: {
“title”: “小米”
}}
],
“must_not”: [
{“match”: {
“title”: “电视”
}}
],
“should”: [
{“match”: {
“title”: “手机”
}}
]
}
}
}

响应结果

{
“took” : 9,
“timed_out” : false,
“_shards” : {
“total” : 5,
“successful” : 5,
“skipped” : 0,
“failed” : 0
},
“hits” : {
“total” : 1,
“max_score” : 0.5753642,
“hits” : [
{
“_index” : “shopping”,
“_type” : “product”,
“_id” : “1”,
“_score” : 0.5753642,
“_source” : {
“title” : “小米手机”,
“images” : “http://www.youngdonkey.cn/xm.jpg",
“price” : 3999.0
}
}
]
}
}

文本 主要是记录一些 有关于ElasticSearch的DSL语句的使用

上一篇文章 说明了 索引库操作 以及 类型及映射操作 本文将详细说明其他的使用语法

具体操作

1.文档操作【基本的CURD】

1.1 新建文档

发送请求

POST /shopping/product

{

​ “title”:”小米手机”,

​ “images”:”http://www.youngdonkey.cn/xm.jpg",

​ “price”:3999.00

}

响应结果

{
“_index” : “shopping”,
“_type” : “product”,
“_id” :
“indGaHEB1ahbZ0SRrXt3”,
“_version” : 1,
“result” : “created”,
“_shards” : {
“total” : 2,
“successful” : 1,
“failed” : 0
},
“_seq_no” : 0,
“_primary_term” : 1
}

响应结果解释

{
“_index【索引库】” : “shopping”,
“_type【类型】” : “product”,
“_id【主键id】” :
“indGaHEB1ahbZ0SRrXt3”,
“_version【版本】” : 1,
“result【操作结果】” : “created”,
“_shards【分片】” : {
“total【总数】” : 2,
“successful【成功】” : 1,
“failed【失败】” : 0
},
“_seq_no” : 0,
“_primary_term” : 1
}

可以看到结果显示为：created，是创建成功了。

另外，需要注意的是，在响应结果中有个_id字段，这个就是这条文档数据的唯一标识，以后的增删改查都依赖这个id作为唯一标示。可以看到id的值为：indGaHEB1ahbZ0SRrXt3，这里我们新增时没有指定id，所以是ES帮我们随机生成的id。

多创建几条数据：
POST /shopping/product/2
{
“title”:”华为手机”,

“images”:”http://www.youngdonkey.cn/hw.jpg",
“price”:4999.00
}

POST /shopping/product/3
{
“title”:”小米电视”,

“images”:”http://www.youngdonkey.cn/xmds.jpg",
“price”:5999.00
}

文本 主要是记录一些 有关于ElasticSearch的入门的使用

是什么？

• ElasticSearch 简称 ES 是一个 开源的 高扩展的 分布式 全文检索 引擎
• 可以 近乎实时 的 存储 检索 数据 本身扩展性很好 可扩展到 上百台 服务器 处理 PB 级别的数据
• ElasticSearch 可以使用 Java开发 并使用 Lucene【注:1】作为其核心 来实现 所有 检索 和 搜索的功能 但是 它(ElasticSearch)的目的 是通过 简单的 RESTful API 来隐藏 Lucene 的 复杂性 从而 让 全文搜索变得简单

ElasticSearch 和 Solr 的 对比

• 上面说到了 目前常见的 两款 搜索引擎服务软件 接下来说说两者的区别

• Solr 利用Zookeeper 进行 分布式 管理 而 ElasticSearch 自身 带有 分布式 协调 管理功能
• Solr 支持 更多格式的数据 而 ElasticSearch 仅仅支持 JSON文件格式
• Solr 官方提供 的功能更多 而 ElasticSearch 本身更注重于核心功能 高级功能多由 第三方 插件提供
• Solr 在 传统的搜索 应用中表现 好于 ElasticSearch 但 在处理 实时搜索 应用时 效率 明显低于 ElasticSearch

应用场景

• 为 用户 提供 按 关键字 查询 的 全文搜索功能
• 著名的ELK框架(ElasticSearch,Logstash,Kibana【注:2】) 实现企业海量日志的 处理 分析 的解决方案 是 大数据 领域的重要一份子
• 分析用户的行为 精准营销 例如：用户鼠标在哪个商品上 图片上的停留时间 对商品的点击量 查看评论的条数

本片文章为 分布式锁 相关的系列文章

​ 本系列文章 将从 缓存的使用 本地锁 ** 一直写到 **分布式锁 以及相关的一些 知识点 问题

上一篇文章说明了八种Redisson 分布式锁和同步器的基本用法 本章将详细讲解如何使用Redisson做分布式锁

上一篇文章：“分布式锁：有关于分布式锁集合（三）”

Redisson 的 快速入门

1
2
3
4
5
6
7
8
9
10

// 1. Create config object
// 创建一个配置类对象 （那么我前面肯定就现需要有一个配置类或者配置文件）
Config config = new Config();
config.useClusterServers()
       // use "rediss://" for SSL connection
      .addNodeAddress("redis://127.0.0.1:7181");

// or read config from file
// 配置信息 可以 通过 配置文件获取
config = Config.fromYAML(new File("config-file.yaml")); 

1
2
3
4
5
6
7
8
9
10
11

// 2. Create Redisson instance
// 创建Redisson实例对象
// Sync and Async API
// 使用静态 非静态的 api方法
RedissonClient redisson = Redisson.create(config);

// Reactive API
RedissonReactiveClient redissonReactive = Redisson.createReactive(config);

// RxJava2 API
RedissonRxClient redissonRx = Redisson.createRx(config);