Tech Blog

2024-09-04

由于您提供的信息不足，导致无法给出具体的错误原因和解决方案。PL/SQL 无法连接到 Oracle 数据库可能有多种原因，以下是一些常见的原因及其解决方法：

网络问题：
- 确保数据库服务器正在运行并且可以访问。
- 检查网络连接，确保客户端和服务器之间的网络通畅。
数据库服务未启动：
- 在数据库服务器上启动 Oracle 数据库服务。
监听器未运行：
- 启动监听器服务。
- 使用 lsnrctl start 命令。
错误的连接字符串：
- 检查 PL/SQL 中的连接字符串是否正确。
认证问题：
- 确认提供的用户名和密码是否正确。
- 检查用户账号是否被锁定或者没有连接权限。
防火墙设置：
- 确保没有防火墙阻止连接。
Oracle 客户端和服务器版本不兼容：
- 确保客户端和服务器版本兼容。
TNS配置问题：
- 检查 tnsnames.ora 文件配置是否正确。
Oracle 参数设置问题：
- 检查数据库初始化参数，如 processes 和 sessions。
Oracle 客户端未正确配置：
- 确保客户端正确安装，并且环境变量配置指向正确的 Oracle 客户端目录。

为了给出更具体的解决方案，需要提供更详细的错误信息，例如错误代码或异常信息。

2024-09-04

所有,redis

以下是一个简化的例子，展示了如何在Spring Boot 3和Spring Security 6中使用JWT和Redis实现登录和令牌身份验证。




// SecurityConfig.java
@EnableWebSecurity
public class SecurityConfig extends WebSecurityConfigurerAdapter {
 
    @Autowired
    private AuthenticationEntryPoint authenticationEntryPoint;
 
    @Autowired
    private UserDetailsService userDetailsService;
 
    @Autowired
    private JwtAuthenticationFilter jwtAuthenticationFilter;
 
    @Override
    protected void configure(AuthenticationManagerBuilder auth) throws Exception {
        auth.userDetailsService(userDetailsService);
    }
 
    @Bean
    public PasswordEncoder passwordEncoder() {
        return new BCryptPasswordEncoder();
    }
 
    @Override
    protected void configure(HttpSecurity http) throws Exception {
        http
            .cors()
            .and()
            .csrf().disable()
            .exceptionHandling().authenticationEntryPoint(authenticationEntryPoint)
            .and()
            .sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS)
            .and()
            .authorizeRequests()
            .antMatchers("/api/v1/auth/login").permitAll()
            .anyRequest().authenticated();
 
        http.addFilterBefore(jwtAuthenticationFilter, UsernamePasswordAuthenticationFilter.class);
    }
}
 
// JwtAuthenticationFilter.java
public class JwtAuthenticationFilter extends UsernamePasswordAuthenticationFilter {
 
    private final AuthenticationManager authenticationManager;
    private final JwtTokenProvider jwtTokenProvider;
 
    public JwtAuthenticationFilter(AuthenticationManager authenticationManager, JwtTokenProvider jwtTokenProvider) {
        this.authenticationManager = authenticationManager;
        this.jwtTokenProvider = jwtTokenProvider;
        this.setPostOnly(true);
    }
 
