事务

Redis 事务本质：一组命令的集合。一个事务中所有的命令都会被序列化，在事务执行过程中，会按照顺序执行。

一次性、顺序性、排他性。

要么同时成功，要么同时失败，原子性。

==Redis 事务没有隔离级别的概念==

所有的命令在事务中，并没有直接被执行，只有发起执行命令的时候才会执行。Exec

==Redis 单条命令是保证原子性的，但是事务不保证原子性==

redis 的事务：

• 开启事务（multi）
• 命令入队（......）
• 执行事务（exec）

正常执行事务

127.0.0.1:6379> multi        # 开启事务
OK
# 命令入队
127.0.0.1:6379> set k1 v1
QUEUED
127.0.0.1:6379> set k2 v2
QUEUED
127.0.0.1:6379> get k2
QUEUED
127.0.0.1:6379> set k3 v3
QUEUED
127.0.0.1:6379> exec        # 执行事务
1) OK
2) OK
3) "v2"
4) OK

放弃事务

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set k1 v1
QUEUED
127.0.0.1:6379> set k2 v2
QUEUED
127.0.0.1:6379> set k4 v4
QUEUED
127.0.0.1:6379> DISCARD        # 取消事务  放弃事务
OK
127.0.0.1:6379> get k4        # 事务队列中的命令都不会被执行
(nil)

编译型异常（命令有错），事务中所有的命令都不会被执行

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set k1 v1
QUEUED
127.0.0.1:6379> set k2 v3
QUEUED
127.0.0.1:6379> set k3 v3
QUEUED
127.0.0.1:6379> getset k3 3
QUEUED
127.0.0.1:6379> getset k3    # 错误的命令
(error) ERR wrong number of arguments for 'getset' command
127.0.0.1:6379> set k4 v4
QUEUED
127.0.0.1:6379> set k5 v5
QUEUED
127.0.0.1:6379> exec        # 执行事务报错
(error) EXECABORT Transaction discarded because of previous errors.
127.0.0.1:6379> get k1        # 所有的命令都不会被执行
(nil)
127.0.0.1:6379> get k5
(nil)

运行时异常（ 1/0 ），如果事务队列中存在语法性错误，那么执行命令时其他命令是可以正常执行的，错误命令会抛出异常

127.0.0.1:6379> set k1 v1
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> incr k1        # 会执行的时候失败
QUEUED
127.0.0.1:6379> set k2 v2
QUEUED
127.0.0.1:6379> set k3 v3
QUEUED
127.0.0.1:6379> get k3
QUEUED
127.0.0.1:6379> exec
1) (error) ERR value is not an integer or out of range    # 虽然第一条命令报错了，但是整个事务依旧正常执行成功
2) OK
3) OK
4) "v3"
127.0.0.1:6379> get k2
"v2"
127.0.0.1:6379> get k3
"v3"

监控 Watch

悲观锁：

• 很悲观，认为什么时候都会出问题，无论做什么都会加锁

乐观锁：

• 很乐观，认为什么时候都不会出问题，所以不会上锁，更新数据的时候去判断一下，在此期间，是否有人修改过这个数据
• 获取 version
• 更新的时候比较 version

Redis 的监视测试

正常执行成功：

127.0.0.1:6379> set money 100
OK
127.0.0.1:6379> set out 0
OK
127.0.0.1:6379> watch money        # 监视 money 对象
OK
127.0.0.1:6379> MULTI        # 事务正常结束，数据期间没有发生变动，这个时候就正常执行成功
OK
127.0.0.1:6379> decrby money 20
QUEUED
127.0.0.1:6379> incrby out 20
QUEUED
127.0.0.1:6379> exec
1) (integer) 80
2) (integer) 20

测试多线程修改值，使用 watch 可以当做 redis 的乐观锁

127.0.0.1:6379> watch money    # 监视 money
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> decrby money 10
QUEUED
127.0.0.1:6379> incrby out 10
QUEUED
127.0.0.1:6379> exec    # 执行之前，另外一个线程，修改了我们的值，这个时候，就会导致事务执行失败.
(nil)

# 如果发现事务执行失败 就先解锁
127.0.0.1:6379> UNWATCH
OK
127.0.0.1:6379> watch money    # 获取最新的值 再次监视
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> decrby money 10
QUEUED
127.0.0.1:6379> incrby out 10
QUEUED
127.0.0.1:6379> exec        # 比对监视的值是否发生了变化如果没有变化,那么可以执行成功,如果变化就执行失败
1) (integer) 990
2) (integer) 30

三种特殊数据类型

geospatial 地理位置

朋友的定位，附近的人，打车距离计算等

Redis 的 Geo，这个功能可以推算地理位置信息，两地之间的距离，方圆几里的人。

只有六个命令：

geoadd 添加地理位置

规则：两级无法直接添加，我们一般会下载城市数据，直接通过 java 程序一次性导入

参数 key 值(经度、纬度、名称)

127.0.0.1:6379> geoadd china:city 116.40 39.90 beijing
(integer) 1
127.0.0.1:6379> geoadd china:city 121.47 31.23 shanghai
(integer) 1
127.0.0.1:6379> geoadd china:city 106.50 29.53 chongqing 114.08 22.54 shenzhen
(integer) 2
127.0.0.1:6379> geoadd china:city 120.16 30.24 hangzhou 108.96 34.26 xian
(integer) 2

geopos 获取当前定位 一定是一个坐标值

获取指定城市的经度和纬度

127.0.0.1:6379> geopos china:city beijing
1) 1) "116.39999896287918091"
   2) "39.90000009167092543"
127.0.0.1:6379> geopos china:city beijing chongqing
1) 1) "116.39999896287918091"
   2) "39.90000009167092543"
2) 1) "106.49999767541885376"
   2) "29.52999957900659211"

geodist

两人之间的距离

单位：

• m 米
• km 千米
• mi 英里
• ft 英尺

