分类后端技术下的文章

2024-09-05

MongoDB 是一个基于分布式文件存储的开源数据库系统，旨在为 WEB 应用提供可扩展的高性能数据存储解决方案。MongoDB 支持的数据结构非常灵活，是类似 JSON 的 BSON 格式，可以是嵌套的文档。其主要特性包括：高性能、易部署、易使用，存储数据的格式是 BSON（一种类 JSON 的二进制存储格式）。

以下是 MongoDB 增、删、改的基本操作：

增加数据

在 MongoDB 中，我们可以使用 insertOne() 或 insertMany() 方法来添加单个或多个文档到集合中。




// 添加单个文档
db.collection.insertOne({
  name: "John",
  age: 30,
  address: "New York"
});
 
// 添加多个文档
db.collection.insertMany([
  { name: "Jane", age: 25, address: "Chicago" },
  { name: "Mike", age: 20, address: "Los Angeles" }
]);

删除数据

在 MongoDB 中，我们可以使用 deleteOne() 或 deleteMany() 方法来删除单个或多个文档。




// 删除单个文档
db.collection.deleteOne({
  name: "John"
});
 
// 删除多个文档
db.collection.deleteMany({
  age: { $gt: 20 }
});

修改数据

在 MongoDB 中，我们可以使用 updateOne() 或 updateMany() 方法来修改单个或多个文档。




// 修改单个文档
db.collection.updateOne(
  { name: "Jane" },
  { $set: { address: "San Francisco" } }
);
 
// 修改多个文档
db.collection.updateMany(
  { age: { $gt: 22 } },
  { $set: { address: "Detroit" } }
);

以上就是 MongoDB 增、删、改的基本操作，在实际开发中，我们还可以根据需要进行更复杂的查询和修改操作。

- 阅读更多 -

PostgreSQL Linux安装

System

2024-09-05

所有,数据库

在Linux上安装PostgreSQL，可以使用以下步骤：

更新包管理器索引：




sudo apt update

安装PostgreSQL：




sudo apt install postgresql postgresql-contrib

启动PostgreSQL服务：




sudo systemctl start postgresql

确保PostgreSQL随系统启动：




sudo systemctl enable postgresql

切换到PostgreSQL用户（默认为postgres）：




sudo -i -u postgres

创建一个新的角色（可选）：




createuser --interactive

创建一个新的数据库（可选）：




createdb <your_database_name>

登录到PostgreSQL命令行界面：




psql

以上步骤适用于基于Debian的系统，如Ubuntu。对于基于RPM的系统，如CentOS，你可能需要使用yum或dnf作为包管理器，并可能需要修改一些命令来启动和管理PostgreSQL服务。

- 阅读更多 -

Spring Boot实现接口签名验证

System

2024-09-05

所有,java




import org.springframework.stereotype.Service;
import org.springframework.util.DigestUtils;
import java.nio.charset.StandardCharsets;
import java.util.Map;
import java.util.TreeMap;
 
@Service
public class SignatureService {
 
    // 根据请求参数生成签名
    public String generateSignature(Map<String, String> params, String secretKey) {
        // 按参数名称升序排序
        Map<String, String> sortedParams = new TreeMap<>(params);
        StringBuilder toSign = new StringBuilder();
        for (Map.Entry<String, String> entry : sortedParams.entrySet()) {
            // 忽略空值
            if (entry.getValue() != null && !entry.getValue().isEmpty()) {
                toSign.append(entry.getKey()).append(entry.getValue());
            }
        }
        toSign.append(secretKey); // 添加密钥作为签名的一部分
        String signature = DigestUtils.md5DigestAsHex(toSign.toString().getBytes(StandardCharsets.UTF_8));
        return signature;
    }
 
    // 验证签名是否正确
    public boolean validateSignature(Map<String, String> params, String signature, String secretKey) {
        String actualSignature = generateSignature(params, secretKey);
        return actualSignature.equals(signature);
    }
}

这段代码提供了一个SignatureService服务类，其中包含了生成签名和验证签名的方法。generateSignature方法接收参数映射和密钥，并返回生成的MD5签名。validateSignature方法接收参数映射、签名和密钥，并返回验证结果。这个服务类可以被Spring Boot应用的其他组件注入和使用。

- 阅读更多 -

SpringBoot整合JavaFX进行桌面应用开发

System

2024-09-05

所有,java




import javafx.application.Application;
import javafx.fxml.FXMLLoader;
import javafx.scene.Scene;
import javafx.scene.layout.AnchorPane;
import javafx.stage.Stage;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
 
@SpringBootApplication
public class MainApp extends Application {
 
    private static ConfigurableApplicationContext springContext;
 
    @Override
    public void init() throws Exception {
        springContext = SpringApplication.run(MainApp.class);
    }
 
    @Override
    public void start(Stage primaryStage) throws Exception {
        FXMLLoader loader = new FXMLLoader(getClass().getResource("/main.fxml"));
        AnchorPane root = loader.load();
        Scene scene = new Scene(root, 800, 600);
        primaryStage.setTitle("Hello World");
        primaryStage.setScene(scene);
        primaryStage.show();
    }
 
