为了解决高并发、高可用、高可扩展,大数据存储等一系列问题而产生的数据库解决方案,就是NoSql。php
NoSql,叫非关系型数据库,它的全名Not only sql。它不能替代关系型数据库,只能做为关系型数据库的一个良好补充。前端
键值(Key-Value)存储数据库 相关产品: Tokyo Cabinet/Tyrant、Redis、Voldemort、Berkeley DB 典型应用: 内容缓存,主要用于处理大量数据的高访问负载。 数据模型: 一系列键值对 优点: 快速查询 劣势: 存储的数据缺乏结构化java
列存储数据库 相关产品:Cassandra, HBase, Riak 典型应用:分布式的文件系统 数据模型:以列簇式存储,将同一列数据存在一块儿 优点:查找速度快,可扩展性强,更容易进行分布式扩展 劣势:功能相对局限node
文档型数据库 相关产品:CouchDB、MongoDB 典型应用:Web应用(与Key-Value相似,Value是结构化的) 数据模型: 一系列键值对 优点:数据结构要求不严格 劣势: 查询性能不高,并且缺少统一的查询语法linux
图形(Graph)数据库 相关数据库:Neo4J、InfoGrid、Infinite Graph 典型应用:社交网络 数据模型:图结构 优点:利用图结构相关算法。 劣势:须要对整个图作计算才能得出结果,不容易作分布式的集群方案。c++
Redis是使用c语言开发的一个高性能键值数据库。Redis能够经过一些键值类型来存储数据。 键值类型: String字符类型 map散列类型 list列表类型 set集合类型 sortedset有序集合类型git
2008年,意大利的一家创业公司Merzia推出了一款基于MySQL的网站实时统计系统LLOOGG,然而没过多久该公司的创始人 Salvatore Sanfilippo便 对MySQL的性能感到失望,因而他决定亲自为LLOOGG量身定作一个数据库,并于2009年开发完成,这个数据库就是Redis。 不过Salvatore Sanfilippo并不知足只将Redis用于LLOOGG这一款产品,而是但愿更多的人使用它,因而在同一年Salvatore Sanfilippo将Redis开源发布,并开始和Redis的另外一名主要的代码贡献者Pieter Noordhuis一块儿继续着Redis的开发,直到今天。github
Salvatore Sanfilippo本身也没有想到,短短的几年时间,Redis就拥有了庞大的用户群体。Hacker News在2012年发布了一份数据库的使用状况调查,结果显示有近12%的公司在使用Redis。国内如新浪微博、街旁网、知乎网,国外如GitHub、Stack Overflow、Flickr等都是Redis的用户。redis
VMware公司从2010年开始赞助Redis的开发, Salvatore Sanfilippo和Pieter Noordhuis也分别在3月和5月加入VMware,全职开发Redis。算法
缓存(数据查询、短链接、新闻内容、商品内容等等)。(最多使用) 分布式集群架构中的session分离。 聊天室的在线好友列表。 任务队列。(秒杀、抢购、12306等等) 应用排行榜。 网站访问统计。 数据过时处理(能够精确到毫秒)
官网地址:http://redis.io/ 下载地址:http://download.redis.io/releases/redis-3.0.0.tar.gz
#sftp 上传安装包到linux
#解压
tar -zxvf redis.3.0.0.tar.gz
#安装c语言环境
sudo apt-get install gcc-c++
#编译
cd redis-3.0.0
make
#安装
make install PREFIX = /usr/local/redis
# 查看
cd /usr/local/redis
ls
复制代码
./redis-server
ctrl+c
正常关闭 ./redis-cli shutdown
**tips:**一旦客户端关闭,则redis服务也会停掉
cp /root/redis-3.0.0/redis.conf
vim redis.conf
./redis-server redis.conf
ps -aux | grep redis
kill -9 进程号
正常关闭:./redis-cli shutdown
./redis-cli -h 127.0.0.1 -p 6379
-h 指定访问 redis 服务器的 ip 地址 -p 指定访问的 redis 服务器的 port 端口 还能够写成 ./redis-cli 使用默认配置,默认ip 127.0.0.1,默认端口 6379redis-desktop-manager 打开以下:
选择数据库方式: select 加上数据库的下标,就能够选择指定的数据库使用,下标从0开始。
127.0.0.1:6379> select 15
OK
127.0.0.1:6379[15]>
复制代码
Redis不只是使用命令来操做,如今基本上主流的语言都有客户端支持,好比java、C、C#、C++、php、Node.js、Go等。
在官方网站里列一些Java的客户端,有Jedis、Redisson、Jredis、JDBC-Redis、等其中官方推荐使用Jedis和Redisson。 在企业中用的最多的就是Jedis,下面咱们就重点学习下Jedis。
Jedis一样也是托管在github上,地址:https://github.com/xetorthio/jedis
添加 spring 的 jar 包 配置 spring 配置文件 applicationContext.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd ">
<!-- 链接池配置 -->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<!-- 最大链接数 -->
<property name="maxTotal" value="30" />
<!-- 最大空闲链接数 -->
<property name="maxIdle" value="10" />
<!-- 每次释放链接的最大数目 -->
<property name="numTestsPerEvictionRun" value="1024" />
<!-- 释放链接的扫描间隔(毫秒) -->
<property name="timeBetweenEvictionRunsMillis" value="30000" />
<!-- 链接最小空闲时间 -->
<property name="minEvictableIdleTimeMillis" value="1800000" />
<!-- 链接空闲多久后释放, 当空闲时间>该值 且 空闲链接>最大空闲链接数 时直接释放 -->
<property name="softMinEvictableIdleTimeMillis" value="10000" />
<!-- 获取链接时的最大等待毫秒数,小于零:阻塞不肯定的时间,默认-1 -->
<property name="maxWaitMillis" value="1500" />
<!-- 在获取链接的时候检查有效性, 默认false -->
<property name="testOnBorrow" value="false" />
<!-- 在空闲时检查有效性, 默认false -->
<property name="testWhileIdle" value="true" />
<!-- 链接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true -->
<property name="blockWhenExhausted" value="false" />
</bean>
<!-- redis单机 经过链接池 -->
<bean id="jedisPool" class="redis.clients.jedis.JedisPool" destroy-method="close">
<constructor-arg name="poolConfig" ref="jedisPoolConfig" />
<constructor-arg name="host" value="192.168.242.130" />
<constructor-arg name="port" value="6379" />
</bean>
</beans>
复制代码
测试代码
@Test
public void testJedisPool() {
JedisPool pool = (JedisPool) applicationContext.getBean("jedisPool");
Jedis jedis = null;
try {
jedis = pool.getResource();
jedis.set("name", "lisi");
String name = jedis.get("name");
System.out.println(name);
} catch (Exception ex) {
ex.printStackTrace();
} finally {
if (jedis != null) {
// 关闭链接
jedis.close();
}
}
}
复制代码
赋值 set key value
127.0.0.1:6379> set test 123
OK
复制代码
取值 get key
127.0.0.1:6379> get test
"123"
复制代码
取值并赋值 getset key value
127.0.0.1:6379> getset test 321
"123"
127.0.0.1:6379> get test
"321"
复制代码
设置获取多个键值 mset key value [key value...] mget key [key...]
127.0.0.1:6379> mset k1 v1 k2 v2 k3 v3
OK
127.0.0.1:6379> mget k1 k2
1) "v1"
2) "v2"
复制代码
删除 del key
127.0.0.1:6379> del test
(integer) 1
复制代码
数值增减
127.0.0.1:6379> set num 1
OK
127.0.0.1:6379> incr num
(integer) 2
127.0.0.1:6379> incr num
(integer) 3
127.0.0.1:6379> incr num
(integer) 4
复制代码
127.0.0.1:6379> incrby num 2
(integer) 8
127.0.0.1:6379> incrby num 2
(integer) 10
复制代码
127.0.0.1:6379> decr num
(integer) 9
127.0.0.1:6379> decr num
(integer) 8
复制代码
127.0.0.1:6379> decrby num 2
(integer) 6
127.0.0.1:6379> decrby num 2
(integer) 4
复制代码
向尾部追加值 APPEND的做用是向键值的末尾追加value。若是键不存在则将该键的值设置为value,即至关于 SET key value。返回值是追加后字符串的总长度。 语法:append key value
127.0.0.1:6379> set str hello
OK
127.0.0.1:6379> append str "world"
(integer) 10
127.0.0.1:6379> get str
"helloworld"
复制代码
获取字符串长度 STRLEN命令返回键值的长度,若是键不存在则返回0。 语法:strlen key
127.0.0.1:6379> strlen str
(integer) 10
复制代码
应用
假设有User对象以JSON序列化的形式存储到Redis中,User对象有id,username、password、age、name等属性,存储的过程以下: 保存、更新:User对象 json(string) redis
若是在业务上只是更新age属性,其余的属性并不作更新我应该怎么作呢? 若是仍然采用上边的方法在传输、处理时会形成资源浪费,下边讲的hash能够很好的解决这个问题。
hash叫散列类型,它提供了字段和字段值的映射。字段值只能是字符串类型,不支持散列类型、集合类型等其它类型。以下:
赋值 HSET命令不区分插入和更新操做,当执行插入操做时HSET命令返回1,当执行更新操做时返回0。
127.0.0.1:6379> hset user username zhangsan
(integer) 1
复制代码
127.0.0.1:6379> hmset user age 20 username lisi
OK
复制代码
127.0.0.1:6379> hsetnx user age 30
(integer) 0
复制代码
取值
127.0.0.1:6379> hget user username
"lisi"
复制代码
127.0.0.1:6379> hmget user age username
1) "20"
2) "lisi"
复制代码
127.0.0.1:6379> hgetall user
1) "username"
2) "lisi"
3) "age"
4) "20"
复制代码
删除字段 能够删除一个或多个字段,返回值是被删除的字段的个数。 语法:hdel key field [field...]
127.0.0.1:6379> hdel user age
(integer) 1
127.0.0.1:6379> hdel user age username
(integer) 1
复制代码
增长数字 语法:hincrby key field increment
127.0.0.1:6379> hincrby user age 2
(integer) 2
复制代码
判断字段是否存在 语法:hexists key field
127.0.0.1:6379> hexists user age
(integer) 1
复制代码
只获取字段名或字段值 语法: hkeys key hvals key
127.0.0.1:6379> hkeys user
1) "age"
复制代码
获取字段数量 语法:hlen key
127.0.0.1:6379> hlen user
(integer) 1
复制代码
应用 存储商品信息
127.0.0.1:6379> hlen user
(integer) 1
复制代码
获取商品信息
127.0.0.1:6379> hgetall items:1001
1) "id"
2) "3"
3) "name"
4) "apple"
5) "price"
6) "5.00"
复制代码
Arraylist是使用数组来存储数据,特色:查询快、增删慢
Linkedlist是使用双向链表存储数据,特色:增删快、查询慢,可是查询链表两端的数据也很快。
Redis的list是采用来链表来存储的,因此对于redis的list数据类型的操做,是操做list的两端数据来操做的。
向列表两端增长元素
127.0.0.1:6379> lpush list:1 1 2 3
(integer) 3
复制代码
127.0.0.1:6379> rpush list:1 4 5 6
(integer) 6
复制代码
查看列表 LRANGE命令是列表类型最经常使用的命令之一,获取列表中的某一片断,将返回start、stop之间的全部元素(包含两端的元素),索引从0开始。索引能够是负数,如:“-1”表明最后边的一个元素。
语法:lrange key start stop
127.0.0.1:6379> lrange list:1 0 2
1) "3"
2) "2"
3) "1"
127.0.0.1:6379> lrange list:1 0 -1
1) "3"
2) "2"
3) "1"
4) "4"
5) "5"
6) "6"
复制代码
从列表两端弹出元素 LPOP命令从列表左边弹出一个元素,会分两步完成:
127.0.0.1:6379> lpop list:1
"3"
127.0.0.1:6379> rpop list:1
"6"
复制代码
获取列表中元素的个数 语法:llen key
127.0.0.1:6379> llen list:1
(integer) 4
复制代码
删除列表中指定的值 LREM命令会删除列表中前count个值为value的元素,返回实际删除的元素个数。根据count值的不一样,该命令的执行方式会有所不一样:
语法:lrem key count value
得到/设置指定索引的元素值
127.0.0.1:6379> lindex list:1 2
"4"
复制代码
127.0.0.1:6379> lset list:1 2 2
OK
复制代码
只保留列表指定片断 指定范围和 lrange 一致 语法:ltrim key start stop
127.0.0.1:6379> lrange list:1 0 -1
1) "2"
2) "1"
3) "2"
4) "5"
127.0.0.1:6379> ltrim list:1 0 2
OK
127.0.0.1:6379> lrange list:1 0 -1
1) "2"
2) "1"
3) "2"
复制代码
向列表中插入元素 该命令首先会在列表中从左到右查找值为pivot的元素,而后根据第二个参数是BEFORE仍是AFTER来决定将value插入到该元素的前面仍是后面。 语法:linsert key before | after pivot value
127.0.0.1:6379> lrange list:1 0 -1
1) "2"
2) "1"
3) "2"
127.0.0.1:6379> linsert list:1 after 1 9
(integer) 4
127.0.0.1:6379> lrange list:1 0 -1
1) "2"
2) "1"
3) "9"
4) "2"
复制代码
将元素从一个列表转移到另外一个列表 语法:rpoplpush source destination
127.0.0.1:6379> lrange list:1 0 -1
1) "2"
2) "1"
3) "9"
4) "2"
127.0.0.1:6379> rpoplpush list:1 newlist
"2"
127.0.0.1:6379> lrange newlist 0 -1
1) "2"
127.0.0.1:6379> lrange list:1 0 -1
1) "2"
2) "1"
3) "9"
复制代码
应用 在Redis中建立商品评论列表 用户发布商品评论,将评论信息转成json存储到list中。 用户在页面查询评论列表,从redis中取出json数据展现到页面。
定义商品评论列表key: 商品编号为1001的商品评论key【items: comment:1001】
集合类型:无序、不可重复 列表类型:有序、可重复
增长/删除元素 语法:sadd key member [member...]
127.0.0.1:6379> sadd set a b c
(integer) 3
127.0.0.1:6379> sadd set a
(integer) 0
复制代码
语法:srem key member [member...]
127.0.0.1:6379> srem set c
(integer) 1
复制代码
得到集合中的全部元素 语法:smembers key
127.0.0.1:6379> smembers set
1) "b"
2) "a"
复制代码
判断元素是否在集合中 语法:sismember key member
127.0.0.1:6379> sismember set a
(integer) 1
127.0.0.1:6379> sismember set h
(integer) 0
复制代码
集合的差集运算 A-B 属于 A 而且 不属于 B 的元素构成的集合
127.0.0.1:6379> sadd setA 1 2 3
(integer) 3
127.0.0.1:6379> sadd setB 2 3 4
(integer) 3
127.0.0.1:6379> sdiff setA setB
1) "1"
127.0.0.1:6379> sdiff setB setA
1) "4"
复制代码
集合的交集运算 属于A且属于B的元素构成的集合
127.0.0.1:6379> sinter setA setB
1) "2"
2) "3"
复制代码
集合的并集运算 属于 A 或者 属于 B 的元素构成的集合
127.0.0.1:6379> sunion setA setB
1) "1"
2) "2"
3) "3"
4) "4"
复制代码
得到集合中元素的个数 语法:scard key
127.0.0.1:6379> smembers setA
1) "1"
2) "2"
3) "3"
127.0.0.1:6379> scard setA
(integer) 3
复制代码
从集合中弹出一个元素 注意:因为集合是无序的,全部spop命令会从集合中随机选择一个元素弹出。 语法:spop key
127.0.0.1:6379> spop setA
"2"
复制代码
Sortedset 又叫 zset Sortedset 是有序集合,可排序的,可是惟一。 Sortedset 和 set 的不一样之处,会给 set 中元素添加一个分数,而后经过这个分数进行排序。
向有序集合中加入一个元素和该元素的分数,若是该元素已经存在则会用新的分数替换原有的分数。返回值是新加入到集合中的元素个数,不包含以前已经存在的元素。 语法:zadd key score member [score member...]
127.0.0.1:6379> zadd scoreboard 80 zhangsan 89 lisi 94 wangwu
(integer) 3
127.0.0.1:6379> zadd scoreboard 97 lisi
(integer) 0
复制代码
语法:zscore key member
127.0.0.1:6379> zscore scoreboard lisi
"97"
复制代码
移除有序集key中的一个或多个成员,不存在的成员将被忽略。 当key存在但不是有序集类型时,返回一个错误。
语法:zrem key member [member...]
127.0.0.1:6379> zrem scoreboard lisi
(integer) 1
复制代码
得到排名在某个范围的元素列表
127.0.0.1:6379> zrange scoreboard 0 2
1) "zhangsan"
2) "wangwu"
复制代码
127.0.0.1:6379> zrevrange scoreboard 0 2
1) "wangwu"
2) "zhangsan"
复制代码
若是须要得到元素的分数能够在命令末尾加上 withscores 参数 ··· 127.0.0.1:6379> zrevrange scoreboard 0 2 withscores
127.0.0.1:6379> zrank scoreboard zhangsan
(integer) 0
复制代码
127.0.0.1:6379> zrevrank scoreboard zhangsan
(integer) 1
复制代码
语法:zrangebyscore key min max [withscores] [limit offset count]
127.0.0.1:6379> ZRANGEBYSCORE scoreboard 90 97 WITHSCORES
1) "wangwu"
2) "94"
3) "lisi"
4) "97"
127.0.0.1:6379> ZRANGEBYSCORE scoreboard 70 100 limit 1 2
1) "wangwu"
2) "lisi"
复制代码
返回值是更改后的分数 语法:zincrby key increment member
127.0.0.1:6379> ZINCRBY scoreboard 4 lisi
"101“ 复制代码
语法:zcard key
127.0.0.1:6379> zcard scoreboard
(integer) 3
复制代码
语法:zcount key min max
127.0.0.1:6379> zcount scoreboard 80 90
(integer) 1
复制代码
语法:zremrangebyrank key start stop
127.0.0.1:6379> zremrangebyrank scoreboard 0 1
(integer) 2
127.0.0.1:6379> zrange scoreboard 0 -1
1) "wangwu"
复制代码
语法:zremrangebyscore key min max
127.0.0.1:6379> zadd scoreboard 84 zhangsan
(integer) 1
127.0.0.1:6379> ZREMRANGEBYSCORE scoreboard 80 100
(integer) 1
复制代码
需求:根据商品销售量对商品进行排行显示 思路:定义商品销售排行榜(sorted set集合),Key为items:sellsort,分数为商品销售量。
写入商品销售量:
商品编号1001的销量是9,商品编号1002的销量是10 192.168.101.3:7007> ZADD items:sellsort 9 1001 10 1002
商品编号1001的销量加1 192.168.101.3:7001> ZINCRBY items:sellsort 1 1001
商品销量前10名: 192.168.101.3:7001> ZRANGE items:sellsort 0 9 withscores
keys 返回知足给定pattern 的全部key redis 127.0.0.1:6379> keys mylist*
exists 确认一个key 是否存在 示例:从结果来看,数据库中不存在HongWan 这个key,可是age 这个key 是存在的 redis 127.0.0.1:6379> exists HongWan (integer) 0 redis 127.0.0.1:6379> exists age (integer) 1 redis 127.0.0.1:6379>
del 删除一个key redis 127.0.0.1:6379> del age (integer) 1 redis 127.0.0.1:6379> exists age (integer) 0
rename 重命名key 示例:age 成功的被咱们更名为age_new 了 redis 127.0.0.1:6379[1]> keys *
type 返回值的类型 示例:这个方法能够很是简单的判断出值的类型 redis 127.0.0.1:6379> type addr string redis 127.0.0.1:6379> type myzset2 zset redis 127.0.0.1:6379> type mylist list redis 127.0.0.1:6379>
Redis在实际使用过程当中更多的用做缓存,然而缓存的数据通常都是须要设置生存时间的,即:到期后数据销毁。
EXPIRE key seconds | 设置key的生存时间(单位:秒)key在多少秒后会自动删除 |
TTL key | 查看key剩余的生存时间 |
PERSIST key | 清除生存时间 |
PEXPIRE key milliseconds | 生存时间设置单位为:毫秒 |
例子:
192.168.101.3:7002> set test 1 设置test的值为1
OK
192.168.101.3:7002> get test 获取test的值
"1"
192.168.101.3:7002> EXPIRE test 5 设置test的生存时间为5秒
(integer) 1
192.168.101.3:7002> TTL test 查看test的生于生成时间还有1秒删除
(integer) 1
192.168.101.3:7002> TTL test
(integer) -2
192.168.101.3:7002> get test 获取test的值,已经删除
(nil)
复制代码
Redis 默认的方式,redis 经过快照方式将数据持久化到磁盘中。
在 redis.conf 中修改持久化快照的条件:
在 redis.conf 中能够指定持久化文件的存储目录
一旦redis非法关闭,那么会丢失最后一次持久化以后的数据。
若是数据不重要,则没必要要关心。 若是数据不能容许丢失,那么要使用 aof 方式。
Redis 默认是不使用该方式持久化的。Aof 方式的持久化,是操做一次 redis 数据库,则将操做的记录存储到 aof 持久化文件中。
第一步:开启 aof 方式持久化方案。 将redis.conf中的appendonly改成yes,即开启aof方式的持久化方案。
Aof文件存储的目录和rdb方式的同样。 Aof文件存储的名称
在使用aof和rdb方式时,若是redis重启,则数据从aof文件加载。
持久化保证了即便redis服务重启也不会丢失数据,由于redis服务重启后会将硬盘上持久化的数据恢复到内存中,可是当redis服务器的硬盘损坏了可能会致使数据丢失,若是经过redis的主从复制机制就能够避免这种单点故障,以下图:
无需配置
cp bin/ bin2 -r
rm -rf appendonly.aof dump.rdb
./redis-server redis.conf
./redis-cli -p 6380
注意: 主机一旦发生增删改操做,那么从机会将数据同步到从机中 从机不能执行写操做
架构细节: (1)全部的redis节点彼此互联(PING-PONG机制),内部使用二进制协议优化传输速度和带宽. (2)节点的fail是经过集群中超过半数的节点检测失效时才生效. (3)客户端与redis节点直连,不须要中间proxy层.客户端不须要链接集群全部节点,链接集群中任何一个可用节点便可 (4)redis-cluster把全部的物理节点映射到[0-16383]slot上,cluster 负责维护node<->slot<->value Redis 集群中内置了 16384 个哈希槽,当须要在 Redis 集群中放置一个 key-value 时,redis 先对 key 使用 crc16 算法算出一个结果,而后把结果对 16384 求余数,这样每一个 key 都会对应一个编号在 0-16383 之间的哈希槽,redis 会根据节点数量大体均等的将哈希槽映射到不一样的节点.
(1)集群中全部master参与投票,若是半数以上master节点与其中一个master节点通讯超过(cluster-node-timeout),认为该master节点挂掉. (2):何时整个集群不可用(cluster_state:fail)?
集群管理工具(redis-trib.rb)是使用 ruby 脚本语言编写的。
sudo apt-get install ruby
复制代码
gem install redis-3.0.0.gem
cd /usr/local/redis/
mkdir redis-cluster
cd /root/redis-3.0.0/src/
cp redis-trib.rb /usr/local/redis/redis-cluster
复制代码
搭建集群最少须要 3 台主机,若是每台主机再配置一台从机的话,则最少须要6台机器。 端口设计:7001-7006
cp bin ./redis-cluster/7001 -r
rm -rf appendonly.aof dump.rdb
cp 7001/ 7002-r
cp 7001/ 7003-r
cp 7001/ 7004-r
cp 7001/ 7005-r
cp 7001/ 7006-r
复制代码
cd 7001
./redis-server redis.conf
cd ..
cd 7002
./redis-server redis.conf
cd ..
cd 7003
./redis-server redis.conf
cd ..
cd 7004
./redis-server redis.conf
cd ..
cd 7005
./redis-server redis.conf
cd ..
cd 7006
./redis-server redis.conf
cd ..
复制代码
chmod u+x start-all.sh
复制代码
./start-all.sh
复制代码
./redis-trib.rb create --replicas 1 192.168.126.128:7001 192.168.126.128:7002 192.168.126.128:7003 192.168.126.128:7004 192.168.126.128:7005 192.168.126.128:7006
root@ubuntu:/usr/local/redis/redis-cluster/7001# ./redis-cli -p 7001 -c
-c 指定集群链接
查看集群信息
192.168.126.128:7002> cluster info
cluster_state:ok
cluster_slots_assigned:16384
cluster_slots_ok:16384
cluster_slots_pfail:0
cluster_slots_fail:0
cluster_known_nodes:6
cluster_size:3
cluster_current_epoch:6
cluster_my_epoch:2
cluster_stats_messages_sent:260
cluster_stats_messages_received:260
复制代码
查看集群节点
192.168.126.128:7002> cluster nodes
3a15e73dacb512745156535ae7f959acf65ae12e 192.168.126.128:7005 slave 23e173cdc0b7673dc28cae70efaabbc41308bfdc 0 1531452321139 5 connected
2a58a53a5b10f7bd91af04128a6ed439d534c0ee 192.168.126.128:7001 master - 0 1531452322145 1 connected 0-5460
d0808388485dd08f1a2ecdfe3d2b213742d0050d 192.168.126.128:7004 slave 2a58a53a5b10f7bd91af04128a6ed439d534c0ee 0 1531452318117 4 connected
23e173cdc0b7673dc28cae70efaabbc41308bfdc 192.168.126.128:7002 myself,master - 0 0 2 connected 5461-10922
2af2312acc56552f9f73470f90d9a51973fc74d3 192.168.126.128:7006 slave 78faf92cfdbd12e1b27b270fb0798e67017f4d0b 0 1531452320132 6 connected
78faf92cfdbd12e1b27b270fb0798e67017f4d0b 192.168.126.128:7007 master - 0 1531452319123 3 connected 10923-16383
复制代码
@Test
public void jedisCluster() {
// 建立jedisCluster
Set<HostAndPort> nodes = new HashSet<>();
nodes.add(new HostAndPort("192.168.242.137", 7001));
nodes.add(new HostAndPort("192.168.242.137", 7002));
nodes.add(new HostAndPort("192.168.242.137", 7003));
nodes.add(new HostAndPort("192.168.242.137", 7004));
nodes.add(new HostAndPort("192.168.242.137", 7005));
nodes.add(new HostAndPort("192.168.242.137", 7006));
nodes.add(new HostAndPort("192.168.242.137", 7007));
JedisCluster cluster = new JedisCluster(nodes);
cluster.set("s4", "444");
String result = cluster.get("s4");
System.out.println(result);
cluster.close();
}
复制代码
配置 applicationContext.xml
<!-- 链接池配置 -->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<!-- 最大链接数 -->
<property name="maxTotal" value="30" />
<!-- 最大空闲链接数 -->
<property name="maxIdle" value="10" />
<!-- 每次释放链接的最大数目 -->
<property name="numTestsPerEvictionRun" value="1024" />
<!-- 释放链接的扫描间隔(毫秒) -->
<property name="timeBetweenEvictionRunsMillis" value="30000" />
<!-- 链接最小空闲时间 -->
<property name="minEvictableIdleTimeMillis" value="1800000" />
<!-- 链接空闲多久后释放, 当空闲时间>该值 且 空闲链接>最大空闲链接数 时直接释放 -->
<property name="softMinEvictableIdleTimeMillis" value="10000" />
<!-- 获取链接时的最大等待毫秒数,小于零:阻塞不肯定的时间,默认-1 -->
<property name="maxWaitMillis" value="1500" />
<!-- 在获取链接的时候检查有效性, 默认false -->
<property name="testOnBorrow" value="true" />
<!-- 在空闲时检查有效性, 默认false -->
<property name="testWhileIdle" value="true" />
<!-- 链接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true -->
<property name="blockWhenExhausted" value="false" />
</bean>
<!-- redis集群 -->
<bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">
<constructor-arg index="0">
<set>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.101.3"></constructor-arg>
<constructor-arg index="1" value="7001"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.101.3"></constructor-arg>
<constructor-arg index="1" value="7002"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.101.3"></constructor-arg>
<constructor-arg index="1" value="7003"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.101.3"></constructor-arg>
<constructor-arg index="1" value="7004"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.101.3"></constructor-arg>
<constructor-arg index="1" value="7005"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg index="0" value="192.168.101.3"></constructor-arg>
<constructor-arg index="1" value="7006"></constructor-arg>
</bean>
</set>
</constructor-arg>
<constructor-arg index="1" ref="jedisPoolConfig"></constructor-arg>
</bean>
复制代码
测试代码
private ApplicationContext applicationContext;
@Before
public void init() {
applicationContext = new ClassPathXmlApplicationContext(
"classpath:applicationContext.xml");
}
// redis集群
@Test
public void testJedisCluster() {
JedisCluster jedisCluster = (JedisCluster) applicationContext
.getBean("jedisCluster");
jedisCluster.set("name", "zhangsan");
String value = jedisCluster.get("name");
System.out.println(value);
}
复制代码