当前位置：首页 > news >正文

docker安装Emqx并使用自签名证书开启 SSL/TLS 连接

news 来源：原创 2025/7/15 7:26:13

docker安装Emqx并使用自签名证书开启 SSL/TLS 连接

一、获取自签名证书
- 1、创建openssl.cnf文件
- 2、生成证书自签名证书
二、docker安装EMQX
- 1、初始化目录
- 2、加载镜像文件并挂载相应的文件目录
- 3、启动docker容器
- 4、EMQX加载自签名证书
三、客户端MQTTX连接测试
四、Springboot整合

详细操作过程可以参考官方说明文档：官方说明文档
客户端TLS接入示例：客户端接入示例
从官方的文档中我们了解到，EMQX支持通过 X.509 证书实现单向和双向客户端/服务器互信认证，这里我们使用单项认证。

认证方式	说明	验证方式	优缺点
单向认证	客户端验证服务器身份，但服务器不验证客户端的身份	客户端通常不需要提供证书，仅需验证服务器的证书是否由受信任的证书颁发机构（CA）签发	只能实现通信数据的机密性和完整性，但无法保证通信双方的身份
双向认证	服务器和客户端彼此验证对方的身份	需要为每个设备签发证书，服务器验证客户端的证书以确认其身份的合法性	可以确保服务器和客户端之间的互信关系，并防止中间人攻击

一、获取自签名证书

1、创建openssl.cnf文件

[ req ]
default_bits        = 2048
default_keyfile     = server-key.pem
distinguished_name  = req_distinguished_name
x509_extensions     = v3_req
prompt = no[ req_distinguished_name ]
C = CN
ST = California
L = San Francisco
O = Example Organization
OU = Example Unit
CN = 192.168.3.51  # 这里设置为服务器的IP地址[ v3_req ]
subjectAltName = @alt_names[ alt_names ]
DNS.1 = 192.168.3.51  # 这里设置为服务器的IP地址
IP.1 = 192.168.3.51   # 这里设置为服务器的IP地址

2、生成证书自签名证书

在openssl.cnf目录下执行如下命令生成自签名证书：

openssl genpkey -algorithm RSA -out server-key.pem
openssl req -new -key server-key.pem -out server.csr -config openssl.cnf
openssl x509 -req -in server.csr -out server-cert.pem -signkey server-keyi.pem -days 3650 -extensions v3_req -extfile openssl.cnf

二、docker安装EMQX

1、初始化目录

mkdir -p /wz_conf/emqx/etc
mkdir -p /wz_conf/emqx/data
mkdir -p /wz_conf/emqx/etc

2、加载镜像文件并挂载相应的文件目录

docker load -i emqx.tar.gz
这里也可以使用docker pull emqx/emqx:latest拉取镜像包

