1. 首页
  2. 分类
  3. 所有
一文详解SpringBoot 定时任务(cron表达式)
System
2024-09-04
所有,java

在Spring Boot中，我们可以使用@Scheduled注解和cron表达式来创建定时任务。

Cron表达式是一个字符串，包含6个或7个字段，用空格分隔，表示特定的时间计划。字段必须满足特定的条件，如下所示：




Seconds (0~59)
Minutes (0~59)
Hours (0~23)
Day of month (1~31)
Month (1~12 or JAN~DEC)
Day of week (1~7 or SUN~SAT)
Year (1970~2099)

这里是一个使用@Scheduled注解和cron表达式的例子：

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.format.DateTimeFormatter;
import java.time.LocalDateTime;

@Component
public class ScheduledTasks {

    private static final DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("HH:mm:ss");

    // 每5秒执行一次
    @Scheduled(fixedRate = 5000)
    public void reportCurrentTime() {
        System.out.println("现在时间是：" + dateTimeFormatter.format(LocalDateTime.now()));
    }

    // 在每天的下午10:15执行
    @Scheduled(cron = "0 15 10 * * ?")
    public void performTaskUsingCron() {
        System.out.println("使用Cron表达式执行定时任务：" + dateTimeFormatter.format(LocalDateTime.now()));
    }
}
Java

在这个例子中，我们定义了两个方法，reportCurrentTime使用fixedRate属性，每5秒执行一次。另一个方法performTaskUsingCron使用cron表达式，在每天下午10:15执行。

要启用定时任务，你需要在Spring Boot应用的主类或配置类上添加@EnableScheduling注解：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
public class ScheduledTasksApplication {

    public static void main(String[] args) {
        SpringApplication.run(ScheduledTasksApplication.class);
    }
}
Java

@EnableScheduling注解会启用Spring的调度器，发现注解了@Scheduled的方法，并按照指定的计划执行它们。

- 阅读更多 -
使用dg将单实例oracle12c迁移升级到oracle19.22 RAC
System
2024-09-04
所有,数据库

Oracle 12c到19.2 RAC的迁移和升级通常涉及以下步骤：

  1. 检查兼容性：确保你的12c数据库和19.2 RAC版本兼容。
  2. 备份数据库：使用RMAN或expdp/expdp进行全备份。
  3. 创建19.2 RAC数据库软件：在所有节点上安装Oracle 19.2 RAC数据库软件。
  4. 配置网络和共享存储：确保所有节点可以通过网络访问共享存储。
  5. 创建新的Oracle实例：在RAC配置中创建新的实例。
  6. 恢复数据库：使用RMAN进行数据库恢复或impdp/impdp进行数据导入。
  7. 验证数据完整性：确保数据一致，可以运行一些验证脚本或查询。
  8. 测试和优化：进行性能测试和优化工作。

以下是一个简化的示例迁移脚本流程：

# 1. 检查兼容性

# 2. 备份数据库
rman target /
RMAN> BACKUP DATABASE;

# 3. 安装Oracle 19.2 RAC数据库软件
# 在所有节点上安装Oracle软件

# 4. 配置网络和存储
# 配置网络和确保存储可用

# 5. 创建新的Oracle实例
srvctl stop database -d orcl

# 使用dbca创建实例
dbca -silent -createDatabase \
-templateName General_Purpose.dbc \
-gdbName orcl \
-sid orcl \
-createAsContainerDatabase false \
-numberOfPDBs 1 \
-pdbName pdb01 \
-pdbAdminPassword pdbadmin \
-sysPassword syspassword \
-systemPassword systempassword \
-characterset AL32UTF8 \
-nationalCharacterSet AL16UTF16 \
-sampleSchema true \
-automaticMemoryManagement true \
-totalMemory 2048 \
-databaseType MULTIPURPOSE \
-storageType FS \
-recoveryAreaDestination /u01/app/oracle/oradata/orcl/recovery_area \
-redoLogFileSize 50 \
-enableArchive true \
-archiveLogDestinations /u01/app/oracle/oradata/orcl/archivelogs \
-nodeinfo IPIPNODE1,IPIPNODE2 \
-clusterName RACCluster \
-cluster_database true \
-responseFile /u01/app/oracle/product/19.2/dbhome_1/assistants/dbca/templates/General_Purpose.dbc

# 6. 恢复数据库
# 使用RMAN恢复数据库

# 7. 验证数据完整性
# 运行一些验证查询

