分类后端技术下的文章

2024-09-09

在Linux系统上使用SQLite，首先需要确保已经安装了SQLite。可以通过终端运行以下命令来安装SQLite：




sudo apt-get update
sudo apt-get install sqlite3

安装完成后，可以通过终端运行sqlite3命令来启动SQLite。

以下是一些基本的SQLite命令和操作：

创建数据库：




sqlite3 database_name.db

创建表：




CREATE TABLE table_name (column1 datatype, column2 datatype, ...);

插入数据：




INSERT INTO table_name (column1, column2, ...) VALUES (value1, value2, ...);

查询数据：




SELECT * FROM table_name;

更新数据：




UPDATE table_name SET column1 = value1 WHERE condition;

删除数据：




DELETE FROM table_name WHERE condition;

退出SQLite：




.quit

以下是一个简单的示例，演示如何在SQLite中创建数据库、表，并进行数据的插入、查询操作：




sqlite3 example.db

在SQLite命令行界面中：




CREATE TABLE users (id INTEGER PRIMARY KEY, name TEXT, age INTEGER);
INSERT INTO users (name, age) VALUES ('Alice', 30);
SELECT * FROM users;

退出SQLite：




.quit

这个示例演示了如何在SQLite中创建一个名为example.db的数据库，创建一个名为users的表，并插入一条记录。然后，它查询了users表中的所有记录，并退出了SQLite。

- 阅读更多 -

【SpringCloud微服务笔记11】服务网关Zuul

System

2024-09-09

所有,java

在Spring Cloud中，服务网关通常使用Zuul来实现。以下是一个使用Zuul作为服务网关的简单示例：

添加依赖到你的pom.xml：




<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
</dependency>

配置你的application.properties或application.yml以启用Zuul：




spring.application.name=api-gateway
server.port=80
 
