Linux实战笔记-----redis

x33g5p2x  于2021-09-25 转载在 Linux  
字(5.3k)|赞(0)|评价(0)|浏览(601)

一、redis安装配置

实验环境为三台主机,其中server1为master端,server2,3为slave,均安装redis,首先准备redis安装包

  1. tar zxf redis-6.2.1.tar.gz
  2. cd redis-6.2.1
  3. make
  4. make install
  5. ./install_server.sh

发现安装失败,提示使用systemd

注释掉安装文件的systemd

  1. vim /root/redis-6.2.1/utils/install_server.sh

重新安装,成功

启动redis

  1. /etc/init.d/redis_6379 start

二、redis主从复制

server1,添加master网段

  1. vim /etc/redis/6379.conf

重新启动

  1. /etc/init.d/redis_6379 restart
  2. redis-cli

server2,server3配置文件

  1. vim /etc/redis/6379.conf

server1查看slave数量

  1. info

三、sentinel分布式监控

当集群某节点出现故障,可以进行故障转移操作

server1修改sentinel文件,指向主机master端

  1. cp /root/redis-6.2.1/sentinel.conf /etc/red
  2. cd /etc/redis/
  3. vim sentinel.conf

将该配置文件传给两台slave,三台机器均开始监控

  1. redis-sentinel /etc/redis/sentinel.conf

模拟master端故障,可以看到master切换

  1. redis-cli
  2. SHUTDOWN

server2端查看info

重启server1后变为slave

四、redis集群cluster

虽然做了主从复制,但单个master的容量受机器内存限制,往往要做集群来提升容量。

redis集群特点:

  • 去中心化,不存在中心节点或者代理节点
  • 没有统一的入口,集群内部的节点是相互通信的(PING-PONG机制),每个节点都是一个redis实例
  • redis-cluster 投票容错机制判断节点是否能够正常使用,少数过半判断节点down掉则判定节点down
  • 哈希槽:集群内置了16384个slot(哈希槽),将所有的物理节点映射到了这16384[0-16383]个slot上,或者说把这些slot均等的分配给了各个节点。注意:当任意一个节点挂掉后,集群将无法使用
  • redis集群最多有16384个节点

1、手动创建集群

创建集群目录

  1. cd /usr/local/
  2. mkdir cluster
  3. cd cluster
  4. mkdir 7000 7001 7002 7003 7004 7005

编辑各个节点配置文件

  1. cd 7000
  2. vim redis.conf
  3. port 7000
  4. cluster-enabled yes
  5. cluster-config-file nodes.conf
  6. cluster-node-timeout 5000
  7. appendonly yes
  8. daemonize yes

启动集群

  1. redis-server redis.conf
  2. ps ax

以此类推,各节点编辑同样的配置文件,启动

安装tcl, 创建集群并配对

  1. yum install tcl
  2. redis-cli --cluster create --cluster-replicas 1 127.0.0.1:7000 127.0.0.1:7001 127.0.0.1:7002 127.0.0.1:7003 127.0.0.1:7004 127.0.0.1:7005

测试

  1. redis-cli -c -p 7000

重新启动集群需要进入指定集群目录!!!

关掉其中的一个master,集群会自动分配

  1. redis-cli --cluster check 127.0.0.1:7000

重新启动后变为slave

2、脚本创建

生成集群

  1. cd /root/redis-6.2.1/utils/create-cluster
  2. ./create-cluster start

集群配对

  1. ./create-cluster create

五、redis结合mysql

1.mysql与redis不实时同步

需要三台主机,由于前面的实验server2成为了master,其余节点变为slave

server1,3中查看系统文件

  1. vim .bash_profile
  2. source .bash_profile

server3作为数据库,若有已存在的数据库,关闭,安装MariaDB数据库

  1. /etc/init.d/mysqld stop
  2. yum install -y mariadb-server

修改配置文件,启动

  1. vim /etc/my.cnf
  2. systemctl start mariadb

