Tech Blog

使用SpringBoot+Redis做一个排行榜【推荐】

2024-09-05

所有,redis

在Spring Boot中使用Redis做排行榜，你可以使用Spring Data Redis或Jedis。以下是一个简单的例子，使用Spring Data Redis操作ZSet（有序集合）。

添加依赖到你的pom.xml：




<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

配置Redis。在application.properties或application.yml中设置Redis连接信息：




spring.redis.host=localhost
spring.redis.port=6379

在你的服务中使用RedisTemplate操作ZSet：




import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ZSetOperations;
import org.springframework.stereotype.Service;
 
@Service
public class LeaderboardService {
 
    @Autowired
    private RedisTemplate<String, String> redisTemplate;
 
    private ZSetOperations<String, String> zSetOps;
 
    public LeaderboardService() {
        this.zSetOps = redisTemplate.opsForZSet();
    }
 
    public void addScoreToLeaderboard(String userId, double score) {
        zSetOps.add(getLeaderboardKey(), userId, score);
    }
 
    public List<String> fetchTopUsers(int limit) {
        Set<String> userIds = zSetOps.reverseRange(getLeaderboardKey(), 0, limit - 1);
        return new ArrayList<>(userIds);
    }
 
    private String getLeaderboardKey() {
        return "leaderboard";
    }
}

在这个例子中，addScoreToLeaderboard方法将用户的分数添加到排行榜中，而fetchTopUsers方法则用于获取前N名用户的列表。

确保你的应用程序配置了Redis，并且有一个定时任务或者某种触发机制来调用addScoreToLeaderboard方法，以更新用户的分数。

Spring Boot实战：无缝对接通义千问

2024-09-05

所有,java




import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.web.servlet.config.annotation.CorsRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
import com.tencent.tbss.app.api.AppApi;
import com.tencent.tbss.app.api.impl.AppApiImpl;
 
@SpringBootApplication
public class Application {
 
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
 
    @Bean
    public WebMvcConfigurer corsConfigurer() {
        return new WebMvcConfigurer() {
            @Override
            public void addCorsMappings(CorsRegistry registry) {
                registry.addMapping("/**").allowedOrigins("*");
            }
        };
    }
 
    @Bean
    public AppApi appApi() {
        return new AppApiImpl();
    }
}

这段代码定义了一个Spring Boot应用程序的入口点，并通过@Bean注解提供了跨源资源共享（CORS）的配置和AppApi的实现bean。在实际的业务场景中，你可以根据需要对AppApiImpl进行相应的调整和扩展。

2024-09-05

以下是一个简单的哈希表实现示例，使用了开放地址法中的线性探测再散列技术：




#include <stdlib.h>
#include <string.h>
 
#define HASH_TABLE_SIZE 256
 
typedef struct HashNode {
    char *key;
    char *value;
    struct HashNode *next;
} HashNode;
 
typedef struct HashTable {
    HashNode *nodes[HASH_TABLE_SIZE];
} HashTable;
 
unsigned int hash(const char *key) {
    unsigned int hash_value = 0;
    while (*key) {
        hash_value = (hash_value << 5) - hash_value + (unsigned char)(*key++);
    }
    return hash_value % HASH_TABLE_SIZE;
}
 
HashTable *create_hash_table() {
    HashTable *table = (HashTable *)malloc(sizeof(HashTable));
    if (table == NULL) {
        return NULL;
    }
    memset(table, 0, sizeof(HashTable));
    return table;
}
 
int hash_table_insert(HashTable *table, const char *key, const char *value) {
    if (table == NULL || key == NULL || value == NULL) {
        return -1;
    }
    unsigned int key_hash = hash(key);
    HashNode *node = table->nodes[key_hash];
 
    while (node != NULL && strcmp(node->key, key) != 0) {
        node = node->next;
    }
 
    if (node == NULL) {
        node = (HashNode *)malloc(sizeof(HashNode));
        if (node == NULL) {
            return -1;
        }
        node->key = strdup(key);
        node->value = strdup(value);
        node->next = table->nodes[key_hash];
        table->nodes[key_hash] = node;
    } else {
        free(node->value);
        node->value = strdup(value);
    }
 
    return 0;
}
 
char *hash_table_search(HashTable *table, const char *key) {
    if (table == NULL || key == NULL) {
        return NULL;
    }
    unsigned int key_hash = hash(key);
    HashNode *node = table->nodes[key_hash];
 
    while (node != NULL && strcmp(node->key, key) != 0) {
        node = node->next;
    }
 
    return node ? node->value : NULL;
}
 
