分类后端技术下的文章

2024-09-02

在Spring Boot中，你可以通过实现CommandLineRunner或ApplicationRunner接口来在应用启动后执行初始化任务。以下是两种方式的简单示例：

使用`CommandLineRunner`




import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
 
@SpringBootApplication
public class MyApplication {
 
    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }
 
    @Bean
    public CommandLineRunner run() {
        return args -> {
            // 在这里编写你的初始化逻辑
            System.out.println("Application started with arguments: " + args);
        };
    }
}

使用`ApplicationRunner`




import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
 
@SpringBootApplication
public class MyApplication {
 
    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }
 
    @Bean
    public ApplicationRunner appRunner() {
        return new ApplicationRunner() {
            @Override
            public void run(ApplicationArguments args) throws Exception {
                // 在这里编写你的初始化逻辑
                System.out.println("Application started with arguments: " + args);
            }
        };
    }
}

两种方式都可以在Spring Boot应用启动后执行一些初始化代码。CommandLineRunner通过run方法提供了命令行参数，而ApplicationRunner通过run方法提供了一个封装了命令行参数的ApplicationArguments对象。你可以根据需要选择其中一种实现。

- 阅读更多 -

Elasticsearch与MongoDB的整合与应用

System

2024-09-02

所有,数据库




from pymongo import MongoClient
from elasticsearch import Elasticsearch
 
# 连接MongoDB
mongo_client = MongoClient('mongodb://localhost:27017/')
db = mongo_client['mydatabase']
collection = db['mycollection']
 
# 连接Elasticsearch
es = Elasticsearch(['http://localhost:9200/'])
 
# 将MongoDB数据同步到Elasticsearch
def sync_to_es(collection, es, index):
    for doc in collection.find():
        # 将MongoDB文档转换为Elasticsearch格式
        doc_id = str(doc['_id'])
        doc_body = {
            '_id': doc_id,
            **doc
        }
        del doc_body['_id']  # 移除MongoDB的'_id'字段
        
        # 将文档索引到Elasticsearch
        es.index(index=index, id=doc_id, body=doc_body)
 
# 使用函数同步数据
sync_to_es(collection, es, 'myindex')

这段代码展示了如何使用pymongo库连接MongoDB，并使用elasticsearch库连接Elasticsearch。然后定义了一个函数sync_to_es，它遍历MongoDB中的文档，将它们转换为Elasticsearch可以理解的格式，并将它们索引到指定的Elasticsearch索引中。最后，使用这个函数将MongoDB中的数据同步到Elasticsearch。

- 阅读更多 -

springboot整合MyBatis-Plus和postgresql

System

2024-09-02

所有,数据库

要在Spring Boot项目中整合MyBatis-Plus和PostgreSQL，你需要按照以下步骤操作：

在pom.xml中添加依赖：




<!-- Spring Boot Starter -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
</dependency>
 
<!-- Spring Boot Starter for PostgreSQL -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jdbc</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
    <groupId>org.postgresql</groupId>
    <artifactId>postgresql</artifactId>
    <scope>runtime</scope>
</dependency>
 
<!-- MyBatis-Plus Starter -->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>3.x.x</version> <!-- 替换为实际的版本号 -->
</dependency>

配置application.properties或application.yml文件：




# PostgreSQL数据库连接配置
spring.datasource.url=jdbc:postgresql://localhost:5432/your_database
spring.datasource.username=your_username
spring.datasource.password=your_password
spring.datasource.driver-class-name=org.postgresql.Driver
 
# JPA配置
spring.jpa.hibernate.ddl-auto=update
spring.jpa.show-sql=true
 
# MyBatis-Plus配置
mybatis-plus.mapper-locations=classpath:/mappers/**/*.xml
mybatis-plus.type-aliases-package=com.yourpackage.model
mybatis-plus.global-config.db-config.id-type=auto
mybatis-plus.global-config.db-config.field-strategy=not_empty
mybatis-plus.global-config.db-config.table-prefix=tbl_

创建实体类和Mapper接口：




// 实体类
@Entity
@Table(name = "tbl_user")
public class User {
    @Id
    private Long id;
    private String name;
    // 省略getter和setter
}
 
// Mapper接口
@Mapper
public interface UserMapper extends BaseMapper<User> {
    // 这里可以添加自定义方法，但对于通用CRUD操作BaseMapper已经足够
}

在启动类上添加@MapperScan注解来扫描Mapper接口：




@SpringBootApplication
@MapperScan("com.yourpackage.mapper")
public class YourApplication {
    public static void main(String[] args) {
        SpringApplication.run(YourApplication.class, args);
    }
}

使用MyBatis-Plus提供的BaseMapper进行CRUD操作：




@Service
public class UserService {
 