127.0.0.1:6379> geodist china:city beijing shanghai
"1067378.7564"
127.0.0.1:6379> geodist china:city beijing shanghai km
"1067.3788"
127.0.0.1:6379> geodist china:city beijing chongqing km
"1464.0708"

georadius 以给定的经纬度为中心，找出某一半径内的元素

附近的人（获得所有附近的人的住址，定位）通过半径来查询

获得指定数量的人

所有数据应该都录入：china:city 才会让结果更加清晰

127.0.0.1:6379> GEORADIUS china:city 110 30 1000 km    #以 100 30 这个经纬度为中心 寻找方圆1000km内的城市
1) "chongqing"
2) "xian"
3) "shenzhen"
4) "hangzhou"
127.0.0.1:6379> GEORADIUS china:city 110 30 500 km
1) "chongqing"
2) "xian"
127.0.0.1:6379> GEORADIUS china:city 110 30 500 km withdist        # 显示到中心距离的位置
1) 1) "chongqing"
   2) "341.9374"
2) 1) "xian"
   2) "483.8340"
127.0.0.1:6379> GEORADIUS china:city 110 30 500 km withcoord    # 显示出他人的定位信息
1) 1) "chongqing"
   2) 1) "106.49999767541885376"
      2) "29.52999957900659211"
2) 1) "xian"
   2) 1) "108.96000176668167114"
      2) "34.25999964418929977"
127.0.0.1:6379> GEORADIUS china:city 110 30 500 km withdist withcoord count 1    # 筛选出指定的结果
1) 1) "chongqing"
   2) "341.9374"
   3) 1) "106.49999767541885376"
      2) "29.52999957900659211"
127.0.0.1:6379> GEORADIUS china:city 110 30 500 km withdist withcoord count 2
1) 1) "chongqing"
   2) "341.9374"
   3) 1) "106.49999767541885376"
      2) "29.52999957900659211"
2) 1) "xian"
   2) "483.8340"
   3) 1) "108.96000176668167114"
      2) "34.25999964418929977"
127.0.0.1:6379> GEORADIUS china:city 110 30 500 km withdist withcoord count 3
1) 1) "chongqing"
   2) "341.9374"
   3) 1) "106.49999767541885376"
      2) "29.52999957900659211"
2) 1) "xian"
   2) "483.8340"
   3) 1) "108.96000176668167114"
      2) "34.25999964418929977"
127.0.0.1:6379>

georadiusbymember

找出位于指定元素周围的其他元素

127.0.0.1:6379> georadiusbymember china:city beijing 1000 km
1) "beijing"
2) "xian"
127.0.0.1:6379> georadiusbymember china:city shanghai 400 km
1) "hangzhou"
2) "shanghai"

geohash

该命令将返回 11 个字符的 geohash 字符串

将二维的经纬度转换为一维的字符串，如果两个字符串越接近，则距离越近。

127.0.0.1:6379> GEOHASH china:city beijing chongqing
1) "wx4fbxxfke0"
2) "wm5xzrybty0"

GEO 底层实现原理其实就是 Zset，可以使用 Zet 命令来操作 GEO

127.0.0.1:6379> zrange china:city 0 -1    # 查看地图中全部元素
1) "chongqing"
2) "xian"
3) "shenzhen"
4) "hangzhou"
5) "shanghai"
6) "beijing"
127.0.0.1:6379> zrem china:city beijing        # 移除指定元素
(integer) 1
127.0.0.1:6379> zrange china:city 0 -1
1) "chongqing"
2) "xian"
3) "shenzhen"
4) "hangzhou"
5) "shanghai"

hyperloglog

基数：不重复的元素，可以接受误差

hyperloglog 简介

是一种数据结构，用来做基数统计的算法

优点：占用内存是固定的

127.0.0.1:6379> PFADD mykey a b c d e f g h i j        # 创建第一组元素
(integer) 1
127.0.0.1:6379> PFCOUNT mykey        # 统计 mykey 中元素的基数数量
(integer) 10
127.0.0.1:6379> pfadd mykey2 i j z x c v b n m        # 创建第二组元素
(integer) 1
127.0.0.1:6379> PFCOUNT mykey2
(integer) 9
127.0.0.1:6379> PFMERGE mykey3 mykey mykey2        # 合并两组 mykey mykey2 => mykey3  并集
OK
127.0.0.1:6379> PFCOUNT mykey3    # 查看并集的数量
(integer) 15

如果允许容错，那么一定可以使用 Hyperloglog

bitmap

位存储

统计用户信息，活跃/不活跃，登录/未登录，打卡/未打卡等这种两个状态的，都可以使用 bitmap

bitmap 叫位图，也是一种数据结构，都是操作二进制位来进行记录，就只有 0 和 1 两个状态。

使用 bitmaps 来记录周一到周日的打卡：

127.0.0.1:6379> setbit sign 0 1
(integer) 0
127.0.0.1:6379> setbit sign 1 0
(integer) 0
127.0.0.1:6379> setbit sign 2 0
(integer) 0
127.0.0.1:6379> setbit sign 3 1
(integer) 0
127.0.0.1:6379> setbit sign 4 1
(integer) 0
127.0.0.1:6379> setbit sign 5 0
(integer) 0
127.0.0.1:6379> setbit sign 6 0
(integer) 0

查看某一天是否有打卡：

127.0.0.1:6379> getbit sign 3
(integer) 1
127.0.0.1:6379> getbit sign 6
(integer) 0

统计操作，统计打卡的天数：

127.0.0.1:6379> BITCOUNT sign    # 统计这周的打卡记录，就可以看到是否有全勤
(integer) 3

五大数据类型

Redis-Key

