jedispool 连接池_redis-cli连接redis数据库

jedispool 连接池_redis-cli连接redis数据库一、连接前的准备1.确保windows能够ping通linux,linux能够ping通windows。2.开放CentOS7的端口6379。firewall-cmd–add-port=6379/tcp–permanent3.注释掉redis.conf文件中的bind。#bind127.0.0.14….

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

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

目录

一、连接前的准备

二、使用JedisPool连接池创建连接

ThreadLocal为多线程保证一个线程始终同一个连接

多线程测试

三、配置多数据源 


一、连接前的准备

        1 . 确保windows能够ping通linux,linux能够ping通windows。

        2. 开放CentOS7的端口6379 。

      firewall-cmd –add-port=6379/tcp –permanent

        3. 将redis.conf文件中的bind 改为 0.0.0.0

      bind 0.0.0.0

        4. 需要给redis设置密码才能访问,要不然会提醒没有设置密码, 修改redis.conf配置文件,指定永久密码:  

     # requirepass foobared
       requirepass 123456   

        5. 将protecetd-mode 设置为no 

protected-mode no

        6. 启动服务器。

./redis-server ../redis.conf

        windows:

cd D:\Program Files\redis-server-5.0.9

d:

redis-server.exe redis.windows-service.conf

     jedispool 连接池_redis-cli连接redis数据库

二、使用JedisPool连接池创建连接

        添加pom依赖:

  <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>2.4.2</version>
</dependency>

        注:访问的地址为ping通linux的地址,可以先通过redis桌面程序RedisDesktopManager测试是否可以通,再进行如下的工作。

ThreadLocal为多线程保证一个线程始终同一个连接

定义RedisConstants常量

package com.bing.sh.redis;

public class RedisConstants {


    public static final String DEFAULT_REDIS_HOST = "localhost";
    //端口
    public static final int DEFAULT_REDIS_PORT = 6379;
    //密码
    public static final String DEFAULT_REDIS_PWD = "123456";

    public static final int DEFAULT_REDIS_MAX_ACTIVE = 1024;
    //控制一个pool最多有多少个状态为idle(空闲的)的jedis实例,默认值也是8。
    public static final int DEFAULT_REDIS_MAX_IDLE = 200;
    //等待可用连接的最大时间,单位毫秒,默认值为-1,表示永不超时。如果超过等待时间,则直接抛出JedisConnectionException
    public static final int DEFAULT_REDIS_MAX_WAIT = 10000;
    //连接超时的时间  
    public static final int DEFAULT_REDIS_TIMEOUT = 10000;
    // 在borrow一个jedis实例时,是否提前进行validate操作;如果为true,则得到的jedis实例均是可用的;
    public static final boolean DEFAULT_REDIS_TEST_ON_BORROW = true;
    // 默认数据库
    public static final int DEFAULT_REDIS_DATABASE = 0;


}

定义RedisProperty类:

package com.bing.sh.redis;


import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;


@Data
@AllArgsConstructor
@NoArgsConstructor
public class RedisProperty {

    //服务器IP地址
    private String host = RedisConstants.DEFAULT_REDIS_HOST;
    //端口
    private int port = RedisConstants.DEFAULT_REDIS_PORT;
    //密码
    private String pwd = RedisConstants.DEFAULT_REDIS_PWD;
    //连接实例的最大连接数
    private int maxActive = RedisConstants.DEFAULT_REDIS_MAX_ACTIVE;
    //控制一个pool最多有多少个状态为idle(空闲的)的jedis实例,默认值也是8。
    private int maxIdle = RedisConstants.DEFAULT_REDIS_MAX_IDLE;
    //等待可用连接的最大时间,单位毫秒,默认值为-1,表示永不超时。如果超过等待时间,则直接抛出JedisConnectionException
    private int maxWait = RedisConstants.DEFAULT_REDIS_MAX_WAIT;
    //连接超时的时间  
    private int timeout = RedisConstants.DEFAULT_REDIS_TIMEOUT;
    // 在borrow一个jedis实例时,是否提前进行validate操作;如果为true,则得到的jedis实例均是可用的;
    private boolean testOnBorrow = RedisConstants.DEFAULT_REDIS_TEST_ON_BORROW;
    //数据库模式是16个数据库 0~15
    public int defaultDatabase = RedisConstants.DEFAULT_REDIS_DATABASE;


}

         使用ThreadLocal存放Jedis实例,保证一个线程使用的连接始终是同一个, 获取连接的时候直接从ThreadLocal里拿