    @Override
    public Authentication attemptAuthentication(HttpServletRequest request,
                                                HttpServletResponse response) throws AuthenticationException {
        UsernamePasswordAuthenticationToken authenticationToken = getAuthentication(request);
        return authenticationManager.authenticate(authentication

02 MySQL数据库管理

2024-09-04

在MySQL中，您可以使用以下命令来创建一个新的数据库：




CREATE DATABASE my_database;

这里，my_database 是您想要创建的新数据库的名称。创建数据库后，您可以使用以下命令来选择数据库：




USE my_database;

然后，您可以创建新的表：




CREATE TABLE my_table (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(100) NOT NULL,
    age INT
);

在这个例子中，my_table 是新表的名称，它有三个字段：id 是自动增量的主键，name 是一个最大长度为100字符的字符串，不允许为空，age 是整数类型的字段。

要插入数据到表中，可以使用：




INSERT INTO my_table (name, age) VALUES ('Alice', 30);

要查询表中的数据，可以使用：




SELECT * FROM my_table;

这将返回my_table中的所有记录。

如果您需要删除数据库或表，请确保您有足够的权限，并且要非常小心，因为这些操作是不可逆的：




-- 删除数据库
DROP DATABASE my_database;
 
-- 删除表
DROP TABLE my_table;

WPF 数据库 SQLite 分页处理

2024-09-04




// 使用WPF和SQLite进行分页处理的示例代码
using System;
using System.Windows;
using System.Data.SQLite;
 
public partial class MainWindow : Window
{
    public MainWindow()
    {
        InitializeComponent();
    }
 
    private void BtnPrevious_Click(object sender, RoutedEventArgs e)
    {
        // 上一页的处理逻辑
        ChangePage(-1);
    }
 
    private void BtnNext_Click(object sender, RoutedEventArgs e)
    {
        // 下一页的处理逻辑
        ChangePage(1);
    }
 
    private void ChangePage(int direction)
    {
        int currentPage = Convert.ToInt32(txtCurrentPage.Text);
        int pageSize = Convert.ToInt32(txtPageSize.Text);
        int newPage = currentPage + direction;
 
        if (newPage > 0 && newPage <= CalculateTotalPages())
        {
            // 使用新页码重新加载数据
            LoadData(newPage, pageSize);
            txtCurrentPage.Text = newPage.ToString();
        }
    }
 
    private int CalculateTotalPages()
    {
        int totalRecords = GetTotalRecords();
        int pageSize = Convert.ToInt32(txtPageSize.Text);
        return (int)Math.Ceiling((double)totalRecords / pageSize);
    }
 
    private int GetTotalRecords()
    {
        int totalRecords = 0;
        // 这里应该是查询数据库以获取总记录数的代码
        // 示例代码省略
        return totalRecords;
    }
 
    private void LoadData(int page, int pageSize)
    {
        // 这里应该是根据页码和页大小从数据库加载数据的代码
        // 示例代码省略
    }
}

这个示例代码提供了一个简化的框架，展示了如何在WPF应用程序中处理分页逻辑。代码中的ChangePage方法根据用户的分页请求更新页码，并调用LoadData方法加载新页的数据。同时，它还提供了计算总页数的CalculateTotalPages方法和获取总记录数的GetTotalRecords方法。这些方法的具体实现将依赖于SQLite数据库的查询。

Tomcat get请求传数组集合参数

2024-09-04

在Java Web应用中，使用Tomcat作为服务器，可以通过HttpServletRequest对象获取GET请求中的数组集合参数。以下是一个简单的示例，演示如何在Servlet中获取GET请求的数组集合参数：

假设你有以下URL的GET请求:




http://localhost:8080/myapp/myservlet?myCollection=value1&myCollection=value2&myCollection=value3

你可以通过如下方式在Servlet中获取myCollection参数的值：




import javax.servlet.*;
import javax.servlet.http.*;
import java.io.IOException;
import java.util.Arrays;
import java.util.List;
 
public class MyServlet extends HttpServlet {
    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 获取请求参数myCollection，它是一个集合
        String[] myCollection = request.getParameterValues("myCollection");
        
        // 如果需要转换为List
        List<String> myList = myCollection != null ? Arrays.asList(myCollection) : null;
        
        // 输出获取到的集合参数
        response.getWriter().write("Collection as Array: " + Arrays.toString(myCollection) + "\n");
        response.getWriter().write("Collection as List: " + myList + "\n");
    }
}

在这个Servlet中，doGet方法通过request.getParameterValues("myCollection")获取了名为myCollection的请求参数数组。然后，可以将其转换为List，并将结果写入响应中。

确保你的web.xml或使用的注解配置了正确的URL映射，以便请求能正确地路由到这个Servlet。

Spring Cloud微服务架构下的安全通信、系统稳定性和扩展性

2024-09-04

在Spring Cloud微服务架构中，提高系统的安全性、稳定性和扩展性通常涉及以下几个方面：

使用Spring Cloud Security进行服务间调用的认证和授权。
对服务进行负载均衡，并使用断路器模式确保系统的健壮性。
利用Spring Cloud Config进行服务配置的集中管理，便于服务的扩展和维护。

以下是一个简化的示例代码，展示如何在Spring Cloud微服务中使用Eureka进行服务注册与发现，Feign进行服务间调用，并使用Hystrix做断路器。




// 引入依赖（部分）
dependencies {
    implementation 'org.springframework.cloud:spring-cloud-starter-netflix-eureka-client'
    implementation 'org.springframework.cloud:spring-cloud-starter-openfeign'
    implementation 'org.springframework.cloud:spring-cloud-starter-netflix-hystrix'
}
 
// 启动类开启Feign和Hystrix支持
@EnableFeignClients
@EnableHystrix
@EnableDiscoveryClient
@SpringBootApplication
public class MyApplication {
    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }
}
 
// 服务调用接口
@FeignClient(name = "service-provider", fallback = ServiceProviderFallback.class)
public interface ServiceProviderClient {
    @GetMapping("/data")
    String getData();
}
 
// 服务调用的备用实现
public class ServiceProviderFallback implements ServiceProviderClient {
    @Override
    public String getData() {
        return "Fallback response";
    }
}
 
// 配置类，配置Hystrix的超时时间和断路器行为
@Configuration
public class HystrixConfig {
    @Bean
    public HystrixCommandAspect hystrixCommandAspect() {
        return new HystrixCommandAspect();
    }
 
