分类后端技术下的文章

2024-08-28

由于提供整个Java项目源代码和文档可能涉及版权和隐私问题，我无法直接提供源代码和文档。但我可以提供一个概念性的解决方案和示例代码。

假设我们要创建一个简单的分布式电商系统中的商品服务模块，以下是一个简化的代码示例：




// 假设的商品服务模块
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
 
@RestController
public class ProductController {
 
    // 获取商品信息的接口
    @GetMapping("/product")
    public Product getProduct(@RequestParam("id") Long id) {
        // 假设这里是从数据库或者缓存中获取商品信息
        Product product = new Product();
        product.setId(id);
        product.setName("示例商品");
        product.setPrice(99.99);
        return product;
    }
}
 
class Product {
    private Long id;
    private String name;
    private Double price;
 
    // 省略getter和setter方法
}

这个示例展示了一个简单的RESTful API，用于获取商品信息。在实际的项目中，你需要实现数据库访问逻辑、异常处理、安全控制、服务发现和负载均衡等功能。

请注意，这个示例不包含Spring Cloud的特定功能，如服务注册与发现、配置管理、负载均衡、断路器等。这些功能需要通过Spring Cloud的库和注解实现，并且需要在分布式系统的上下文中进行配置。

- 阅读更多 -

【Redis一】Redis配置与优化

System

2024-08-28

所有,redis

在配置和优化Redis时，可以通过修改Redis配置文件来实现。以下是一些关键配置和优化技巧的例子：

设置最大内存（maxmemory）:




maxmemory 2gb

选择内存淘汰策略（maxmemory-policy）:




maxmemory-policy allkeys-lru

设置数据持久化（appendonly）:




appendonly yes

设置持久化文件的写入频率（appendfsync）:




appendfsync everysec

设置客户端超时时间（timeout）:




timeout 300

设置最大连接数（maxclients）:




maxclients 10000

配置网络IO模型（io-model），根据系统选择:




io-model reactor

设置TCP连接的监听队列长度（tcp-backlog）:




tcp-backlog 511

优化实践可能包括调整数据结构、使用管道和批量操作、合理使用键的生命周期等。

以下是一个基本的Redis配置文件示例：




# Redis配置文件示例
 
# 设置Redis监听的IP地址
bind 127.0.0.1
 
# 设置Redis监听的端口
port 6379
 
# 设置客户端连接超时时间
timeout 300
 
# 设置日志级别
loglevel notice
 
# 设置日志文件路径
logfile "/var/log/redis/redis-server.log"
 
# 设置数据库数量
databases 16
 
# 设置最大内存
maxmemory 2gb
 
# 设置内存淘汰策略
maxmemory-policy allkeys-lru
 
# 开启数据持久化
appendonly yes
 
# 设置AOF持久化策略
appendfsync everysec
 
# 设置TCP连接的监听队列长度
tcp-backlog 511
 
# 设置最大连接数
maxclients 10000
 
# 设置IO模型
io-model reactor
 
# 设置是否允许保存空数据库
save 900 1
save 300 10
save 60 10000
 
# 设置密码
requirepass yourpassword

在实际部署时，应根据服务器的硬件和需求进行具体的配置调整。

- 阅读更多 -

Mongodb6.0在CentOS7上安装实践

System

2024-08-28

所有,数据库




#!/bin/bash
 
# 更新系统包信息
sudo yum update -y
 
# 安装MongoDB的官方仓库
sudo tee /etc/yum.repos.d/mongodb-org-6.0.repo <<EOF
[mongodb-org-6.0]
name=MongoDB Repository
baseurl=https://repo.mongodb.org/yum/redhat/\$releasever/mongodb-org/6.0/x86_64/
gpgcheck=1
enabled=1
gpgkey=https://www.mongodb.org/static/pgp/server-6.0.asc
EOF
 
# 安装MongoDB
sudo yum install -y mongodb-org
 
# 启动MongoDB并设置开机自启
sudo systemctl start mongod
sudo systemctl enable mongod
 
# 检查MongoDB服务状态
sudo systemctl status mongod