# 8. 测试和优化
# 进行性能测试和调优
Bash

注意：以上流程是一个高层次的概要，实际的迁移可能需要根据你的环境和特定需求进行详细的计划和执行。在执行任何操作之前，请确保你有完整的备份、恢复测试和支持团队的指导。

- 阅读更多 -
构建基于Spring Cloud的微服务监控系统
System
2024-09-04
所有,java

为了构建一个基于Spring Cloud的微服务监控系统，我们可以使用Spring Boot Actuator来收集应用程序的运行信息，并使用Spring Cloud Stream来发送数据到消息中间件（如RabbitMQ或Kafka），然后通过Spring Boot Admin来展示这些信息。以下是一个简化的示例：

  1. 在微服务中添加Spring Boot Actuator依赖：
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
XML
  1. 配置application.properties或application.yml以开启所需的端点和指标。
management:
  endpoints:
    web:
      exposure:
        include: health,info,metrics
  metrics:
    tags:
      application: ${spring.application.name}
YAML
  1. 在微服务中集成Spring Cloud Stream，发送监控信息到消息中间件。
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
</dependency>
XML
  1. 在微服务中配置消息发送。
@Autowired
private StreamBridge streamBridge;

@Scheduled(fixedRate = 1000)
public void sendMetrics() {
    Map<String, Object> metrics = MetricsFetcher.fetchMetrics();
    streamBridge.send("output-metrics-stream", metrics);
}
Java
  1. 创建接收端接收监控信息，并将其展示。
@Autowired
private MessageReceiver receiver;

@StreamListener("input-metrics-stream")
public void handle(MetricData metricData) {
    metricRepository.save(metricData);
}
Java
  1. 使用Spring Boot Admin来展示监控信息。
<dependency>
    <groupId>de.codecentric</groupId>
    <artifactId>spring-boot-admin-starter-server</artifactId>
</dependency>
<dependency>
    <groupId>de.codecentric</groupId>
    <artifactId>spring-boot-admin-starter-client</artifactId>
</dependency>
XML

以上代码仅为示例，实际应用时需要根据具体的微服务架构和需求进行调整。

- 阅读更多 -
Oracle字符串聚合函数LISTAGG
System
2024-09-04
所有,数据库

Oracle的LISTAGG函数用于将多个行的字符串值聚集到一个单独的行中，并可以在聚集的字符串之间插入一个指定的分隔符。

以下是一个简单的示例，假设我们有一个名为employees的表，它有两列：department\_id和employee\_name。

SELECT department_id, LISTAGG(employee_name, ', ') WITHIN GROUP (ORDER BY employee_name) AS employees
FROM employees
GROUP BY department_id;
SQL

在这个例子中，我们按部门对员工名字进行分组，并使用LISTAGG函数将同一部门的所有员工名字聚合成一个由逗号和空格分隔的单一字符串。

如果你需要处理更复杂的字符串聚合，例如在LISTAGG的结果中包含动态内容或者控制输出格式，你可能需要使用更复杂的SQL语句或者PL/SQL函数来实现。

- 阅读更多 -
Oracle创建表空间并捆绑新建的用户
System
2024-09-04
所有,数据库
-- 创建一个新的表空间
CREATE TABLESPACE my_tablespace
DATAFILE 'path_to_datafile/my_tablespace.dbf' SIZE 100M
AUTOEXTEND ON NEXT 10M MAXSIZE 500M
LOGGING
ONLINE
PERMANENT
EXTENT MANAGEMENT LOCAL;

-- 创建一个新用户并将其表空间设置为刚创建的my_tablespace
CREATE USER my_user IDENTIFIED BY my_password
DEFAULT TABLESPACE my_tablespace
TEMPORARY TABLESPACE temp
QUOTA UNLIMITED ON my_tablespace;

-- 给新用户授权
GRANT CONNECT, RESOURCE TO my_user;
SQL

在这个例子中，我们首先创建了一个名为my_tablespace的新表空间，并指定了数据文件的路径和大小，以及自动扩展的规则。接着，我们创建了一个新用户my_user，并设置了其默认表空间为my_tablespace，临时表空间为temp，并为新用户在my_tablespace设置了无限额的配额。最后，我们给新用户授予了连接（CONNECT）和资源（RESOURCE）角色。

- 阅读更多 -
SpringCloud 接入 Skywalking 9.4.0（开发环境）
System
2024-09-04
所有,java