    @Autowired

- 阅读更多 -

【Oracle数据库表空间查询设置】

System

2024-09-02

所有,数据库

在Oracle数据库中，您可以使用以下SQL查询来获取表空间的相关信息：




SELECT
    TABLESPACE_NAME,
    FILE_NAME,
    BYTES,
    AUTOEXTENSIBLE
FROM
    DBA_DATA_FILES;

这将列出数据库中所有表空间的名称、关联的文件名、文件大小以及是否自动扩展。

如果您想查看表空间的使用情况，可以使用以下查询：




SELECT
    TABLESPACE_NAME,
    ROUND(SUM(BYTES) / 1024 / 1024, 2) AS "Size (MB)",
    ROUND(SUM(MAXBYTES) / 1024 / 1024, 2) AS "Max Size (MB)"
FROM
    DBA_DATA_FILES
GROUP BY
    TABLESPACE_NAME;

这将显示每个表空间的当前大小（MB）和最大大小（如果已设置）。

如果您想设置或更改表空间的大小，您可以使用ALTER TABLESPACE语句添加数据文件或扩大现有数据文件的大小。例如：




ALTER TABLESPACE your_tablespace_name
  ADD DATAFILE '/path/to/new/datafile.dbf' SIZE 100M AUTOEXTEND ON NEXT 10M MAXSIZE UNLIMITED;

这将向指定的表空间添加一个新的数据文件，起始大小为100MB，并设置为自动扩展，每次增加10MB，没有最大大小限制。记得替换your_tablespace_name、/path/to/new/datafile.dbf、大小值和文件路径以适应您的具体情况。

- 阅读更多 -

查询Oracle数据库版本有几种方法

System

2024-09-02

所有,数据库

查询Oracle数据库版本的方法有几种，以下是几种常见的方法：

使用SQL*Plus工具：




SQL> SELECT * FROM v$version;

使用数据库的VERSION初始化参数：




SQL> SELECT * FROM global_name;

使用DBMS_UTILITY.DB_VERSION函数：




SQL> DECLARE
v_version VARCHAR2(100);
BEGIN
  v_version := DBMS_UTILITY.DB_VERSION;
  DBMS_OUTPUT.PUT_LINE('Database Version: ' || v_version);
END;
/

查看数据库的服务名称：




SQL> SELECT name FROM v$services;

查看数据库的参数文件：
在数据库的参数文件中，通常会有数据库的版本信息，可以直接查看该文件。
使用opatch工具检查补丁级别：




$ $ORACLE_HOME/OPatch/opatch lsinventory

这些方法可以帮助你获取Oracle数据库的版本信息。

- 阅读更多 -

【SpringCloud应用框架】Nacos安装和服务提供者注册

System

2024-09-02

所有,java

Nacos作为服务注册中心和配置中心，可以用来管理微服务的服务地址。以下是Nacos的安装和使用Spring Cloud进行服务提供者注册的简要步骤：

下载Nacos:




wget https://github.com/alibaba/nacos/releases/download/[版本号]/nacos-server-[版本号].tar.gz

解压Nacos:




tar -zxvf nacos-server-[版本号].tar.gz

运行Nacos:




cd nacos/bin
./startup.sh -m standalone

在Spring Cloud应用中添加依赖:




<dependencies>
    <dependency>
        <groupId>com.alibaba.cloud</groupId>
        <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    </dependency>
</dependencies>

配置application.properties或application.yml:




spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848

启动类添加@EnableDiscoveryClient注解:




@SpringBootApplication
@EnableDiscoveryClient
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

启动Spring Cloud应用后，它将自动注册到Nacos服务列表中。可以在Nacos的控制台（通常是 http://127.0.0.1:8848/nacos ）查看服务列表。

- 阅读更多 -

Spring Cloud Alibaba Nacos配置导入问题解决方案

System

2024-09-02

所有,java




import com.alibaba.cloud.nacos.NacosConfigProperties;
import com.alibaba.nacos.api.config.ConfigType;
import com.alibaba.nacos.api.config.ConfigUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.env.Environment;
import org.springframework.stereotype.Component;
 
import javax.annotation.PostConstruct;
import java.util.Properties;
 
@Component
public class NacosConfigService {
 
    @Autowired
    private NacosConfigProperties nacosConfigProperties;
 
    @Autowired
    private Environment environment;
 