这段脚本首先更新系统包信息，然后安装MongoDB的官方仓库配置，接着安装MongoDB，并启动及设置开机自启。最后，检查MongoDB服务的状态。这样的实践方式有利于在安装MongoDB时避免潜在的依赖问题，并确保服务能够在系统启动时自动运行。

- 阅读更多 -

Oracle创建表空间和用户并还原数据库备份

System

2024-08-28

所有,数据库




-- 创建表空间
CREATE TABLESPACE my_tablespace
DATAFILE 'path_to_datafile/my_tablespace.dbf' SIZE 100M AUTOEXTEND ON NEXT 10M MAXSIZE UNLIMITED
LOGGING
ONLINE
PERMANENT
EXTENT MANAGEMENT LOCAL;
 
-- 创建用户并指定表空间
CREATE USER my_user IDENTIFIED BY my_password
DEFAULT TABLESPACE my_tablespace
TEMPORARY TABLESPACE temp
PROFILE DEFAULT
ACCOUNT UNLOCK;
 
-- 给用户授权
GRANT CONNECT, RESOURCE TO my_user;
 
-- 还原数据库备份，这里需要使用操作系统命令
-- 假设expdp命令可用，并且已经有了足够权限
-- 这里的'my_directory'是一个已经定义的目录对象，指向有效的文件夹
-- 备份文件名为'backup_file.dmp'
RESTORE DATABASE WITH CONTROLFILE FROM 'backup_file.dmp' USING BACKUP CONTROLFILE;

注意：

需要根据实际情况调整数据文件路径、大小、自动扩展设置。
用户名、密码和表空间名需要根据实际情况进行替换。
在实际操作中，还原数据库备份通常需要数据库管理员权限，并且可能涉及到更多的参数和步骤。

- 阅读更多 -

SpringBoot时区转换规则

System

2024-08-28

所有,java

在Spring Boot中，时区转换通常是通过配置application.properties或application.yml文件来实现的。你可以设置JVM的时区或者使用@DateTimeFormat注解来指定时区。

设置JVM时区：
在application.properties中设置JVM的默认时区：
```
spring.jpa.properties.hibernate.jdbc.time_zone=UTC
```
或者在application.yml中设置：
```
spring:
  jpa:
    properties:
      hibernate:
        jdbc:
          time_zone: UTC
```
这将设置Hibernate JDBC连接使用UTC时区。

使用@DateTimeFormat注解指定时区：

在你的Controller中，你可以使用@DateTimeFormat注解来指定日期时间的格式和时区：




@RestController
public class MyController {
    
    @PostMapping("/dates")
    public void handleDates(
        @RequestParam("date")
        @DateTimeFormat(iso = DateTimeFormat.ISO.DATE, pattern = "yyyy-MM-dd", timezone = "UTC") LocalDate date) {
        // ...
    }
}

这将确保传入的日期时间字符串被解析为UTC时区的日期时间。

设置服务器时区：
如果你的应用程序运行在Web服务器上，例如Tomcat，你可以在服务器的环境设置中设置时区：
```
JAVA_OPTS="-Duser.timezone=UTC"
```
或者在启动脚本中设置。

确保选择的时区符合你的应用程序的需求和数据的时区要求。

- 阅读更多 -

Tomcat 架构分析及配置详解

System

2024-08-28

所有,java

Tomcat 是一个开源的 Java Servlet 容器，提供了对 Servlet 和 JSP 的支持。以下是对 Tomcat 的核心组件以及配置方法的简要说明：

Connector: 负责处理网络连接，包括HTTP和AJP。
Container: 由Engine、Host、Context和Wrapper组成，负责处理请求。
Service: 包含一个或多个Connector和一个Engine，用于处理请求。

配置文件:

server.xml: 定义Service、Connector、Listener和GlobalNamingResources。
web.xml: 定义Servlet、Filter和Listener的默认映射。
context.xml: 为特定Web应用程序提供全局配置。

配置示例:




