springboot + jediscluster怎么集成多个集群

Posted 2023-05-16

参考技术A 也就是有main函数的那个。这个说明是写在文件：manifest.mf 里，你可以先创建一个空白的文本文件，命名为manifest.mf，指定里面加入：Main-Class:yourpackagename.classname 用 jar cvfm [jar-文件] [manifest-文件] class目录及文件名 命令生成...

????????? ??????jedisCluster

?????????

??????????????????redis2.x???????????????????????????????????????Shard????????????????????????????????????????????? ??????????????????--???????????????Redis(1)  ????????? ??????????????????--???????????????Redis(2)???

??????????????????redis3.x?????????????????????????????????jedisCluster???

1???????????????

 

2???pom.xml

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 3     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
 4 
 5     <modelVersion>4.0.0</modelVersion>
 6 
 7     <groupId>com.xxx</groupId>
 8     <artifactId>myboot</artifactId>
 9     <version>1.0-SNAPSHOT</version>
10 
11     <properties>
12         <java.version>1.8</java.version><!-- ???????????? -->
13     </properties>
14     <!-- ??????spring-boot-starter-parent???parent????????????????????? 
15          ????????????????????????????????????????????????parent????????????????????????????????? 
16          1??????????????????parent???pom.xml???parent??????spring-boot-starter-parent????????????????????????????????????????????? 
17          2?????????springboot??????????????????:???spring-boot-1.2.5-reference.pdf??????13??? 
18     -->
19     <parent> 
20         <groupId>org.springframework.boot</groupId> 
21         <artifactId>spring-boot-starter-parent</artifactId> 
22         <version>1.2.5.RELEASE</version> 
23     </parent>
24 
25     <!-- <dependencyManagement>
26         <dependencies>
27             <dependency>
28                 Import dependency management from Spring Boot
29                 <groupId>org.springframework.boot</groupId>
30                 <artifactId>spring-boot-dependencies</artifactId>
31                 <version>1.2.5.RELEASE</version>
32                 <type>pom</type>
33                 <scope>import</scope>
34             </dependency>
35         </dependencies>
36     </dependencyManagement> -->
37 
38     <!-- ?????????????????? -->
39     <dependencies>
40         <dependency>
41             <groupId>org.springframework.boot</groupId>
42             <artifactId>spring-boot-starter-web</artifactId>
43         </dependency>
44         <dependency>
45             <groupId>redis.clients</groupId>
46             <artifactId>jedis</artifactId>
47         </dependency>
48         <dependency>
49             <groupId>com.alibaba</groupId>
50             <artifactId>fastjson</artifactId>
51             <version>1.1.15</version>
52         </dependency>
53         <dependency>
54             <groupId>org.apache.commons</groupId>
55             <artifactId>commons-lang3</artifactId>
56             <version>3.3.2</version>
57         </dependency>
58     </dependencies>
59 
60     <build>
61         <plugins>
62             <!-- ???????????????????????????????????????jar??????jar??????????????????????????????jar??? ???????????????????????????????????????spring-boot-starter-parent???parent??? 
63                 ???????????????????????????????????????????????????????????????????????? -->
64             <plugin>
65                 <groupId>org.springframework.boot</groupId>
66                 <artifactId>spring-boot-maven-plugin</artifactId>
67             </plugin>
68         </plugins>
69     </build>
70 </project>

View Code

???????????????????????????????????????????????????jedis?????????jar???

 

3???application.properties

 1 #user info
 2 user.id=1
 3 user.username=zhaojigang
 4 user.password=123
 5 
 6 #redis cluster
 7 redis.cache.clusterNodes=localhost:8080
 8 redis.cache.commandTimeout=5
 9 #unit:second
10 redis.cache.expireSeconds=120

View Code

???????????????????????????????????????????????????redis cluster???????????????

 

4???Application.java???springboot?????????????????????????????????

