添加redis客户端-redisson相关操作

Author: sanshengshui

pom.xml

@@ -42,6 +42,7 @@
         <slf4j.version>1.7.32</slf4j.version>
         <logback.version>1.2.6</logback.version>
         <apache.commons-lang3.version>3.12.0</apache.commons-lang3.version>
+        <redisson.version>3.13.6</redisson.version>
     </properties>
 
     <dependencies>
@@ -53,6 +54,7 @@
 
     <dependencyManagement>
         <dependencies>
+            <!-- 内部module依赖 start-->
             <dependency>
                 <groupId>iot-technology</groupId>
                 <artifactId>server</artifactId>
@@ -63,16 +65,8 @@
                 <artifactId>storage</artifactId>
                 <version>${project.version}</version>
             </dependency>
-            <dependency>
-                <groupId>org.springframework.boot</groupId>
-                <artifactId>spring-boot-starter-web</artifactId>
-                <version>${spring-boot.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>io.netty</groupId>
-                <artifactId>netty-all</artifactId>
-                <version>${netty.version}</version>
-            </dependency>
+            <!-- 内部module依赖 end-->
+            <!-- 日志依赖 start-->
             <dependency>
                 <groupId>org.slf4j</groupId>
                 <artifactId>slf4j-api</artifactId>
@@ -93,6 +87,8 @@
                 <artifactId>logback-classic</artifactId>
                 <version>${logback.version}</version>
             </dependency>
+            <!-- 日志依赖 end-->
+            <!-- 工具类 start-->
             <dependency>
                 <groupId>org.projectlombok</groupId>
                 <artifactId>lombok</artifactId>
@@ -114,6 +110,30 @@
                 <artifactId>spring-context-support</artifactId>
                 <version>${spring.version}</version>
             </dependency>
+            <!-- web框架依赖 -->
+            <dependency>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-starter-web</artifactId>
+                <version>${spring-boot.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-starter-test</artifactId>
+                <version>${spring-boot.version}</version>
+                <scope>test</scope>
+            </dependency>
+            <!-- 底层通讯框架依赖 -->
+            <dependency>
+                <groupId>io.netty</groupId>
+                <artifactId>netty-all</artifactId>
+                <version>${netty.version}</version>
+            </dependency>
+            <!-- redisson -->
+            <dependency>
+                <groupId>org.redisson</groupId>
+                <artifactId>redisson-spring-boot-starter</artifactId>
+                <version>${redisson.version}</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>
 

server/pom.xml

@@ -18,10 +18,19 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>iot-technology</groupId>
+            <artifactId>storage</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>io.netty</groupId>
             <artifactId>netty-all</artifactId>
@@ -30,10 +39,6 @@
             <groupId>org.apache.commons</groupId>
             <artifactId>commons-lang3</artifactId>
         </dependency>
-        <dependency>
-            <groupId>iot-technology</groupId>
-            <artifactId>storage</artifactId>
-        </dependency>
     </dependencies>
 
     <build>

server/src/main/resources/application.yml

@@ -9,4 +9,12 @@ mqtt:
     leak_detector_level: DISABLED
     boss_group_thread_count: 1
     worker_group_thread_count: 8
-    max_payload_size: 65536
+    max_payload_size: 65536
+
+
+spring:
+  application:
+    name: IoT-Technology-MQTT-Broker
+  redis:
+    redisson:
+      file: classpath:redisson.yml

server/src/main/resources/redisson.yml

@@ -0,0 +1,41 @@
+# 单节点配置
+singleServerConfig:
+  # 连接空闲超时，单位：毫秒
+  idleConnectionTimeout: 10000
+  # 连接超时，单位：毫秒
+  connectTimeout: 10000
+  # 命令等待超时，单位：毫秒
+  timeout: 3000
+  # 命令失败重试次数,如果尝试达到 retryAttempts（命令失败重试次数） 仍然不能将命令发送至某个指定的节点时，将抛出错误。
+  # 如果尝试在此限制之内发送成功，则开始启用 timeout（命令等待超时） 计时。
+  retryAttempts: 3
+  # 命令重试发送时间间隔，单位：毫秒
+  retryInterval: 1500
+  # 密码
+  password:
+  # 单个连接最大订阅数量
+  subscriptionsPerConnection: 5
+  # 客户端名称
+  clientName: mqtt-redis
+  # 节点地址
+  address: redis://127.0.0.1:6379
+  # 发布和订阅连接的最小空闲连接数
+  subscriptionConnectionMinimumIdleSize: 1
+  # 发布和订阅连接池大小
+  subscriptionConnectionPoolSize: 50
+  # 最小空闲连接数
+  connectionMinimumIdleSize: 32
+  # 连接池大小
+  connectionPoolSize: 64
+  # 数据库编号
+  database: 0
+  # DNS监测时间间隔，单位：毫秒
+  dnsMonitoringInterval: 5000
+# 线程池数量,默认值: 当前处理核数量 * 2
+#threads: 0
+# Netty线程池数量,默认值: 当前处理核数量 * 2
+#nettyThreads: 0
+# 编码
+codec: !<org.redisson.codec.JsonJacksonCodec> {}
+# 传输模式
+transportMode : "NIO"

server/src/test/java/iot/technology/mqtt/server/MQTTRedissonApplicationTests.java

@@ -0,0 +1,33 @@
+package iot.technology.mqtt.server;
+
+import iot.technology.mqtt.server.domain.Book;
+import iot.technology.mqtt.storage.session.cache.RedissonClientService;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import javax.annotation.Resource;
+
+/**
+ * @author mushuwei
+ */
+@Slf4j
+@RunWith(SpringRunner.class)
+@SpringBootTest
+public class MQTTRedissonApplicationTests {
+
+	@Resource
+	private RedissonClientService clientService;
+
+	@Test
+	public void redisStringOperations() {
+		Book book = new Book().setName("Harry Potter").setAuthor("J.K.Rowling").setPrice(120.00);
+		clientService.put("harry-potter", book, null);
+		Book bookCache = (Book) clientService.get("harry-potter");
+		log.info("book:{}", bookCache);
+
+	}
+
+}

server/src/test/java/iot/technology/mqtt/server/domain/Book.java

@@ -0,0 +1,28 @@
+package iot.technology.mqtt.server.domain;
+
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.io.Serializable;
+
+/**
+ * @author mushuwei
+ */
+@Data
+@Accessors(chain = true)
+public class Book implements Serializable {
+	/**
+	 * 书名
+	 */
+	private String name;
+
+	/**
+	 * 作者
+	 */
+	private String author;
+
+	/**
+	 * 售价
+	 */
+	private Double price;
+}

server/target/classes/application.yml

@@ -9,4 +9,12 @@ mqtt:
     leak_detector_level: DISABLED
     boss_group_thread_count: 1
     worker_group_thread_count: 8
-    max_payload_size: 65536
+    max_payload_size: 65536
+
+
+spring:
+  application:
+    name: IoT-Technology-MQTT-Broker
+  redis:
+    redisson:
+      file: classpath:redisson.yml

storage/pom.xml

@@ -30,6 +30,10 @@
             <groupId>org.springframework</groupId>
             <artifactId>spring-context</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.redisson</groupId>
+            <artifactId>redisson-spring-boot-starter</artifactId>
+        </dependency>
     </dependencies>
 
 </project>

storage/src/main/java/iot/technology/mqtt/storage/session/cache/CacheManager.java

@@ -0,0 +1,23 @@
+package iot.technology.mqtt.storage.session.cache;
+
+/**
+ * @author mushuwei
+ */
+public interface CacheManager {
+
+	Boolean delete(String key);
+
+
+	Boolean put(String key, Object value, Integer expireTime);
+
+
+	Object get(String key);
+
+
+	Boolean existsKey(String key);
+
+
+	Object getMap(String key, String mapKey);
+
+	Boolean putMap(String key, String mapKey, Object mapValue);
+}

storage/src/main/java/iot/technology/mqtt/storage/session/cache/RedissonClientService.java

@@ -0,0 +1,64 @@
+package iot.technology.mqtt.storage.session.cache;
+
+import org.redisson.api.RBucket;
+import org.redisson.api.RKeys;
+import org.redisson.api.RMap;
+import org.redisson.api.RedissonClient;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.Objects;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author mushuwei
+ */
+@Service("redissonClientService")
+public class RedissonClientService implements CacheManager {
+
+	@Resource
+	private RedissonClient redissonClient;
+
+	@Override
+	public Boolean delete(String key) {
+		RKeys keys = redissonClient.getKeys();
+		keys.delete(key);
+		return Boolean.TRUE;
+	}
+
+
+	@Override
+	public Boolean put(String key, Object value, Integer expireTime) {
+		RBucket<Object> bucket = redissonClient.getBucket(key);
+		int cacheTime = (Objects.nonNull(expireTime) && expireTime > 0) ? expireTime : 300;
+		bucket.set(value, cacheTime, TimeUnit.SECONDS);
+		return Boolean.TRUE;
+	}
+
+	@Override
+	public Object get(String key) {
+		RBucket<Object> bucket = redissonClient.getBucket(key);
+		return bucket.get();
+	}
+
+	@Override
+	public Boolean existsKey(String key) {
+		RKeys keys = redissonClient.getKeys();
+		Boolean result = keys.countExists(key) > 0 ? Boolean.TRUE : Boolean.FALSE;
+		return result;
+	}
+
+
+	@Override
+	public Object getMap(String key, String mapKey) {
+		RMap<String, Object> map = redissonClient.getMap(key);
+		return map.get(mapKey);
+	}
+
+	@Override
+	public Boolean putMap(String key, String mapKey, Object mapValue) {
+		RMap<String, Object> map = redissonClient.getMap(key);
+		map.put(mapKey, mapValue);
+		return Boolean.TRUE;
+	}
+}