<Server port="8005" shutdown="SHUTDOWN">
  <Service name="Catalina">
    <Connector port="8080" protocol="HTTP/1.1" connectionTimeout="20000" redirectPort="8443" />
    <Engine name="Catalina" defaultHost="localhost">
      <Host name="localhost" appBase="webapps" unpackWARs="true" autoDeploy="true">
        <Context path="/myapp" docBase="/path/to/myapp" reloadable="true" />
      </Host>
    </Engine>
  </Service>
</Server>

在这个配置中，我们定义了一个名为Catalina的Service，它包含一个监听在端口8080上的HTTP连接器，以及一个名为Catalina的Engine，它管理了一个名为localhost的Host，该Host 从webapps目录下部署应用程序，并且为路径/myapp定义了一个Context，该Context 指向文件系统上的一个特定位置。

配置说明:

port: 指定Tomcat监听的关闭指令端口。
shutdown: 指定关闭Tomcat的命令字符串。
Service name: 标识Service。
Connector port: 定义连接器监听的端口。
protocol: 指定协议，如HTTP/1.1。
Engine name: 标识Engine。
Host name: 定义虚拟主机名称。
appBase: 应用程序基本目录。
Context path: 应用的上下文路径。
docBase: 应用的文档基础目录。

这只是Tomcat配置的一个简单概述，实际配置可能会涉及更多的参数和设置。

- 阅读更多 -

vue3+SpringBoot+postgresql 项目前后端传参

System

2024-08-28

所有,数据库

在Vue 3 + Spring Boot + PostgreSQL项目中，前后端传递参数通常涉及以下步骤：

前端（Vue 3）：

定义API接口。
使用axios或者其他HTTP客户端发送请求。
绑定数据到请求参数。

后端（Spring Boot）：

创建Controller类。
定义请求处理方法。
使用@RequestBody或@RequestParam等注解接收参数。

以下是一个简单的例子：

前端（Vue 3）：




// 使用axios发送POST请求
import axios from 'axios';
 
const postData = async (url = '', data = {}) => {
  const response = await axios.post(url, data);
  return response.data;
};
 
// 发送数据到后端
const sendData = async () => {
  const url = 'http://localhost:8080/api/data';
  const data = { key: 'value' };
  try {
    const result = await postData(url, data);
    console.log(result);
  } catch (error) {
    console.error(error);
  }
};
 
// 调用函数发送数据
sendData();

后端（Spring Boot）：




import org.springframework.web.bind.annotation.*;
 
@RestController
@RequestMapping("/api")
public class DataController {
 
  @PostMapping("/data")
  public String receiveData(@RequestBody Map<String, String> data) {
    // 处理接收到的数据
    String receivedValue = data.get("key");
    // 返回响应
    return "Received: " + receivedValue;
  }
}

在这个例子中，前端使用axios库发送一个POST请求，后端的Controller接收这个请求并处理。这里的@RequestBody注解用于将请求体中的JSON数据绑定到方法参数上。如果是表单数据或简单参数，可以使用@RequestParam注解。

- 阅读更多 -

Tomcat线程实践

System

2024-08-28

所有,java

Tomcat是一个开源的Java Servlet容器，也可以作为Java Web应用服务器。以下是一些与Tomcat线程相关的实践：

调整连接器（Connector）的线程池配置：




<Connector port="8080" protocol="HTTP/1.1"
           connectionTimeout="20000"
           redirectPort="8443"
           executor="tomcatThreadPool">
    <Executor name="tomcatThreadPool"
              namePrefix="catalina-exec-"
              maxThreads="200" minSpareThreads="20"/>
</Connector>

在这个例子中，我们配置了Tomcat的连接器使用名为tomcatThreadPool的执行器，并设置了最大线程数（maxThreads）和最小空闲线程数（minSpareThreads）。

使用异步Servlet处理长时间运行的任务：




public class AsyncServlet extends HttpServlet {
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) {
        AsyncContext asyncContext = req.startAsync();
        asyncContext.setTimeout(30000);
        asyncContext.start(new Runnable() {
            @Override
            public void run() {
                longProcessing();
                asyncContext.complete();
            }
        });
    }
 
    private void longProcessing() {
        // 长时间运行的任务
    }
}