5???RedisProperties.java???Redis???????????????

 1 package com.xxx.firstboot.redis;
 2 
 3 import org.springframework.boot.context.properties.ConfigurationProperties;
 4 import org.springframework.stereotype.Component;
 5 
 6 @Component
 7 @ConfigurationProperties(prefix = "redis.cache")
 8 public class RedisProperties {
 9 
10     private int    expireSeconds;
11     private String clusterNodes;
12     private int    commandTimeout;
13 
14     public int getExpireSeconds() {
15         return expireSeconds;
16     }
17 
18     public void setExpireSeconds(int expireSeconds) {
19         this.expireSeconds = expireSeconds;
20     }
21 
22     public String getClusterNodes() {
23         return clusterNodes;
24     }
25 
26     public void setClusterNodes(String clusterNodes) {
27         this.clusterNodes = clusterNodes;
28     }
29 
30     public int getCommandTimeout() {
31         return commandTimeout;
32     }
33 
34     public void setCommandTimeout(int commandTimeout) {
35         this.commandTimeout = commandTimeout;
36     }
37 
38 }

View Code

????????????????????????User???????????????@ConfigurationProperties??????????????????application.properties???????????????????????????RedisProperties???????????????????????????

 

6???JedisClusterConfig.java?????????JedisCluster?????????

 1 package com.xxx.firstboot.redis;
 2 
 3 import java.util.HashSet;
 4 import java.util.Set;
 5 
 6 import org.springframework.beans.factory.annotation.Autowired;
 7 import org.springframework.context.annotation.Bean;
 8 import org.springframework.context.annotation.Configuration;
 9 
10 import redis.clients.jedis.HostAndPort;
11 import redis.clients.jedis.JedisCluster;
12 
13 @Configuration
14 public class JedisClusterConfig {
15 
16     @Autowired
17     private RedisProperties redisProperties;
18 
19     /**
20      * ?????????
21      * ???????????????JedisCluster???????????????????????????????????????????????????????????????
22      * @return
23      */
24     @Bean
25     public JedisCluster getJedisCluster() {
26         String[] serverArray = redisProperties.getClusterNodes().split(",");//?????????????????????(??????????????????????????????????????????????????????????????????)
27         Set<HostAndPort> nodes = new HashSet<>();
28 
29         for (String ipPort : serverArray) {
30             String[] ipPortPair = ipPort.split(":");
31             nodes.add(new HostAndPort(ipPortPair[0].trim(), Integer.valueOf(ipPortPair[1].trim())));
32         }
33 
34         return new JedisCluster(nodes, redisProperties.getCommandTimeout());
35     }
36 
37 }

View Code

?????????

• ???????????????RedisProperties?????????????????????????????????
• ???????????????jedis?????????????????????????????????????????????????????????????????????????????????????????????

?????????

• ???????????????Java?????????@Configuration???@Bean???
  • ??????????????????@Bean?????????????????????????????????????????????
  • ???????????????????????????????????????????????????????????????
  • @Bean????????????????????????
• ???????????????????????????spring??????@Component???
  • ???????????????????????????????????????????????????????????????????????????
  • ???????????????????????????????????????????????????????????????
  • ?????????????????????????????????

 

7???MyRedisTemplate.java?????????redis?????????

 1 package com.xxx.firstboot.redis;
 2 
 3 import org.slf4j.Logger;
 4 import org.slf4j.LoggerFactory;
 5 import org.springframework.beans.factory.annotation.Autowired;
 6 import org.springframework.stereotype.Component;
 7 
 8 import redis.clients.jedis.JedisCluster;
 9 
