技术栈

主页 > 数据库 >

redis集群之jedis连接集群版

技术栈 - 中国领先的IT技术门户

1. Jedis

需要把jedis依赖的jar包添加到工程中。Maven工程中需要把jedis的坐标添加到依赖。

推荐添加到服务层。E3-content-Service工程中。




  redis.clients
  jedis
  ${jedis.version}

2. 连接单机版

2.1. 步骤

第一步:创建一个Jedis对象。需要指定服务端的ip及端口。

第二步:使用Jedis对象操作数据库,每个redis命令对应一个方法。

第三步:打印结果。

第四步:关闭Jedis

2.2. Demo


@Test public void testJedis() throws Exception { //创建一个连接Jedis对象,参数:host、port Jedis jedis = new Jedis("192.168.25.101", 6379); //直接使用jedis操作redis。所有jedis的命令都对应一个方法。 jedis.set("test123", "my first jedis test"); String string = jedis.get("test123"); System.out.println(string); //关闭连接 jedis.close(); }

3. 连接单机版使用连接池

3.1. 步骤

第一步:创建一个JedisPool对象。需要指定服务端的ip及端口。

第二步:从JedisPool中获得Jedis对象。

第三步:使用Jedis操作redis服务器。

第四步:操作完毕后关闭jedis对象,连接池回收资源。

第五步:关闭JedisPool对象。

3.2. Demo


@Test public void testJedisPool() throws Exception { //创建一个连接池对象,两个参数host、port JedisPool jedisPool = new JedisPool("192.168.25.101", 6379); //从连接池获得一个连接,就是一个jedis对象。 Jedis jedis = jedisPool.getResource(); //使用jedis操作redis String string = jedis.get("test123"); System.out.println(string); //关闭连接,每次使用完毕后关闭连接。连接池回收资源。 jedis.close(); //关闭连接池。 jedisPool.close(); } 

4. 连接集群版

4.1. 步骤

第一步:使用JedisCluster对象。需要一个Set参数。Redis节点的列表。

第二步:直接使用JedisCluster对象操作redis。在系统中单例存在。

第三步:打印结果

第四步:系统关闭前,关闭JedisCluster对象。

4.2. Demo


@Test public void testJedisCluster() throws Exception { //创建一个JedisCluster对象。有一个参数nodes是一个set类型。 // set中包含若干个HostAndPort对象。 Set nodes = new HashSet(); nodes.add(new HostAndPort("192.168.25.101", 6379)); nodes.add(new HostAndPort("192.168.25.101", 6380)); nodes.add(new HostAndPort("192.168.25.101", 6381)); nodes.add(new HostAndPort("192.168.25.101", 6382)); JedisCluster jedisCluster = new JedisCluster(nodes); //直接使用JedisCluster对象操作redis。 jedisCluster.set("test1", "123"); String string = jedisCluster.get("test"); System.out.println(string); //关闭JedisCluster对象 jedisCluster.close(); } 
责任编辑:admin  二维码分享:
本文标签: jedis