From adcfe77861db5a8791331a7727670d812a0988a6 Mon Sep 17 00:00:00 2001
From: 赵文轩 <1652863494@qq.com>
Date: 星期四, 31 十月 2024 10:07:10 +0800
Subject: [PATCH] 增加Redission配置
---
ltkj-framework/src/main/java/com/ltkj/framework/config/RedissionConfig.java | 75 +++++++++++++++++++++++++++++++++++++
ltkj-common/pom.xml | 6 +++
2 files changed, 81 insertions(+), 0 deletions(-)
diff --git a/ltkj-common/pom.xml b/ltkj-common/pom.xml
index 0f64d5f..7c58bd2 100644
--- a/ltkj-common/pom.xml
+++ b/ltkj-common/pom.xml
@@ -292,6 +292,12 @@
<version>4.0.0</version>
</dependency>
<!-- WxJava寰俊寮�鍙戝伐鍏� end-->
+
+ <dependency>
+ <groupId>org.redisson</groupId>
+ <artifactId>redisson-spring-boot-starter</artifactId>
+ <version>3.23.5</version>
+ </dependency>
</dependencies>
</project>
diff --git a/ltkj-framework/src/main/java/com/ltkj/framework/config/RedissionConfig.java b/ltkj-framework/src/main/java/com/ltkj/framework/config/RedissionConfig.java
new file mode 100644
index 0000000..741aa0a
--- /dev/null
+++ b/ltkj-framework/src/main/java/com/ltkj/framework/config/RedissionConfig.java
@@ -0,0 +1,75 @@
+package com.ltkj.framework.config;
+
+import lombok.extern.slf4j.Slf4j;
+import org.redisson.Redisson;
+import org.redisson.api.RedissonClient;
+import org.redisson.config.Config;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.io.*;
+import java.util.Properties;
+
+@Slf4j
+@Configuration
+public class RedissionConfig {
+
+ @Value("${config.properties}")
+ private String url;
+
+ @Value ("${config.path}")
+ private String path;
+
+ @Bean
+ public RedissonClient redissonClient(){
+ Config config = new Config();
+ try {
+ FileInputStream fis = null;
+ Properties props = new Properties();
+ try {
+ fis = new FileInputStream(url);
+ } catch (FileNotFoundException e) {
+ log.info("閰嶇疆鏂囦欢鎵句笉鍒� 绯荤粺姝ｅ湪鍒涘缓锛�");
+ File f = new File(path);
+ if(!f.exists()){
+ f.mkdirs();
+ }
+ File file = new File(url);
+ try {
+ FileWriter fileWriter = new FileWriter(file);
+ fileWriter.write("ip = 浣犵殑涓绘暟鎹簱杩炴帴ip鍦板潃\n");
+ fileWriter.write("prot = 浣犵殑涓绘暟鎹簱杩炴帴绔彛\n");
+ fileWriter.write("name = 浣犵殑涓绘暟鎹簱杩炴帴鍚嶇О\n");
+ fileWriter.write("username = 浣犵殑涓绘暟鎹簱杩炴帴鐢ㄦ埛鍚峔n");
+ fileWriter.write("password = 浣犵殑涓绘暟鎹簱杩炴帴瀵嗙爜\n");
+ fileWriter.write("redisIp = 浣犵殑redisIp鍦板潃");
+ fileWriter.write("redisProt = 浣犵殑redis绔彛");
+ fileWriter.write("redisIpDatabase = 浣犵殑redis閾炬帴搴�");
+ fileWriter.write("redisPassword = 浣犵殑redis瀵嗙爜");
+ fileWriter.write("");
+ fileWriter.close();
+ log.info("閰嶇疆鏂囦欢鍒涘缓鎴愬姛锛�");
+ } catch (IOException ioException) {
+ log.info("閰嶇疆鏂囦欢鍒涘缓澶辫触 璇疯仈绯荤鐞嗗憳鎵嬪姩鍒涘缓锛�");
+ ioException.printStackTrace();
+ }
+ e.printStackTrace();
+ }
+ props.load(fis);
+ fis.close();
+ String redisPassword = props.getProperty("redisPassword");
+ int database = Integer.parseInt(props.getProperty("redisIpDatabase"));
+ String address = "redis://"+props.getProperty("redisIp")+":"+props.getProperty("redisProt");
+ config.useSingleServer()
+ .setAddress(address)
+ .setPassword(redisPassword)
+ .setDatabase(database);
+ log.info("redisson杩炴帴鎴愬姛!!!");
+ } catch (IOException e) {
+ log.info("redisson杩炴帴澶辫触 璇疯仈绯荤鐞嗗憳锛�");
+ e.printStackTrace();
+ }
+ return Redisson.create(config);
+ }
+}
--
Gitblit v1.8.0