zuul.routes.my-service.path=/my-service/**
zuul.routes.my-service.serviceId=my-service

创建一个Spring Boot应用并使用@EnableZuulProxy注解启用Zuul代理功能：




import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
 
@EnableZuulProxy
@SpringBootApplication
public class ApiGatewayApplication {
    public static void main(String[] args) {
        SpringApplication.run(ApiGatewayApplication.class, args);
    }
}

在这个例子中，服务网关会代理所有到/my-service/**的请求到名为my-service的服务。这个服务应该在Spring Cloud服务发现机制下注册，例如Eureka。这样配置后，访问http://localhost/my-service/...的请求会被转发到对应的服务。

- 阅读更多 -

oracle递归查询父级或子级转换成mysql的语句

System

2024-09-09

所有,数据库

在MySQL中，没有直接等价的"CONNECT BY"语法。但是，可以使用递归公用表表达式（Common Table Expressions, CTEs）来模拟Oracle的递归查询。

以下是一个简化的例子，假设我们有一个名为category的表，它具有id和parent_id字段，其中parent_id表示父级分类的id。

Oracle递归查询示例（获取所有子级分类）:




SELECT id, parent_id, name
FROM category
START WITH id = :start_id
CONNECT BY PRIOR id = parent_id;

对应的MySQL递归公用表表达式（CTE）示例：




WITH RECURSIVE sub_categories AS (
  SELECT id, parent_id, name
  FROM category
  WHERE id = :start_id -- 起始条件，例如，你想要获取的根分类ID
  UNION ALL
  SELECT c.id, c.parent_id, c.name
  FROM category c
  INNER JOIN sub_categories sc ON sc.id = c.parent_id -- 递归连接条件
)
SELECT * FROM sub_categories;

在这个MySQL示例中，:start_id是传入的参数，表示你想要开始递归查询的根节点的ID。sub_categories是一个CTE，它首先从根节点开始（即WHERE id = :start_id），然后递归地将子节点添加到查询结果中，直到没有更多的子节点为止。

System

2024-09-09

所有,redis

以下是一个简化的Spring Boot 3 + Spring Security 6 + JWT + Redis的项目框架示例。

引入依赖（pom.xml）：




<dependencies>
    <!-- Spring Boot 3 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!-- Spring Security 6 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-security</artifactId>
    </dependency>
    <!-- JWT -->
    <dependency>
        <groupId>io.jsonwebtoken</groupId>
        <artifactId>jjwt</artifactId>
        <version>0.9.1</version>
    </dependency>
    <!-- Redis -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
</dependencies>

配置Security和JWT（SecurityConfig.java）：




@EnableWebSecurity
public class SecurityConfig extends WebSecurityConfigurerAdapter {
 
    @Autowired
    private UserDetailsService userDetailsService;
 
    @Autowired
    private JwtAuthenticationEntryPoint jwtAuthenticationEntryPoint;
 
    @Autowired
    private JwtRequestFilter jwtRequestFilter;
 
    @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(jwtAuthenticationEntryPoint)
            .and()
            .sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS)
            .and()
            .authorizeRequests()
            .antMatchers("/authenticate").permitAll()
            .anyRequest().authenticated();
 
        http.addFilterBefore(jwtRequestFilter, UsernamePasswordAuthenticationFilter.class);
    }
}

JWT认证和授权过滤器（JwtTokenUtil.java）：




public class JwtTokenUtil {
 
    // ... JWT工具类的实现 ...
 
    public String generateToken(UserDetails userDetails) {
        return Jwts.builder()
                .setSubject(userDetails.getUsername())
                .signWith(SignatureAlgorithm.HS512, SECRET_KEY)
                .compact();
    }
 
    public boolean va

- 阅读更多 -

Spring Boot+OAuth2，如何自定义返回的 Token 信息

System

2024-09-09

所有,java

在Spring Boot中，要自定义OAuth2返回的Token信息，你可以通过扩展TokenGranter接口来创建自定义的TokenGranter实现。以下是一个简单的例子，演示如何添加自定义的响应字段：

创建自定义的TokenGranter实现：




import org.springframework.security.oauth2.common.DefaultOAuth2AccessToken;
import org.springframework.security.oauth2.provider.OAuth2Request;
import org.springframework.security.oauth2.provider.TokenGranter;
import org.springframework.security.oauth2.provider.token.AuthorizationServerTokenServices;
 
import java.util.LinkedHashMap;
import java.util.Map;
 
public class CustomTokenGranter implements TokenGranter {
    private final AuthorizationServerTokenServices tokenServices;
    private final TokenGranter delegate;
 
    public CustomTokenGranter(AuthorizationServerTokenServices tokenServices, TokenGranter delegate) {
        this.tokenServices = tokenServices;
        this.delegate = delegate;
    }
 
    @Override
    public OAuth2AccessToken grant(String grantType, TokenRequest tokenRequest) {
        OAuth2AccessToken token = delegate.grant(grantType, tokenRequest);
 
        if (token != null) {
            // 自定义响应字段
            Map<String, Object> additionalInformation = new LinkedHashMap<>(token.getAdditionalInformation());
            additionalInformation.put("custom_field", "custom_value");
 
            // 创建一个新的token，添加自定义信息
            DefaultOAuth2AccessToken customToken = new DefaultOAuth2AccessToken(token);
            customToken.setAdditionalInformation(additionalInformation);
 
            return customToken;
        }
 
        return token;
    }
}

注册自定义TokenGranter：




import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.security.oauth2.config.annotation.web.configuration.AuthorizationServerConfigurerAdapter;
import org.springframework.security.oauth2.provider.TokenGranter;
import org.springframework.security.oauth2.provider.token.AuthorizationServerTokenServices;
 
@Configuration
public class OAuth2Config extends AuthorizationServerConfigurerAdapter {
 
    private final TokenGranter tokenGranter;
    private final AuthorizationServerTokenServices tokenServices;
 
    public OAuth2Config(TokenGranter tokenGranter, AuthorizationServerTokenServices tokenServices) {
        this.tokenGranter = tokenGranter;
        this.tokenServices = tokenServices;
    }
 
    @Bean
    public TokenGranter tokenGrante

- 阅读更多 -

Oracle-主备切换问题（BUG-31747989）

System

2024-09-09

所有,数据库

报错问题：Oracle-主备切换问题(BUG-31747989)

解释：

这个报错指的是Oracle数据库在执行主备切换操作时遇到的一个BUG。BUG编号为31747989，这个问题发生在12.1版本到12.2版本的Oracle数据库中，主备切换后，备用数据库可能无法正确接管主数据库的角色，导致数据服务不可用。

解决方法：

如果你使用的是Oracle 12.2，可以通过应用一个补丁来解决这个问题。Oracle已经发布了补丁31747989，你需要从Oracle Support下载并安装该补丁。
如果补丁不可用，可以考虑以下临时解决方案：
- 手动进行故障转移：在主数据库不可用时，手动将Oracle RAC中的服务和资源转移到备用数据库。
- 使用Oracle Data Guard的“FASTCLONE”特性：在主数据库不可用时，可以将备用数据库快速转换为主数据库继续服务。
如果你使用的是Oracle Real Application Clusters (RAC)，可以考虑升级到12.2.0.1或更高版本，这样就会包含此BUG的修复。
在执行主备切换前，确保备用数据库的数据同步和应用的兼容性测试。
如果你不能立即应用补丁或采取上述措施，请考虑在等待Oracle官方修复补丁的同时，实施备份和故障转移策略，以最大程度减少服务中断的影响。

- 阅读更多 -

Golang 用户界面：Web 网页前端

System

2024-09-09

所有,golang

在Go语言中，可以使用net/http标准库来创建一个简单的Web服务器，并在前端使用HTML、CSS和JavaScript来构建交互式界面。以下是一个简单的例子，展示了如何用Go创建一个Web服务器，并在前端显示一个简单的网页。




package main
 
import (
    "fmt"
    "log"
    "net/http"
)
 
// 处理HTTP请求
func handler(w http.ResponseWriter, r *http.Request) {
    // 设置响应内容类型
    w.Header().Set("Content-Type", "text/html")
    // 输出HTML内容
    fmt.Fprintf(w, "<html><head><title>Go Web 界面</title></head><body><h1>Hello, World!</h1></body></html>")
}
 
func main() {
    // 创建路由
    http.HandleFunc("/", handler)
 
    // 设置服务器监听在端口8080
    log.Fatal(http.ListenAndServe(":8080", nil))
}

在上述代码中，我们定义了一个handler函数来处理根路径/的HTTP请求，并返回一个简单的HTML文档。然后在main函数中，我们使用http.HandleFunc来注册这个处理函数，并使用http.ListenAndServe来启动服务器，监听8080端口。

要运行这段代码，你需要有Go环境，并在命令行中运行go run命令。之后，打开浏览器，访问http://localhost:8080，你将看到一个简单的Web页面。

如果你想要更复杂的前端页面，你可以创建相应的HTML文件，并通过Go的http.FileServer来提供静态文件。这里只是给出了最基本的示例。

- 阅读更多 -

（windows）MongoDB分片部署

System

2024-09-09

所有,数据库

在Windows上部署MongoDB分片集群，你需要准备三种角色的服务器：配置服务器（Config Server）、分片（Shard）服务器和路由（Mongos）服务器。以下是部署的基本步骤和示例配置：

安装MongoDB并确保版本支持分片。
配置配置服务器，在mongod.cfg中设置configsvr标记。
配置分片服务器，在mongod.cfg中设置shardsvr和不同的端口。
启动配置服务器和分片服务器。
使用mongos启动路由服务，并添加配置服务器。
设置分片，通过mongos执行sh.addShard()。

以下是示例配置和启动命令：

配置服务器配置（config-svr.cfg）:




systemLog:
  destination: file
  logAppend: true
storage:
  dbPath: C:\data\configdb
net:
  port: 27019
  bindIp: localhost
processManagement:
  fork: true
replication:
  replSetName: configrs
sharding:
  clusterRole: configsvr

分片服务器配置（shard-svr1.cfg）:




systemLog:
  destination: file
  logAppend: true
storage:
  dbPath: C:\data\sharddb
net:
  port: 27018
  bindIp: localhost
processManagement:
  fork: true
replication:
  replSetName: shardrs
sharding:
  autoSplit: true
  clusterRole: shardsvr

启动配置服务器:




mongod --config config-svr.cfg

启动分片服务器:




mongod --config shard-svr1.cfg

启动路由服务（Mongos）:




mongos --configdb localhost:27019 --port 27017

在Mongos中添加分片:




sh.addShard("localhost:27018")

确保你的防火墙和安全组设置允许相应端口的通信。这只是一个基础示例，根据你的实际网络环境和安全需求，你可能需要进行相应的调整。

- 阅读更多 -

SpringMVC进阶（自定义拦截器以及异常处理）

System

2024-09-09

所有,java

在Spring MVC中，自定义拦截器可以用于拦截请求并在其处理之前或之后执行一些逻辑。同时，自定义异常处理可以帮助我们更优雅地处理和响应错误情况。

以下是一个简单的自定义拦截器和异常处理器的示例：

自定义拦截器：




import org.springframework.web.servlet.HandlerInterceptor;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
public class CustomInterceptor implements HandlerInterceptor {
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
        // 在请求处理之前执行的逻辑
        return true; // 如果返回false，则停止流程，api不会被调用
    }
 
    @Override
    public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) {
        // 在请求处理之后，视图被渲染之前执行的逻辑
    }
 
    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) {
        // 在整个请求结束之后执行的逻辑
    }
}

自定义异常处理器：




import org.springframework.web.servlet.HandlerExceptionResolver;
import org.springframework.web.servlet.ModelAndView;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
public class CustomExceptionResolver implements HandlerExceptionResolver {
    @Override
    public ModelAndView resolveException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) {
        // 创建ModelAndView对象，将之设置为错误视图，并添加错误信息
        ModelAndView modelAndView = new ModelAndView();
        modelAndView.addObject("error", ex.getMessage());
        modelAndView.setViewName("error"); // 假设有一个名为error的视图用于显示错误信息
        return modelAndView;
    }
}

在Spring MVC配置中添加自定义拦截器和异常处理器：




import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
 
@Configuration
public class WebConfig implements WebMvcConfigurer {
 
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(new CustomInterceptor());
    }
 
    @Override
    public void configureHandlerExceptionReso

- 阅读更多 -

Oracle日志文件清理

System

2024-09-09

所有,数据库

在Oracle数据库中，清理日志文件通常涉及到删除旧的归档日志文件，以释放磁盘空间。以下是一个简单的SQL脚本，用于删除超过特定天数的归档日志文件：




DECLARE
  v_archived_scn   NUMBER;
  v_dest_id         NUMBER;
  v_error           VARCHAR2(500);
BEGIN
  -- 设置保留的天数
  v_archived_scn := DBMS_FLASHBACK.GET_SYSTEM_CHANGE_NUMBER - (24 * 60 * 60 * 100); -- 24小时前
 
  -- 获取目标日志的ID，这里假设是归档日志的目的地
  SELECT dest_id INTO v_dest_id FROM v$archived_dest WHERE dest_name = '日志目的地名称';
 
  -- 删除旧的归档日志
  DBMS_ARCHIVE_ADMIN.GATHER_STALE_ARCHIVELOG_FILES(
    stale_scn => v_archived_scn,
    dest_id   => v_dest_id,
    min_slack => 0,
    max_slack => 1000000000,
    error     => v_error
  );
 
  -- 如果有错误，输出错误信息
  IF v_error IS NOT NULL THEN
    DBMS_OUTPUT.PUT_LINE('Error: ' || v_error);
  END IF;
END;
/

请注意，在执行此操作之前，确保您已经备份了所有重要的数据，并且理解这些命令的作用，因为删除归档日志文件可能会影响恢复操作和数据保护。

此外，在实际环境中，您可能需要根据具体情况调整保留策略，例如保留足够的日志以应对可能的恢复需求，或者保留最近一定时间内的日志以便于调查和分析问题。

- 阅读更多 -