要在Spring Cloud接入SkyWalking 9.4.0进行追踪，你需要做以下几步：

  1. 确保SkyWalking OAP服务正在运行。
  2. 在Spring Cloud应用中添加SkyWalking客户端依赖。
  3. 配置应用以连接到SkyWalking OAP服务。

以下是一个简化的Maven依赖示例和配置步骤：

Maven依赖 (pom.xml):

<dependencies>
    <!-- SkyWalking客户端 -->
    <dependency>
        <groupId>org.apache.skywalking</groupId>
        <artifactId>apm-toolkit-trace</artifactId>
        <version>9.4.0</version>
    </dependency>
</dependencies>
XML

配置文件 (application.yml):

spring:
  application:
    name: my-spring-cloud-service

# SkyWalking配置
skywalking:
  agent:
    service-name: ${spring.application.name}
    namespace: ${SW_NAMESPACE:my-namespace}
    agent-g-u-i-d: ${SW_AGENT_G_U_I_D:my-agent-uid}
    application-instance: ${SW_AGENT_APPLICATION_INSTANCE:my-application-instance}
    server-span-limit: ${SW_SERVER_SPAN_LIMIT:1000}
    sample-n-per-3-secs: ${SW_SAMPLE_N_PER_3_SECS:-1}
    ignore-suffix: ${SW_IGNORE_SUFFIX:.jpg,.jpeg,.js,.css,.png,.bmp,.gif,.ico,.mp3,.mp4,.html,.svg}

    # OAP服务地址
    oap:
      address: ${SW_OAP_ADDRESS:http://localhost:12800}
YAML

确保替换skywalking.agent.namespace、skywalking.agent.application_instance和skywalking.agent.oap.address为你的SkyWalking环境的实际值。

注意: 在生产环境中，你可能需要配置更多的SkyWalking参数，比如采样策略和持久化策略。

以上步骤和配置足以让你的Spring Cloud应用与SkyWalking 9.4.0进行接入和追踪。记得在启动应用之前，确保SkyWalking OAP服务正在运行，并且检查SkyWalking的日志以确保没有错误。

- 阅读更多 -
oracle 表分区设置
System
2024-09-04
所有,数据库

在Oracle中，表分区是一种将大型数据库表划分为更小、更易管理的部分的技术。以下是创建分区表的基本SQL语法和示例：

-- 创建范围分区表
CREATE TABLE sales (
    sales_id NUMBER,
    product_id NUMBER,
    sale_date DATE,
    amount NUMBER
)
PARTITION BY RANGE (sale_date) (
    PARTITION sales_q1 VALUES LESS THAN (TO_DATE('01-APR-2023', 'DD-MON-YYYY')),
    PARTITION sales_q2 VALUES LESS THAN (TO_DATE('01-JUL-2023', 'DD-MON-YYYY')),
    PARTITION sales_q3 VALUES LESS THAN (TO_DATE('01-OCT-2023', 'DD-MON-YYYY')),
    PARTITION sales_q4 VALUES LESS THAN (TO_DATE('01-JAN-2024', 'DD-MON-YYYY'))
);

-- 创建列表分区表
CREATE TABLE employees (
    employee_id NUMBER,
    department_id NUMBER,
    first_name VARCHAR2(50),
    last_name VARCHAR2(50)
)
PARTITION BY LIST (department_id) (
    PARTITION dep_sales VALUES (10),
    PARTITION dep_hr VALUES (20),
    PARTITION dep_other VALUES (DEFAULT)
);

-- 创建哈希分区表
CREATE TABLE customers (
    customer_id NUMBER,
    first_name VARCHAR2(50),
    last_name VARCHAR2(50)
)
PARTITION BY HASH (customer_id)
PARTITIONS 4;
SQL

在这些示例中，我们创建了按日期范围划分的sales表，按部门划分的employees表，以及按customer_id哈希的customers表。分区可以提高查询性能，简化数据管理，并支持特定类型的维护操作，如重组分区或迁移数据。

- 阅读更多 -
Can‘t connect to X11 window server using ‘localhost:10.0‘ as the value of th
System
2024-09-04
所有,java

报错信息 "Can't connect to X11 window server using 'localhost:10.0'" 表示无法连接到X11窗口服务器。X11是一种用于Unix和Unix-like操作系统的图形用户界面通信协议。

可能的原因和解决方法：

  1. X服务器未运行：确保X服务器正在运行。可以使用xdpyinfo命令检查X服务器是否运行。
  2. 显示变量设置不正确：检查环境变量DISPLAY是否设置正确。通常，它应该被设置为:0或localhost:0，如果X服务器运行在本地机器上。可以通过echo $DISPLAY来查看当前设置，使用export DISPLAY=:0来设置。
  3. 权限问题：确保当前用户有权限连接到X服务器。如果是通过ssh连接，需要使用-X或-Y选项来启动X11转发（ssh -X user@host）。
  4. 防火墙或网络问题：如果X服务器和客户端之间有防火墙或网络配置问题，可能会阻止连接。检查防火墙设置，确保X服务器端口（通常是6000号端口）对于需要连接的客户端开放。
  5. X服务器配置问题：检查X服务器的配置文件（例如/etc/X11/xinit/xserverrc或~/.Xserverrc），确保没有设置错误的访问控制。
  6. X11 forwarding问题：如果你是通过SSH连接并尝试启用X11转发，检查SSH服务器配置文件（通常是/etc/ssh/sshd_config）以确保X11转发被允许，并且客户端正确地使用了-X或-Y选项。

根据具体情况，可能需要结合多种方法来解决问题。

- 阅读更多 -
【Spring AOP + 自定义注解 + 动态数据源 实现主从库切换&读写分离】—— 案例实战
System
2024-09-04
所有,java

以下是一个简化的示例，展示如何使用Spring AOP、自定义注解和动态数据源实现数据库的主从库切换和读写分离。

// 自定义注解
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface DataSource {
    String value();
}

// 数据源路由
public class DataSourceRouter {
    private final Map<Object, Object> dataSourceMap = new HashMap<>();

    public void addDataSource(Object key, Object value) {
        dataSourceMap.put(key, value);
    }

    public Object getDataSource(Object key) {
        return dataSourceMap.get(key);
    }
}

// AOP切面实现
@Aspect
@Component
public class DataSourceAspect {
    @Autowired
    private DataSourceRouter dataSourceRouter;

    @Before("@annotation(dataSource)")
    public void switchDataSource(JoinPoint point, DataSource dataSource) {
        // 动态设置数据源
        String dataSourceName = dataSource.value();
        DataSourceType dataSourceType = DataSourceType.valueOf(dataSourceName);
        dataSourceRouter.addDataSource("dataSource", dataSourceType.getDataSource());
    }
}

// 使用示例
@Service
public class SomeService {
    @DataSource("MASTER")
    public void insertRecord() {
        // 写入操作
    }

    @DataSource("SLAVE")
    public void selectRecord() {
        // 读取操作
    }
}
Java

在这个示例中，我们定义了一个DataSource注解来标注方法使用的数据源类型，并创建了一个简单的DataSourceRouter类来管理数据源的路由。DataSourceAspect是一个Spring AOP切面，它会在方法执行前根据注解的值切换数据源。SomeService中的方法通过@DataSource注解指定了操作的数据源类型。

注意：这只是一个概念性的示例，实际应用中需要根据实际情况进行数据源的初始化和管理。

- 阅读更多 -
postgresql之inet类型IP地址范围查询
System
2024-09-04
所有,数据库
-- 假设我们有一个名为iplist的表，它有一个名为ip_range的inet类型列
-- 我们想要查询包含特定IP地址的所有IP范围

-- 创建临时表来存储IP地址
CREATE TEMP TABLE ips_to_lookup (ip inet);

-- 插入我们想要查询的IP地址
INSERT INTO ips_to_lookup VALUES ('192.168.1.100');

-- 查询包含这些IP地址的行
SELECT * FROM iplist
WHERE ips_to_lookup.ip <<= ip_range  -- 检查ips_to_lookup中的IP是否在ip_range范围内
  OR ips_to_lookup.ip >>= ip_range; -- 检查ips_to_lookup中的IP是否为ip_range范围的起始地址

-- 清理，删除临时表
DROP TABLE ips_to_lookup;
SQL

这个例子展示了如何在PostgreSQL中使用inet类型进行IP范围查询。它首先创建了一个临时表来存储要查询的IP地址，然后执行了一个查询来找出包含这些IP地址的行。最后，它清理了创建的临时表。这个例子是一个实际的查询，可以在具有相应表和列的数据库上运行。

- 阅读更多 -
Copyright © 2025 Tech Blog
All Right Reserved | 京ICP备19053165号