Jediscluster_唧唧pc客户端

Jediscluster_唧唧pc客户端前言:由于spring-data-redis不支持,redis集群的操作。所以更换客户端,使用Jediscluster。正文:一.序言   前面搭建了个3个msater-slave的本地集群测试,这里用java的客户端进行一些简单测试,看看集群是否生效。   redisclient推荐:http://redis.io/clients 

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

前言:

由于spring-data-redis不支持,redis集群的操作。所以更换客户端,使用Jedis cluster。

正文:

一.序言

     前面搭建了个3个msater-slave 的本地集群测试,这里用java 的客户端 进行一些简单测试,看看集群是否生效。

     redis client 推荐:http://redis.io/clients

     我使用的:https://github.com/xetorthio/jedis

 

二.测试

    maven:

    

Java代码  
收藏代码

  1. <dependency>  
  2.     <groupId>redis.clients</groupId>  
  3.     <artifactId>jedis</artifactId>  
  4.     <version>2.7.2</version>  
  5.     <type>jar</type>  
  6.     <scope>compile</scope>  
  7. </dependency>  

 

     

Java代码  
收藏代码

  1. @org.junit.Test  
  2. public  void cluster(){  
  3.     String key = “2”;  
  4.     // 这东西 可以直接看到key 的分片数,就能知道放哪个 节点  
  5.     System.out.println(JedisClusterCRC16.getSlot(key));  
  6.     Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>();  
  7.     jedisClusterNodes.add(new HostAndPort(“127.0.0.1”7000));  
  8.     jedisClusterNodes.add(new HostAndPort(“127.0.0.1”7001));  
  9.     jedisClusterNodes.add(new HostAndPort(“127.0.0.1”7002));  
  10.     // 3个master 节点  
  11.     JedisCluster jc = new JedisCluster(jedisClusterNodes);  
  12.     System.out.println(jc.get(key));  
  13.     jc.setnx(key, “bar”);  
  14.     String value = jc.get(key);  
  15.     System.out.println(value);  
  16. }  

   别人的例子,我测试:

   

Java代码  
收藏代码

  1. Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>();  
  2.      jedisClusterNodes.add(new HostAndPort(“127.0.0.1”7000));  
  3.      jedisClusterNodes.add(new HostAndPort(“127.0.0.1”7001));  
  4.      jedisClusterNodes.add(new HostAndPort(“127.0.0.1”7002));  
  5.      JedisCluster jc = new JedisCluster(jedisClusterNodes);  
  6.      for (int i = 1; i <= 10000; i++) {  
  7.          long start = System.currentTimeMillis();  
  8.          jc.set(“k:” + i, “v” + i);  
  9.          System.out.print(“set “ + i +“th value in “ + (System.currentTimeMillis() – start) + ” ms”);  
  10.          start = System.currentTimeMillis();  
  11.          jc.get(“k:” + i);  
  12.          System.out.println(“, get “ + i +“th value in “ + (System.currentTimeMillis() – start) + ” ms”);  
  13.      }  

   由于是本机 固态硬盘,速度 杠杆的。

    

 

 三.测试反馈: 

     1.集群正常,基本操作都OK

     2.如果某个master 挂了,比如7001, 集群依然可用,会存放到对应的salve 7004 上去。

     3.如果master -slave 都挂了,会导致 整个集群不可用,异常,因此最好配有M-S 的结构

     4.我默认配置,有rdb 和 aof  持久化,因此master 挂了,重启,数据可以从salve 上恢复

     5.存放的key 会根据返回的位置,放在不同的slot 上,实现均衡

 

小结:

      1.这里仅仅是最基本的配置,和简单测试

      2.如果配置文件以及更多命令得参考文档

         2.1 客户端命令:http://redis.io/topics/clients

         2.2 中文jredis API:http://www.360doc.com/content/15/0328/12/5054188_458684113.shtml  建议看源码用例

        2.3 redis.conf 中文(旧):http://www.cppblog.com/HappySky2046/archive/2014/06/18/207323.html

      

      3.如果前期负载不很大,可以开启持久化,毕竟集群 还不熟悉,如果负载高了,而且集群比较熟悉了,业务也不依赖的情况下,可以关闭,或者 适当调整,调整多看看 原理 和 配置文件说明 就行了。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/182024.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • 均值不等式四个公式

    均值不等式四个公式假设有一根长度为24cm的钢筋,现在对其进行截取焊接成一个长方体框架,如何截取焊接才能保证长方体的体积最大?下面引出均值不等式可以解决这个问题。则有:     对进行证明:构建两个序列由排序不等式顺序和≥乱序和≥倒序和显然有下列不等式关系 接下来利用这个关系证明不等式两边同时取倒数不等…

    2022年4月30日
    149
  • mysql数据库日志存储位置_MySQL数据库之mysql日志文件在哪 如何修改MySQL日志文件位置…「建议收藏」

    mysql数据库日志存储位置_MySQL数据库之mysql日志文件在哪 如何修改MySQL日志文件位置…「建议收藏」本文主要向大家介绍了MySQL数据库之mysql日志文件在哪如何修改MySQL日志文件位置,通过具体的内容向大家展现,希望对大家学习MySQL数据库有所帮助。MySQL日志文件相信大家都有很多的了解,MySQL日志文件一般在:/var/log/mysqld.log,下面就教您修改MySQL日志文件位置的方法,供您参考。今天需要改MySQL日志文件的位置,发现在/etc/my.cnf中怎么也改不…

    2022年10月14日
    0
  • mssql注入与绕过

    0x00前言上篇文章写了mssql的查询方式与mssql和mysql的区别。在注入当中也是有些区别的。下面直接来看到几种mssql注入的方法与特性,绕过方式。因为mssql加aspx的站懒得搭建

    2021年12月11日
    47
  • 信息学奥赛GoC编程测试题题库

    信息学奥赛GoC编程测试题题库在线答题和答案详解请参考https://blog.csdn.net/zhengzyx2040/article/details/118632561一、单选题(15题,每题4分,满分60分)1、GoC的编译+运行的快捷键是()A、F5B、F11C、F8D、F122、GoC程序的源文件扩展名是(),经过编译后生成的可执行文件扩展名是()A、CPPEXEB、EXECPP…

    2022年6月18日
    60
  • python下mqtt服务器的搭建_搭建MQTT服务器

    python下mqtt服务器的搭建_搭建MQTT服务器就让我来试试传说中最适用于IOT的MQTT协议。安装虽然搜索资料很多,但大多是MQTT的使用,尽管有搭建服务器的文章,但我感觉写的不太清楚,大多数文章选择了Mosquitto(也许是Eclipse大厂出品的原因)。经过寻找,找到了Nodejs写的mosca,但在Pi上老是安装失败,翻了翻Issues,找到了同作者写的依赖性小,轻量化的aedes。npminstallaedes–save//…

    2022年5月8日
    506
  • 44h11资料_acwing是什么

    44h11资料_acwing是什么原题链接给定 N 个正整数 A1,A2,…,AN,从中选出若干个数,使它们的和为 M,求有多少种选择方案。输入格式第一行包含两个整数 N 和 M。第二行包含 N 个整数,表示 A1,A2,…,AN。输出格式包含一个整数,表示可选方案数。数据范围1≤N≤100,1≤M≤10000,1≤Ai≤1000输入样例:4 41 1 2 2输出样例:3#include<bits/stdc++.h>using namespace std;const int M = 1e4

    2022年8月8日
    0

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号