分类 java 下的文章

【WEEK8】【DAY5】Spring Boot Operational Principles【English Version】

2024-09-09

在Spring Boot中，操作原则主要指导我们如何有效地进行开发和部署生产级别的应用程序。以下是一些操作原则的概述和示例：

灵活的配置：使用Spring Boot的外部化配置功能，可以轻松更改应用程序的配置而不需要重新编译代码。
```
server:
  port: 8080
```

自动化配置：Spring Boot的自动配置功能可以减少样板式的配置代码。




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

健壮的健康检查：Spring Boot的actuator模块提供了健康检查、度量收集等功能，可以帮助我们监控应用程序的运行状态。
```
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
```

生产级别的功能：例如，使用Spring Security来保护应用程序，使用Spring Data JPA进行数据库访问等。




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

持续集成和部署：通过持续集成和部署工具（如Jenkins, Travis CI）自动化部署流程。

日志管理：使用logback或log4j2等日志框架来管理应用程序的日志。




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

异步和非阻塞IO：使用Spring WebFlux进行异步编程，提高系统的可伸缩性。




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

性能监控和优化：使用Spring Boot Actuator的metrics端点来监控应用程序性能，并采取措施进行优化。

这些操作原则有助于开发者写出易于维护、可伸缩和安全的Spring Boot应用程序。

- 阅读更多 -

SpringCloud + Nacos配置文件加载顺序和优先级详解

System

2024-09-09

所有,java

Spring Cloud Nacos Config 的配置文件加载顺序和优先级如下：

外部配置文件：在启动 Spring Boot 应用时通过命令行参数指定的外部配置文件，如java -jar yourapp.jar --spring.config.location=file:/path/to/application.properties。
配置中心的配置文件：Nacos Config 中的配置文件，按照 Data ID 和 Group 从 Nacos 服务器加载。
本地配置文件：位于file:/${user.home}/${spring.config.name}/${spring.config.name}.properties或file:/${user.home}/${spring.config.name}/${spring.config.name}.yml的本地配置文件。
默认配置文件：位于classpath:/application.properties或classpath:/application.yml的默认配置文件。

在所有这些位置中，优先级从高到低是：外部配置文件 > 配置中心的配置文件。也就是说，如果在 Nacos 中有相同的配置项，并且该配置项也通过外部配置文件或本地配置文件进行了覆盖，那么最终生效的是外部配置文件或本地配置文件中的值。

具体的配置优先级如下：

bootstrap.yml 或 bootstrap.properties 中的spring.cloud.nacos.config部分配置
环境变量
JVM 系统属性
外部配置文件（如命令行参数指定的--spring.config.location）
本地配置文件（如application.properties）
配置中心的配置文件（Data ID 和 Group 指定的配置）

注意：bootstrap.yml 或 bootstrap.properties 的优先级高于其他配置源。

在实际使用中，可以通过设置spring.cloud.nacos.config.extension-configs[n].data-id、spring.cloud.nacos.config.extension-configs[n].group、spring.cloud.nacos.config.extension-configs[n].refresh等属性来指定加载的 Data ID 和 Group，以及是否启用自动刷新。

示例代码：




spring:
  cloud:
    nacos:
      config:
        server-addr: 127.0.0.1:8848
        namespace: 001f2e3a-4d37-436e-9dff-010hyc45kab
        group: DEFAULT_GROUP
        extension-configs:
          - data-id: common.properties
            group: DEFAULT_GROUP
            refresh: true

在这个配置中，除了默认的配置中心配置文件之外，还会额外加载common.properties配置文件，并且开启自动刷新。

- 阅读更多 -

Linux安装jdk&tomcat&MySQl一战完成

System

2024-09-09

所有,java

以下是一个简化的Linux脚本，用于安装JDK、Tomcat和MySQL。请注意，这个脚本只是一个示例，并且假设你已经具备了相应的权限（例如使用了sudo）。




#!/bin/bash
 
# 安装JDK
install_jdk() {
    local version=$1
    local install_dir=$2
 
    # 下载JDK
    wget --no-check-certificate -c -O jdk.tar.gz "http://download.oracle.com/otn-pub/java/jdk/$version/jdk-$version-linux-x64.tar.gz"
 
    # 解压JDK
    mkdir -p $install_dir
    tar -zxf jdk.tar.gz -C $install_dir
 
    # 设置环境变量
    echo "export JAVA_HOME=$install_dir/jdk-$version" | sudo tee -a /etc/profile
    echo "export PATH=\$PATH:\$JAVA_HOME/bin" | sudo tee -a /etc/profile
 
    source /etc/profile
}
 
