相关依赖
<dependencies>
<dependency>
<!-- lettuce 依赖-->
<groupId>io.lettuce</groupId>
<artifactId>lettuce-core</artifactId>
<version>5.0.5.RELEASE</version>
</dependency>
<dependency>
<!-- 相关的依赖jedis-->
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.0.1</version>
</dependency>
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>3.12.5</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.1.13.Final</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.25</version>
</dependency>
<dependency>
<groupId>org.elasticsearch.plugin</groupId>
<artifactId>transport-netty4-client</artifactId>
<version>7.1.0</version>
</dependency>
</dependencies>
Java类库代码:
import io.lettuce.core.RedisClient;
import io.lettuce.core.ScriptOutputType;
import io.lettuce.core.api.StatefulRedisConnection;
import io.lettuce.core.api.sync.RedisCommands;
import org.redisson.Redisson;
import org.redisson.api.RBucket;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.config.SingleServerConfig;
import redis.clients.jedis.Jedis;
/**
* @author Modesty.P.Gao
* @version 1.0
* @description: TODO
* @date 2021/12/3 13:31
*/
public class Main {
public static void main(String[] args) {
RedissonData();
}
/**
* 使用Redisson来连接Redis
*/
private static void RedissonData() {
//创建配置
Config config = new Config();
//指定使用单节点部署方式
config.useSingleServer().setAddress("redis://10.16.78.134:9100");
config.useSingleServer().setPassword("bigdata");
//创建客户端(发现这一非常耗时,基本在2秒-4秒左右)
RedissonClient redisson = Redisson.create(config);
//首先获取redis中的key-value对象,key不存在没关系
RBucket<String> keyObject = redisson.getBucket("key");
//如果key存在,就设置key的值为新值value
//如果key不存在,就设置key的值为value
keyObject.set("value");
//最后关闭RedissonClient
redisson.shutdown();
}
/**
* 使用jedis来连接Redis
*/
private static void jedisData() {
//连接redis服务器
Jedis jedis = new Jedis("10.16.78.134", 9100);
//权限认证
jedis.auth("bigdata");
//添加数据
jedis.set("Modesty", "gps");
//取出数据
System.out.println("取出来的数据是:" + jedis.get("Modesty"));
}
/**
* 使用lettuce来连接Redis
*/
private static void lettuceData() {
//redis的连接地址
RedisClient redisClient = RedisClient.create("redis://[email protected]:9100");
StatefulRedisConnection<String, String> connect = redisClient.connect();
RedisCommands<String, String> sync = connect.sync();
//存储数据
sync.set("GPS1", "Hello Redis");
//取数据
String gps = sync.get("GPS1");
System.out.println("从redis取出来的数据是:" + gps);
connect.close();
redisClient.shutdown();
}
}