redis

1：安装

        官网：http://redis.io/download/

        jar：https://github.com/xetorthio/jedis/   （下载源码，使用mvn编译）

         学习：http://redis.readthedocs.org/en/latest/index.html

maven包

<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.0.0</version>
<type>jar</type>
<scope>compile</scope>
</dependency>

 

 

从官网下载的为源码，须要编译

$ tar xzf redis-2.8.11.tar.gz
$ cd redis-2.8.11
$ make

 make install

$ cd utils
$./install_server

启动和使用(在src目录下)

$./redis-server
注意这种方式启动redis 使用的是默认配置。也可以通过启动参数告诉redis使用指定配置文件使用下面命令启动.
$ ./redis-server redis.conf
redis.conf是一个默认的配置文件。我们可以根据需要使用自己的配置文件。
启动redis服务进程后，就可以使用测试客户端程序redis-cli和redis服务交互了.
比如
$ ./redis-cli
redis> set foo bar
OK
redis> get foo
"bar"

 或

    /etc/init.d/redis_6379 start |stop

 

redis.conf一些参数

daemonize：是否以后台daemon方式运行
pidfile：pid文件位置
port：监听的端口号
timeout：请求超时时间
loglevel：log信息级别
logfile：log文件位置
databases：开启数据库的数量
save * *：保存快照的频率，第一个*表示多长时间，第三个*表示执行多少次写操作。在一定时间内执行一定数量的写操作时，自动保存快照。可设置多个条件。
rdbcompression：是否使用压缩
dbfilename：数据快照文件名（只是文件名，不包括目录）
dir：数据快照的保存目录（这个是目录）
appendonly：是否开启appendonlylog，开启的话每次写操作会记一条log，这会提高数据抗风险能力，但影响效率。
appendfsync：appendonlylog如何同步到磁盘（三个选项，分别是每次写都强制调用fsync、每秒启用一次fsync、不调用fsync等待系统自己同步）

 

2：helloword

把编译好的jar放到lib下加入项目（jar为2.5）

import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;

import org.junit.Before;
import org.junit.Test;

import redis.clients.jedis.Jedis;

public class TestRedis {

	private static final String SERVER_ADDRESS = "192.168.169.128";	//服务器地址
	private static final Integer SERVER_PORT = 6379 ;	//端口
	
	private Jedis jedis ;
	
	@Before
	public void init(){
		jedis = new Jedis(SERVER_ADDRESS, SERVER_PORT); 
	}
	
	
	
	/**
	 * 操作普通键值对
	 */
	@Test
	public void test01(){
		jedis.set("name", "zhoufeng");//存入1个key=name value=zhoufeng的键值对
		String value = jedis.get("name");  	//获取key=name的值
		System.out.println(value);
	}
	
	/**
	 * 操作List
	 */
	@Test
	public void test02(){
		
		//将zhoufeng 加入students数组的结尾,如果该元素是第一个元素，那么会自动创建students数组
		jedis.rpush("students", "zhoufeng");	
		
		//将zhangsan加入到students的末尾
		jedis.lpush("students", "zhangsan");
		
		//移除students的第一个元素
		jedis.lpop("students");
		
		//移除students的最后一个元素
		jedis.rpop("students");
		
		//移除制定的元素,第二个参数表示要移除的个数，因为list中是允许出现重复元素的
		jedis.lrem("student", 1, "zhangsan") ;
		//获取students数组的所有元素
		List <String> students = jedis.lrange("students", 0, -1) ;
		
		System.out.println(students);
	}
	
	/**
	 * 操作Set
	 */
	@Test
	public void test03(){
		//添加元素
		jedis.sadd("teachers", "zhangsan");
		jedis.sadd("teachers", "lisi");
		jedis.sadd("teachers", "wangwu");
		
		//判断Set是否包含制定元素
		Boolean b1 = jedis.sismember("teachers", "wangwu");
		Boolean b2 = jedis.sismember("teachers", "xxxxx");
		System.out.println(b1 + "   " + b2);  
		
		//获取Set内所有的元素
		Set<String> members =  jedis.smembers("teachers");
		Iterator<String> it = members.iterator() ;
		while(it.hasNext()){
			System.out.println(it.next());
		}
		
	//	jedis.sunion(keys...) 可以将多个Set合并成1个并返回合并后的Set
		
	}
	