    @Override
    public void stop() throws Exception {
        springContext.close();
    }
 
    public static void main(String[] args) {
        launch(args);
    }
}

这段代码展示了如何在SpringBoot应用中整合JavaFX来进行桌面应用开发。在MainApp类中，我们继承了Application类并重写了init、start和stop方法。init方法中启动了Spring应用上下文，start方法中使用JavaFX加载并显示了一个FXML文件，stop方法中关闭了Spring应用上下文。最后，通过main方法启动了JavaFX应用。

- 阅读更多 -

Redis 哨兵机制

System

2024-09-05

所有,redis

Redis哨兵（Sentinel）机制是用来实现Redis高可用性的解决方案。它由一个或多个哨兵实例组成，这些实例会监控主Redis服务器和其从服务器，并在主服务器宕机时自动进行故障转移，选举新的主服务器，并将其他的从服务器指向新的主服务器。

以下是一个基本的哨兵配置文件示例：




# sentinel.conf
sentinel monitor mymaster 127.0.0.1 6379 2
sentinel down-after-milliseconds mymaster 30000
sentinel parallel-syncs mymaster 1
sentinel failover-timeout mymaster 180000

解释：

sentinel monitor mymaster: 这行指定了哨兵监控的主服务器名称和地址，以及最少需要多少个哨兵同意主服务器已经失效才会进行故障转移。
sentinel down-after-milliseconds: 如果一个服务器在指定的毫秒数内没有响应，则认为它是主观下线。
sentinel parallel-syncs: 在故障转移期间，可以有几个从服务器同时进行同步。
sentinel failover-timeout: 故障转移超时时间，即主服务器未能在指定时间内完成故障转移的处理。

启动哨兵的命令：




redis-sentinel /path/to/sentinel.conf

在实际应用中，哨兵通常与Redis主从架构搭配使用，以保障数据存储的高可用性。当哨兵检测到主服务器不可达时，它会开始故障转移过程，选举新的主服务器，并将其他的从服务器重新指向新的主服务器。

- 阅读更多 -

Rust 语言使用 SQLite 数据库

System

2024-09-05

所有,数据库




// 引入SQLite库
extern crate sqlite;
 
use sqlite::{Connection, State};
 
fn main() {
    // 打开或创建数据库
    let db = Connection::open("test.db");
    if let Ok(conn) = db {
        // 创建一个表
        conn.execute(
            "CREATE TABLE IF NOT EXISTS users (
                id INTEGER PRIMARY KEY,
                name TEXT NOT NULL
            )"
        );
 
        // 插入数据
        conn.execute("INSERT INTO users (name) VALUES (?)", &["Alice"]);
 
        // 查询数据
        let mut stmt = conn.prepare("SELECT id, name FROM users WHERE name = ?")
            .expect("Failed to prepare select statement");
 
        let user_name = "Alice";
        let user_iter = stmt.query_map([user_name], |row| {
            row.get(0) // 获取第一列的值
        })
        .expect("Failed to query user");
 
        // 遍历查询结果
        for user_id in user_iter {
            println!("User ID: {}", user_id.expect("Failed to get user ID"));
        }
    } else {
        println!("Failed to open database");
    }
}

这段代码展示了如何在Rust中使用sqlite库来打开或创建一个SQLite数据库，创建一个表，插入数据，以及查询数据。代码简洁，注重于展示核心功能，并使用了错误处理来确保代码的健壮性。

- 阅读更多 -

Redis篇一：初识Redis

System

2024-09-05

所有,redis

Redis是一个开源的使用C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库，并提供多种语言的API。

Redis不仅仅支持简单的key-value类型的数据，同时还提供list，set，zset，hash等数据结构的存储。

Redis的数据都是缓存在内存中，同时可以配置数据持久化到硬盘，但是Redis的性能非常高，每秒可以处理数十万的读写操作。

Redis的所有操作都是原子性的，意思就是要么成功执行要么失败完全不执行，一般用于处理如：计数器、排行榜、消息队列系统等。

以下是一些基本的Redis命令：

设置键值对：




set key value

获取键值对：




get key

删除键值对：




del key

设置键的过期时间：




expire key seconds

检查键是否存在：




exists key

列出所有键：




keys *

获取键的数据结构类型：




type key

将值追加到已存在的列表尾部：




rpush list value

移除并返回列表中的最后一个元素：




rpop list

将一个或多个成员元素加入到集合中：




sadd set member

移除集合中的一个或多个成员：




srem set member

返回集合中的所有成员：




smembers set

添加一个或多个成员到zset：




zadd zset score member

返回有序集合中成员的排名：




zrank zset member

移除有序集合中的一个或多个成员：




zrem zset member

计算集合的交集：




sinter set1 set2

计算集合的并集：




sunion set1 set2

计算集合的差集：




sdiff set1 set2

将一个值插入到已存在的sorted set中：




zincrby zset increment member

将值插入到列表头部：




lpush list value

返回列表中指定区间内的元素：




