一.Redis的分布式
Redis本身不支持分布式,通过Jedis客户端可以实现使用Redis分布式。
package com.gqshao.redis.connection; import com.google.common.collect.Lists; import com.gqshao.redis.utils.JedisUtils; import org.junit.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import redis.clients.jedis.*; import java.util.Arrays; import java.util.List; /** * Jedis 独有的分布式 * 根据List<JedisShardInfo>中Redis顺序和key,指定固定的Redis * 扩容时使用 Pre-Sharding */ public class ShardedJedisTest { protected static Logger logger = LoggerFactory.getLogger(ShardedJedisTest.class); private static ShardedJedisPool pool = null; protected ShardedJedis jedis = null; @BeforeClass public static void createPool() { JedisPoolConfig poolConfig = JedisUtils.getMyDefaultJedisPoolConfig(); // List<JedisShardInfo> shards = Arrays.asList(new JedisShardInfo("192.168.3.98", 6379) // , new JedisShardInfo("192.168.3.98", 6380)); List<JedisShardInfo> shards = Lists.newArrayList(); JedisShardInfo info1 = new JedisShardInfo("192.168.3.98", 6379); JedisShardInfo info2 = new JedisShardInfo("192.168.3.98", 6380); // 添加的顺序有意义 shards.add(info1); shards.add(info2); pool = new ShardedJedisPool(poolConfig, shards); } @Before public void getResource() { jedis = pool.getResource(); } @After public void destroyJedis() { pool.returnResource(jedis); } @AfterClass public static void destroyPool() { pool.destroy(); } /** * 不同的key分配根据List<JedisShardInfo>中的顺序,分配不同的Redis连接 */ @Test public void testSet() { for (int i = 0; i < 20; i++) { try { logger.info(i + " - " + jedis.getShard("" + i).getClient().getHost() + " : " + jedis.getShard(i + "").getClient().getPort()); logger.info(jedis.set("" + i, "true")); } catch (Exception e) { e.printStackTrace(); } } } /** * 修改List<JedisShardInfo>中的顺序,无法得到结果,确定该顺序是有意义的 */ @Test public void testGet() { for (int i = 0; i < 20; i++) { try { logger.info(i + " - " + jedis.getShard(i + "").getClient().getHost() + ":" + jedis.getShard(i + "").getClient().getPort() + " ? " + jedis.get("" + i)); } catch (Exception e) { e.printStackTrace(); } } } }
二.Redis主从复制
redis的主重复制有两种方式,第一种是写在.conf配置文件中,第二种是通过命令slaveof ip port 或 slaveof no one
slaveof no one 之后,当前Redis节点提升为Master但之前数据不会丢失,所以通过程序动态的设置主从复制可以解决Redis单点故障的问题
package com.gqshao.redis.connection; import com.gqshao.redis.utils.JedisUtils; import org.junit.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; /** * slaveof 和 slaveofNoOne方法可以在运行中动态设置服务器为Master或Slave */ public class SlaveofTest { protected static Logger logger = LoggerFactory.getLogger(SlaveofTest.class); private static JedisPool pool1 = null; protected Jedis jedis1 = null; private static JedisPool pool2 = null; protected Jedis jedis2 = null; @BeforeClass public static void init() { JedisPoolConfig poolConfig = JedisUtils.getMyDefaultJedisPoolConfig(); // timeout设置为0,解决JedisConnectionException pool1 = new JedisPool(poolConfig, "192.168.3.98", 6379, 0); pool2 = new JedisPool(poolConfig, "192.168.3.98", 6380, 0); logger.info("----------------------create resource----------------------"); } @AfterClass public static void destroy() { pool1.destroy(); pool2.destroy(); } @Before public void initJedis() { jedis1 = pool1.getResource(); jedis2 = pool2.getResource(); } @After public void destroyJedis() { pool1.returnResource(jedis1); pool2.returnResource(jedis2); } /** * 测试主从复制 注意设置Slave之后需要时间复制数据 */ @Test public void test() { // 设置 Redis2为Redis1的slave logger.info("jedis1 slaveof no one"); jedis1.slaveofNoOne(); logger.info("jedis2 slaveof 192.168.3.98 6379"); jedis2.slaveof("192.168.3.98", 6379); try { jedis2.set("key", "value"); } catch (Exception e) { logger.warn("由于设置的原因slave为read only"); } // 主从复制 Redis1中保存数据Redis2中可以读取 logger.info("jedis1.set mykey1 myvalue1 : " + jedis1.set("mykey1", "myvalue1")); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } logger.info("jedis2.get mykey1: " + jedis2.get("mykey1")); // 单点问题解决思路(思路启用Redis2为Master,Redis1为SlaveOf Redis1) // 提升Redis2为Master,读取刚才的数据,重启Redis1,将Redis2设置为Redis1的Master jedis2.slaveofNoOne(); // 测试值仍然存在 logger.info("jedis2.get again : " + jedis2.get("mykey1")); // Redis2中存入数据 logger.info("jedis2.set mykey2 myvalue2 : "+jedis2.set("mykey2", "myvalue2")); // Redis1设置为Redis2的slave jedis1.slaveof("192.168.3.98", 6380); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } // 测试jedis1中读取数据 logger.info("jedis1.get mykey2 : " + jedis1.get("mykey2")); logger.info("jedis1 slaveof no one"); jedis1.slaveofNoOne(); jedis1.del("mykey1", "mykey2"); jedis2.del("mykey1", "mykey2"); } }
相关推荐
把下载的三个文件(StackExchange.Redis.dll、StackExchange.Redis.dll.refresh、StackExchange.Redis.xml)复制粘贴到计算机上的某个目录下。然后在vs2010的解决方案资源管理器窗口中右击项目,单击“添加引用”,...
把下载的三个文件(StackExchange.Redis.dll、StackExchange.Redis.dll.refresh、StackExchange.Redis.xml)复制粘贴到计算机上的某个目录下。然后在vs2010的解决方案资源管理器窗口中右击项目,单击“添加引用”,...
Java开发基于SpringBoot+WebSocket+Redis分布式即时通讯群聊系统。一个基于Spring Boot + WebSocket + Redis,可快速开发的分布式即时通讯群聊系统。适用于直播间聊天、游戏内聊天、客服聊天等临时性群聊场景。 ...
Redis推荐的最好的.Net客户端。 ServiceStack.Redis 4.0 已经收费 并且有每小时6000次插入的限制。这个是ServiceStack.Redis 3系版本的最终最新版本3.9.60,无使用限制, Redis.NET客户端无限制版
最近需要在C#中使用Redis,ServiceStack.Redis的4.0版本已开始收费,之前版本Bug较多。建议使用StackExchange.Redis,支持异步的客户端,据说性能比ServiceStack.Redis更好,而且据说Stack Overflow也是使用的这个...
ServiceStack.Redis 4.5.0.0 已解除license限制
最近需要在C#中使用Redis,在Redis的官网找到了ServiceStack.Redis,最后在测试的时候发现这是个坑,4.0已上已经收费,后面只好找到3系列的最终版本,最后测试发现还是有BUG或者是我不会用。没有办法,最好找到了...
Scrapy-Redis分布式爬虫与搜索网站构建-搜索引擎论文-图书档案学论文.docxScrapy-Redis分布式爬虫与搜索网站构建-搜索引擎论文-图书档案学论文.docxScrapy-Redis分布式爬虫与搜索网站构建-搜索引擎论文-图书档案学...
本例子是用ServiceStack.Redis+log4net做的一个分布式记日志的功能,使用场景:分布式系统中的各个服务向redis服务添加日志,服务定时轮询生成记录日志到数据库或文本中。如果你的系统所有的方法调记录都需要记录的...
现在很多项目单机版已经不满足了,分布式变得越受欢迎,同时也带来很多问题,分布式锁也变得没那么容易实现,分享一个redis分布式锁工具类,里面的加锁采用lua脚本(脚本比较简单,采用java代码实现,无须外部调用...
本资源为一步一步实现redis分布式锁的demo,利用redis实现高可用的分布式锁,规避各种坑、坑、坑!
C# StackExchange.Redis 操作封装类库,分别封装了Redis五大数据结构(String,Hash,List,Set,ZSet)的增删改查的操作方法,支持Async异步操作。支持Redis分库操作。支持信息队列操作。 带有单元测试,为每个...
4.《Redis实战》红丸出品 5.redis命令参考中文版 6.Redis学习笔记 7.redis项目实战 8.Redis 多机特性工作原理简介 9.redis深入研究及大集群实战经验 10.Redis 的安装配置介绍 12.Redis 的安装配置 等等 helloredis ...
由于ServiceStack.Redis已经收费,所以开始转向StackExchange.Redis使用,这里不讨论性能,只是封装其使用;...主要原理:一个实例一个连接,同时通过连接字符串相同来共享连接;关闭完实例则释放;
SpringBoot基于redis的分布式锁,有word使用文档,根据文档配置即可使用
redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-5.0.5.redis-...
实现Redis分布式缓存,此文件为相关原理
毕业设计+Python基于Scrapy+Redis分布式爬虫设计+源码案例+Python + Scrapy + redis 毕业设计+Python基于Scrapy+Redis分布式爬虫设计+源码案例+Python + Scrapy + redis 毕业设计+Python基于Scrapy+Redis分布式爬虫...
redis集群采用无中心节点方式实现,无需proxy代理,客户端直接与redis集群的每个节点连接,根据同样的hash算法计算出key对应的slot,然后直接在slot对应的redisj节点上执行命令。在redis看来,响应时间是最苛刻的...
ServiceStack.Redis 源代码,可以编译通过。Redis C#连接源代码