课后作业
1 Redis常用的数据类型有什么？
2 如何配置启动持久化AOF？
3 查看以test开头的所有的key
4 Redis如何将key为a的hash中key为b对应的值加1
5 Redis有几种订阅方法？
6 简述Redis建立连接池的代码
7 使用jedis向队列b发布值a
8 使用代码简述通过通道执行添加数据操作
9 thrift生成java接口的命令
### Java大数据作业知识点详解
#### 1. Redis常用的数据类型有什么？
Redis 提供了多种数据类型，主要包括五种基本类型：String（字符串）、Hash（哈希）、List（列表）、Set（集合）以及Sorted Set（有序集合）。
- **String（字符串）**：最简单的一种数据类型，可以存储二进制数据或者文本数据。
- **Hash（哈希）**：用于存储字段和值的映射关系，类似于Java中的Map。
- **List（列表）**：链表结构，适合做消息队列等场景，两端都可以进行插入和删除操作。
- **Set（集合）**：存储无序的不重复的元素集合。
- **Sorted Set（有序集合）**：与Set类似，但是每个成员都会关联一个分数，以此来排序集合中的成员。
这些数据类型在处理各种复杂的数据结构时非常有用，比如缓存、计数器、排行榜等场景。
#### 2. 如何配置启动持久化AOF？
AOF（Append Only File）是Redis提供的一种持久化机制，通过记录每一条写入操作的命令来实现数据恢复。
配置步骤如下：
1. 打开Redis配置文件`redis.conf`。
2. 设置`appendonly yes`开启AOF持久化。
3. 配置`appendfilename`设置AOF文件的名字，默认为`appendonly.aof`。
4. 可以通过`appendfsync`设置同步频率：
- `always`：每次执行写操作时都同步到磁盘，最安全但性能较差。
- `everysec`：每秒同步一次，默认选项，平衡了性能和安全性。
- `no`：由操作系统决定何时同步，性能最好但安全性最低。
重启Redis服务使配置生效。
#### 3. 查看以test开头的所有的key
可以通过命令`KEYS test*`来查询所有以`test`开头的key。需要注意的是，在生产环境中大量使用`KEYS`命令可能会导致Redis阻塞，建议在测试环境中使用或者采用其他方式如扫描命令`SCAN`来替代。
#### 4. Redis如何将key为a的hash中key为b对应的值加1
使用`HINCRBY`命令可以轻松地实现这个功能：
```
HINCRBY a b 1
```
这里`a`是hash的主键，`b`是要修改的字段名，`1`是增加的数值。
#### 5. Redis有几种订阅方法？
Redis提供了两种订阅模式：
1. **订阅频道**：客户端可以通过`SUBSCRIBE channel1 [channel2]`命令订阅一个或多个频道，然后通过`PUBLISH channel message`命令发送消息到指定的频道上，所有订阅该频道的客户端都会收到消息。
2. **模式订阅**：使用`PSUBSCRIBE pattern [pattern ...]`命令订阅模式，例如`PSUBSCRIBE __keyevent@0__:expired`可以订阅所有过期的key事件。
#### 6. 简述Redis建立连接池的代码
在Java中使用Jedis作为Redis客户端库，可以通过以下方式建立连接池：
```java
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
public class JedisConnectionPool {
private static final String REDIS_HOST = "localhost";
private static final int REDIS_PORT = 6379;
private static JedisPool jedisPool;
public static void main(String[] args) {
// 创建连接池配置对象
JedisPoolConfig poolConfig = new JedisPoolConfig();
poolConfig.setMaxTotal(100); // 最大连接数
poolConfig.setMaxIdle(50); // 最大空闲连接数
poolConfig.setMinIdle(20); // 最小空闲连接数
poolConfig.setMaxWaitMillis(1000 * 10); // 最大等待时间
// 初始化连接池
jedisPool = new JedisPool(poolConfig, REDIS_HOST, REDIS_PORT);
// 使用示例
Jedis jedis = null;
try {
jedis = jedisPool.getResource(); // 从连接池获取连接
jedis.set("key", "value"); // 写入数据
String value = jedis.get("key"); // 读取数据
System.out.println(value);
} finally {
if (jedis != null) {
jedis.close(); // 归还连接
}
}
}
}
```
这段代码创建了一个最大连接数为100的连接池，并且设置了最大空闲连接数和最小空闲连接数。
#### 7. 使用jedis向队列b发布值a
使用Jedis发布消息到Redis的队列中可以通过以下方式实现：
```java
import redis.clients.jedis.Jedis;
public class JedisPubSubExample {
public static void main(String[] args) {
Jedis jedis = new Jedis("localhost", 6379);
String channel = "b"; // 指定频道
String message = "a"; // 消息内容
// 发布消息
long result = jedis.publish(channel, message);
System.out.println("Published to " + channel + ": " + message + " (" + result + " subscribers)");
jedis.close();
}
}
```
这里我们向名为`b`的频道发布了内容为`a`的消息。
#### 8. 使用代码简述通过通道执行添加数据操作
使用Jedis通过管道(Pipeline)批量执行Redis命令可以有效提高性能：
```java
import redis.clients.jedis.Jedis;
public class JedisPipelineExample {
public static void main(String[] args) {
Jedis jedis = new Jedis("localhost", 6379);
// 开始管道
jedis.pipelined(new Jedis.Pipeline() {
@Override
public void execute() {
jedis.set("key1", "value1");
jedis.set("key2", "value2");
}
});
// 获取结果
String key1Value = jedis.get("key1");
String key2Value = jedis.get("key2");
System.out.println("Key1 value: " + key1Value);
System.out.println("Key2 value: " + key2Value);
jedis.close();
}
}
```
这段代码使用了管道`pipelined`方法来批量执行两个`set`命令。
#### 9. thrift生成java接口的命令
Thrift是一种跨语言的服务开发框架，它支持多种语言。要生成Java接口，可以通过以下命令：
```bash
thrift --gen java <your_thrift_file>.thrift
```
这里`<your_thrift_file>.thrift`是你的Thrift定义文件。该命令会生成相应的Java接口文件和实现类，方便你在Java程序中调用Thrift服务。
以上就是本次Java大数据作业中涉及的主要知识点，包括Redis的各种数据类型、配置、命令使用，以及Thrift的Java接口生成命令。希望这些内容能够帮助你更好地理解和掌握这些技术。