# 安装Tomcat
install_tomcat() {
    local version=$1
    local install_dir=$2
 
    # 下载Tomcat
    wget --no-check-certificate -c -O tomcat.tar.gz "https://downloads.apache.org/tomcat/tomcat-$version/v$version/bin/apache-tomcat-$version.tar.gz"
 
    # 解压Tomcat
    mkdir -p $install_dir
    tar -zxf tomcat.tar.gz -C $install_dir
 
    # 启动Tomcat
    $install_dir/apache-tomcat-$version/bin/startup.sh
}
 
# 安装MySQL
install_mysql() {
    local version=$1
 
    # 下载MySQL
    wget --no-check-certificate -c -O mysql.tar.gz "https://dev.mysql.com/get/Downloads/MySQL-${version}/mysql-${version}.tar.gz"
 
    # 安装MySQL依赖
    sudo apt-get install -y cmake ncurses-dev
 
    # 编译安装MySQL
    tar -zxf mysql.tar.gz
    cd mysql-${version}
    cmake . -LH
    make
    sudo make install
 
    # 配置MySQL（这里省略了具体配置步骤，需要根据实际情况设置）
    ...
 
    # 启动MySQL
    sudo /usr/local/mysql/bin/mysqld_safe &
}
 
# 调用函数安装
install_jdk 8 /usr/local/java
install_tomcat 9 /usr/local/tomcat
install_mysql 5.7

请注意，这个脚本只是一个示例，并且可能需要根据你的Linux发行版和环境进行一些调整。例如，安装JDK和MySQL可能会有不同的包管理器和依赖，你可能需要根据你的发行版（如Debian、Ubuntu、CentOS等）来安装这些依赖。对于Tomcat，你可能需要根据你想要安装的版本调整下载链接。

System

2024-09-09

所有,java

报错信息“Cannot access ‘org.springframework.context.ConfigurableApplicationContext‘”通常表明Java编译器无法访问到Spring框架的某个类。这可能是因为以下原因：

缺少依赖：项目中可能没有包含Spring框架的相关依赖。
依赖版本不兼容：项目中包含的Spring框架依赖版本与其他库不兼容。
依赖未正确导入：可能是由于IDE配置不正确或者Maven/Gradle配置不当导致依赖未能正确导入。

解决方法：

检查项目的依赖管理文件（如pom.xml或build.gradle），确保已经添加了Spring Context的依赖，并且版本是适当的。
如果使用IDE（如IntelliJ IDEA或Eclipse），请确保依赖已经被正确导入。
如果依赖版本存在冲突，尝试解决版本冲突，或者更新至兼容的版本。
清理并重新构建项目，确保所有的依赖都已经下载并且没有缓存的问题。

例如，如果你使用Maven，可以尝试运行以下命令：




mvn clean install

如果你使用Gradle，可以运行：




gradle clean build

这些命令会清理旧的构建文件，并重新构建项目，有助于解决依赖问题。

- 阅读更多 -

SpringBoot集成系列--Flowable

System

2024-09-09

所有,java

Flowable 是一个用 Java 编写的轻量级业务流程引擎，它实现了 BPMN 2.0 标准。Flowable 可以在 Apache 许可下免费用于商业和开源目的。

Spring Boot 与 Flowable 的集成可以通过以下步骤实现：

在 Spring Boot 项目的 pom.xml 文件中添加 Flowable 依赖。




<dependencies>
    <!-- Flowable 核心库 -->
    <dependency>
        <groupId>org.flowable</groupId>
        <artifactId>flowable-engine</artifactId>
        <version>6.7.2</version>
    </dependency>
    <!-- Flowable 任务服务（可选，如果需要与流程相关的界面交互） -->
    <dependency>
        <groupId>org.flowable</groupId>
        <artifactId>flowable-task</artifactId>
        <version>6.7.2</version>
    </dependency>
    <!-- Flowable rest API（可选，如果需要通过 REST 方式与流程交互） -->
    <dependency>
        <groupId>org.flowable</groupId>
        <artifactId>flowable-rest</artifactId>
        <version>6.7.2</version>
    </dependency>
    <!-- Flowable 事件订阅（可选，如果需要通过事件订阅方式与流程交互） -->
    <dependency>
        <groupId>org.flowable</groupId>
        <artifactId>flowable-eventregistry-spring</artifactId>
        <version>6.7.2</version>
    </dependency>
</dependencies>

在 application.properties 或 application.yml 配置文件中配置 Flowable。




# 数据库配置
spring.datasource.url=jdbc:mysql://localhost:3306/flowable?useSSL=false
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
 
# 流程引擎配置
flowable.database-schema-update=true
flowable.async-executor-activate=false

在 Spring Boot 启动类中配置 Flowable 的 ProcessEngine。




import org.flowable.engine.ProcessEngine;
import org.flowable.spring.boot.EngineConfigurationKey;
import org.flowable.spring.boot.FlowableServletDeploymentListener;
import org.flowable.spring.boot.SpringBootProcessEngineConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
 