// 示例用法
int main() {
    HashTable *table = create_hash_table();
    if (table == NULL) {
        return -1;
    }
 
    hash_table_insert(table, "name", "John");
    hash_table_insert(table, "age", "30");
    hash_table_insert(table, "city", "New York");
 
    char *value = hash_table_search(table, "name");
    if (value) {

Postgresql数据库密码忘记的解决方法

2024-09-05

如果您忘记了PostgreSQL数据库的密码，可以按照以下步骤来解决问题：

停止PostgreSQL服务。
- 在Linux系统中，可以使用sudo service postgresql stop或者sudo systemctl stop postgresql。
- 在Windows系统中，可以通过“服务”管理工具停止PostgreSQL服务。
以无密码模式启动PostgreSQL服务。编辑PostgreSQL的启动配置文件（通常是postgresql.conf），找到password_encryption设置项，并将其设置为md5或scram-sha-256（取决于你的版本和配置）。
重启PostgreSQL服务。
- 在Linux系统中，可以使用sudo service postgresql start或者sudo systemctl start postgresql。
- 在Windows系统中，重新启动PostgreSQL服务。
以无密码模式登录到PostgreSQL。
```
psql -U postgres
```
如果您是postgres用户，则可以不指定-U参数。
修改用户密码。
```
ALTER USER postgres WITH PASSWORD 'newpassword';
```
将newpassword替换为您想要设置的新密码。
重新编辑postgresql.conf文件，将password_encryption设置改回原来的值（如果之前更改过）。
再次停止并以正常模式重启PostgreSQL服务。

请注意，这些步骤可能会根据您的操作系统和PostgreSQL的版本略有不同。在执行这些操作时，请确保您有足够的权限，并在操作之前备份相关配置文件和数据。

Django执行查询-创建对象

2024-09-05




from django.shortcuts import render
from .models import Topic
 
# 创建新的Topic实例
def create_topic(request):
    topic = Topic.objects.create(text='新的主题', date='2021-06-20')
    return render(request, 'learning_logs/topic.html', {'topic': topic})

这段代码首先从learning_logs/models.py导入了Topic模型，然后定义了一个名为create_topic的视图函数，该函数使用Topic模型的objects.create方法来创建一个新的Topic实例，并将其渲染到页面上。这个例子展示了如何在Django中创建数据库记录，并且是学习如何使用Django框架进行数据库交互的一个很好的起点。

如何修改大模型的位置编码 --以LLama为例

2024-09-05

所有,AIGC

位置编码是自然语言处理中对输入序列中词的位置信息进行编码的一种方法。在LLaMA中，位置编码通常是在模型的自注意力（self-attention）层之前添加的。

如果你想要修改LLaMa的位置编码，你可以按照以下步骤进行：

确定LLaMA模型中位置编码的实现方式。
修改对应的代码，以生成新的位置编码。
重新训练模型。

由于LLaMA使用的是基于Transformer的架构，其位置编码通常遵循Transformer中的标准做法，即学习一个可训练的位置编码矩阵。

假设LLaMA的位置编码矩阵名为pos_encoding，你可以在模型初始化的代码中找到它，并按照你的需求进行修改。例如，你可以使用一个更复杂的函数来生成位置编码，或者直接替换整个pos_encoding矩阵。

以下是一个简单的Python示例，演示如何生成一个简单的正弦位置编码：




import math
import torch
 
def generate_position_encoding(seq_length, hidden_size, max_seq_length=1024):
    position_enc = torch.zeros(seq_length, hidden_size).float()
    for pos in range(seq_length):
        for i in range(hidden_size):
            position_enc[pos, i] = math.sin(pos / math.sqrt(i // 2 ** 0.5))
            if i % 2 == 0:
                position_enc[pos, i] *= math.cos(pos / math.sqrt(i // 2 ** 0.5))
    return position_enc
 
# 使用函数生成位置编码
seq_length = 10
hidden_size = 512
position_encoding = generate_position_encoding(seq_length, hidden_size)
print(position_encoding)

请注意，你需要根据LLaMA模型的具体实现来修改位置编码的生成方式。如果LLaMA使用的是预先计算好的位置编码，那么你可能需要替换预计算的位置编码矩阵。

在实际应用中，通常不建议直接修改预训练的模型参数，因为这可能会影响模型的表现。如果你只是想要调整位置编码的函数，可以考虑在模型中添加一个可训练的位置编码层，或者在自注意力层之前插入一个新的编码层。

重新训练模型时，确保你的数据预处理步骤包括生成新的位置编码，并在模型中相应地更新它们。如果你只是想调整位置编码的参数，而不是结构，那么你可以在模型的参数字典中找到对应的位置编码参数，并更新它们。

请记住，修改位置编码可能会影响模型的性能，因此在进行修改之前应该充分理解其影响，并进行充分的测试。

2024-09-05




# 导入 sqlite3 模块
import sqlite3
 
# 连接到数据库，如果数据库不存在，则会自动创建
conn = sqlite3.connect('example.db')
 
# 创建游标对象
cursor = conn.cursor()
 
# 执行 SQL 语句创建 users 表
cursor.execute('''
CREATE TABLE IF NOT EXISTS users (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    username TEXT NOT NULL,
    password TEXT NOT NULL
);
''')
 
# 关闭游标
cursor.close()
 
# 提交事务
conn.commit()
 
# 关闭连接
conn.close()

这段代码展示了如何使用 sqlite3 模块来连接到一个 SQLite 数据库，创建一个名为 users 的表（如果该表不存在的话），并且在操作完成后关闭游标和数据库连接。这是使用 Python 进行数据库操作的基本流程。

# Mybatis 高级用法和tk.mybatis使用

2024-09-05

所有,java




import tk.mybatis.mapper.entity.Example;
import tk.mybatis.mapper.entity.Condition;
 
// 假设有一个UserMapper继承自tk.mybatis.mapper.common.Mapper
UserMapper userMapper = ...; 
 
// 创建Example查询对象
Example example = new Example(User.class);
 
// 设置查询条件
example.createCriteria()
    .andEqualTo("username", "admin")  // 等价于where username = 'admin'
    .andGreaterThan("age", 18);       // 并且age > 18
 
// 使用Example查询
List<User> users = userMapper.selectByExample(example);
 
// 如果需要根据某个条件排序
example.orderBy("age").desc();  // 按年龄降序排序
 
// 如果需要分页
example.limit(PageHelper.getStart(pageInfo), pageInfo.getPageSize());
 
// 再次执行查询
users = userMapper.selectByExample(example);

在这个例子中，我们创建了一个Example查询对象，并通过andEqualTo和andGreaterThan方法添加了两个查询条件，最后通过selectByExample方法执行查询。同时，我们可以使用orderBy方法进行排序，以及使用limit方法进行分页。这些操作都是基于tk.mybatis提供的Mapper接口和Example类。

openGauss Cluster Manager RTO Test

2024-09-05

由于您提出的query是关于openGauss的RTO（Recovery Time Objective）测试，我们可以假设openGauss是一个数据库管理系统，并且它有一个集群管理器来管理多个数据库节点。RTO是指系统恢复正常操作的时间目标。

在实施RTO测试时，通常会考虑以下几个方面：

故障模拟：使用集群管理器模拟节点故障或服务中断。
快速检测：集群管理器应该能快速检测到故障并作出响应。
恢复服务：确保在恢复过程中，服务能够正常运行，不会对客户端造成影响。
数据一致性：确保恢复过程中不会引起数据不一致或丢失。
自动化测试：使用自动化工具来执行和验证测试场景。

下面是一个简化的伪代码示例，演示如何使用集群管理器进行RTO测试：




# 模拟故障函数
def simulate_node_failure(node):
    # 实现节点故障的逻辑
    pass
 
# 快速恢复服务函数
def recover_service(node):
    # 实现服务恢复的逻辑
    pass
 
# RTO测试函数
def test_rto():
    # 模拟节点故障
    failed_node = simulate_node_failure(node_id)
    
    # 检查服务是否立即停止
    if service_is_stopped():
        print("服务已立即停止")
    else:
        print("服务未能立即停止")
    
    # 尝试恢复服务
    recover_service(failed_node)
    
    # 检查服务是否正常运行
    if service_is_running():
        print("服务恢复正常")
    else:
        print("服务恢复失败")
 
# 执行RTO测试
test_rto()

在实际的RTO测试中，你需要替换模拟故障和恢复服务的逻辑以适应你的具体环境和集群管理器。同时，你还需要有一套监控系统来确保故障被准确快速地检测到，并且有一套日志系统来记录和分析故障和恢复过程中的数据。