Redis分布式解决方案-Coids

Codis是一个分布式

Redis

解决方案,对于上层的应用来说,连接到CodisProxy和连接原生的RedisServer没有明显的区别(不支持的命令列表),上层应用可以像使用单机的Redis一样使用,Codis底层会处理请求的转发,不停机的数据迁移等工作,所有后边的一切事情,对于前面的客户端来说是透明的,可以简单的认为后边连接的是一个内存无限大的Redis服务.

Codis由四部分组成:CodisProxy

(codis-proxy)

实现redis协议，由于本身是无状态的，因此可以部署很多个节点CodisManager(codis-config)

是codis的管理工具，包括添加/删除redis节点添加删除proxy节点，发起数据迁移等操作，自带httpserver，支持管理后台方式管理配置CodisRedis

(codis-server)

是codis维护的redis分支，基于2.8.21分支，加入了slot的支持和原子的数据迁移命令;codis-proxy和codis-config只能和这个版本的redis交互才能正常运行ZooKeeper

用于codis集群元数据的存储,维护codis集群节点Codis优缺点–

优点•

对客户端透明，与codis交互方式和redis本身交互一样•

支持在线数据迁移，迁移过程对客户端透明•

有简单的管理和监控界面•

支持高可用，无论是redis数据存储还是代理节点•

自动进行数据的均衡分配•

最大支持1024个redis实例，存储容量海量•

高性能–

缺点

•

采用自有的redis分支，不能与原版的redis保持同࠵•

如果codis的proxy只有一个的情况下，redis的性能会下降20%左右•

某些命令不支持，比如事务命令muti•

国内开源产品，活跃度相对弱一些Codis架构Codis的性能(代理+两个redis节点

首先需要安装go环境[html]

\o"viewplain"viewplain

\o"copy"copy

wget

/golang/go1.4.1.linux-amd64.tar.gz

解压[html]

\o"viewplain"viewplain

\o"copy"copy

tar

-zxvf

go1.4.1.linux-amd64.tar.gz

下载zookeeper[html]

\o"viewplain"viewplain

\o"copy"copy

wget

/apache/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz

解压[html]

\o"viewplain"viewplain

\o"copy"copy

vi

~/.bash_profile

配置go环境变量还有zkhome[html]

\o"viewplain"viewplain

\o"copy"copy

vi

~/.bash_profile

[html]

\o"viewplain"viewplain

\o"copy"copy

PATH=$PATH:$HOME/bin

export

PATH

JAVA_HOME=/java/jdk1.7.0_76

PATH=$JAVA_HOME/bin:$PATH

CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar

export

JAVA_HOME

export

CLASSPATH

ZOOKEEPER_HOME=/java/zookeeper-3.4.6

GOROOT=/java/go

export

GOPATH=/java/codis

PATH=$PATH:$GOROOT/bin:$GOPATH/bin:$ZOOKEEPER_HOME/bin

export

PATH

令环境变量生效[html]

\o"viewplain"viewplain

\o"copy"copy

source

~/.bash_profile

创建codis目录[html]

\o"viewplain"viewplain

\o"copy"copy

mkdir

codis

下载codis代码[html]

\o"viewplain"viewplain

\o"copy"copy

go

get

-u

-d

/CodisLabs/codis

进入到coids里面执行make编译代码编译完成后会在bin目录下面产生3个可执行文件修改config.ini文件[html]

\o"viewplain"viewplain

\o"copy"copy

vi

config.ini

进入zk目录启动zk[html]

\o"viewplain"viewplain

\o"copy"copy

cd

/java/zookeeper-3.4.6/bin

./zkServer.sh

start

通过jps命令查看zk是否启动codis启动步骤[html]

\o"viewplain"viewplain

\o"copy"copy

./codis-config

-c

../config.ini

dashboard

你也可以在后面加上&表示后台启动可以查看zk里面的数据然后初始化slots[html]

\o"viewplain"viewplain

\o"copy"copy

./codis-config

-c

../config.ini

slot

init

这些slot的信息都会保存在zk里面首先可以启动一个codis-server复制一份redis的配置文件过来,然后启动[html]

\o"viewplain"viewplain

\o"copy"copy

./codis-server

./redis.6379.conf

然后添加一个groupserver每一个Servicegroup

作为一个Redis服务器组存在,只允许有一个master,可以有多个slave,groupid

仅支持大于1的整数添加成功

分配slot

启动codis-proxy[html]

\o"viewplain"viewplain

\o"copy"copy

./codis-proxy

-c

../config.ini

-L

./proxy.log

--cpu=1

--addr=03:19000

--http-addr=03:11000

•

Addr为代理绑定的ip和端口•

--cpu为代理使用的cpu核数，与虚拟机的配置有关，一般跟核数相同•

http-addr用于测试的地址

•

-L

指定代理的日志文件

刚启动的时候,默认是offline状态,处于此状态不能对外提供服务把代理状态修改为online访问11000端口申博官网澳门金沙导航宅男福利社www.zhainan.hk

查看到proxy的id,然后修改codisproxy的状态[html]

\o"viewplain"viewplain

\o"copy"copy

./codis-config

-c

../config.ini

proxy

online

proxy_1

也可以通过dashboard查看

连接proxy[html]

\o"viewplain"viewplain

\o"copy"copy

./redis-cli

-p

19000

-h

03

通过\o"JavaEE知识库"Java

客户端连接codis

Pom.xml[html]

\o"viewplain"viewplain

\o"copy"copy

<dependency>

<groupId>redis.clients</groupId>

<artifactId>jedis</artifactId>

<version>2.8.0</version>

<type>jar</type>

<scope>compile</scope>

</dependency>

<dependency>

<groupId>io.codis.jodis</groupId>

<artifactId>jodis</artifactId>

<version>0.3.1</version>

</dependency>

<dependency>

<groupId>com.wandoulabs.jodis</groupId>

<artifactId>jodis</artifactId>

<version>0.2.2</version>

</dependency>

<dependency>

<groupId>junit</groupId>

<artifactId>junit</artifactId>

<version>4.11</version>

<type>jar</type>

<scope>test</scope>

</dependency>

Java代码:[java]

\o"viewplain"viewplain

\o"copy"copy

JedisResourcePool

jedisPool

=

RoundRobinJedisPool.create()

.curatorClient("03:2181",

30000).zkProxyDir("/zk/codis/db_test/proxy").build();

try

(Jedis

jedis

=

jedisPool.getResource())

{

jedis.set("foo",

"bar");

String

value

=

jedis.get("foo");

System.out.println(value);

}

删除刚刚设置的key

运行程序查看结果

Codis高可用codis-haCodis-ha需要单独安装codis-ha

[html]

\o"viewplain"viewplain

\o"copy"copy

go

get

/ngaut/codis-ha

进入codis-ha目录执行build命令[html]

\o"viewplain"viewplain

\o"copy"copy

go

build

启动codis-ha

[html]

HYPERLINK"/a67474