@SpringBootApplication
public class FlowableApplication {
 
    public static void main(String[] args) {
        SpringApplication.run(FlowableApplication.class, args);
    }
 
    @Bean
    public SpringBootProcessEngineConfiguration processEngineConfig

- 阅读更多 -

SpringCloud学习笔记 - Boot和Cloud版本选型

System

2024-09-09

所有,java

Spring Boot和Spring Cloud版本的兼容性问题是一个常见的问题。为了避免潜在的错误和兼容性问题，建议参考Spring官方文档提供的兼容性指南。

以下是一个兼容性对照表的示例代码，这不是完整的代码，而是说明如何查看兼容性对照表。




// 导入Spring Cloud和Spring Boot版本兼容性的类
import org.springframework.cloud.spring.boot.project.Version;
 
// 定义Spring Cloud和Spring Boot版本的兼容性
public class CompatibilityMatrix {
    public static void main(String[] args) {
        // 获取Spring Cloud的版本
        Version springCloudVersion = Version.getCurrentVersion();
 
        // 获取Spring Boot的版本
        String springBootVersion = "2.3.12.RELEASE"; // 示例版本
 
        // 检查版本兼容性
        boolean isCompatible = springCloudVersion.isCompatibleWith(springBootVersion);
 
        // 输出结果
        System.out.println("Spring Cloud " + springCloudVersion + " is compatible with Spring Boot " + springBootVersion + ": " + isCompatible);
    }
}

在实际开发中，你需要根据项目需求选择合适的Spring Boot和Spring Cloud版本，并参考Spring官方文档提供的兼容性指南进行选型。

System

2024-09-09

所有,java

在Spring Cloud Alibaba微服务从入门到进阶(五)(1)中，我们已经介绍了网络安全和网络编程的相关内容，这里我们将对这些内容进行一个总结。

网络安全概述
网络安全是指保护网络系统免受未授权的非法访问、破坏、监控或者破坏的措施。
加密技术
加密技术主要有对称加密和非对称加密。对称加密算法的速度快，但是安全性低；非对称加密算法的速度慢，但是安全性高。
传输层安全协议TLS
TLS是提供网络通信过程中的数据加密、服务器认证和消息完整性验证的一种安全协议。
SSL/TLS的区别
SSL(Secure Sockets Layer)和TLS(Transport Layer Security)都是为网络通信提供安全和数据加密的技术。SSL是TLS的前身，两者的主要区别在于它们所支持的协议标准不同，SSL支持的是SSL3.0，而TLS支持的是TLS1.0及其以上版本。
网络编程
网络编程主要涉及到套接字(socket)编程，套接字是网络通信的基本构件，通过套接字可以实现不同设备之间的数据交换。
网络编程的要素
网络编程通常包括以下要素：

服务器地址：确定服务器的IP地址和端口号。
通信协议：选择一个合适的通信协议，如TCP或UDP。
数据包处理：发送和接收数据时，需要对数据进行封装和解封装。

网络编程的步骤
网络编程通常包括以下步骤：

创建套接字(socket)。
绑定套接字到一个本地地址和端口上。
监听客户端的请求。
接受客户端的连接请求。
发送和接收数据。
关闭套接字。

网络编程的技巧

异步处理：使用非阻塞I/O或者事件驱动模型，提高系统的并发处理能力。
错误处理：在网络编程中，错误处理是非常重要的，需要对所有可能出现的错误进行处理。
超时设置：设置合理的超时时间，避免因为网络问题导致的程序无限等待。
资源管理：确保在出现异常的情况下也能正确释放资源，防止资源泄露。

综上所述，网络安全主要通过加密技术和传输层安全协议TLS来保障，而网络编程则涉及到套接字编程、地址选择、协议选择、数据处理等步骤，同时还需注意异步处理、错误处理、超时设置和资源管理等技巧。

- 阅读更多 -

SpringBoot整合EMQX（MQTT协议）

System

2024-09-09

所有,java

Spring Boot整合EMQX（MQTT协议）主要涉及到以下几个步骤：

引入Spring Boot的MQTT依赖。
配置MQTT连接参数。
创建MQTT消息监听器。
发送和接收MQTT消息。

以下是一个简单的例子：

添加依赖到你的pom.xml：




<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-mqtt</artifactId>
    <version>5.5.1</version>
</dependency>

在application.properties中配置MQTT连接参数：




spring.mqtt.username=admin
spring.mqtt.password=public
spring.mqtt.url=tcp://localhost:1883
spring.mqtt.client.id=clientId
spring.mqtt.default.topic=testTopic

创建MQTT配置类：




@Configuration
public class MqttConfig {
 
    @Value("${spring.mqtt.username}")
    private String username;
 