package com.bing.sh.redis;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.ObjectUtils;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class JedisTemplate {
    private static Logger logger = LoggerFactory.getLogger(JedisTemplate.class);


    private static ThreadLocal<Jedis> jedisThreadLocal = new ThreadLocal<>();


    private static JedisTemplate jedisTemplate = new JedisTemplate();

    private static JedisPoolConfig config;

    private static JedisPool jedisPool;


    public static JedisTemplate getJedisTemplate(RedisProperty prop) {
        if (jedisPool == null) {
            initJedisPool(prop.getHost(), prop.getPort(), prop.getPwd(), prop.getTimeout(), prop.getDefaultDatabase());
        }
        return jedisTemplate;
    }

    public static JedisTemplate getJedisTemplate() {
        RedisProperty prop = new RedisProperty();
        if (jedisPool == null) {
            initJedisPool(prop.getHost(), prop.getPort(), prop.getPwd(), prop.getTimeout(), prop.getDefaultDatabase());
        }
        return jedisTemplate;
    }


    static {
        config = new JedisPoolConfig();
        config.setMaxTotal(RedisConstants.DEFAULT_REDIS_MAX_ACTIVE);
        config.setMaxIdle(RedisConstants.DEFAULT_REDIS_MAX_IDLE);
        config.setMaxWaitMillis(RedisConstants.DEFAULT_REDIS_MAX_WAIT);
        config.setTestOnBorrow(RedisConstants.DEFAULT_REDIS_TEST_ON_BORROW);
    }


    public static JedisPool initJedisPool(String host, int port, String pwd, int timeout, int db) {
        jedisPool = new JedisPool(config, host, port, timeout, pwd, db);
        logger.info("init jedis pool success >>>" + jedisPool.hashCode());
        return jedisPool;
    }




    public Jedis getJedisConnection() {
        Jedis jedis = jedisThreadLocal.get();
        if (ObjectUtils.isEmpty(jedis)) {
            jedis = jedisPool.getResource();
            jedisThreadLocal.set(jedis);
        }
        return jedis;

    }

    public void releaseConnection() {
        Jedis jedis = jedisThreadLocal.get();
        if (!ObjectUtils.isEmpty(jedis)) {
            jedisPool.returnResource(jedis);
            System.out.println("线程 ID " + Thread.currentThread().getId() + " 释放连接, jedis code=" + jedis.hashCode() + " release success !");
        }
        jedisThreadLocal.remove();
    }


}

多线程测试

    public static void main(String[] args) {
        RedisProperty property = new RedisProperty();
        // 将自定义属性注入
        property.setPwd("mypassword");
        JedisTemplate jedisTemplate = JedisTemplate.getJedisTemplate(property);
        for (int i = 0; i < 10; i++) {
            new Thread(() -> {
                System.out.println("线程 ID " + Thread.currentThread().getId() + " 获取连接, jedis code=" + jedisTemplate.getJedisConnection().hashCode());
                jedisTemplate.releaseConnection();
            }).start();
        }
    }

jedispool 连接池_redis-cli连接redis数据库

三、配置多数据源 

       也可以采用如下的方式配置redis的多数据源,只要从jedisPoolsMap根据host取出连接池列表即可。

package com.bing.sh.redis;