    @PostConstruct
    public void loadNacosConfiguration() {
        Properties properties = new Properties();
        properties.putAll(nacosConfigProperties.getSharedConfigs());
        // 设置配置的类型，默认为PROPERTIES
        properties.put(ConfigUtils.CONFIG_TYPE, ConfigType.PROPERTIES.getType());
        // 设置配置的群组，默认为DEFAULT_GROUP
        properties.put(ConfigUtils.CONFIG_GROUP, nacosConfigProperties.getGroup());
        // 设置命名空间，如果在bootstrap.properties中配置了spring.cloud.nacos.config.namespace，则优先使用该配置
        String namespace = environment.getProperty("spring.cloud.nacos.config.namespace");
        if (namespace != null) {
            properties.put(ConfigUtils.NAMESPACE, namespace);
        }
        // 这里可以添加自定义的配置加载逻辑
        // ...
    }
}

这段代码示例展示了如何在Spring Cloud Alibaba项目中使用Nacos作为配置中心时，自定义加载配置的逻辑。它使用了@PostConstruct注解，在Bean初始化完成后自动执行加载Nacos配置的方法。同时，它展示了如何从Environment中获取配置，并根据需要设置配置的类型和群组。这个示例可以作为开发者在实际项目中自定义配置加载的参考。

- 阅读更多 -

PostgreSQL 语句记录

System

2024-09-02

所有,数据库

在PostgreSQL中，如果你想记录执行的SQL语句，你可以使用PostgreSQL的日志功能。PostgreSQL提供了多种日志记录级别，包括记录所有语句的详细日志。

以下是如何设置PostgreSQL以记录所有执行的语句的步骤：

修改PostgreSQL配置文件（通常是postgresql.conf），找到log_statement参数，并将其设置为'all'。




log_statement = 'all'

修改log_directory和log_filename参数，指定日志文件的存储路径和文件名。




log_directory = 'pg_log'
log_filename = 'postgresql-%Y-%m-%d_%H%M%S.log'

重新加载配置或重启PostgreSQL服务以使更改生效。

在命令行中重新加载配置的命令：




pg_ctl reload

或者重启PostgreSQL服务：




service postgresql restart

或者




systemctl restart postgresql

在配置正确并重新加载或重启服务后，所有执行的SQL语句都会记录到指定的日志文件中。记得检查文件权限和所有权，确保PostgreSQL有权限写入日志文件。

System

2024-09-02

所有,数据库

这个错误通常表示在尝试通过SSH连接GaussDB数据库时，客户端和服务器之间无法协商一个安全的连接，因为它们无法生成一个DH（Diffie-Hellman）密钥对。

解决方法：

检查SSH服务器配置文件（通常是/etc/ssh/sshd_config），确保以下参数设置正确：
- DHParamsSize 需要设置一个足够的值来生成合适大小的DH参数。
如果配置文件中没有设置DHParamsSize，或者设置的值不足，你可以手动生成DH参数：
- 使用ssh-keygen -t dh命令生成DH参数。
- 生成的参数通常保存在/etc/ssh/ssh_host_dh_key。
- 确保sshd服务有读权限访问这个文件。
重启SSH服务以应用更改：
- 在Linux系统中，通常使用service ssh restart或systemctl restart sshd命令。
如果你不是服务器的管理员，联系管理员进行上述配置更改。
确保客户端SSH版本支持服务器的加密算法和DH参数。如果客户端版本较旧，升级到支持的最新版本可能是必要的。
如果问题依旧存在，可以考虑查看SSH服务器日志文件（例如/var/log/auth.log或/var/log/secure），以获取更多错误信息，并根据日志中的错误提示进行故障排除。

- 阅读更多 -

如何使用缓存提升SpringBoot性能（EhCache和Redis方式）

System

2024-09-02

所有,redis

在Spring Boot中使用EhCache或Redis作为缓存可以显著提高应用程序的性能。以下是如何配置和使用EhCache和Redis作为缓存的示例。

EhCache配置:

添加依赖到pom.xml:




<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-cache</artifactId>
</dependency>
<dependency>
    <groupId>net.sf.ehcache</groupId>
    <artifactId>ehcache</artifactId>
</dependency>

在src/main/resources目录下创建ehcache.xml配置文件:




<ehcache>
    <!-- 缓存配置 -->
    <cache name="sampleCache"
           maxEntriesLocalHeap="10000"
           timeToIdleSeconds="3600"
           timeToLiveSeconds="3600"
           maxEntriesLocalDisk="10000000"
           diskExpiryThreadIntervalSeconds="1200">
        <persistence strategy="localTempSwap"/>
    </cache>
</ehcache>

在Spring Boot配置类中启用缓存:




@Configuration
@EnableCaching
public class CacheConfig {
}

使用缓存:




@Service
public class SampleService {
 
    @Cacheable(value = "sampleCache", key = "#key")
    public String getData(String key) {
        // 实际的数据获取逻辑
        return "data";
    }
}

Redis配置:

添加依赖到pom.xml:




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

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




# application.properties
spring.redis.host=localhost
spring.redis.port=6379

在Spring Boot配置类中配置Redis缓存管理器:




@Configuration
public class RedisCacheConfig {
 
    @Bean
    public CacheManager cacheManager(RedisConnectionFactory redisConnectionFactory) {
        return RedisCacheManager.builder(RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory))
            .cacheDefaults(CacheConfiguration.defaultCacheConfig())
            .build();
    }
}

使用缓存:




@Service
public class SampleService {
 
    @Cacheable(value = "sampleCache", key = "#key")
    public String getData(String key) {
        // 实际的数据获取逻辑
        return "data";
    }
}

在这两种情况下，@Cacheable注解都用于标

- 阅读更多 -

使用CommandLineRunner

使用ApplicationRunner

使用`CommandLineRunner`

使用`ApplicationRunner`