Jedis 连接Redis 集群[通俗易懂]

Jedis 连接Redis 集群[通俗易懂]1.Jedis实现了连接Redis集群的操作,但是操作Redis集群的API是JedisCluster,和单机版api不一致(Jedis);2.创建JedisCluster需要一个Set集合,Set集合的每一个元素是HostAndPort;JedisCluster实际上可以根据一个节点的IP和端口号自动发现集群中的其它节点;代码:packagecom.etoak;importredis.clients.jedis.HostAndPort;importredis.client

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

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

1. Jedis实现了连接Redis集群的操作,但是操作Redis集群的API是JedisCluster,和单机版api不一致 (Jedis);

2. 创建JedisCluster需要一个Set集合,Set集合的每一个元素是HostAndPort; JedisCluster实际上可以根据一个节点的IP和端口号自动发现集群中的其它节点;

代码:

package com.etoak;

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;

import java.util.HashSet;
import java.util.Set;

public class ClusterTest {
    public static void main(String[] args) {
        //set 集合,用来装集群的ip 和端口的
        Set<HostAndPort> nodes = new HashSet<>();
        //通过for循环把集群的主机信息装到集合
        for (int port = 8001;port<=8006;port++) {
            nodes.add(new HostAndPort("192.168.132.139",port));
        }

        //创建JedisCluster
        JedisCluster cluster = new JedisCluster(nodes);
        //set k v
        cluster.set("name","et2106");
        //hset k field value
        cluster.hset("user:1","id","1");
        cluster.hset("user:1","x","x");
        //sadd
        cluster.sadd("set","a","b","c");

        System.out.println(cluster.get("name"));

        cluster.hgetAll("user:1").forEach((k,v)-> System.out.println(k+":"+v));

        cluster.smembers("set").forEach(x-> System.out.println(x));

        cluster.close();



    }
}

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

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

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


相关推荐

  • Insecure Direct Object References

    Insecure Direct Object References目录越权分类危害解决越权访问一些心得InsecureDirectObjectReference不安全对象是怎么直接被引用的?其它可能不安全对象直接引用…

    2022年6月1日
    57
  • httpclient4.x访问https[通俗易懂]

    httpclient4.x访问https[通俗易懂]https有单向认证和双向认证之分,单向认证即客户端只会认证服务端,双向认证是客户端需要认证服务端,服务端也需要认证客户端。先说单向认证,浏览器访问服务端,服务端接收请求,会把证书(包含密钥和其他信息)和加密后响应返回给浏览器。如果这个证书不是向第三方权威机构申请的,浏览器会提示证书有问题(使用httpclient访问的话会报错)。如果忽略错误,则浏览器接受证书并解密响应,发送的数据也用此密钥

    2022年7月22日
    11
  • 剑指 Offer 56 – II. 数组中数字出现的次数 II

    剑指 Offer 56 – II. 数组中数字出现的次数 II在一个数组 nums 中除一个数字只出现一次之外,其他数字都出现了三次。请找出那个只出现一次的数字。示例 1:输入:nums = [3,4,3,3]输出:4示例 2:输入:nums = [9,1,7,9,7,9,7]输出:1限制:1 <= nums.length <= 100001 <= nums[i] < 2^31设置一个数组代表32位,每一位代表当前所有数组中当前位出现次数之和。然后%3,然后拼凑class Solution {public: in

    2022年8月8日
    6
  • STM32编程怎么入门,聊聊我的入门经历

    STM32编程怎么入门,聊聊我的入门经历我第一次接触STM32大概是在8,9年前。当时刚出来工作不久,在此之前主要用stc和nxp的单片机比较多。那个时候还没有固件库开发的概念,基本都是配置寄存器去使用单片机外设资源。虽然说用起来比较麻烦,但是执行的效率也相对高一点,习惯了也挺好用。新项目比较复杂一点,一个老工程师建议我用stm32的单片机做效率比较高。听大佬的话照做是一个小菜鸟的基本素养,所以我选了stm32。对于学习这块,我也比较舍得(当时月薪只有1.8K),毫不犹豫花了几百大洋购买了一套stm32开发板。学习一款

    2025年9月29日
    1
  • SecureCRTPortable(CRT)快捷键方法

    SecureCRTPortable(CRT)快捷键方法1.添加按钮,以进入beeline为例1)选中按钮栏2)3)beeline\r\p\p!connectjdbc:hive2://jh01:10000\rroot\r123456\r2.查找历史命令Ctrl+r

    2022年6月10日
    61
  • 如何理解python报错信息_csb报错

    如何理解python报错信息_csb报错#软件版本python3.7pycharm2018.3.1遇到的问题解释及处理方法#1报错#TypeError:‘key’isaninvalidkeywordargumentforprint()代码:def_cmp(x,y):ifx&amp;amp;amp;amp;amp;amp;amp;amp;amp;gt;y:return-1ifx&amp;amp;amp;amp;amp;amp;amp;amp;amp;lt;y:return

    2022年8月28日
    2

发表回复

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

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