lrange list start stop

设置哈希表字段的值：




hset hash field value

获取哈希表中字段的值：




hget hash field

获取所有给定字段的值：




hgetall hash

删除字段：




hdel hash field

获取字段的数量：




hlen hash

获取所有字段名或值：




hkeys hash
hvals hash

用于设置键的过期时间：




expire key seconds

查看键的剩余生存时间：




ttl key

- 阅读更多 -

spring cloud activiti 审批流的用法

System

2024-09-05

所有,java

Spring Cloud Activiti 是一个用于集成Activiti工作流引擎和Spring Cloud配置管理的项目。使用Spring Cloud Activiti，你可以很容易地在Spring Cloud应用中集成Activiti进行审批流的处理。

以下是一个简单的例子，展示如何使用Spring Cloud Activiti启动一个简单的审批流程定义：

首先，在pom.xml中添加Spring Cloud Activiti的依赖：




<dependency>
    <groupId>org.activiti</groupId>
    <artifactId>activiti-spring-boot-starter-basic</artifactId>
    <version>6.0.0</version>
</dependency>

定义BPMN流程文件（例如my-process.bpmn20.xml），描述了审批流程：




<process id="MyApprovalProcess" name="My Approval Process" isExecutable="true">
  <startEvent id="start" />
  <userTask id="approveTask" name="Approve" activiti:assignee="admin" />
  <endEvent id="end" />
  <sequenceFlow id="flow1" sourceRef="start" targetRef="approveTask" />
  <sequenceFlow id="flow2" sourceRef="approveTask" targetRef="end" />
</process>

在Spring Boot应用中启动流程实例：




@Autowired
private RuntimeService runtimeService;
 
public void startProcessInstance() {
    runtimeService.startProcessInstanceByKey("MyApprovalProcess");
}

创建一个任务监听器来处理任务：




@Component
public class ApprovalTaskListener implements TaskListener {
    @Autowired
    private TaskService taskService;
 
    public void notify(DelegateTask delegateTask) {
        // 处理任务逻辑
        taskService.complete(delegateTask.getId());
    }
}

确保你的Spring Boot应用已经配置了Activiti，并且有一个ProcessEngine Bean。这样，你就可以通过RuntimeService启动流程，通过TaskService完成任务，从而实现一个简单的基于Activiti的审批流程。

- 阅读更多 -

Springboot 开发之 RestTemplate 简介

System

2024-09-05

所有,java

Spring Boot 提供了一个名为 RestTemplate 的类，它是一个用于发送 REST 请求的简单实用工具。RestTemplate 提供了多种方法来发送不同类型的 HTTP 请求。

RestTemplate 是由 Spring Framework 提供的一个 REST 客户端，用于在 Java 应用程序中发送 HTTP 请求。它提供了一些方法，如 getForObject(), postForObject(), getForEntity(), postForEntity() 等，这些方法使用请求的 URI 和一个返回值类型来发送请求并接收结果。

以下是一些使用 RestTemplate 的示例：

使用 getForObject() 方法发送 GET 请求：




RestTemplate restTemplate = new RestTemplate();
String result = restTemplate.getForObject("http://example.com/users/{id}", String.class, 1);
System.out.println(result);

使用 postForObject() 方法发送 POST 请求：




RestTemplate restTemplate = new RestTemplate();
String result = restTemplate.postForObject("http://example.com/users", HttpEntity<?>, String.class);
System.out.println(result);

使用 exchange() 方法发送请求并获取响应对象：




RestTemplate restTemplate = new RestTemplate();
ResponseEntity<String> response = restTemplate.exchange("http://example.com/users/{id}", 
                                                       HttpMethod.GET, 
                                                       null, 
                                                       String.class, 1);
System.out.println(response.getBody());

注意：RestTemplate 在 Spring Framework 5.0 后被标记为过时，建议使用更现代的 WebClient。然而，如果你正在使用的是旧版本的 Spring Boot，或者不打算迁移到 WebClient，那么 RestTemplate 仍然是一个可行的选择。

System

2024-09-05

所有,java

在Spring Boot中，可以通过配置来实现不同服务实例间的session共享。以下是一个使用Redis作为session存储的配置示例：

添加依赖到pom.xml：




<dependency>
    <groupId>org.springframework.session</groupId>
    <artifactId>spring-session-data-redis</artifactId>
</dependency>
<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
</dependency>

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




# application.properties
spring.redis.host=localhost
spring.redis.port=6379
spring.session.store-type=redis

或者使用YAML格式：




# application.yml
spring:
  redis:
    host: localhost
    port: 6379
  session:
    store-type: redis

确保你的Spring Boot应用配置了一个@EnableRedisHttpSession注解：




import org.springframework.session.data.redis.config.annotation.web.http.EnableRedisHttpSession;
import org.springframework.context.annotation.Configuration;
 
@Configuration
@EnableRedisHttpSession
public class SessionConfig {
}

以上配置将启用Redis作为session存储，所有服务实例都将从Redis中读取和写入session数据。这样就实现了session的共享。

- 阅读更多 -