127.0.0.1:6379> keys *    # 查看所有的 key
1) "age"
127.0.0.1:6379> set name azhang        # set key
OK
127.0.0.1:6379> keys *
1) "name"
2) "age"
127.0.0.1:6379> exists name        # 判断当前 key 是否存在
(integer) 1
127.0.0.1:6379> exists name1
(integer) 0
127.0.0.1:6379> move name 1        # 将 key 移动到指定 DB
(integer) 0
127.0.0.1:6379>  keys *
1) "name"
2) "age"
127.0.0.1:6379> move name 2
(integer) 1
127.0.0.1:6379>  keys *
1) "age"
127.0.0.1:6379> set name azhang
OK
127.0.0.1:6379>  keys *
1) "name"
2) "age"
127.0.0.1:6379> get name
"azhang"
127.0.0.1:6379> expire name 10        # 设置过期时间 单位是 s
(integer) 1
127.0.0.1:6379> ttl name    # 查看当前 key 的剩余时间
(integer) 7
127.0.0.1:6379> ttl name
(integer) 3
127.0.0.1:6379> ttl name
(integer) -2
127.0.0.1:6379> keys *
1) "age"
127.0.0.1:6379> set name azhang
OK
127.0.0.1:6379> del name    # 删除指定 key
(integer) 1
127.0.0.1:6379> keys *
1) "age"
127.0.0.1:6379> set name azhang
OK
127.0.0.1:6379> keys *
1) "name"
2) "age"
127.0.0.1:6379> type name    # 查看当前 key 的类型
string
127.0.0.1:6379> type age
string
127.0.0.1:6379> clear    # 清空控制台

String

#####################################################
127.0.0.1:6379> set key1 v1        # 设置值
OK
127.0.0.1:6379> get key1        # 获得值
"v1"
127.0.0.1:6379> keys *            # 获得所有的 key
1) "key1"
127.0.0.1:6379> exists key1        # 判断当前 key 是否存在
(integer) 1
127.0.0.1:6379> append key1 hello    # 往某个 key 中追加 字符串 如果当前 key 不存在 就相当于 set key
(integer) 7
127.0.0.1:6379> keys *
1) "key1"
127.0.0.1:6379> get key1
"v1hello"
127.0.0.1:6379> STRLEN key1        # 获取字符串长度
(integer) 7
127.0.0.1:6379> append key1 ,azhang
(integer) 14
#####################################################
# i++
# 步长 i+=
127.0.0.1:6379> set views 0        # 初始浏览量为 0
OK
127.0.0.1:6379> get views
"0"
127.0.0.1:6379> INCR views        # 自增 1    浏览量变为 1
(integer) 1
127.0.0.1:6379> INCR views
(integer) 2
127.0.0.1:6379> get views
"2"
127.0.0.1:6379> DECR views
(integer) 1
127.0.0.1:6379> DECR views        # 自减 1    浏览量变为 0
(integer) 0
127.0.0.1:6379> INCRBY views 10    # 可以设置步长来指定增量
(integer) 10
127.0.0.1:6379> INCRBY views 10
(integer) 20
127.0.0.1:6379> DECRBY views 10
(integer) 10
127.0.0.1:6379> DECRBY views 10
(integer) 0
#####################################################
# 字符串范围 range
127.0.0.1:6379> set key1 hello,azhang    # 设置 key1 的值
OK
127.0.0.1:6379> get key1
"hello,azhang"
127.0.0.1:6379> GETRANGE key1 0 3        # 截取字符串 [0,3]
"hell"
127.0.0.1:6379> GETRANGE key1 6 -1
"azhang"
127.0.0.1:6379> GETRANGE key1 0 -1        # 获取全部的字符串和 get key 是一样的
"hello,azhang"

# 替换
127.0.0.1:6379> set key2 abcdefg
OK
127.0.0.1:6379> get key2
"abcdefg"
127.0.0.1:6379> SETRANGE key2 1 xx    # 替换指定位置开始的字符串
(integer) 7
127.0.0.1:6379> get key2
"axxdefg"
#####################################################
# setex (set with expire) 设置过期时间
# setnx (set if not exist) 不存在再设置 (在分布式锁中常常使用)
127.0.0.1:6379> setex key3 30 hello        # 设置 key3 的值为 hello 30s后过期
OK
127.0.0.1:6379> ttl key3
(integer) 25
127.0.0.1:6379> get key3
"hello"
127.0.0.1:6379> ttl key3
(integer) 18
127.0.0.1:6379> setnx mykey redis    # 如果 mykey 不存在 创建 mykey
(integer) 1
127.0.0.1:6379> keys *
1) "key2"
2) "mykey"
3) "key1"
127.0.0.1:6379> ttl key3
(integer) -2
127.0.0.1:6379> setnx mykey mongoDB    # 如果 mykey 存在 创建失败
(integer) 0
127.0.0.1:6379> get mykey
"redis"
#####################################################
# mset
# mget
127.0.0.1:6379> mset k1 v1 k2 v2 k3 v3    # 同时设置多个值
OK
127.0.0.1:6379> keys *
1) "k3"
2) "k2"
3) "k1"
127.0.0.1:6379> mget k1 k2 k3    # 同时获取多个值
1) "v1"
2) "v2"
3) "v3"
127.0.0.1:6379> msetnx k1 v1 k4 v4    # msetnx 是一个原子性操作 要么一起成功 要么一起失败
(integer) 0
127.0.0.1:6379> get k4
(nil)

# 对象
set user:1 {name:azhang, age:21}    # 设置一个 user:1 对象 值为 json 字符来保存一个对象

# 这里的 key 设计巧妙： user:{id}:{filed} 如此设计在 redis 中是可以的
127.0.0.1:6379> mset user:1:name azhang user:1:age 21
OK
127.0.0.1:6379> mget user:1:name user:1:age
1) "azhang"
2) "21"

##################################################### getset 先 get 然后再 set
127.0.0.1:6379> GETSET db redis     # 如果不存在值 则返回 null
(nil)
127.0.0.1:6379> get db
"redis"
127.0.0.1:6379> GETSET db mongodb    # 如果存在值 获取原来的值 并设置新的值
"redis"
127.0.0.1:6379> get db
"mongodb"
####################################################

String 的应用场景：value 除了是我们的字符串还可以是我们的数字

