Tech Blog

2024-09-04

授予用户DBA权限的SQL命令如下：




GRANT DBA TO 用户名;

查看哪些用户具有DBA权限的SQL命令如下：




SELECT * FROM dba_role_privs WHERE granted_role = 'DBA';

请将用户名替换为实际要授予DBA权限的用户名。执行这些命令前，您需要具有授予DBA权限的相应权限，通常这是由数据库管理员（DBA）执行的。

System

2024-09-04

所有,数据库




import psycopg2
import pymysql
 
# 连接PostgreSQL
def connect_postgresql():
    conn = psycopg2.connect(
        dbname="your_dbname",
        user="your_username",
        password="your_password",
        host="your_host",
        port="your_port"
    )
    return conn
 
# 连接MySQL
def connect_mysql():
    conn = pymysql.connect(
        host="your_host",
        user="your_username",
        password="your_password",
        db="your_dbname",
        charset='utf8mb4'
    )
    return conn
 
# 向PostgreSQL批量插入数据
def insert_data_postgresql(data):
    conn = connect_postgresql()
    cur = conn.cursor()
    for row in data:
        cur.execute("INSERT INTO your_table (column1, column2) VALUES (%s, %s)", row)
    conn.commit()
    conn.close()
 
# 向MySQL批量插入数据
def insert_data_mysql(data):
    conn = connect_mysql()
    cur = conn.cursor()
    for row in data:
        cur.execute("INSERT INTO your_table (column1, column2) VALUES (%s, %s)", row)
    conn.commit()
    conn.close()
 
# 示例数据
data_postgresql = [(1, 'Alice'), (2, 'Bob')]
data_mysql = [(3, 'Charlie'), (4, 'David')]
 
# 执行批量插入
insert_data_postgresql(data_postgresql)
insert_data_mysql(data_mysql)

在这个例子中，我们定义了两个函数connect_postgresql和connect_mysql来分别连接PostgreSQL和MySQL数据库。然后定义了两个函数insert_data_postgresql和insert_data_mysql来批量向对应的数据库表中插入数据。最后，我们使用示例数据执行了这两个函数。在实际应用中，你需要替换your_dbname, your_username, your_password, your_host, your_port, your_table, column1, column2以及data变量的内容。

- 阅读更多 -

SpringCloud基础篇-10-服务网关-Gateway

System

2024-09-04

所有,java

在Spring Cloud中，Spring Cloud Gateway是一种提供路由及过滤功能的API网关服务。

以下是一个简单的Spring Cloud Gateway示例配置：

在pom.xml中添加依赖：




<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-gateway</artifactId>
    </dependency>
    <!-- 如果需要使用到Eureka客户端进行服务发现，请添加以下依赖 -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
</dependencies>
 
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

配置application.yml：