    @Bean
    public HystrixConcurrencyStrategy concurrencyStrategy() {
        return new FeignHystrixConcurrencyStrategy();
    }
}
 
// application.yml配置文件
spring:
  application:
    name: service-consumer
server:
  port: 8080
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
feign:
  hystrix:
    enabled: true
hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 1000

在这个例子中，我们使用@EnableFeignClients注解开启Feign客户端支持，并定义了一个Feign客户端接口用于服务间的通信。同时，我们使用@EnableHystrix开启了Hystrix断路器的支持，并通过配置文件设置了Hystrix的超时时间。通过这样的配置，我们可以确保服务间通信是安全的，并且在服务提供者不可用时能够提供备选方案，从而提高了系统的健壮性和扩展性。

SpringBoot 使用JNDI 与 Tomcat容器以及多数据源操作总结

2024-09-04




import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.jdbc.datasource.lookup.JndiDataSourceLookup;
import javax.sql.DataSource;
import java.util.Properties;
 
@Configuration
public class DataSourceConfig {
 
    @Bean
    public JndiDataSourceLookup dataSourceLookup() {
        JndiDataSourceLookup lookup = new JndiDataSourceLookup();
        Properties jndiProperties = new Properties();
        jndiProperties.put("java.naming.factory.initial", "org.apache.naming.java.javaURLContextFactory");
        jndiProperties.put("java.naming.provider.url", ""); // 设置Tomcat的jndi路径
        lookup.setJndiProperties(jndiProperties);
        return lookup;
    }
 
    @Bean
    @Primary
    public DataSource primaryDataSource() {
        DataSource dataSource = dataSourceLookup().getDataSource("jdbc/MyDS");
        return dataSource;
    }
 