• 计数器
• 统计多单位的数量 uid:{95256449}:follow 0
• 粉丝数
• 对象缓存存储

List

在 redis 中，list 可以实现 栈、队列、阻塞队列。

所有的 list 命令都是用 l 开头的，不区分大小写命令

####################################################
# lpush
# lrange
# rpush

127.0.0.1:6379> LPUSH list one two    # 将一个值或者多个值插入列表的头部（左）
(integer) 2
127.0.0.1:6379> lrange list 0 -1    # 获取 list 中的值
1) "two"
2) "one"
127.0.0.1:6379> LPUSH list three
(integer) 3
127.0.0.1:6379> LRANGE list 0 1        # 通过区间获取具体的值
1) "three"
2) "two"
127.0.0.1:6379> RPUSH list zero        # 将一个值或者多个值插入列表的尾部（右）
(integer) 4
127.0.0.1:6379> lrange list 0 -1
1) "three"
2) "two"
3) "one"
4) "zero"

####################################################
# lpop
# rpop

127.0.0.1:6379> lrange list 0 -1
1) "three"
2) "two"
3) "one"
4) "zero"
127.0.0.1:6379> lpop list    # 移除 list 的第一个元素
"three"
127.0.0.1:6379> lrange list 0 -1
1) "two"
2) "one"
3) "zero"
127.0.0.1:6379> rpop list    # 移除 list 的最后一个元素
"zero"
127.0.0.1:6379> lrange list 0 -1
1) "two"
2) "one"

####################################################
# lindex

127.0.0.1:6379> lrange list 0 -1
1) "two"
2) "one"
127.0.0.1:6379> LINDEX list 1    #通过下标获得 list 中的某一个值
"one"
127.0.0.1:6379> LINDEX list 0
"two"

####################################################
# llen

127.0.0.1:6379> lpush list one two three
(integer) 3
127.0.0.1:6379> llen list    # 返回 list 的长度
(integer) 3
127.0.0.1:6379>

####################################################
# 移除指定的值
# lrem

127.0.0.1:6379> lrange list 0 -1
1) "three"
2) "three"
3) "two"
4) "one"
127.0.0.1:6379> lrem list 1 one    # 移除 list 集合中指定个数的 value 精确匹配
(integer) 1
127.0.0.1:6379> lrange list 0 -1
1) "three"
2) "three"
3) "two"
127.0.0.1:6379> lrem list 1 three
(integer) 1
127.0.0.1:6379> lrange list 0 -1
1) "three"
2) "two"
127.0.0.1:6379> lpush list three
(integer) 3
127.0.0.1:6379> lrem list 2 three
(integer) 2
127.0.0.1:6379> lrange list 0 -1
1) "two"
127.0.0.1:6379>

####################################################
# ltrim 截断

127.0.0.1:6379> rpush mylist hello
(integer) 1
127.0.0.1:6379> rpush mylist hello1
(integer) 2
127.0.0.1:6379> rpush mylist hello2
(integer) 3
127.0.0.1:6379> rpush mylist hello3
(integer) 4
127.0.0.1:6379> ltrim mylist 1 2    # 通过下标截取指定的长度
OK
127.0.0.1:6379> lrange mylist 0 -1
1) "hello1"
2) "hello2"

####################################################
# rpoplpush 移除列表的最后一个元素 并将它移动到新的列表中

127.0.0.1:6379> rpush mylist hello hello1 hello2
(integer) 3
127.0.0.1:6379> RPOPLPUSH mylist myotherlist    # 移除列表的最后一个元素 并将它移动到新的列表中
"hello2"
127.0.0.1:6379> lrange mylist 0 -1
1) "hello"
2) "hello1"
127.0.0.1:6379> lrange myotherlist 0 -1
1) "hello2"
127.0.0.1:6379>

####################################################
# lset 将列表中指定下标的值替换为另外一个值，更新操作

127.0.0.1:6379> EXISTS list        # 判断列表是否存在
(integer) 0
127.0.0.1:6379> lset list 0 v1    # 如果不存在列表 更新就会报错
(error) ERR no such key
127.0.0.1:6379> lpush list v1
(integer) 1
127.0.0.1:6379> lrange list 0 0
1) "v1"
127.0.0.1:6379> lset list 0 item    #如果存在 更新当前下标的值
OK
127.0.0.1:6379> lrange list 0 0
1) "item"
127.0.0.1:6379> lset list 1 other    # 如果下标不存在 会报错
(error) ERR index out of range

####################################################
# linsert 将某个具体的 value 插入到列表中某个元素的前面或者后面

127.0.0.1:6379> rpush mylist hello world
(integer) 2
127.0.0.1:6379> linsert mylist before world other
(integer) 3
127.0.0.1:6379> lrange mylist 0 -1
1) "hello"
2) "other"
3) "world"
127.0.0.1:6379> linsert mylist after world new
(integer) 4
127.0.0.1:6379> lrange mylist 0 -1
1) "hello"
2) "other"
3) "world"
4) "new"

####################################################

• list 实际上是一个链表，before Node after，left right 都可以插入值
• 如果 key 不存在，可以创建新的链表
• 如果 key 存在，可以新增内容
• 如果移除了所有值，空链表，也代表不存在
• 在两边插入或者改动值效率最高，中间元素相对效率会低一点

Set

set 中的值是不能重复的

####################################################
127.0.0.1:6379> sadd myset hello    # set集合中添加元素
(integer) 1
127.0.0.1:6379> sadd myset azhang
(integer) 1
127.0.0.1:6379> sadd myset love
(integer) 1
127.0.0.1:6379> smembers myset        # 查看指定 set 的所有值
1) "azhang"
2) "love"
3) "hello"
127.0.0.1:6379> sismember myset hello    # 判断某一个值是否在 set集合中
(integer) 1
127.0.0.1:6379> sismember myset world
(integer) 0

####################################################
127.0.0.1:6379> scard myset        # 获取 set 集合中的内容元素个数
(integer) 3