    @Value("${spring.mqtt.password}")
    private String password;
 
    @Value("${spring.mqtt.url}")
    private String url;
 
    @Value("${spring.mqtt.client.id}")
    private String clientId;
 
    @Value("${spring.mqtt.default.topic}")
    private String defaultTopic;
 
    @Bean
    public MqttPahoClientFactory mqttClientFactory() {
        DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
        MqttConnectOptions options = new MqttConnectOptions();
        options.setServerURIs(new String[]{url});
        options.setUserName(username);
        options.setPassword(password.toCharArray());
        factory.setConnectionOptions(options);
        return factory;
    }
 
    @Bean
    public MessageChannel mqttInputChannel() {
        return new DirectChannel();
    }
 
    @Bean
    public MessageProducer inbound() {
        MqttPahoMessageDrivenChannelAdapter adapter =
                new MqttPahoMessageDrivenChannelAdapter(clientId, mqttClientFactory(), defaultTopic);
        adapter.setQos(1);
        adapter.setOutputChannel(mqttInputChannel());
        return adapter;
    }
}

创建监听器来接收消息：




@Component
public class MqttReceiver {
 
    @Autowired
    private SimpMessagingTemplate simpMessagingTemplate;
 
    @JmsListener(destination = "testTopic")
    public void receiveMessage(String payload) {
        System.out.println("Received Message: " + payload);
        // 可以进行进一步处理，并通过SimpMessagingTemplate转发消息等。
    }
}

发送消息的方法：




@Autowired
private MqttPahoClientFactory mqttClientFactory;
 
@Autowired
private MessageChannel mqttOutboundChannel;
 
public void sendMessage(S

- 阅读更多 -

【SpringCloud】Spring Cloud Gateway熔断降级

System

2024-09-09

所有,java

在Spring Cloud Gateway中，我们可以使用Hystrix进行熔断降级操作。以下是一个简单的示例，展示如何为Gateway的路由配置熔断降级逻辑。

首先，确保你的项目中包含了Spring Cloud Gateway、Hystrix以及Hystrix Dashboard的依赖。




<dependencies>
    <!-- Spring Cloud Gateway -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-gateway</artifactId>
    </dependency>
    <!-- Hystrix -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
    </dependency>
</dependencies>

在application.yml中配置Gateway路由，并为需要熔断的服务添加熔断器配置。




spring:
  cloud:
    gateway:
      routes:
        - id: my_service
          uri: http://localhost:8081
          predicates:
            - Path=/myservice/**
          filters:
            - name: Hystrix
              args:
                name: fallbackcmd
            - name: RewritePath
              args:
                regexp: /myservice/(?<path>.*)
                replacement: /${path}

创建一个回退的Controller或者FallbackFactory。




@RestController
public class FallbackController {
 
    @RequestMapping("/fallback")
    public Mono<String> handleFallback() {
        return Mono.just("fallback response");
    }
}

配置HystrixCommand。




@Configuration
public class HystrixConfig {
 
    @Bean
    public CommandWithFallback<?> fallbackCommand() {
        return new CommandWithFallback<Object>() {
            @Override
            protected Observable<Object> run() {
                // 这里放置原始请求逻辑
                return null;
            }
 
            @Override
            protected Observable<Object> getFallback() {
                // 当原始请求失败时执行的逻辑
                return Observable.just("fallback response");
            }
        };
    }
}

在这个配置中，如果my_service的服务响应超时或者失败，Gateway会自动调用FallbackController中定义的回退方法返回一个默认的响应。这样就实现了熔断降级的功能。

- 阅读更多 -

Spring boot集成通义千问大模型实现智能问答

System

2024-09-09

所有,java

为了提供一个完整的解决方案，我们需要假设已经有了一个可用的Spring Boot项目，并且已经集成了通义千问大模型的接口。以下是一个简化的代码示例，展示了如何在Spring Boot应用中使用通义千问大模型来提供智能问答服务：




import com.canonical.EdsService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
 
@RestController
public class QuestionAnsweringController {
 
    private final EdsService edsService;
 
    @Autowired
    public QuestionAnsweringController(EdsService edsService) {
        this.edsService = edsService;
    }
 
    @GetMapping("/ask")
    public String askQuestion(@RequestParam String question) {
        return edsService.askQuestion(question);
    }
}

在这个例子中，我们定义了一个QuestionAnsweringController，它提供了一个通过GET请求访问的/ask接口，接收一个问题作为参数，并返回通义千问大模型生成的答案。EdsService是通义千问大模型的抽象接口，它封装了与模型交互的细节。

请注意，这个代码示例假定EdsService已经定义了一个askQuestion方法，该方法接收一个问题作为参数，并返回模型生成的答案。实际的实现细节会依赖于通义千问大模型的API和具体的技术栈。

- 阅读更多 -