	/**
	 * 操作带排序功能的Set
	 */
	@Test
	public void test04(){
		//添加元素，会根据第二个参数排序
		jedis.zadd("emps", 5 , "aaa") ;
		jedis.zadd("emps", 1 , "bbbb") ;
		jedis.zadd("emps", 3 , "ccc") ;
		jedis.zadd("emps", 2 , "ddd") ;
		
		//获取所有元素
		Set<String> emps = jedis.zrange("emps", 0, -1) ;
		Iterator<String> it = emps.iterator() ;
		while(it.hasNext()){
			System.out.println(it.next());
		}
	}
	
	/**
	 * 存入对象,使用Map作为对象
	 */
	@Test
	public void test05(){
		Map<String , String > car = new HashMap<String , String >() ;
		car.put("COLOR", "red") ;
		car.put("SIZE", "2T");
		car.put("NO", "京8888");
		//存入对象，使用car:01当作key，是为了方便和其他car区分。比如car:02
		jedis.hmset("car:01", car);
		
		//获取整个对象
		Map<String, String> result = jedis.hgetAll("car:01");	
		Iterator<Entry<String, String>>  it = result.entrySet().iterator();
		while(it.hasNext()){
			Entry<String, String> entry = it.next() ;  
			System.out.println("key:" + entry.getKey() + " value:" + entry.getValue());
		}
		
		//也可以获取制定的属性
		String no = jedis.hget("car:01", "NO") ;
		System.out.println("NO:" + no);
	}
	
}

 

 3：监控（redis live）

      官网：https://github.com/gleicon/RedisLive 

须要安装python环境和一些python包(这里介绍下pip安装python包)

      pip安装：

            下载网址：https://pypi.python.org/pypi/pip/

             解压后使用：python setup.py install 安装

须要安装的包有：

# pip-python install tornado
# pip-python install redis
# pip-python install python-dateutil
# pip-python install argparse

 从github上下载源码：git clone https://github.com/kumarnitin/RedisLive.git

安装完成后配置redis-live.conf文件

 

cd RedisLive/src  

vi redis-live.conf 

 

redis-live.conf配置如下：

 

{
        "RedisServers":
        [ 
                {
                        "server": "127.0.0.1",
                        "port" : 6379
                }
        ],

        "DataStoreType" : "sqlite",

        "RedisStatsServer":
        {
                "server" : "127.0.0.1",
                "port" : 6385
        },
"SqliteStatsStore":{
}
}

 启动服务即可

./redis-monitor.py –duration 120 &
./redis-live.py &

 

帮助：

./redis-live.py --help

 查看端口：netstat -ntpl |grep python

 登入：XXX.XXX.XXX.XXX:8888/index.html    

 

4：主从

   复制两个redis.conf文件，从机文件修改 port 和 pidfile ，加上slaveof 127.0.0.1 6379（主）即可 

 5：HA

环境

主机：127.0.0.1 6379

从机：127.0.0.1 6380

 1）手动切换

       从机上执行：slaveof no one 使它变为主机

       主机上执行：slaveof 127.0.0.1 6380（从机地址）使用它变成从机

查看主从状态：info Replication

2）自动切换(还没整好，参考：http://blog.csdn.net/wilbertzhou/article/details/17784965

                                                 http://blog.csdn.net/dc_726/article/details/11694437)

       定义两个sentinel1.conf文件，其中端口不同

少写一个port 26479（两个conf文件port不同）

#redismaster是Master的名称，127.0.0.1是Master的Ip，2表示确认一个Master为O_DOWN最少需要多少个哨兵认可()
sentinel monitor redismaster 127.0.0.1 6379 2

#多少秒（默认30秒）后Maste不可用被确认为S_DOWN状态
sentinel down-after-milliseconds redismaster 30000

#是否对redismaster指向failover(2.8没这项)
sentinel can-failover redismaster yes

#指定redismaster failover的超时时间（毫秒）
sentinel failover-timeout redismaster 900000

#在failover过程中，需要多少个Slave指向新的Slave
sentinel parallel-syncs redismaster 1