####################################################
127.0.0.1:6379> srem myset hello    # 移除 set 中的指定元素
(integer) 1
127.0.0.1:6379> scard myset
(integer) 2
127.0.0.1:6379> SMEMBERS myset
1) "azhang"
2) "love"

####################################################
# set 无序不重复集合，抽随机

127.0.0.1:6379> SMEMBERS myset
1) "azhang"
2) "love"
127.0.0.1:6379> SRANDMEMBER myset    # 随机抽选出一个元素
"love"
127.0.0.1:6379> SRANDMEMBER myset
"azhang"
127.0.0.1:6379> SRANDMEMBER myset
"love"
127.0.0.1:6379> SRANDMEMBER myset
"azhang"
127.0.0.1:6379> SRANDMEMBER myset 2    # 随机抽选出指定个数的元素
1) "azhang"
2) "love"
127.0.0.1:6379> SRANDMEMBER myset 2
1) "azhang"
2) "love"

####################################################
# 删除指定的 key
# 随机删除 key

127.0.0.1:6379> SMEMBERS myset
1) "azhang"
2) "love"
127.0.0.1:6379> spop myset    # 随机删除一些 set 集合中的元素
"love"
127.0.0.1:6379> spop myset
"azhang"
127.0.0.1:6379> SMEMBERS myset
(empty list or set)

####################################################
# 将一个指定的值，移动到另外一个 set 集合中

127.0.0.1:6379> sadd myset hello world azhang
(integer) 3
127.0.0.1:6379> sadd myset2 set2
(integer) 1
127.0.0.1:6379> smove myset myset2 azhang    # 将一个指定的值，移动到另外一个 set 集合中
(integer) 1
127.0.0.1:6379> SMEMBERS myset
1) "hello"
2) "world"
127.0.0.1:6379> SMEMBERS myset2
1) "azhang"
2) "set2"

####################################################
数字集合类：
  - 差集
  - 交集
  - 并集

127.0.0.1:6379> sadd key1 a b c
(integer) 3
127.0.0.1:6379> sadd key2 c d e
(integer) 3
127.0.0.1:6379> sdiff key1 key2        # 差集
1) "b"
2) "a"
127.0.0.1:6379> sinter key1 key2    # 交集 （共同好友）
1) "c"
127.0.0.1:6379> sunion key1 key2    # 并集
1) "e"
2) "c"
3) "a"
4) "b"
5) "d"
127.0.0.1:6379>

####################################################

Hash

Map 集合，key - map，这时候这个值是一个 map 集合，本质和 String 类型没有太大区别，还是一个简单的 key - value

####################################################
127.0.0.1:6379> hset myhash f1 azhang    # set 一个具体的 key-value
(integer) 1
127.0.0.1:6379> hget myhash f1        # 获取一个字段值
"azhang"
127.0.0.1:6379> hmset myhash f1 hello f2 world    # set 多个 key-value
OK
127.0.0.1:6379> hmget myhash f1 f2    # 获取多个字段值
1) "hello"
2) "world"
127.0.0.1:6379> hgetall myhash    # 获取全部的数据
1) "f1"
2) "hello"
3) "f2"
4) "world"
127.0.0.1:6379> hdel myhash f1    # 删除 hash 指定的 key 字段，对应的 value 值也就消失了
(integer) 1
127.0.0.1:6379> hgetall myhash
1) "f2"
2) "world"
127.0.0.1:6379> hgetall myhash
####################################################
# hlen

127.0.0.1:6379> hmset myhash f1 hello f2 world
OK
127.0.0.1:6379> hgetall myhash
1) "f2"
2) "world"
3) "f1"
4) "hello"
127.0.0.1:6379> hlen myhash    # 获取 hash 表的字段数量
(integer) 2

####################################################
127.0.0.1:6379> HEXISTS myhash f1    # 判断 hash 中指定字段是否存在
(integer) 1
127.0.0.1:6379> HEXISTS myhash f3
(integer) 0

####################################################
# 只获得所有 filed
# 只获得所有 value

127.0.0.1:6379> hkeys myhash
1) "f2"
2) "f1"
127.0.0.1:6379> hvals myhash
1) "world"
2) "hello"

####################################################
# incr decr

127.0.0.1:6379> hset myhash f3 5    # 指定增量
(integer) 1
127.0.0.1:6379> hincrby myhash f3 1
(integer) 6
127.0.0.1:6379> hincrby myhash f3 -1
(integer) 5
127.0.0.1:6379> hsetnx myhash f4 hello    # 如果不存在则可以设置
(integer) 1
127.0.0.1:6379> hsetnx myhash f4 world    # 如果存在则不能设置
(integer) 0
127.0.0.1:6379> hgetall myhash
1) "f2"
2) "world"
3) "f1"
4) "hello"
5) "f3"
6) "5"
7) "f4"
8) "hello"

####################################################

hash 变更的数据 user name age，尤其是用户信息之类的，经常变动的信息。

hash 更适合对象的存储，String 更加适合字符串存储。

Zset

在 set 的基础上，增加了一个值，set k1 v1，Zset k1 score1 v1

####################################################
127.0.0.1:6379> zadd myset 1 one    # 添加一个值
(integer) 1
127.0.0.1:6379> zadd myset 2 two
(integer) 1
127.0.0.1:6379> zadd myset 2 two
(integer) 0
127.0.0.1:6379> zadd myset 2 two 3 three    # 添加多个值
(integer) 1
127.0.0.1:6379> zrange myset 0 -1
1) "one"
2) "two"
3) "three"
127.0.0.1:6379>

####################################################
# 实现排序