在这个例子中，我们创建了一个异步的Servlet，在doGet方法中，我们启动一个异步线程来处理长时间运行的任务，并在任务完成后调用asyncContext.complete()。

调整JVM的线程堆栈大小：

如果你的应用经常创建大量线程，或者线程的堆栈大小需要调整，可以在启动JVM时设置-Xss参数来调整线程的堆栈大小。




java -Xss128k -jar your-tomcat-app.war

在这个例子中，我们将每个线程的堆栈大小设置为128KB。

这些实践涵盖了Tomcat线程配置的基本方面，具体应用时需要根据实际需求和服务器的负载情况进行调整。

System

2024-08-28

所有,java

在Spring Security 6.0中，WebSecurityConfigurationAdapter已被弃用。如果您需要自定义安全配置，可以实现WebSecurityCustomizer接口或者继承WebSecurityConfigurerAdapter的替代方法。

以下是一个使用WebSecurityCustomizer的示例：




import org.springframework.security.config.annotation.web.builders.HttpSecurity;
import org.springframework.security.config.annotation.web.configuration.WebSecurityCustomizer;
import org.springframework.stereotype.Component;
 
@Component
public class CustomWebSecurity implements WebSecurityCustomizer {
 
    @Override
    public void customize(HttpSecurity http) throws Exception {
        http
            .authorizeRequests()
                .anyRequest().authenticated()
                .and()
            .formLogin()
                .loginPage("/login")
                .permitAll();
    }
}

如果您需要更多的自定义，可以创建一个配置类，使用@EnableWebSecurity注解，并提供一个继承了WebSecurityConfigurerAdapter的类，但不要覆盖configure(HttpSecurity)方法。




import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
 
@EnableWebSecurity
public class SecurityConfig extends WebSecurityConfigurerAdapter {
 
    // 其他自定义配置...
 
}

然后创建一个配置类来提供额外的配置：




import org.springframework.security.config.annotation.web.builders.HttpSecurity;
import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
import org.springframework.stereotype.Component;
 
@Component
public class CustomWebSecurityConfigurer extends WebSecurityConfigurerAdapter {
 
    @Override
    protected void configure(HttpSecurity http) throws Exception {
        http
            .authorizeRequests()
                .anyRequest().authenticated()
                .and()
            .formLogin()
                .loginPage("/login")
                .permitAll();
    }
}

确保这些配置类能够被Spring扫描到，例如通过@ComponentScan或者将它们放在正确的包中。

- 阅读更多 -

Spring Boot整合RabbitMQ

System

2024-08-28

所有,java

Spring Boot整合RabbitMQ通常涉及以下步骤：

添加依赖：在pom.xml中添加Spring Boot和RabbitMQ的依赖。




<dependencies>
    <!-- Spring Boot相关依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>
    <!-- RabbitMQ支持 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>
</dependencies>

配置RabbitMQ：在application.properties或application.yml中配置RabbitMQ连接信息。




# application.properties
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

创建配置类：配置消息队列、交换器、队列及绑定关系。




@Configuration
public class RabbitMQConfig {
 
    @Bean
    Queue queue() {
        return new Queue("myQueue", true);
    }
 
    @Bean
    DirectExchange exchange() {
        return new DirectExchange("myExchange");
    }
 
    @Bean
    Binding binding(Queue queue, DirectExchange exchange) {
        return BindingBuilder.bind(queue).to(exchange).with("myRoutingKey");
    }
}

发送消息：使用RabbitTemplate发送消息到RabbitMQ。




@Autowired
private RabbitTemplate rabbitTemplate;
 
public void sendMessage(String message) {
    rabbitTemplate.convertAndSend("myExchange", "myRoutingKey", message);
}

接收消息：使用@RabbitListener注解创建监听器来接收消息。




@Component
public class Receiver {
 
    @RabbitListener(queues = "myQueue")
    public void receiveMessage(String message) {
        System.out.println("Received <" + message + ">");
    }
}

以上步骤提供了一个基本的整合示例。在实际应用中，你可能需要根据具体需求进行更复杂的配置，比如消息确认、持久化、高可用性等。

- 阅读更多 -