cd /wz_conf/emqx  
chmod 777 ./*  
docker run -d --privileged=true --name emqx emqx/emqx:latest
# 将容器中的相关配置文件挂在到物理机，方便后续修改，*******则为容器id
docker cp *********:/opt/emqx/etc /wz_conf/emqx  
docker stop *******
docker rm *******

3、启动docker容器

docker run -d \
--privileged=true \
--restart=always \
--name emqx \
-p 1883:1883 \
-p 8883:8883 \
-p 8083:8083 \
-p 8084:8084 \
-p 8081:8081 \
-p 18083:18083 \
-v /wz_conf/emqx/etc:/opt/emqx/etc \
-v /wz_conf/emqx/data:/opt/emqx/data \
-v /wz_conf/emqx/log:/opt/emqx/log \
emqx/emqx:latest

这里就不再详细说明了，如果不需要开启SSL/TLS，到这里也就可以了。

4、EMQX加载自签名证书

这里我是用的EMQX是5.8.0版本的，通过修改emqx.conf配置文件实现，也可以通过官方文档说的在dashboard中配置。
将生成的证书文件挂载到容器内/opt/emqx/etc/certs目录下，修改/opt/emqx/etc/emqx.conf配置文件末尾添加如下内容：

listeners.ssl.default {bind = "0.0.0.0:8883"ssl_options {# PEM 格式的文件，包含一个或多个用于验证客户端证书的根 CA 证书# 单向认证时，该文件内容可以为空# cacertfile = "etc/certs/rootCAs.pem"# PEM 格式的服务器证书，如果证书不是直接由根 CA 签发，那么中间 CA 的证书必须加在服务器证书的后面组成一个证书链certfile = "/opt/emqx/etc/certs/server-cert.pem"# PEM 格式的密钥文件keyfile = "/opt/emqx/etc/certs/server-keyi.pem"# 设置成 'verify_peer' 来验证客户端证书是否为 cacertfile 中某个根证书签发。双向认证时，必须设置成 'verify_peer'。# 设置成 'verify_none' 则不验证客户端证书，即单向认证。verify = verify_none# 如果设置成 true，但是客户端在握手时候没有发送证书，服务端会终止握手。双向认证时，必须设置成 true。# 如果设置成 false，那么服务端只有在客户端发送一个非法证书时才会终止握手fail_if_no_peer_cert = false}
}

配置后重启docker容器即可。重启后也可以通过dashboard查看
在这里插入图片描述

三、客户端MQTTX连接测试

在这里插入图片描述

四、Springboot整合

<!-- mqtt -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-integration</artifactId>
</dependency>
<dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-stream</artifactId>
</dependency>
<dependency><groupId>org.springframework.integration</groupId><artifactId>spring-integration-mqtt</artifactId>
</dependency>

核心代码块
MqttPushCallback.java

import com.webuild.ai.outside.service.OutsideBaseService;
import com.webuild.ai.utils.WelMaxEncryptionUtil;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import java.util.Collection;@Component
@Slf4j
public class MqttPushCallback implements MqttCallback {@Autowiredprivate MqttConfig mqttConfig;private static MqttClient client;@Overridepublic void connectionLost(Throwable throwable) {log.info("连接断开，可以做重连");// 连接丢失后，一般在这里面进行重连if (client == null || !client.isConnected()) {mqttConfig.getMqttPushClient();}}@Overridepublic void messageArrived(String topic, MqttMessage mqttMessage) throws Exception {byte[] payload = mqttMessage.getPayload();String mqttMessagePayload = new String(payload);// 接收消息内容(转为字符串格式)// TODO 自己的处理逻辑}@Overridepublic void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {log.info("deliveryComplete---------" + iMqttDeliveryToken.isComplete());}
}

MqttPushClient.java

import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;import javax.net.ssl.SSLContext;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;
import java.security.cert.X509Certificate;@Component
@Slf4j
public class MqttPushClient {@Autowiredprivate MqttPushCallback mqttPushCallback;private static MqttClient client;public MqttClient getClient() {return client;}private static void setClient(MqttClient client) {MqttPushClient.client = client;}/*** 客户端连接** @param host      ip+端口* @param clientID  客户端Id* @param username  用户名* @param password  密码* @param timeout   超时时间* @param keepalive 保留数*/public void connect(String host, String clientID, String username, String password, int timeout, int keepalive) {MqttClient client;try {client = new MqttClient(host, clientID, new MemoryPersistence());MqttConnectOptions options = new MqttConnectOptions();if(host.startsWith("ssl")) {// 配置忽略 CN 验证SSLContext sslContext = SSLContext.getInstance("TLSv1.2");sslContext.init(null, new TrustManager[]{new X509TrustManager() {@Overridepublic void checkClientTrusted(X509Certificate[] chain, String authType) {}@Overridepublic void checkServerTrusted(X509Certificate[] chain, String authType) {}@Overridepublic X509Certificate[] getAcceptedIssuers() {return new X509Certificate[0];}}}, new java.security.SecureRandom());options.setSocketFactory(sslContext.getSocketFactory());}options.setCleanSession(true);options.setUserName(username);options.setPassword(password.toCharArray());options.setConnectionTimeout(timeout);options.setKeepAliveInterval(keepalive);MqttPushClient.setClient(client);try {client.setCallback(mqttPushCallback);client.connect(options);} catch (Exception e) {log.error("设置mqttPushCallback异常. e={}",e);}} catch (Exception e) {log.error("mqtt链接异常. e={}", e);}}
}

MqttClientUtil.java

import com.webuild.ai.config.MqttPushClient;
import com.webuild.ai.config.SpringValueConfig;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.MqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.MqttTopic;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;@Component
@Slf4j
public class MqttClientUtil {@Autowiredprivate MqttPushClient mqttPushClient;/*** 发布消息** @Description* @Param pushMessage* @Param topic* @Return void* @Author Administrator* @Date 2024/9/2 11:13**/public void publish(String pushMessage, String topic) {try {log.info(">>>>>>>mqtt推送消息>>>>>>>>. pushMessage={}, topic={}", pushMessage, topic);publish(pushMessage, topic, 0, false);} catch (Exception e) {log.error("mqtt发布消息异常. topic={}, pushMessage={}", topic, pushMessage);}}/*** 发布消息* * @Description * @Param pushMessage* @Param topic* @Param qos* QoS 0: 至多一次（At most once） 消息会被尽力而为地传递，但不保证消息会被送达。也就是说，消息可能会丢失，不会有确认消息发送给发布者* 1: 至少一次（At least once） 消息会被至少传递一次。发布者发送消息后会等待接收方的确认（PUBACK）。如果没有收到确认，消息会被重新发送，直到收到确认消息为止。这意味着接收方可能会收到重复的消息。* 2: 只一次（Only once）消息确保只会传递一次。通过四步握手（四个消息交换：PUBLISH、PUBREC、PUBREL、PUBCOMP）来保证消息既不会丢失也不会重复。这是最可靠的传输模式，但也会带来最大的开销* @Param retained* True (保留消息):当retained设为true时，Broker会保留这条消息，当新的客户端订阅这个Topic时，Broker会立即将这条保留消息发送给订阅者。新的保留消息会覆盖之前的保留消息。* False (非保留消息):当retained设为false时，消息不会被Broker保留。只有在消息发布后已有订阅者能收到该消息，新的订阅者不会收到这个消息。* @Return void* @Author Administrator* @Date 2024/9/2 11:07     **/public void publish(String pushMessage, String topic, int qos, boolean retained) {MqttMessage message = new MqttMessage();message.setPayload(pushMessage.getBytes());message.setQos(qos);message.setRetained(retained);MqttTopic mqttTopic = mqttPushClient.getClient().getTopic(topic);if (null == mqttTopic) {log.error("topic is not exist");}MqttDeliveryToken token;//Delivery:配送synchronized (this) {//注意：这里一定要同步，否则，在多线程publish的情况下，线程会发生死锁try {token = mqttTopic.publish(message);//也是发送到执行队列中，等待执行线程执行，将消息发送到消息中间件
//                token.waitForCompletion(5000L);} catch (Exception e) {log.error("mqtt publish error:={}", e);}}}
}

docker安装Emqx并使用自签名证书开启 SSL/TLS 连接

docker安装Emqx并使用自签名证书开启 SSL/TLS 连接一、获取自签名证书1、创建openssl.cnf文件2、生成证书自签名证书二、docker安装EMQX1、初始化目录2、加载镜像文件并挂载相应的文件目录3、启动docker容器4、EMQX加载自签名证书三、客户端MQTTX连接测试四、Springboot整合…...

编程日记 2025/7/15 7:26:13

AI驱动的低代码平台：解密背后的算法与架构创新

引言在如今的数字化浪潮中，企业对软件的需求正以前所未有的速度增长。传统的开发方式由于开发周期长、成本高，已逐渐无法满足市场的快速变化。而低代码平台的出现，使得开发者和业务人员能够以极简的方式快速构建应用。然而，随着企…...

编程日记 2025/7/9 7:24:59

ruoyi的excel批量导入

最简单方式若依的官方文档提供了教程，可以按照起前后端的教学，进行代码编写前段组件 <el-dialogtitle"导入数据"v-model"openImport"width"500px"append-to-body><el-uploadref&quo…...

编程日记 2025/7/13 22:25:14

大数据-244 离线数仓 - 电商核心交易 ODS层数据库结构数据加载 DataX

点一下关注吧！！！非常感谢！！持续更新！！！ Java篇开始了！ 目前开始更新 MyBatis，一起深入浅出！ 目前已经更新到了： Hadoop&#xff0…...

编程日记 2025/7/14 1:24:17

Spring Security

一.权限控制 1.1 认证和授权概念问题1：在生产环境下我们如果不登录后台系统就可以完成这些功能操作吗？ 答案显然是否定的，要操作这些功能必须首先登录到系统才可以。问题2：是不是所有用户，只要登录成功就都可以操…...

编程日记 2025/7/14 18:17:47

OpenAI 正式发布 o1 完整版

OpenAI 在 o1 模型完整版，该模型相较于之前的 o1-preview 版本在智能能力上有所提升，特别是在编程能力方面，并且能够根据问题的难度智能调节响应速度。此外还新增了图像识别功能，但目前仍然不支持网页浏览、文件上传等功能 o1 模…...

编程日记 2025/7/15 7:23:17

Ubuntu22.04搭建LAMP环境（linux服务器学习笔记）

目录引言： 一、系统更新二、安装搭建Apache2 1.你可以通过以下命令安装它： 2.查看Apache2版本 3.查看Apache2运行状态 4.浏览器访问三、安装搭建MySQL 1.安装MySQL 2.查看MySQL 版本 3.安全配置MySQL 3.1是否设置密码？(按y|Y表…...

编程日记 2025/7/10 23:42:45

C#与PLC通讯时，数据读取和写入浮点数，字节转换问题（ModbusTCP）

在与PLC进行通讯时，会发现一个问题，浮点数1.2接收过来后，居然变成了两个16位的整数。经过一系列的分析，这是因为在PLC存储浮点数时32位，我们接收过来的数据会变成两个16位的高低字节，而且我们进行下发数据…...

编程日记 2025/7/12 15:44:45

synchronized的特性

1.互斥对于synchronized修饰的方法及代码块不同线程想同时进行访问就会互斥。就比如synchronized修饰代码块时，一个线程进入该代码块就会进行“加锁”。退出代码块时会进行“解锁”。当其他线程想要访问被加锁的代码块时，就会阻塞等待。阻塞等待…...

编程日记 2025/7/9 1:56:11

NLP与LLM的工程化实践与学习思考 - 说说知识图谱

NLP与LLM的工程化实践与学习思考[24年半年工作总结] - 说说知识图谱 0 真的就是先说说1 为什么知识图谱什么是知识图谱？基于图的数据结构？基于数据结构的图？知识图谱的技术要点两个技术维度：知识、图七个技术要点：表示…...

编程日记 2025/7/13 20:47:46

php 系统函数记录

PHP intval() 函数 PHP函数介绍—array_key_exists(): 检查数组中是否存在特定键名如何使用PHP中的parse_url函数解析URL PHP is_array()函数详解，PHP判断是否为数组 PHP函数介绍：in_array()函数 strpos定义和用法 strpos() 函数查找字符串在另一字符串…...

编程日记 2025/7/8 21:31:49

游戏引擎学习第38天

仓库: https://gitee.com/mrxiao_com/2d_game 回顾上次的内容。我们之前讨论了将精灵放在屏幕上，但颜色错误的问题。问题最终查明是因为使用了一个调整工具，导致文件的字节顺序发生了变化。重新运行“image magic”工具对一些大图像进行重新处理后&am…...

编程日记 2025/7/13 20:20:23

Android 15 行为变更：所有应用

Android 15 平台包含一些可能会影响您的应用的行为变更。以下行为变更将影响在 Android 15 上运行的所有应用，无论采用哪种 targetSdkVersion 都不例外。您应该测试您的应用，然后根据需要进行修改，以适当地支持这些变更。此外，请…...

编程日记 2025/7/14 18:51:00

基于pytorch的深度学习基础4——损失函数和优化器

四．损失函数和优化器 4.1 均值初始化为减轻梯度消失和梯度爆炸，选择合适的权重初值。十种初始化方法 Initialization Methods 1. Xavie r均匀分布 2. Xavie r正态分布 4. Kaiming正态分布 5. 均匀分布 6. 正态分布 7. 常数分布 8. 正交矩阵初…...

编程日记 2025/7/8 5:18:57

《Clustering Propagation for Universal Medical Image Segmentation》CVPR2024

摘要这篇论文介绍了S2VNet，这是一个用于医学图像分割的通用框架，它通过切片到体积的传播（Slice-to-Volume propagation）来统一自动（AMIS）和交互式（IMIS）医学图像分割任务。S2VNet利…...

编程日记 2025/7/12 17:47:07

Webpack Source Map 配置详解与优化策略

前言 Source Map 是前端开发和调试中的核心工具之一，它可以显著提高我们在代码调试和错误追踪方面的效率。随着 JavaScript 应用越来越复杂，代码打包和优化成为必然，而这一过程会使得调试变得异常困难。Source Map 的出现，为我们…...

编程日记 2025/7/11 14:48:22

el-tree组件刷新指定id的节点数据

示例封装一个可以刷新多个指定id的节点数据。 <template><el-tree ref"treeRef"></el-tree> </template><script lang"ts" setup> const treeRef ref()function refreshTreeById(nodeIds: number[]) {nodeIds.forEach((…...

编程日记 2025/7/14 5:30:27

深入 Java 基础 XML：高级特性与最佳实践

在上一篇文章中，我们对 Java 基础 XML 有了一个初步的认识，了解了 XML 的基本结构以及在 Java 中常见的解析方式。今天，我们将进一步深入探讨 Java 与 XML 的结合，包括一些高级特性和最佳实践。一、XML 命名空间在复杂的 XML …...

编程日记 2025/7/13 23:06:08

aws(学习笔记第十六课) 使用负载均衡器(ELB)解耦webserver以及输出ELB的日志到S3

aws(学习笔记第十六课) 使用负载均衡器(ELB)以及输出ELB的日志到S3 学习内容： 使用负载均衡器(ELB)解耦web server输出ELB的日志到S3 1. 使用负载均衡器(ELB) 全体架构使用ELB(Elastic Load Balancer)能够解耦外部internet访问和web server之间的耦合&#xff0c…...

编程日记 2025/7/13 8:06:18

Ubuntu与Centos系统有何区别？

Ubuntu和CentOS都是基于Linux内核的操作系统，但它们在设计理念、使用场景和技术实现上有显著的区别。以下是详细的对比： 1. 基础和发行版本 Ubuntu： 基于Debian，使用.deb包管理系统。包含两个主要版本： LTS&#xff…...

编程日记 2025/7/13 23:05:54

【OpenDRIVE_Python】使用python脚本读取txt指定内容，输出OpenDRIVE数据中对应的信息

示例代码说明： 读取txt指定内容如地物id，输出OpenDRIVE数据中的对应地物id和名称name信息为xml文件 import xml.dom.minidom from xml.dom.minidom import parse from xml.dom import Node import sys import os # 读取OpenDRIVE文件路径 xml_filepath…...

编程日记 2025/7/15 4:00:45

Qt入门8——Qt文件

1. Qt文件概述文件操作是应用程序必不可少的部分。Qt作为⼀个通用开发库，提供了跨平台的文件操作能力。Qt 提供了很多关于文件的类，通过这些类能够对文件系统进行操作，如文件读写、文件信息获取、文件复制或重命名等。 2. 输入输出设备类在…...

编程日记 2025/7/9 1:14:24

【每天一道面试题】JWT是什么？Java-jwt是什么？（2024/12/7)

【每天一道面试题】JWT是什么？Java-jwt是什么？（2024/12/7) JWT：JSON Web Token 俗称令牌当我们想实现： 1.用户不用输入用户名和密码就可以登录（不用每次都输入用户名和密码） 2.用户的信息在传…...

编程日记 2025/7/13 8:21:35

ORB-SLAM3源码学习：ImuTypes.cc：Eigen::Matrix3f RightJacobianSO3计算右雅可比矩阵

前言计算右雅可比矩阵这个函数涉及到了函数重载，可以接受不同的参数来实现计算右雅可比矩阵。代码分析右雅可比矩阵： /** * brief 计算右雅可比* param xyz 李代数* return Jr*/ Eigen::Matrix3f RightJacobianSO3(const float &x, const fl…...

编程日记 2025/7/13 14:13:13

电子公文交换系统设计 ——基于商用密码标准的密码模块的应用

文章目录《密码系统设计》实验实验项目实验四密码模块的应用实践要求（40 分） 《密码系统设计》实验实验项目实验序号实验名称实验学时数实验目的实验内容实验类型学生学习预期成果实验四密码模块的应用6基于商用密码标准的密码模块的应用对电子公文…...

编程日记 2025/7/13 13:01:43

java抽象类

目录一.抽象类 1.什么是抽象类 2.抽象类特点 (1)抽象类不能直接实例化对象 (2)可以包含抽象方法和具体方法 (3)可以有构造方法 (4)抽象类必须被继承，并且继承后子类要重写父类中的抽象方法，否则子类也是抽象类，必须要使用 abstract 修…...

编程日记 2025/7/14 5:43:19

渤海证券基于互联网环境的漏洞主动防护方案探索与实践

来源：中国金融电脑作者：渤海证券股份有限公司信息技术总部刘洋伴随互联网业务的蓬勃发展，证券行业成为黑客进行网络攻击的重要目标之一，网络攻击的形式也变得愈发多样且复杂。网络攻击如同悬于行业之上的达摩克利斯之剑&…...

编程日记 2025/7/13 12:40:55

前提：服务器之前做过域名映射、免密登录 ClouderaManager 集群 1. 组件分布规划服务器服务器h1zk、hdfs(dn)、yarn(nm)、spark、kafka、flumeh2hdfs(nn-standy)、yarn(rm-active)、sparkh3hdfs(nn-active)、yarn(rm-standy)、hive、sparkh4zk、hdfs(dn)、yarn(n…...

编程日记 2025/7/9 14:38:42

Nginx部署PHP服务端跨域以及跨域携带cookie

🤵 作者：coderYYY 🧑 个人简介：前端程序媛，目前主攻web前端，后端辅助，其他技术知识也会偶尔分享🍀欢迎和我一起交流！🚀（评论和私信一般会回！！） 👉 个人专栏推荐：《前端项目教程以及代码》 ✨一、前言前端技术栈Vue+后端技术栈PHP+Mysql鉴权以及存储信息用…...

编程日记 2025/7/15 6:02:55

流量转发利器之Burpsuite概述(1)

目录一、Burpsuite Burp Suite Spider 的主要特点： 在 Burp Suite 中使用 Spider： Spider 的用例： 限制： 声明：学习视频来自b站up主泷羽sec，如涉及侵权马上删除文章声明：本文主要用作技…...

编程日记 2025/7/14 8:33:19

【优选算法二分查找】二分查找算法入门详解：二分查找小专题

x 的平方根题目解析算法原理解法一： 暴力解法如果要求一个数(x)的平方根，可以从 0 往后枚举，直到有一个数(a)，a^2<x，(a1)^2>x，a即为所求； 解法二：二分查找 …...

编程日记 2025/7/10 13:34:45

LeetCode—56. 合并区间（中等）

题目描述： 以数组 intervals 表示若干个区间的集合，其中单个区间为 intervals[i] [starti, endi] 。请你合并所有重叠的区间，并返回一个不重叠的区间数组，该数组需恰好覆盖输入中的所有区间。示例1： 输入&#x…...

编程日记 2025/7/14 16:47:33

SHELL----正则表达式

一、文本搜索工具——grep grep -参数条件文件名其中参数有以下： -i 忽略大小写 -c 统计匹配的行数 -v 取反，不显示匹配的行 -w 匹配单词 -E 等价于 egrep ，即启用扩展正则表达式 -n 显示行号 -rl 将指定目录内的文件打…...

编程日记 2025/7/9 5:15:58

web斗地主游戏实现指北

前后端通信作为一个即时多人游戏，不论是即时聊天还是更新玩家状态，都需要服务端有主动推送功能，或者客户端轮询。轮询的时间间隔可能导致游玩体验差，因为不即时更新，而且请求数量太多可能会打崩服务器。建议在cs间…...

编程日记 2025/7/13 23:10:58

ES(elasticsearch)整合Spring boot使用实例

1.1通过docker安装es详细教程参考 docker部署elasticsearch(内涵集群部署的compose文件)-CSDN博客 2.1创建MySQL数据库，通过sql命令进行表的创建与数据的写入（sql命令如下） /*Navicat Premium Data TransferSource Server : localSo…...

编程日记 2025/7/14 15:40:13

创建简单的 PL/pgSQL 存储过程

文章目录创建简单的 PL/pgSQL 存储过程CREATE OR REPLACE FUNCTIONadd_two_numbers(a integer, b integer)RETURNS integerAS$$ ... $$函数体LANGUAGE plpgsql 创建带有 IN 和 OUT 参数的存储过程创建修改数据的存储过程创建带有异常处理的复杂存储过程在 PostgreSQL 中&…...

编程日记 2025/7/10 22:01:27

前端路径“@/“的使用和配置

环境：vitets 需要安装types/node npm install types/node --save-dev在tsconfig.json中添加如果有tsconfig.app.json和tsconfig.node.json文件，则在app.json中添加 "compilerOptions": {"baseUrl":".","paths&q…...

编程日记 2025/7/9 4:33:07

彻底理解ThreadLocal的应用场景和底层实现

一.概念定义： ThreadLocal 是 Java 中所提供的线程本地存储机制，可以利用该机制将数据缓存在某个线程内部，该线程可以在任意时刻、任意方法中获取缓存的数据。其实是可以通过调用 Set() 方法往里面存入值，存入的值是每个线程互…...

编程日记 2025/7/13 9:57:27

机器学习（5）无监督模型之降维PCA算法

主成分分析（Principal Component Analysis, PCA） 是一种经典的无监督学习算法，主要用于数据降维、特征提取和数据可视化。它通过线性变换将数据从原始空间映射到一个新的空间，使得数据的方差最大化，从而实现降维。PCA …...

编程日记 2025/7/10 11:28:12

React 组件中 State 的定义、使用及正确更新方式

🌈个人主页：前端青山 🔥系列专栏：React篇 🔖人终将被年少不可得之物困其一生依旧青山,本期给大家带来React篇专栏内容React 组件中 State 的定义、使用及正确更新方式前言在 React 应用开发中，state …...

编程日记 2025/7/8 2:05:50

18 设计模式之迭代器模式（书籍遍历案例）

一、什么是迭代器模式迭代器模式（Iterator Pattern）是一种行为型设计模式，允许客户端通过统一的接口顺序访问一个集合对象中的元素，而无需暴露集合对象的内部实现。这个模式主要用于访问聚合对象（如集合、数组等&…...

编程日记 2025/7/14 8:54:26

Springboot3介绍

一、Springboot3简介: https://docs.spring.io/spring-boot/docs/current/reference/html/getting-started.html?spmwolai.workspace.0.0.68b62306Q6jtTw#getting-started.introducing-spring-boot 无论使用XML、注解、Java配置类还是他们的混合用法，配置文件过于…...

编程日记 2025/7/8 22:43:24

【Leetcode Top 100】23. 合并 K 个升序链表

问题背景给你一个链表数组，每个链表都已经按升序排列。请你将所有链表合并到一个升序链表中，返回合并后的链表。数据约束 k l i s t s . l e n g t h k lists.length klists.length 0 ≤ k ≤ 1 0 4 0 \le k \le 10^4 0≤k≤104 0 ≤ l i s t s […...

编程日记 2025/7/11 21:23:56

显存和GPU之间的通信；GPUDirect P2P，NVLink，NCCL；聚合通信和点对点通信

目录显存和GPU之间的分配显存和GPU之间的通信原语是什么，简单举例说明 GPUDirect P2P，NVLink，NCCL的全称及解释聚合通信和点对点通信聚合通信（Collective Communication）点对点通信（Point-to-Point Communication）为什么使用GPUDirect P2P，NVLink，NCCL…...

编程日记 2025/7/13 14:19:37

2412d,d的7月会议

原文总结卡斯滕 Carsten说,Decard一直在大量试验WebAssembly.他们一直在把d运行时挖出来,直到它工作.他们在浏览器中运行了一些库函数,并试了不同虚机. 他们在移动方面遇见了很多问题,因为不同芯片按不同方式工作.他们想让他们的整个SDK在WASM上运行,但可能需要一年时间才…...

编程日记 2025/7/13 4:30:02

vue框架

以下是一个简单的基于Vue框架的日历组件示例： <template><div class"calendar"><div class"header"><button click"prevMonth"><</button><h2>{{ currentMonth }}</h2><button cli…...

编程日记 2025/7/12 14:12:00

Django drf基于APIView 快速使用

1. 注册 # settings.pyINSTALLED_APPS [,rest_framework, ]2. 路由 from django.urls import pathurlpatterns [path(task/, views.TaskAPIView.as_view()) ]3. 视图 from rest_framework.views import APIView from rest_framework.response import Responseclass TaskAPIV…...

编程日记 2025/7/12 19:03:22

docker安装Emqx并使用自签名证书开启 SSL/TLS 连接

一、获取自签名证书

1、创建openssl.cnf文件

2、生成证书自签名证书

二、docker安装EMQX

1、初始化目录

2、加载镜像文件并挂载相应的文件目录

3、启动docker容器

4、EMQX加载自签名证书

三、客户端MQTTX连接测试

四、Springboot整合

相关文章：