spring:
  cloud:
    gateway:
      routes:
        - id: service_route
          uri: http://localhost:8080
          predicates:
            - Path=/service/**
        - id: service_route_lb
          uri: lb://service-provider
          predicates:
            - Path=/service-lb/**

在这个配置中，我们定义了两条路由规则：

service_route：将匹配/service/**的请求路径转发到http://localhost:8080。
service_route_lb：将匹配/service-lb/**的请求路径转发到名为service-provider的服务，并且使用负载均衡。

启动类：




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

启动类中通常不需要额外的配置。

这个简单的示例展示了如何使用Spring Cloud Gateway配置基本的路由规则。在实际应用中，你可能需要根据具体需求配置额外的过滤器、路由条件等。

System

2024-09-04

所有,java




@Configuration
@EnableConfigServer
public class ConfigServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ConfigServerApplication.class, args);
    }
}

这段代码定义了一个Spring Boot应用程序的入口点，它使用@EnableConfigServer注解启用Spring Cloud Config Server功能。这个配置服务器可以用来集中管理应用程序的配置属性。在实际部署时，通常与Spring Cloud Config和版本控制工具（如Git）一起使用来实现配置的动态更新和热部署。

- 阅读更多 -

【Tomcat 文件读取/文件包含(CVE-2020-1938)漏洞复现】

System

2024-09-04

所有,java

由于CVE-2020-1938是一个关于Tomcat服务器的文件包含漏洞，它不是一个特定的代码问题，而是一个安全问题。要复现这个漏洞，你需要：

一个运行Tomcat服务器的环境。
一个能够向Tomcat服务器发送特定请求的工具，如Burp Suite或者使用curl命令。

漏洞复现步骤：

访问Tomcat服务器上的一个JSP文件，比如http://your-tomcat-server/examples/jsp/hello.jsp。
在请求中包含JNDI注入代码，如http://your-tomcat-server/examples/jsp/hello.jsp?name=<% out.println(application.getRealPath("/")); %>。
如果Tomcat服务器存在这个漏洞，JNDI注入将会被执行，并可能导致服务器文件系统的敏感文件被访问。

请注意，未经授权对任何系统进行安全测试可能违反法律法规，这里提供的信息只应用于学习目的，不应用于非法用途。在实际环境中，应该通过正式的漏洞报告和修复流程来处理安全问题。

- 阅读更多 -

Redis未授权访问漏洞详解（全面）

System

2024-09-04

所有,redis

Redis未授权访问漏洞通常指的是未通过身份验证就能访问Redis服务器，这可能导致敏感数据泄露或被恶意操作。

解决方法：

启用Redis的身份验证功能。编辑Redis配置文件（通常是redis.conf），找到requirepass指令，并设置一个复杂的密码。
```
requirepass yourSecurePassword
```

通过CONFIG SET命令动态设置密码：




CONFIG SET requirepass "yourSecurePassword"

确保只有信任的用户可以访问Redis服务器，可以通过防火墙或者其他网络安全措施来限制访问。
使用TLS/SSL加密来保护数据传输，确保密码在网络传输过程中安全。
定期更新Redis密码和监控访问行为，以防止未授权访问。

监控和响应措施：

使用监控工具定期检查Redis的身份验证状态，如果发现未授权访问，立即采取上述措施防御。
如果已经遭遇未授权访问，应该立即重启Redis服务，并修改所有敏感数据的密钥。

安全建议：

使用强密码管理工具，如pam_pwmake。
定期更新你的密码，并确保它们足够复杂。
使用Redis的最新稳定版本，及时应用安全补丁。
保持Redis的配置文件权限安全，仅有所需的用户可以读取。

安全实践：

不要在不安全的网络上暴露Redis服务，尽量使用内网或VPC。
使用Redis的ACL功能来限制用户权限，仅授予必要的命令和键访问权限。
监控Redis的日志文件，识别异常行为，并在发现可疑活动时采取行动。

- 阅读更多 -

玩转springboot之springboot定制化tomcat

System

2024-09-04

所有,java

在Spring Boot中，你可以通过定义一个EmbeddedServletContainerCustomizer bean来定制Tomcat。以下是一个简单的例子，展示了如何更改Tomcat的端口和编码设置：




import org.springframework.boot.context.embedded.ConfigurableEmbeddedServletContainer;
import org.springframework.boot.context.embedded.EmbeddedServletContainerCustomizer;
import org.springframework.boot.web.servlet.ServletContextInitializer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
@Configuration
public class TomcatConfig {
 
    @Bean
    public EmbeddedServletContainerCustomizer servletContainerCustomizer() {
        return new EmbeddedServletContainerCustomizer() {
            @Override
            public void customize(ConfigurableEmbeddedServletContainer container) {
                // 更改端口号
                container.setPort(9090);
            }
        };
    }
}

如果你需要更深度的定制，例如添加Tomcat的NIO连接器或更改连接器的属性，你可以直接访问ConfigurableEmbeddedServletContainer的Tomcat相关APIs。例如：




import org.apache.catalina.connector.Connector;
import org.springframework.boot.context.embedded.ConfigurableEmbeddedServletContainer;
import org.springframework.boot.context.embedded.EmbeddedServletContainerCustomizer;
import org.springframework.boot.web.embedded.tomcat.TomcatConnectorCustomizer;
import org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory;
import org.springframework.boot.web.server.WebServerFactoryCustomizer;
import org.springframework.stereotype.Component;
 
@Component
public class CustomTomcatConfiguration {
 
    @Bean
    public WebServerFactoryCustomizer<TomcatServletWebServerFactory> tomcatCustomizer() {
        return tomcatServletWebServerFactory -> {
            tomcatServletWebServerFactory.addConnectorCustomizers(new TomcatConnectorCustomizer() {
                @Override
                public void customize(Connector connector) {
                    // 配置NIO连接器
                    connector.setProtocol("org.apache.coyote.http11.Http11NioProtocol");
                }
            });
        };
    }
}

在这个例子中，我们创建了一个WebServerFactoryCustomizer bean，该bean会对Tomcat的ServletWebServerFactory进行定制，包括添加自定义的连接器配置。

- 阅读更多 -

oracle expdp to asm / impdp from asm

System

2024-09-04

所有,数据库

Oracle Data Pump可以直接使用ASM（Automatic Storage Management）进行数据导出（EXPDP）和导入（IMPDP）。以下是使用ASM进行数据导出和导入的基本命令示例。

导出到ASM:




expdp system/password@db11g directory=DATA_PUMP_DIR dumpfile=expdp.dmp logfile=expdp.log schemas=schema_name

在这个命令中，system/password@db11g是连接到数据库的凭据，DATA_PUMP_DIR是已经在ASM中定义好的目录对象，expdp.dmp是导出的数据泵文件，expdp.log是操作日志文件，schema_name是需要导出的模式名。

从ASM导入:




impdp system/password@db11g directory=DATA_PUMP_DIR dumpfile=expdp.dmp logfile=impdp.log schemas=schema_name

导入命令与导出命令类似，只是操作换成了impdp，并指定了要导入的数据泵文件。

确保在执行这些命令之前，已经正确配置了ASM磁盘组和相应的Oracle目录对象，并且用户有足够的权限进行数据泵操作。

- 阅读更多 -

Postgres报错the database system is in recovery mode

System

2024-09-04

所有,数据库

解释：

PostgreSQL数据库在恢复模式（recovery mode）时会出现“the database system is in recovery mode”的错误提示。这通常发生在数据库服务器意外宕机后，系统尝试自动恢复数据库到一致状态时。在恢复模式下，数据库处于只读模式，不允许进行数据修改操作。

解决方法：

等待：如果数据库可以自动完成恢复过程，通常只需耐心等待，直到数据库完全恢复并可以正常访问。
检查主服务器的日志：如果是手动进行主从同步的数据库集群，检查主服务器的日志文件，确认数据同步和恢复过程是否正常。
重启数据库服务：一旦恢复模式结束，数据库会自动退出恢复模式，并可以重启PostgreSQL服务。
使用pg\_controldata查看恢复状态：可以使用pg_controldata命令查看数据库的恢复状态。

注意：

在恢复模式结束之前，不应执行任何可能会影响数据一致性的操作。
如果数据库集群配置了流复制（streaming replication），确保主服务器和从服务器的配置正确，并且网络连接没有问题。
如果数据库长时间处于恢复模式，可能需要进一步检查数据文件、WAL日志文件或配置文件，查找恢复过程中的问题。

System

2024-09-04

所有,redis

在Spring Boot 3中，若要使用fastjson2作为RedisTemplate的序列化策略，你需要自定义配置类来覆盖默认的配置。以下是一个示例代码：




import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.serializer.SerializerFeature;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.RedisSerializer;
import java.nio.charset.StandardCharsets;
 
@Configuration
public class RedisConfig {
 
    @Bean
    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<Object, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(redisConnectionFactory);
 
        // 使用fastjson序列化
        FastJson2JsonRedisSerializer fastJson2JsonRedisSerializer = new FastJson2JsonRedisSerializer(Object.class);
 
        // 设置值（value）的序列化器
        template.setValueSerializer(fastJson2JsonRedisSerializer);
        // 设置键（key）的序列化器
        template.setKeySerializer(fastJson2JsonRedisSerializer);
        // 设置哈希键的序列化器
        template.setHashKeySerializer(fastJson2JsonRedisSerializer);
        // 设置哈希值的序列化器
        template.setHashValueSerializer(fastJson2JsonRedisSerializer);
 
        template.afterPropertiesSet();
        return template;
    }
 
    public static class FastJson2JsonRedisSerializer<T> implements RedisSerializer<T> {
        private Class<T> clazz;
 
        public FastJson2JsonRedisSerializer(Class<T> clazz) {
            super();
            this.clazz = clazz;
        }
 
        @Override
        public byte[] serialize(T t) throws SerializationException {
            if (t == null) {
                return new byte[0];
            }
            return JSON.toJSONString(t, SerializerFeature.WriteClassName).getBytes(StandardCharsets.UTF_8);
        }
 
        @Override
        public T deserialize(byte[] bytes) throws SerializationException {
            if (bytes == null || bytes.length <= 0) {
                return null;
            }
            String str = new String(bytes, StandardCharsets.UTF_8);
            return JSON.parseObject(str, clazz);
        }
    }
}

在这个配置类中，我们定义了一个RedisTemplate的Bean，并且使用了自定义的FastJson2JsonRedisSerializer作为序列化器。这个序列化器使用fastjson2库将对象序列化为JSON字符串，并在反序列化时指

- 阅读更多 -