127.0.0.1:6379> zadd salary 2500 xiaohong    # 添加三个用户
(integer) 1
127.0.0.1:6379> zadd salary 5000 zhangsan
(integer) 1
127.0.0.1:6379> zadd salary 500 azhang
(integer) 1
127.0.0.1:6379> ZRANGEBYSCORE salary -inf +inf # 显示全部用户，从小到大排序
1) "azhang"
2) "xiaohong"
3) "zhangsan"
127.0.0.1:6379> ZREVRANGE salary 0 -1    # 从大到小进行排序
1) "zhangsan"
2) "xiaohong"
3) "azhang"
127.0.0.1:6379> ZRANGEBYSCORE salary -inf +inf withscores    # 显示全部用户并且附带 score
1) "azhang"
2) "500"
3) "xiaohong"
4) "2500"
5) "zhangsan"
6) "5000"
127.0.0.1:6379> ZRANGEBYSCORE salary -inf 2500 withscores    # 显示工资小于 2500 的员工的升序排列
1) "azhang"
2) "500"
3) "xiaohong"
4) "2500"
127.0.0.1:6379>

####################################################
# 移除 zrem

127.0.0.1:6379> ZRANGE salary 0 -1
1) "azhang"
2) "xiaohong"
3) "zhangsan"
127.0.0.1:6379> ZREM salary xiaohong    # 移除有序集合中的指定元素
(integer) 1
127.0.0.1:6379> ZRANGE salary 0 -1
1) "azhang"
2) "zhangsan"

####################################################
# zcard

127.0.0.1:6379> zcard salary    # 获取有序集合中的个数
(integer) 2

####################################################
127.0.0.1:6379> zadd myset 1 hello 2 world 3 azhang
(integer) 3
127.0.0.1:6379> zcount myset 1 3
(integer) 3
127.0.0.1:6379> zcount myset 1 2    # 获取指定区间的成员数量
(integer) 2
127.0.0.1:6379> zcount myset (1 3
(integer) 2

####################################################

其余的一些 API，可以去查看官方文档。

案例思路：set 排序 存储班级成绩，工资表排序......

普通消息1，重要消息2，带权重进行判断

排行榜应用实现，取 Top N 测试

Redis

概述

Redis 是什么

Redis（ ==Re==mote ==Di==ctionary ==S==erver ），远程字典服务

是一个开源的使用ANSI C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库，并提供多种语言的API。

redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件，并且在此基础上实现了master-slave(主从)同步。

Redis 的用途

1. 内存存储、持久化，内存中是断电即失，所以说持久化很重要 ( rdb、aof)
2. 效率高，可以用于高速缓存
3. 发布订阅系统
4. 地图信息分析
5. 计时器、计数器 ( 浏览量 )
6. ......

特性

1. 多样的数据类型
2. 持久化
3. 集群
4. 事务
5. ......

==Redis 推荐在 Linux 服务器上搭建==

redis 的基础知识

1. redis 默认有 16 个数据库。默认使用的是第 0 个，可以使用 select 进行切换。

   127.0.0.1:6379> select 3    # 切换数据库
   OK
   127.0.0.1:6379[3]> DBSIZE    # 查看 DB 大小
   (integer) 0

2. 查看当前所有的 key

   127.0.0.1:6379> keys *
   1) "azhang"

3. 清空数据库

   # 清空全部数据库
   127.0.0.1:6379> flushall
   OK
   127.0.0.1:6379> keys *
   (empty list or set)
   
   # 清空当前数据库
   127.0.0.1:6379> flushdb
   OK

4. redis 是单线程的

Java与MySQL的连接

1.引用sql的操作库

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

你还需要导入一个叫做mysql-connector-java-5.1.44-bin的jar,记住一定要tomcat的lib目录也来一份

2.加载驱动