10 @Component
11 public class MyRedisTemplate {
12     private static final Logger LOGGER    = LoggerFactory.getLogger(MyRedisTemplate.class);
13 
14     @Autowired
15     private JedisCluster        jedisCluster;
16 
17     @Autowired
18     private RedisProperties     redisProperties;
19 
20     private static final String KEY_SPLIT = ":"; //??????????????????????????????????????? 
21 
22     /**
23      * ???????????? 
24      * @param prefix ???????????????????????????????????????????????????????????????
25      * @param key    ??????key
26      * @param value  ??????value
27      */
28     public void set(String prefix, String key, String value) {
29         jedisCluster.set(prefix + KEY_SPLIT + key, value);
30         LOGGER.debug("RedisUtil:set cache key={},value={}", prefix + KEY_SPLIT + key, value);
31     }
32 
33     /**
34      * ?????????????????????????????????????????????
35      * @param prefix
36      * @param key
37      * @param value
38      * @param expireTime ????????????
39      */
40     public void setWithExpireTime(String prefix, String key, String value, int expireTime) {
41         jedisCluster.setex(prefix + KEY_SPLIT + key, expireTime, value);
42         LOGGER.debug("RedisUtil:setWithExpireTime cache key={},value={},expireTime={}", prefix + KEY_SPLIT + key, value,
43             expireTime);
44     }
45 
46     /**
47      * ??????????????????????????????????????????????????????
48      * @param prefix
49      * @param key
50      * @param value
51      */
52     public void setWithExpireTime(String prefix, String key, String value) {
53         int EXPIRE_SECONDS = redisProperties.getExpireSeconds();
54         jedisCluster.setex(prefix + KEY_SPLIT + key, EXPIRE_SECONDS, value);
55         LOGGER.debug("RedisUtil:setWithExpireTime cache key={},value={},expireTime={}", prefix + KEY_SPLIT + key, value,
56             EXPIRE_SECONDS);
57     }
58 
59     /**
60      * ????????????key?????????
61      * @param prefix
62      * @param key
63      */
64     public String get(String prefix, String key) {
65         String value = jedisCluster.get(prefix + KEY_SPLIT + key);
66         LOGGER.debug("RedisUtil:get cache key={},value={}", prefix + KEY_SPLIT + key, value);
67         return value;
68     }
69 
70     /**
71      * ????????????key?????????
72      * @param prefix
73      * @param key
74      */
75     public void deleteWithPrefix(String prefix, String key) {
76         jedisCluster.del(prefix + KEY_SPLIT + key);
77         LOGGER.debug("RedisUtil:delete cache key={}", prefix + KEY_SPLIT + key);
78     }
79     
80     public void delete(String key) {
81         jedisCluster.del(key);
82         LOGGER.debug("RedisUtil:delete cache key={}", key);
83     }
84 
85 }

View Code

?????????

?????????????????????jedisCluster???????????????????????????????????????list/set/sorted set/hash????????????????????????????????????????????????

 

8???MyConstants.java?????????????????????????????????

1 package com.xxx.firstboot.common;
2 
3 /**
4  * ??????????????????
5  */
6 public class MyConstants {
7     public static final String USER_FORWARD_CACHE_PREFIX = "myboot:user";// user????????????
8 }

View Code

?????????

• ????????????????????????redis????????????????????????????????????????????????????????????????????????
• ??????????????????":"???????????????????????????????????????????????????????????????redis-desktop-manager?????????????????????

 

9???UserController.java????????????

 

 1 package com.xxx.firstboot.web;
 2 
 3 import org.apache.commons.lang3.StringUtils;
 4 import org.springframework.beans.factory.annotation.Autowired;
 5 import org.springframework.web.bind.annotation.RequestMapping;
 6 import org.springframework.web.bind.annotation.RequestParam;
 7 import org.springframework.web.bind.annotation.RestController;
 8 
 9 import com.alibaba.fastjson.JSON;
10 import com.xxx.firstboot.common.MyConstants;
11 import com.xxx.firstboot.domain.User;
12 import com.xxx.firstboot.redis.MyRedisTemplate;
13 import com.xxx.firstboot.service.UserService;
14 
15 /**
16  * @RestController:spring mvc????????????
17  * ?????????@Controller???@ResponseBody??????????????????????????????json
18  */
19 @RestController
20 @RequestMapping("/user")
21 public class UserController {
22 
23     @Autowired
24     private UserService userService;
25     
26     @Autowired
27     private MyRedisTemplate myRedisTemplate;
28 
29     @RequestMapping("/getUser")
30     public User getUser() {
31         return userService.getUser();
32     }
33     
34     @RequestMapping("/testJedisCluster")
35     public User testJedisCluster(@RequestParam("username") String username){
36         String value =  myRedisTemplate.get(MyConstants.USER_FORWARD_CACHE_PREFIX, username);
37         if(StringUtils.isBlank(value)){
38             myRedisTemplate.set(MyConstants.USER_FORWARD_CACHE_PREFIX, username, JSON.toJSONString(getUser()));
39             return null;
40         }
41         return JSON.parseObject(value, User.class);
42     }
43 
44 }

View Code

 

??????????????????????????????????????????????????????????????????testJedisCluster???

 

?????????

???Application.properties??????-->run as-->java application?????????????????????"localhost:8080/user/testJedisCluster?username=xxx"?????????

 

????????????redis??????????????????????????????????????????set????????????????????????redis???db????????????????????????

• ??????set??????get?????????????????????????????????get?????????????????????get???????????????????????????
• ???????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????redis-desktop-manager???????????????????????????????????????redis???????????????????????????????????????????????????