非集群中使用是Jedis对象

时间:2022-05-31 05:35:10

第一步:下载安置redis

windows版的下载地点:https://github.com/MSOpenTech/redis/releases

文件目录介绍:

处事端:redis-server.exe

客户端:redis-cli.exe

配置文件:redis.windows.conf

集群工具:redis-trib.rb(windows的安置文件是没有这个的,需要从linux的版本拷贝过来)

第二步:安置ruby

下载安置railsinstaller,,这是一个打包好的一站式安置包,里面包罗了Ruby、Ralis等组件

官方地点:

百度网盘:https://pan.baidu.com/s/1eUje2L8

安置完成后在cmd窗口中执行命令gem install redis,

第三步:配置Redis节点

配置集群节点的要领跟上一节linux环境中的操纵是根基一样的,这里就不在赘述。

第四步:创建集群

进入redis-trib.rb文件地址目录并执行以下命令,这里示例是3主0从:

ruby redis-trib.rb create 127.0.0.1:7000 127.0.0.1:7001 127.0.0.1:7002

最后一步:在java中挪用redis

注:在非集群和集群环境中挪用的方法有所差别,非集群中使用是Jedis东西,而集群中使用的是JedisCluster东西。

附上代码:

package com.cjh; import com.sun.org.apache.regexp.internal.RE; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import redis.clients.jedis.HostAndPort; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisCluster; import java.util.HashMap; import java.util.HashSet; import java.util.Set; /** * Created by 20628_000 on 2018/1/24. */ public class RedisTest { public static void main(String arges[]) { new RedisTest().init(); } private static final Logger logger = LogManager.getLogger(RedisTest.class); private static JedisCluster jc = null; public void init() { //连接本地的 Redis 处事 /*jedis = new Jedis("127.0.0.1",7002); System.out.println("连接告成"); System.out.println("处事正在运行: "+jedis.ping());*/ Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>(); //Jedis Cluster will attempt to discover cluster nodes automatically jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7000)); jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7001)); jedisClusterNodes.add(new HostAndPort("127.0.0.1", 7002)); jc = new JedisCluster(jedisClusterNodes); test(); } public void test() { HashMap map = new HashMap(); map.put("name", "cjh"); map.put("age", "25"); map.put("sex", "male"); jc.hmset("myInfo", map); logger.info(jc.hget("myInfo", "age")); } }

运行措施,检察打印信息:

2018-02-19 17:13:42 INFO com.cjh.RedisTest – 25