import com.bing.sh.exception.custom.RedisInitException;
import com.bing.sh.utils.CollectionUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public class MultipleJedisTemplate extends RedisConn {
    private static Logger logger = LoggerFactory.getLogger(MultipleJedisTemplate.class);

    private static MultipleJedisTemplate multipleJedisTemplate = new MultipleJedisTemplate();


    private static Map<String/**host**/, List<JedisPool>> jedisPoolsMap = new ConcurrentHashMap<>();


    public static Map<String, List<JedisPool>> getJedisPoolsMap() {
        return jedisPoolsMap;
    }


    public List<JedisPool> getJedisPoolsByHost(String host) {
        List<JedisPool> jedisPools = jedisPoolsMap.get(host);
        logger.info(host + " get jedis pool " + jedisPools);
        if (CollectionUtils.isNotEmpty(jedisPools)) return jedisPools;
        throw new RedisInitException(host + "has no JedisPoll found ! please init first");
    }


    private static void initMultipleJedisPool(List<RedisProperty> props) {
        props.forEach((prop) -> {
            String host = prop.getHost();
            List<JedisPool> jedisPools = jedisPoolsMap.get(host);
            if (CollectionUtils.isEmpty(jedisPools)) {
                jedisPools = new ArrayList<>();
            }
            jedisPools.add(new JedisPool(poolConfig, prop.getHost(), prop.getPort(), prop.getTimeout(), prop.getPwd(), prop.getDefaultDatabase()));
            jedisPoolsMap.put(host, jedisPools);
        });
    }


    public static MultipleJedisTemplate getMultipleJedisTemplate(List<RedisProperty> props) {
        if (CollectionUtils.isEmpty(props)) {
            throw new RedisInitException("init jedis fail >>> no properties input !");
        }
        initMultipleJedisPool(props);
        return multipleJedisTemplate;
    }


    @Override
    void setConfig(JedisPoolConfig config) {
        poolConfig = config;
    }
}

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

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/197166.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • python的for循环是什么循环_while循环的用法举例

    python的for循环是什么循环_while循环的用法举例在本篇博客中,我们将讨论Python中for循环的原理。我们将从一组基本例子和它的语法开始,还将讨论与for循环关联的else代码块的用处。然后我们将介绍迭代对象、迭代器和迭代器协议,还会学习如何创建自己的迭代对象和迭代器。之后,我们将讨论如何使用迭代对象和迭代器实现for循环,以及利用while循环通过迭代器协议实现for循环逻辑。最后,我们将反编译一…

  • stm32f4库函数开发指南 pdf_c语言常用的库函数表

    stm32f4库函数开发指南 pdf_c语言常用的库函数表资料介绍STM32F103库函数用户手册(中文)UM0427用户手册32位基于ARM微控制器STM32F101xx与STM32F103xx固件函数库介绍本手册介绍了32位基于ARM微控制器STM32F101x…

    2022年10月15日
  • Linux服务.NO6——http协议

    Linux服务.NO6——http协议9.http9.1.http概念http协议即超文本传输协议,用于从万维网服务器传输超文本到本地浏览器的传送协议。http是基于TCP/IP通信协议来传递数据的一个属于应用层的面向对象的协议。http协议工作于c/s架构,浏览器作为客户端通过url向http服务端(即web服务器)发送所有请求,web服务器根据受到的请求后,向客户端发送响应。9.2.http特点1.简单快速:客户向服务…

    2022年10月26日
  • 集锦——浏览器每次访问自动更新网页,不用手工设置,附Google/firefox/Ie

    在做开发web开发的时候,经常要使用到浏览器来着进行调试,那么有时候自己修改了内容,可是在浏览器上还是没有显示出来,费了好久才发现是浏览器缓存的问题。还要强制刷新缓存 就是 Ctrl + F5。所以在开发时候,最好将自己的调试浏览器设置为访问自动刷新网页,不要使用页面的缓存。下面就是常用开发浏览器的设置:1. Chrome 浏览器打开到开发者模式:将Disable cache

  • 物联网架构及五大通信协议是什么_物联网不能实现哪种通信方式

    物联网架构及五大通信协议是什么_物联网不能实现哪种通信方式消息触达能力是物联网(internetofthings,IOT)的重要支撑,而物联网很多技术都源于移动互联网。柳猫将阐述移动互联网消息推送技术在物联网中的应用和演进。一、物联网架构和关键技术从开发的角度,无线接入是物联网设备端的核心技术,身份设备管理和消息推送技术是物联网云端的核心技术。而从场景体验的角度,除了前者,还要包括手机的前端开发技术。IP互联架构已是物联网的事实标准(有关物联网TCP/IP层关键技术将另文阐述,敬请关注)。本文所讲的消息推送技术是基于TCP/I…

  • python的命名规则_python命名规则[通俗易懂]

    python的命名规则_python命名规则[通俗易懂]广告关闭腾讯云11.11云上盛惠,精选热门产品助力上云,云服务器首年88元起,买的越多返的越多,最高返5000元!1、模块模块尽量使用小写命名,首字母保持小写,尽量不要用下划线(除非多个单词,且数量不多的情况)#正确的模块名importdecoderimporthtml_parser#不推荐的模块名importdecoder-特殊的如init模块,如果模块是包的私有模块会使用前缀加一个…

发表回复

您的电子邮箱地址不会被公开。

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