编写一个测试文件,导入mysql中

  1. vim test.sql
  2. use test;
  3. CREATE TABLE `test` (`id` int(7) NOT NULL AUTO_INCREMENT, `name` char(8) DEFAULT NULL, PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;
  4. INSERT INTO `test` VALUES (1,'test1'),(2,'test2'),(3,'test3'),(4,'test4'),(5,'test5'),(6,'test6'),(7,'test7'),(8,'test8'),(9,'test9');
  5. #DELIMITER $$
  6. #CREATE TRIGGER datatoredis AFTER UPDATE ON test FOR EACH ROW BEGIN
  7. # SET @RECV=gman_do_background('syncToRedis', json_object(NEW.id as `id`, NEW.name as `name`));
  8. # END$$
  9. #DELIMITER ;
  10. mysql < test.sql

使用该数据库

在server1中,安装php-fpm (需从网上下载)httpd psmisc

  1. yum install -y php-fpm httpd psmic
  2. cd /etc/php-fpm.d/

关闭上次实验开启的集群

  1. killall redis-server

编写test.php,连接master与数据库

  1. <?php
  2. $redis = new Redis();
  3. $redis->connect('172.25.34.2',6379) or die ("could net connect redis server");
  4. # $query = "select * from test limit 9";
  5. $query = "select * from test";
  6. for ($key = 1; $key < 10; $key++)
  7. {
  8. if (!$redis->get($key))
  9. {
  10. $connect = mysql_connect('172.25.34.3','redis','westos');
  11. mysql_select_db(test);
  12. $result = mysql_query($query);
  13. //如果没有找到$key,就将该查询sql的结果缓存到redis
  14. while ($row = mysql_fetch_assoc($result))
  15. {
  16. $redis->set($row['id'],$row['name']);
  17. }
  18. $myserver = 'mysql';
  19. break;
  20. }
  21. else
  22. {
  23. $myserver = "redis";
  24. $data[$key] = $redis->get($key);
  25. }
  26. }
  27. echo $myserver;
  28. echo "<br>";
  29. for ($key = 1; $key < 10; $key++)
  30. {
  31. echo "number is <b><font color=#FF0000>$key</font></b>";
  32. echo "<br>";
  33. echo "name is <b><font color=#FF0000>$data[$key]</font></b>";
  34. echo "<br>";
  35. }
  36. ?>

server3授权

  1. grant all on test.* to redis@'%' identified by 'westos';

将test.php放在apache发布目录下,开启httpd服务,测试访问172.25.34.1/test.php

server2的redis中,同步数据

刷新网页

2.配置gearman实现mysql与redis实时同步

gearman是支持分布式任务分发的框架,运行在后台

在server3上gearman安装步骤:
准备lib_mysqludf_json-master.zip文件,解压并进入解压后的目录

  1. unzip lib_mysqludf_json-master.zip
  2. cd lib_mysqludf_json-master/

安装mariadb开发包

  1. yum install -y mariadb-devel

重新编译

  1. gcc $(mysql_config --cflags) -shared -fPIC -o lib_mysqludf_json.so lib_mysqludf_json.c

将编译好的文件复制到/usr/lib64/mysql/plugin/

  1. cp lib_mysqludf_json.so /usr/lib64/mysql/plugin/

模块目录可在数据库查看

  1. cp lib_mysqludf_json.so /usr/lib64/mysql/plugin/

注册udf函数

  1. CREATE FUNCTION json_object RETURNS STRING SONAME 'lib_mysqludf_json.so';

server1中,安装gearman,开启并查看端口

  1. systemctl start gearmand
  2. netstat -antlp|grep :4730

server3中,制定路径解压安装gearman

  1. tar zxf gearman-mysql-udf-0.6.tar.gz
  2. cd gearman-mysql-udf-0.6/
  3. ./configure --libdir=/usr/lib64/plugin

发现需要依赖性

安装相关依赖性libevent-devel libgearman.x86_64 libgearman-devel,重新编译gearman

  1. ./configure --libdir=/usr/lib64/plugin --with-mysql=/usr/bin/mysql_config
  2. make && make install

进入mysql

  1. CREATE FUNCTION gman_do_background RETURNS STRING SONAME 'libgearman_mysql_udf.so';
  2. CREATE FUNCTION gman_servers_set RETURNS STRING SONAME 'libgearman_mysql_udf.so';

查看

编写触发器,输入数据库

  1. vim test.sql
  2. use test;
  3. DELIMITER $$
  4. CREATE TRIGGER datatoredis AFTER UPDATE ON test FOR EACH ROW BEGIN
  5. SET @RECV=gman_do_background('syncToRedis', json_object(NEW.id as `id`, NEW.name as `name`));
  6. END$$
  7. DELIMITER ;
  8. mysql < test.sql

进入数据库查看触发器

  1. SHOW TRIGGERS FROM test;

也可以这样看

  1. SHOW TRIGGERS FROM test\G;

server1编写worker.php,指向master

  1. <?php
  2. $worker = new GearmanWorker();
  3. $worker->addServer();
  4. $worker->addFunction('syncToRedis', 'syncToRedis');
  5. $redis = new Redis();
  6. $redis->connect('172.25.34.2', 6379);
  7. while($worker->work());
  8. function syncToRedis($job)
  9. {
  10. global $redis;
  11. $workString = $job->workload();
  12. $work = json_decode($workString);
  13. if(!isset($work->id)){
  14. return false;
  15. }
  16. $redis->set($work->id, $work->name);
  17. }
  18. ?>

打入后台运行

  1. nohup php worker.php &

进入server3数据库,更新名称为redhat

  1. use test;
  2. update test set name='redhat' where id=1;

进入网页查看更新

在server2查看更新

相关文章

最新文章

更多