1. 首页
  2. 分类
  3. 后端技术
springboot+mqtt使用总结
System
2024-08-29
所有,java



import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.MqttCallback;
 
public class MqttPushClient {
 
    private static final String HOST = "tcp://iot.eclipse.org:1883";
    private static final String CLIENTID = "MyClientID";
    private MqttClient client;
 
    public MqttPushClient() {
        try {
            client = new MqttClient(HOST, CLIENTID);
            MqttConnectOptions options = new MqttConnectOptions();
            options.setUserName("username");
            options.setPassword("password".toCharArray());
            options.setCleanSession(true);
            System.out.println("Connecting to broker: " + HOST);
            client.connect(options);
            client.setCallback(new MqttCallback() {
                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    System.out.println("Message arrived: " + new String(message.getPayload()));
                }
 
                public void connectionLost(Throwable cause) {
                    System.out.println("Connection lost");
                }
 
                public void deliveryComplete(IMqttDeliveryToken token) {
                    System.out.println("Delivery complete");
                }
            });
            System.out.println("Connected");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
    public void subscribe(String topic) {
        try {
            client.subscribe(topic);
            System.out.println("Subscribed to topic: " + topic);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
    public void publish(String topic, String content) {
        try {
            MqttMessage message = new MqttMessage(content.getBytes());
            MqttDeliveryToken token = client.publish(topic, message);
            token.waitForCompletion();
            System.out.println("Message published");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
    public void disconnect() {
        try {
            client.disconnect();
            System.out.println("Disconnected");
            client.close();
        } catch (Exception e) {
- 阅读更多 -
（亲测有效）SpringBoot项目集成腾讯云COS对象存储
System
2024-08-29
所有,java



import com.qcloud.cos.COSClient;
import com.qcloud.cos.ClientConfig;
import com.qcloud.cos.auth.BasicCOSCredentials;
import com.qcloud.cos.auth.COSCredentials;
import com.qcloud.cos.model.PutObjectRequest;
import com.qcloud.cos.model.PutObjectResult;
import com.qcloud.cos.region.Region;
 
// 1. 配置用户身份信息（secretId, secretKey）
String secretId = "您的腾讯云secretId";
String secretKey = "您的腾讯云secretKey";
COSCredentials cred = new BasicCOSCredentials(secretId, secretKey);
 
// 2. 配置客户端的配置项(可选)
ClientConfig clientConfig = new ClientConfig();
// 设置bucket的区域, COS地域的简称请参照 https://cloud.tencent.com/document/product/436/6224
clientConfig.setRegion("ap-nanjing");
 
// 3. 生成COS客户端
COSClient cosClient = new COSClient(cred, clientConfig);
 
// 4. 指定要上传的文件位置，在这里需要指定上传到COS的哪个BUCKET和对象键，即文件路径
File localFile = new File("C:\\Users\\Administrator\\Pictures\\cat.jpg");
InputStream input = new FileInputStream(localFile);
PutObjectRequest putObjectRequest = new PutObjectRequest("examplebucket-1250000000", "cat.jpg", input);
 
// 5. 执行上传操作，并获取上传操作结果
PutObjectResult putObjectResult = cosClient.putObject(putObjectRequest);
System.out.println(putObjectResult);
 
// 6. 关闭客户端
cosClient.shutdown();

这段代码展示了如何使用腾讯云COS SDK在Java中上传文件到COS。首先配置了用户的身份信息，然后设置了客户端的配置项，并创建了COS客户端。接着，指定了要上传的文件和COS中的存储位置，并执行上传操作。最后关闭了客户端以释放资源。

- 阅读更多 -
SpringCloud链路跟踪
System
2024-08-29
所有,java

Spring Cloud Sleuth 提供了一套完整的服务跟踪解决方案，它集成了Zipkin和Brave来实现链路追踪。

以下是使用 Spring Cloud Sleuth 进行链路追踪的基本步骤：

  1. 在你的 Spring Cloud 应用中添加依赖。



<!-- 添加 Spring Cloud Sleuth 依赖 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-sleuth</artifactId>
</dependency>
 
<!-- 如果你想使用 Zipkin 作为追踪信息收集器，还需要添加以下依赖 -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-sleuth-zipkin</artifactId>
</dependency>
  1. 配置 Zipkin 服务器的地址。

在 application.properties 或 application.yml 文件中添加以下配置：




# application.properties
spring.zipkin.base-url=http://localhost:9411
spring.sleuth.sampler.probability=1.0 # 设置为1.0表示记录所有请求，可以根据需要调整采样率

或者使用 YAML 格式：




# application.yml
spring:
  zipkin:
    base-url: http://localhost:9411
  sleuth:
    sampler:
      probability: 1.0 # 记录所有请求
  1. 启动 Zipkin 服务器。

你可以使用 Spring Cloud Sleuth 的依赖中包含的 Zipkin Server。

  1. 启动你的 Spring Cloud 应用，并进行正常的服务调用。
  2. 检查 Zipkin 界面。

启动 Zipkin 服务器后，你可以在浏览器中访问 http://localhost:9411 来查看服务跟踪信息。

以上步骤提供了一个基本的链路追踪设置，实际应用中可能需要根据具体需求进行配置调整。

- 阅读更多 -
VS+QT使用mysql数据库，以及可能遇到的问题
System
2024-08-29
所有,数据库

在Visual Studio中使用Qt连接MySQL数据库，首先确保已经安装了Qt的MySQL数据库驱动。以下是一个简单的示例代码，展示如何在Qt中使用MySQL数据库：

  1. 添加MySQL数据库支持：

    确保在你的项目文件（.pro）中添加了MySQL数据库模块。




QT += sql
  1. 连接到MySQL数据库：



#include <QSqlDatabase>
#include <QSqlError>
#include <QDebug>
 
QSqlDatabase db = QSqlDatabase::addDatabase("QMYSQL");
db.setHostName("localhost"); // 数据库服务器地址
db.setDatabaseName("mydb");  // 数据库名
db.setUserName("user");      // 用户名
db.setPassword("password");  // 密码
 
bool ok = db.open();
if(ok) {
    qDebug() << "数据库连接成功！";
    // 执行数据库操作
} else {
    qDebug() << "数据库连接失败：" << db.lastError().text();
}
  1. 执行数据库操作：



QSqlQuery query;
bool success = query.exec("SELECT * FROM mytable");
if(success) {
    while (query.next()) {
        QString field1 = query.value(0).toString();
        // 获取其他字段...
    }
} else {
    qDebug() << "查询失败：" << query.lastError().text();
}
  1. 关闭数据库连接：



db.close();

可能遇到的问题及解决方法：

  • 确保MySQL服务正在运行。
  • 检查数据库连接参数（主机名、数据库名、用户名和密码）是否正确。
  • 确保Qt的MySQL驱动已正确安装，如果未安装，需要下载并安装。
  • 检查防火墙设置，确保不会阻止对MySQL的连接。
  • 如果编译时出现错误，确保.pro文件中包含了sql模块。

确保在实际环境中更新数据库连接参数，并根据需要调整数据库操作。

- 阅读更多 -
postgresql分区表（partitioning）
System
2024-08-29
所有,数据库

在PostgreSQL中，您可以使用表分区来改善大型数据库的管理和查询性能。以下是创建分区表的基本步骤和示例代码：

  1. 定义分区键。
  2. 创建分区模板。
  3. 创建分区表。

示例代码：




-- 创建一个范围分区的主表
CREATE TABLE measurement (
    city_id         int not null,
    logdate         date not null,
    peaktemp        int,
    unitsales       int
) PARTITION BY RANGE (logdate);
 
-- 创建分区模板
CREATE TABLE measurement_y2020 PARTITION OF measurement
    FOR VALUES FROM ('2020-01-01') TO ('2021-01-01');
 
CREATE TABLE measurement_y2021 PARTITION OF measurement
    FOR VALUES FROM ('2021-01-01') TO ('2022-01-01');
 
-- 插入数据时，PostgreSQL会自动将数据放入正确的分区
INSERT INTO measurement (city_id, logdate, peaktemp, unitsales) VALUES (1, '2020-06-01', 22, 100);
 
-- 查询分区数据
SELECT * FROM measurement WHERE logdate >= '2020-01-01' AND logdate < '2021-01-01';

在这个例子中，我们创建了一个名为measurement的主表，并定义了logdate作为分区键。然后，我们创建了两个分区，measurement_y2020和measurement_y2021，分别对应2020年和2021年的数据。当插入带有日期的数据时，PostgreSQL会根据日期范围将数据放入正确的分区。查询时，只需要指定分区键所在的范围，PostgreSQL会自动优化查询以只扫描相关分区。

- 阅读更多 -
Spring Authorization Server实战
System
2024-08-29
所有,java

由于原代码已经是一个很好的实践，我们可以提取其中的核心部分来展示如何使用Spring Authorization Server：




@Configuration
public class SecurityConfig {
 
    @Bean
    SecurityFilterChain securityFilterChain(HttpSecurity http) throws Exception {
        http
            .authorizeHttpRequests(authorize -> authorize
                .anyRequest().authenticated()
            )
            .oauth2ResourceServer(OAuth2ResourceServerConfigurer::jwt);
        return http.build();
    }
 
    @Bean
    JwtDecoder jwtDecoder(OAuth2ResourceServerProperties properties) {
        return JwtDecoders.fromOidcIssuerLocation(properties.getJwt().getJwkSetUri());
    }
}

这个配置类定义了一个SecurityFilterChain，它配置了一个资源服务器来保护所有的端点，并且使用JWT作为认证方式。JwtDecoder则用于从提供的JWK set URI中解析和验证JWT令牌。这个配置类是Spring Security和Spring Authorization Server集成的一个很好的示例。

- 阅读更多 -
PostgreSQL 存储过程详细案例
System
2024-08-29
所有,数据库



-- 创建一个存储过程，用于计算两个给定点之间的距离
CREATE OR REPLACE FUNCTION distance_between_points(point1 geometry, point2 geometry)
RETURNS float8 AS $$
BEGIN
  RETURN ST_Distance(point1::geography, point2::geography);
END;
$$ LANGUAGE plpgsql IMMUTABLE STRICT;
 
-- 调用存储过程计算两点之间的距离
SELECT distance_between_points(
  ST_GeomFromText('POINT(-71.1043482 42.3150468)')
  , ST_GeomFromText('POINT(-70.885506 42.339829)')
);
 
-- 结果将是两点之间的距离，单位为米

这个例子展示了如何在PostgreSQL中创建一个计算两个地理坐标点之间距离的函数。函数使用PostGIS扩展中的ST_Distance函数，该函数接受两个地理坐标点并返回它们之间的距离。这个存储过程是不可变的（IMMUTABLE）且严格模式（STRICT），意味着它总是返回确定的结果，并且对于NULL输入会返回NULL。

- 阅读更多 -
Linux openEuler系统部署spring boot+vue前后端分离项目
System
2024-08-29
所有,java

在Linux openEuler系统上部署前后端分离的Spring Boot + Vue项目，你需要按照以下步骤操作：

  1. 安装Java环境：

    确保系统已安装Java，并配置好JAVA\_HOME环境变量。

  2. 安装和配置数据库（如MySQL）：

    创建数据库和用户，导入初始数据。

  3. 安装和配置Maven：

    用于编译Spring Boot项目。

  4. 安装Node.js和npm：

    Vue项目需要Node.js环境来构建。

  5. 配置后端服务：

    • 检出Spring Boot项目代码。
    • 在项目中配置数据库连接和其他必要配置。
    • 使用Maven打包项目。
    • 运行Spring Boot应用。

  6. 配置前端服务：

    • 检出Vue项目代码。
    • 安装依赖：npm install。
    • 构建项目：npm run build。
    • 将构建好的静态文件放到Spring Boot项目的静态资源目录下或者通过配置Nginx作为静态资源服务器。

  7. 配置反向代理服务器（Nginx）：

    • 安装Nginx。
    • 配置Nginx，设置前端资源代理和后端API接口代理。

  8. 部署应用并启动：

    • 启动数据库服务。
    • 启动后端Spring Boot应用。
    • 配置好Nginx。
    • 通过系统服务或者直接命令行启动Nginx。

以下是一个简化的示例配置，仅供参考：

后端Maven配置（pom.xml）




<build>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
        </plugin>
    </plugins>
</build>

Nginx 配置文件（/etc/nginx/nginx.conf或/etc/nginx/conf.d/your-project.conf）




server {
    listen 80;
 
    location / {
        root /path/to/your/frontend/build;
        try_files $uri $uri/ /index.html;
    }
 
    location /api/ {
        proxy_pass http://localhost:8080; # 假设后端运行在8080端口
        proxy_set_header Host $host;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
    }
}

启动后端Spring Boot应用




java -jar your-backend-application.jar

启动Nginx




systemctl start nginx

确保所有配置正确无误，并根据实际环境调整端口、路径和配置。记得开放必要的防火墙端口以允许外部访问。

- 阅读更多 -
PostgreSQL源码学习笔记-事务管理
System
2024-08-29
所有,数据库



-- 创建一个新的事务
START TRANSACTION;
 
-- 在事务中进行操作
INSERT INTO accounts (id, balance) VALUES (1, 1000.00);
UPDATE accounts SET balance = balance - 500.00 WHERE id = 1;
 
-- 如果一切正常，提交事务
COMMIT;
 
-- 如果操作遇到问题，回滚事务
ROLLBACK;

这段代码展示了在PostgreSQL中如何使用START TRANSACTION开始一个新事务，然后执行两个简单的操作：向accounts表中插入一条记录和更新该表中的某条记录。之后，根据操作结果是否成功，使用COMMIT或ROLLBACK来结束事务。这是数据库事务管理的基本用法，对于学习PostgreSQL的事务管理具有很好的示例价值。

- 阅读更多 -
【已解决】this version of the Java Runtime only recognizes class file versions up to 52.0
System
2024-08-29
所有,java

报错解释：

这个错误表明你的Java运行时环境（JRE）只能识别指定的Java类文件版本。通常，这意味着你的JRE版本较旧，无法运行较新版本的Java类文件，这是因为Java类文件的版本与JRE的版本是相互对应的。

解决方法：

  1. 更新你的Java运行时环境（JRE）或Java开发工具包（JDK）到与你要运行的类文件版本相匹配的版本。你可以从Oracle的官网或其他Java发行版（如OpenJDK）下载最新版本的JRE/JDK。
  2. 如果你不想更新Java环境，可以尝试编译你的Java源代码为与旧版本JRE兼容的类文件版本。使用javac编译器的-target和-source参数可以指定目标Java版本和源Java版本。

例如，如果你的JRE是Java 8，但你有一个为Java 11编译的类文件，你可以尝试使用以下命令来编译源代码：




javac -source 11 -target 1.8 YourClass.java

这将编译你的代码为与Java 8 兼容的格式。

  1. 如果你是在使用构建工具（如Maven或Gradle），确保你的pom.xml或build.gradle文件中配置了正确的Java版本。

总结，解决这个问题的关键是更新你的Java环境到能够支持你的类文件版本的版本。

- 阅读更多 -
Copyright © 2025 Tech Blog
All Right Reserved | 京ICP备19053165号