    @Bean
    public DataSource secondaryDataSource() {
        DataSource dataSource = dataSourceLookup().getDataSource("jdbc/MySecondDS");
        return dataSource;
    }
}

这段代码展示了如何在Spring Boot应用中配置JNDI数据源。首先创建了JndiDataSourceLookup的Bean，然后使用这个Bean来获取Tomcat容器中配置的主要和次要数据源。通过@Primary注解标注主要数据源，这样Spring就会使用它作为默认的数据源。这个例子简洁明了，并且清晰地展示了如何在Spring Boot中集成JNDI数据源。

学习笔记 : Redis中基于Stream结构的消息队列

2024-09-04

所有,redis




import redis
 
# 连接到Redis服务器
r = redis.Redis(host='localhost', port=6379, db=0)
 
# 使用XADD添加消息到流中
stream_key = 'mystream'
message_id = r.xadd(stream_key, {'message': 'Hello, Redis Streams!'})
print(f"添加的消息ID: {message_id}")
 
# 使用XREAD读取流中的消息
consumer_group_name = 'mygroup'
messages = r.xread({stream_key: 0}, count=1, block=0)
for stream_message in messages:
    stream_key, messages_in_stream = stream_message
    for message_id, message in messages_in_stream:
        print(f"消息ID: {message_id}, 内容: {message}")
 
# 使用XACK确认消息已被消费
message_id_to_ack = message_id  # 假设我们要确认的是上面添加的消息
r.xack(stream_key, consumer_group_name, message_id_to_ack)
 
# 使用XDEL删除流中的消息
message_id_to_delete = message_id  # 假设我们要删除的是上面添加的消息
r.xdel(stream_key, message_id_to_delete)

这段代码展示了如何使用Python的redis模块与Redis服务器交互，执行基本的Stream数据结构操作。代码中包含了添加消息到流、读取消息、确认消息已消费以及删除消息的例子。

PostgreSQL14开启远程连接

2024-09-04

为了在PostgreSQL 14中启用远程连接，请按照以下步骤操作：

编辑PostgreSQL配置文件postgresql.conf，通常位于PostgreSQL的数据目录下。




nano /var/lib/postgresql/data/postgresql.conf

找到listen_addresses参数，修改它以包含*（代表监听所有接口），或者具体的IP地址。




listen_addresses = '*'  # 或者具体的IP地址

确保port参数设置为PostgreSQL服务将监听的端口，默认通常是5432。




port = 5432

编辑pg_hba.conf文件以允许远程连接。




nano /var/lib/postgresql/data/pg_hba.conf

添加一行来允许远程主机连接，用host、all、all、0.0.0.0/0（代表任何IP）和md5（或者scram-sha-256，取决于你想要的认证方式）替换相应部分。




host all all 0.0.0.0/0 md5

重启PostgreSQL服务以应用更改。




sudo systemctl restart postgresql

确保你的防火墙允许远程机器访问PostgreSQL的端口（默认为5432）。如果你使用的是UFW（Uncomplicated Firewall），可以使用以下命令允许5432端口的流量：




sudo ufw allow 5432/tcp

现在应该可以从远程机器使用相应的用户名、密码和端口号连接到PostgreSQL数据库了。

Spring Boot 项目 @Value 注解太强大了，使用者无不称赞

2024-09-04

@Value 注解在Spring Boot项目中用于将外部配置（如属性文件、环境变量、命令行参数等）注入到Spring管理的Bean中。

以下是一个使用@Value注解的简单示例：




import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
 
@Component
public class MyBean {
 
    // 注入配置文件中的属性值
    @Value("${my.property}")
    private String myProperty;
 
    // 注入环境变量
    @Value("${MY_ENV_VAR}")
    private String envVar;
 
    // 注入命令行参数
    @Value("${my.command.line.arg}")
    private String commandLineArg;
 
    // 省略getter和setter方法...
}

在上述代码中，my.property、MY_ENV_VAR 和 my.command.line.arg 是配置的键，它们的值将被注入到myProperty、envVar 和 commandLineArg 字段中。

要使@Value注解正常工作，需要确保配置文件（如application.properties或application.yml）中有相应的键值对，或者环境变量和命令行参数已经设置。

在application.properties中添加：




my.property=someValue

或者在application.yml中添加：




my:
  property: someValue

然后启动Spring Boot应用，@Value 注解将会工作。