IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> redis和java -> 正文阅读

[大数据]redis和java

# 1、linux 安装redis

首先打开redis.io找到下载页面

a、拉取安装包\或者下载好用ssh工具进行上传文件

```bash
wget https://download.redis.io/releases/redis-6.2.6.tar.gz
```

b、解压安装包

```bash
tar zxvf redis-6.2.6.tar.gz
```

c、进入解压出的文件夹并make

```bash
cd redis-6.2.6
make
```

??? ?c1、如果发生报错如:

?

是因为没有安装c语言的编译工具

因为redis是c开发的

```bash
#安装一下
yum -y install gcc
```

再执行make

d、之后我们再继续执行make install

如果有换文件夹的需求,就加一个PREFIX=你要的文件夹

```bash
#直接安装
make install #默认地址是/usr/local/bin
#按目录安装
make install PREFIX=/usr/local/redis #这样就是安装到了/usr/local/redis/bin目录
```

e、这样之后将一开始解压出来的文件夹中的redis.conf

复制一份到新的安装目录中,可以建个文件夹放一下

```bash
cp /root/redis-6.2.6/redis.conf /usr/local/redis/bin
```

f、修改配置文件

因为是java连接所以一步到位

以下展示改好的样子

- 更改连接地址改成这样或者你需要连接的地址

?

- 保护模式改成no

?

- 端口 大家随意

?

- 允许后台运行 --启动后不跳出来那个启动页面

f、以上修改结束后 安装正式结束

启动redis

```bash
#使用redis-server redis.conf启动
/usr/local/redis/bin/redis-server /usr/local/redis/bin/myconf/redis.conf
```

启动完用ps检查

~~~bash
ps aux |grep redis
~~~

看到redis-server 就是成功了

如此redis成功之后进行java连接

其实这样还有可能会失败

你需要检查你的端口是否开放

~~~bash
# 查看防火墙是否已开放6379端口
firewall-cmd --query-port=6379/tcp

# 设置3306端口为永久开放
firewall-cmd --add-port=6379/tcp --permanent

# 查看firewalld状态,发现当前是dead状态,即防火墙未开启
systemctl status firewalld

# 关闭防火墙
systemctl stop firewalld

# 重启防火墙(设置了新的端口记得先关闭,再重启)
systemctl start firewalld
~~~

## java连接

首先导入jar包

~~~xml
?<dependency>
? ? ? ? ? ? <groupId>redis.clients</groupId>
? ? ? ? ? ? <artifactId>jedis</artifactId>
? ? ? ? ? ? <version>3.2.0</version>
?</dependency>
~~~

使用的方法很简单

~~~java
Jedis jedis = new Jedis([(String)ip地址],[(int)端口号])
jedis.set("[(String)key]","[(其他的redis支持的类型)]");
jedis.get([(String)key])
~~~

## 然后整合springboot

导入jar包

```xml
# 用于springboot缓存
<dependency>
? ? <groupId>org.springframework.boot</groupId>
? ? <artifactId>spring-boot-starter-cache</artifactId>
</dependency>
# springboot整合redis
<dependency>
? ? <groupId>org.springframework.boot</groupId>
? ? <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
```

a、在启动项上添加注解

~~~java
@EnableCaching//开启缓存了
@SpringBootApplication
public class Application {
? ? public static void main(String[] args) {
? ? ? ? SpringApplication.run(Application.class,args);
? ? }
}
~~~

b、给需要缓存的类添加注解

```java
@CacheConfig(cacheNames = "user")//括号中为实体类的bean
@Service("userService")
public class UserServiceImpl implements UserService {
? ? @CachePut(value = "user", key = "#result.id")//此注解是一定会执行方法的,将更新后的返回的类进行了缓存
? ? @Override
? ? public User update(User user) {
? ? ? ? System.err.println("开始更新" + user.getId() + "号员工");
? ? ? ? userMapper.updateEmp(user);
? ? ? ? return user;
? ? }

? ? @CacheEvict(value = "user", beforeInvocation = true)//这个用于销毁缓存
? ? @Override
? ? public void delete(Integer id) {
? ? ? ? if (userMapper.delete(id) != 0) {
? ? ? ? ? ? System.out.println("删除成功");
? ? ? ? ? ? return;
? ? ? ? }
? ? ? ? System.out.println("删除失败");
? ? }

? ? @Cacheable(cacheNames = {"user"})//这个用于添加缓存
? ? @Override
? ? public User selectById(Integer id) {
? ? ? ? return userMapper.selectById(id);
? ? }
}
```

c、这样就已经可以使用开箱即用的redis缓存了

但是这样你会发现,你的redis中都是些乱码

### 我们要重写一下CacheManager

新建一个redisconfig

```java
@Configuration
public class Redisconfig{
? ? @Bean
? ? public CacheManager cacheManager(RedisConnectionFactory factory) {
? ? ? ? RedisSerializer<String> redisSerializer = new StringRedisSerializer();
? ? ? ? Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);

? ? ? ? //解决查询缓存转换异常的问题
? ? ? ? ObjectMapper om = new ObjectMapper();
? ? ? ? om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
? ? ? ? //om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);这个方法已经废弃了。使用下面的即可
? ? ? ? om.activateDefaultTyping(LaissezFaireSubTypeValidator.instance ,
? ? ? ? ? ? ? ? ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);
? ? ? ? jackson2JsonRedisSerializer.setObjectMapper(om);
? ? ? ? // 配置序列化(解决乱码的问题),过期时间30秒
? ? ? ? RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
? ? ? ? ? ? ? ? .entryTtl(Duration.ofSeconds(30000))
? ? ? ? ? ? ? ? .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
? ? ? ? ? ? ? ? .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))
? ? ? ? ? ? ? ? .disableCachingNullValues();

? ? ? ? return RedisCacheManager.builder(factory)
? ? ? ? ? ? ? ? .cacheDefaults(config)
? ? ? ? ? ? ? ? .build();
? ? }
}
```

这样咱们再看看redis就发现世界美好了

### 当然了。我们还可以通过重写RedisTemplate

然后使用redistemplate来创建redis工具类来实现redis的缓存

```java
@Configuration
public class Redisconfig{
? ? @Bean
? ? public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
? ? ? ? RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
? ? ? ? redisTemplate.setConnectionFactory(factory);

? ? ? ? // 使用Jackson2JsonRedisSerialize 替换默认序列化
? ? ? ? Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);

? ? ? ? ObjectMapper objectMapper = new ObjectMapper();
? ? ? ? objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
? ? ? ? objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL,JsonTypeInfo.As.PROPERTY);
? ? ? ? jackson2JsonRedisSerializer.setObjectMapper(objectMapper);

? ? ? ? // 设置value的序列化规则和 key的序列化规则
? ? ? ? redisTemplate.setKeySerializer(new StringRedisSerializer());
? ? ? ? redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
? ? ? ? redisTemplate.setHashKeySerializer(new StringRedisSerializer());
? ? ? ? redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
? ? ? ? redisTemplate.afterPropertiesSet();

? ? ? ? return redisTemplate;
? ? }
}
```

而redisTemplate使用起来也是很方便

比如

```java
ValueOperations<String, Object> stringObjectValueOperations = template.opsForValue();//代表拿到了操作了,还有其他的类型的自行探索吧
JSONObject jsonObject = new JSONObject();
jsonObject.put("name","1231231");
jsonObject.put("pwd","12323123");
? ? ? ? stringObjectValueOperations.set("user",jsonObject.toString());
```

以上就是java对redis操作的粗线理解了

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2021-11-23 12:26:02  更:2021-11-23 12:26:35 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/24 8:40:30-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码