Redis(6)Clients - Scala Clients

Redis(6)Clients - Scala Clients

Upgrade the Redis to latest
>wget http://download.redis.io/releases/redis-2.8.7.tar.gz
Unzip it 
>cd redis-2.8.7
>make
>mkdir /Users/carl/tool/redis-2.8.7
>cd src/
>cp redis-server /Users/carl/tool/redis-2.8.7/
>cp redis-benchmark /Users/carl/tool/redis-2.8.7/
>cp redis-cli /Users/carl/tool/redis-2.8.7/

>cd ..
>cp redis.conf /Users/carl/tool/redis-2.8.7/
>pwd
/Users/carl/tool/redis-2.8.7


5. Scala Client

Here is the official website of jedis https://github.com/xetorthio/jedis

5.1 Simple Usage
"redis.clients" % "jedis" % "2.4.1"

package com.sillycat.easynosqlscala.app

import redis.clients.jedis.Jedis

object TestRedisDBConnectionApp extends App{
  val jedis = new Jedis("localhost")
  jedis.set("name","sillycat")
  println(jedis.get("name"))

}

5.2 Working with Cluster

There should be not only the redis-server file, but also this file under the src directory, 
>cp redis-sentinel /Users/carl/tool/redis-2.8.7/

Here is the configuration file
>cp /Users/carl/data/redis-2.8.7/sentinel.conf /opt/redis/

Prepare all these configuration files.
>vi redis-0/redis.conf
port 6379 
>vi redis-1/redis.conf
port 6479
slaveof 127.0.0.1 6379

>vi sentinel-0/sentinel.conf
port 26379

>vi sentinel-1/sentinel.conf 
port 26479

Start Commands
>./redis-server redis-0/redis.conf
>./redis-server redis-1/redis.conf
>./redis-sentinel sentinel-0/sentinel.conf
>./redis-sentinel sentinel-1/sentinel.conf 

Then I have 1 master of Redis instance on 6379, 1 slave of Redis instance on 6479.
1 Sentinel on 26379, 1 sentinel on 26479.

Information
>./redis-cli -h 127.0.0.1 -p 26379 info Sentinel 
# Sentinel
sentinel_masters:1
sentinel_tilt:0
sentinel_running_scripts:0
sentinel_scripts_queue_length:0
master0:name=mymaster,status=ok,address=127.0.0.1:6479,slaves=1,sentinels=2

>./redis-cli -h 127.0.0.1 -p 6479
redis>info

This seems to be only the master-slave mode.

Try to Connect the server with this Jedis Client
package com.sillycat.easynosqlscala.app

import redis.clients.jedis.{JedisCluster, HostAndPort, Jedis}
import java.util.HashSet

object TestRedisDBConnectionApp extends App{
  val jedis = new Jedis("localhost")
  jedis.set("name","sillycat")
  println(jedis.get("name"))

  val jedisClusterNodes = new HashSet[HostAndPort]
  jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6379))
  jedisClusterNodes.add(new HostAndPort("127.0.0.1", 6479))
  val jc = new JedisCluster(jedisClusterNodes)
  jc.set("age","32")
  println("name = " + jedis.get("name") + " age = " + jc.get("age"))

}


Tips:
Error Message:
sbt.ResolveException: download failed: javax.jms#jms;1.1!jms.jar

Solution:
add this to the resolvers
"MIT repo"           at "http://simile.mit.edu/maven/"

Error Message:
Exception in thread "main" redis.clients.jedis.exceptions.JedisDataException: ERR unknown command 'CLUSTER'
     at redis.clients.jedis.Protocol.processError(Protocol.java:100)

Solution:
It seems to me that I am not running Redis under cluster mode.


References:
https://github.com/debasishg/scala-redis
https://github.com/top10/scala-redis-client
https://github.com/alphazero/jredis
https://github.com/xetorthio/jedis

Redis 1~5
http://sillycat.iteye.com/blog/1549504   installation
http://sillycat.iteye.com/blog/1553507   Different Types
http://sillycat.iteye.com/blog/1553508   Different Types
http://sillycat.iteye.com/blog/1553509   Example Operations
http://sillycat.iteye.com/blog/2028180   HA and Setup on MAC


相关推荐