public static void main(String[] args) throws Exception{
        //1.初始化jdbc驱动器 注意一定要在方法中 throws Exception
        Class.forName("com.mysql.jdbc.Driver");//推荐使用这种方式来加载驱动
...

3.数据库的连接

//要连接的数据库URL
String url = "jdbc:mysql://localhost:3306/jdbcStudy";
//连接的数据库时使用的用户名
String username = "root";
//连接的数据库时使用的密码
String password = "123";

Connection conn = DriverManager.getConnection([url], [username], [password]);

4.获取用于向数据库发送指令的statement(声明)

Statement st = conn.createStatement();//获取对象

5.向数据库发送sql语句并获取代表结果集的resultset

String sql = "select id,name,password,email,birthday from users";//定义命令

ResultSet rs = st.executeQuery(sql);//发送命令并获取返回

statement中execute、executeQuery和executeUpdate的区别

executeQuery

用于产生单个结果集（ResultSet）的语句，例如 SELECT 语句

只能执行查询语句，执行后返回代表查询结果的ResultSet对象。

executeUpdate

用于执行 INSERT、UPDATE 或 DELETE 语句以及 SQL DDL（数据定义语言）语句

返回值是一个整数（int），指示受影响的行数（即更新计数）。

对于 CREATE TABLE 或 DROP TABLE 等不操作行的语句，executeUpdate 的返回值总为零。

execute

可用于执行任何SQL语句，返回一个boolean值，表明执行该SQL语句是否返回了ResultSet。

6.取出数据

while(rs.next()){
    System.out.println("id=" + rs.getObject("id"));
    System.out.println("name=" + rs.getObject("name"));
    System.out.println("password=" + rs.getObject("password"));
    System.out.println("email=" + rs.getObject("email"));
    System.out.println("birthday=" + rs.getObject("birthday"));
}

7.关闭连接

rs.close();
st.close();
conn.close();

完整的代码

package program1;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class SqlTest{

    public static void main(String[] args) throws Exception{
        //1.初始化jdbc驱动器 注意一定要在方法中 throws Exception
        Class.forName("com.mysql.jdbc.Driver");
        
        //2.连接数据库
        Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306", "root", "a112233");
        
        
        //3.获取用于向数据库发送指令的statement(声明)
        Statement st = conn.createStatement();//获取对象
        
        //4.换库
        st.execute("USE test");
        
        //5.数据库发送sql语句并获取代表结果集的resultset
        String sql = "SELECT * FROM test1";//定义命令
        ResultSet rs = st.executeQuery(sql);//发送命令并获取返回
        
        //7.取出数据
        while(rs.next()){
            System.out.println("text=" + rs.getObject("text"));
            System.out.println("a1=" + rs.getObject("a1"));
        }
        
        
        //8.更新数据
        sql = "UPDATE test1 SET text=\""+System.currentTimeMillis()+"\" WHERE a1=1";//获取时间戳并写到text中
        int rsi = st.executeUpdate(sql);
        System.out.println("data update "+rsi);
        
        //9.重新查看数据
        rs = st.executeQuery("SELECT * FROM test1");
        while(rs.next()){
            System.out.println("text=" + rs.getObject("text"));
            System.out.println("a1=" + rs.getObject("a1"));
        }
        
        //last.关闭连接
        rs.close();
        st.close();
        conn.close();
        
        System.out.println("program end");
    }
}

各种类的讲解

DriverManager 类讲解

Jdbc程序中的DriverManager用于加载驱动，并创建与数据库的链接，这个API的常用方法：

1. DriverManager.registerDriver(new Driver())
2. DriverManager.getConnection(url,user, password)，

注意：在实际开发中并不推荐采用registerDriver方法注册驱动。原因有二：

1、查看Driver的源代码可以看到，如果采用此种方式，会导致驱动程序注册两次，也就是在内存中会有两个Driver对象。

2、程序依赖mysql的api，脱离mysql的jar包，程序将无法编译，将来程序切换底层数据库将会非常麻烦。

推荐方式：Class.forName("com.mysql.jdbc.Driver");

采用此种方式不会导致驱动对象在内存中重复出现，并且采用此种方式，程序仅仅只需要一个字符串，不需要依赖具体的驱动，使程序的灵活性更高。

数据库URL讲解

URL用于标识数据库的位置，通过URL地址告诉JDBC程序连接哪个数据库，URL的写法为：

![jdbc:mysql: C] //localhost:3306/test ](file:///C:/Users/jmche/AppData/Local/Packages/Microsoft.Office.OneNote_8wekyb3d8bbwe/TempState/msohtmlclip/clip_image001.png)

常用数据库URL地址的写法：

• Oracle写法：jdbc:oracle:thin:@localhost:1521:sid
• SqlServer写法：jdbc:microsoft:sqlserver://localhost:1433; DatabaseName=sid
• MySql写法：jdbc:mysql://localhost:3306/sid

如果连接的是本地的Mysql数据库，并且连接使用的端口是3306，那么的url地址可以简写为： jdbc:mysql:///数据库

Connection类讲解

Jdbc程序中的Connection，它用于代表数据库的链接，Collection是数据库编程中最重要的一个对象，客户端与数据库所有交互都是通过connection对象完成的，这个对象的常用方法：

• createStatement()：创建向数据库发送sql的statement对象。
• prepareStatement(sql) ：创建向数据库发送预编译sql的PrepareSatement对象。
• prepareCall(sql)：创建执行存储过程的callableStatement对象。
• setAutoCommit(boolean autoCommit)：设置事务是否自动提交。
• commit() ：在链接上提交事务。
• rollback() ：在此链接上回滚事务。

Statement类讲解

Jdbc程序中的Statement对象用于向数据库发送SQL语句， Statement对象常用方法：

• executeQuery(String sql) ：用于向数据发送查询语句。
• executeUpdate(String sql)：用于向数据库发送insert、update或delete语句
• execute(String sql)：用于向数据库发送任意sql语句
• addBatch(String sql) ：把多条sql语句放到一个批处理中。
• executeBatch()：向数据库发送一批sql语句执行。

ResultSet类讲解

Jdbc程序中的ResultSet用于代表Sql语句的执行结果。Resultset封装执行结果时，采用的类似于表格的方式。ResultSet 对象维护了一个指向表格数据行的游标，初始的时候，游标在第一行之前，调用ResultSet.next() 方法，可以使游标指向具体的数据行，进行调用方法获取该行的数据。

ResultSet既然用于封装执行结果的，所以该对象提供的都是用于获取数据的get方法：

获取任意类型的数据

getObject(int index)

getObject(string columnName)

获取指定类型的数据，例如：

getString(int index)

getString(String columnName)

ResultSet还提供了对结果集进行滚动的方法：

• next()：移动到下一行
• Previous()：移动到前一行
• absolute(int row)：移动到指定行
• beforeFirst()：移动resultSet的最前面。
• afterLast() ：移动到resultSet的最后面。

释放资源

Jdbc程序运行完后，切记要释放程序在运行过程中，创建的那些与数据库进行交互的对象，这些对象通常是ResultSet, Statement和Connection对象，特别是Connection对象，它是非常稀有的资源，用完后必须马上释放，如果Connection不能及时、正确的关闭，极易导致系统宕机。Connection的使用原则是尽量晚创建，尽量早的释放。

为确保资源释放代码能运行，资源释放代码也一定要放在finally语句中。

MySQL

什么是数据库

数据库是数据管理的有效技术，是由一批数据构成的有序集合，这些数据被存放在结构化的数据表里。数据表之间相互关联，反映客观事物间的本质联系。数据库能有效地帮助一个组织或企业科学地管理各类信息资源。

数据是数据库中存储的基本对象，是按一定顺序排列组合的物理符号。数据有多种表现形式，可以是数字、文字、图像，甚至是音频或视频，它们都可以经过数字化后存入计算机。

数据库是数据的集合，具有统一的结构形式并存放于统一的存储介质内，是多种应用数据的集成，并可被各个应用程序所共享。

在日常生活中，人们可以直接用中文、英文等自然语言描述客观事物。在计算机中，则要抽象出对这些事物感兴趣的特征，并组成一个记录来描述。

例如，在学生档案中，学生信息是由学号、姓名、性别、年龄、籍贯、联系电话等特征组成的，那么这些具体的特征值所构成的一条记录就是一个学生的信息数据，例如“2016010102，张三，男，26，山西，计算机学院，185”。

值得注意的是，数据的描述形式还不能完全表达其内容，需要经过解释。例如，对于上面这条学生记录，了解其含义的人会得到这样的信息：张三的学号是 2016010102，今年 26 岁，山西人，就读于计算机学院，他的联系电话是 185；而不了解其语义的人则无法理解其含义。所以，数据和对数据的解释是不可分的，数据的解释是指对数据含义的说明，数据的含义也称数据的语义，因此数据与其语义密不可分，没有语义的数据是没有意义和不完整的。

怎么操作数据库

1. 通过指令操作

   一般来说，Mysql数据都是通过SQL语言来进行操作的,CRUD(create read update delete)基本操作

   SELECT * FROM user_db;
   
   
   INSERT INTO user_db (username, password) VALUES ('abc','12345')

   Java中使用JDBC来操作数据库

2. 通过一些特定的软件操作

怎么启动/停止数据库

NET START mysql80
#启动数据库
NET STOP mysql80
#关闭数据

怎么进入数据库

cmd中输入指令

mysql -uroot -p{密码}
#-u{用户名}

开始使用数据库

数据库结构

整个数据库服务器--很多个数据库----很多个表-----很多个字段------很多个数值

查看数据库列表

 SHOW DATABASES;
 #大写是为了与一些字符串区分开
 
+--------------------+
| Database           |
+--------------------+
| information_schema |
| mysql              |
| performance_schema |
| sys                |
+--------------------+
6 rows in set (0.00 sec)

创建数据库

 CREATE DATABASE test;
 
 Query OK, 1 row affected (0.02 sec)    
 
 #防止报错
 CREATE DATABASE IF NOT EXISTS test;
 Query OK, 1 row affected, 1 warning (0.01 sec)
 
 #创建 MySQL 数据库时指定字符集和校对规则
 CREATE DATABASE IF NOT EXISTS test_db_char
    -> DEFAULT CHARACTER SET utf8
    -> DEFAULT COLLATE utf8_chinese_ci;
    
    #DEFAULT CHARACTER SET utf8设置指定字符集
    #DEFAULT COLLATE utf8_chinese_ci;设置校对规则，也叫排序规则

删除数据库

 DROP DATABASE IF EXISTS test;

选择数据库

 USE test;
 Database changed

显示数据表

 SHOW TABLES;

创建数据表

CREATE TABLE user_db
    -> (
    -> username varchar(20),
    -> password varchar(20)
    -> );

基本的CRUD（增查改删）

增

INSERT INTO test (username, password) VALUES ('abc', '12345');
#INSER INTO {表名} ([字段名]...) VALUES ([数值]...)

Query OK, 1 row affected (0.02 sec)

查

SELECT * FROM user_db ;
#SELECT {字段名} FROM {表名}

+----------+----------+
| username | password |
+----------+----------+
| abc      | 12345    |
+----------+----------+

改

UPDATE user_db SET username = 'yiban' WHERE username = 'abc';

 UPDATE user_db SET username = 'yiban',password = 'abcd' WHERE username = 'abcd';

删

DELETE FROM user_db WHERE password = '12345';

数据库数据类型

MySQL 常见数据类型
在 MySQL 中常见的数据类型如下：
1) 整数类型
包括 TINYINT(byte)、SMALLINT、MEDIUMINT、INT、BIGINT，浮点数类型 FLOAT 和 DOUBLE，定点数类型 DECIMAL。
2) 日期/时间类型
包括 YEAR、TIME、DATE、DATETIME 和 TIMESTAMP。
3) 字符串类型
包括 CHAR、VARCHAR、BINARY、VARBINARY、BLOB、TEXT、ENUM 和 SET 等。
4) 二进制类型
包括 BIT、BINARY、VARBINARY、TINYBLOB、BLOB、MEDIUMBLOB 和 LONGBLOB。

设计表准则

• [ ] 每一个表必须有一个主键
• [ ] 能用数字替代字符串的就用数字
• [ ] 能加默认值的尽量不要用INSERT来插入

Mysql下载安装教程及部分报错——win10

mysql 下载

​ 下载地址：https://dev.mysql.com/downloads/mysql/

1. 选择 非 Debug 的 zip 包下载
   
2. 点击 No thanks, just start my download
   

配置

1. 将下载包解压并进入文件夹，创建 my.ini 文件，并添加如下信息：

   [client]
   # 设置mysql客户端默认字符集
   default-character-set=utf8
    
   [mysqld]
   # 设置3306端口
   port = 3306
   # 设置mysql的安装目录
   basedir=mysql目录

2. 以管理员身份打开 cmd ，进入 MySQL 中的 bin 目录；

3. 初始化数据库：

   mysqld --initialize --console

   执行完成后，会输出 root 用户的初始默认密码，如：

   2022-11-05T07:24:35.529123Z 6 [Note] [MY-010454] [Server] A temporary password is generated for root@localhost: Wek+ap1q)Bak

   Wek+ap1q)Bak 即为初始密码，在登陆数据库之后要求修改；

4. 安装数据库

   mysqld install

5. 启动数据库服务：

   net start mysql

6. 登录数据库

   mysql -u 用户名 -p

   回车确认之后会出现 Enter password: 直接输入上面哪个随机的初始密码登录；

7. 登录之后要先修改密码才能使用

   ALTER USER USER() IDENTIFIED BY '要修改的密码';

以上步骤都弄好之后就可以正常使用 MySQL 服务了，MySQL 服务是开机自启动的，所以不用担心是否要重新运行的问题。

配置过程中遇到的问题

1. 未创建 my.ini 文件

   G:\Java\mysql\mysql-8.0.31-winx64\bin>mysql install
   ERROR 2003 (HY000): Can't connect to MySQL server on 'localhost:3306' (10061)

2. mysql 未安装成功

   G:\Java\mysql\mysql-8.0.31-winx64\bin>net start mysql
   服务名无效。
   
   请键入 NET HELPMSG 2185 以获得更多的帮助。

3. 未修改密码

   ERROR 1820 (HY000): You must reset your password using ALTER USER statement before executing this statement.