# 全面解剖 消息中间件 RocketMQ-（2）

news2024/11/23 4:47:04

全面解剖 消息中间件 RocketMQ-（2）

一、RocketMQ – RocketMQ 各角色介绍

1、RocketMQ 各角色介绍

  • Producer : 消息的发送者; 举例:发信者。
  • Consumer : 消息接收者; 举例:收信者。
  • Broker : 暂存和传输消息; 举例:邮局。
  • NameServer : 管理 Broker; 举例:各个邮局的管理机构
  • Topic : 区分消息的种类; 一个发送者可以发送消息给一个或者多个 Topic; 一个消息的接收者可以订阅一个或者多个 Topic 消息。
  • Message Queue : 相当于是 Topic 的分区;用于并行发送和接收消息。

2、RocketMQ 各角色 示例图：

在这里插入图片描述

二、RocketMQ – RocketMQ 集群特点

1、NameServer 是一个几乎无状态节点，可集群部署，节点之间无任何信息同步。

2、Broker 部署相对复杂，Broker 分为 Master 与 Slave，一个 Master 可以对应多个 Slave，但是一个 Slave 只能对应一个 Master。Master 与 Slave 的对应关系通过指定相同的 BrokerName，不同的 Brokerld 来定义，Brokerld 为 0 表示 Master，非 0 表示 Slave。

3、Master 也可以部署多个。每个 Broker 与 NameServer 集群中的所有节点建立长连接，定时注册 Topic 信息到所有 NameServer。

4、Producer 与 NameServer 集群中的其中一个节点(随机选择)建立长连接，定期从 NameServer 取 Topic 路由信息，并向提供 Topic 服务的 Master 建立长连接，且定时向 Master 发送心跳。Producer 完全无状态，可集群部署。

5、Consumer 与 NameServer 集群中的其中一个节点(随机选择)建立长连接，定期从 NameServer 取 Topic 路由信息，并向提供 Topic 服务的 Master、Slave 建立长连接，且定时向 Master、Slave 发送心跳。Consumer 既可以从 Master 订阅消息，也可以从 Slave 订阅消息，订阅规则由 Broker 配置决定。

三、RocketMQ – RocketMQ 各种集群模式介绍

1、单 Master 模式

这种方式风险较大，一旦Broker重启或者宕机时，会导致整个服务不可用。不建议线上环境使用,可以用于本地测试。

2、多 Master 模式

一个集群无 Slave，全是 Master，例如2个 Master 或者3个 Master，这种模式的优缺点如下:

  • 优点 : 配置简单，单个 Master 宕机或重启维护对应用无影响，在磁盘配置为 RAID10 时，即使机器宕机不可恢复情况下，由于 RAID10 磁盘非常可靠，消息也不会丢(异步刷盘丢失少量消息，同步刷盘一条不丢)，性能最高;

  • 缺点:单台机器宕机期间，这台机器上未被消费的消息在机器恢复之前不可订阅，消息实时性会受到影响。

3、多 Master 多 Slave 模式(异步)

每个 Master 配置一个 Slave，有多对 Master-Slave，HA 采用异步复制方式，主备有短暂消息延迟(毫秒级)，这种模式的优缺点如下:

  • 优点 :
    即使磁盘损坏，消息丢失的非常少，且消息实时性不会受影响，同时Master宕机后，消费者仍然可以从Slave消费，而且此过程对应用透明，不需要人工干预，性能同多Master模式几乎一样;

  • 缺点 :
    Master宕机，磁盘损坏情况下会丢失少量消息。

4、多 Master 多 Slave 模式(同步)

每个 Master 配置一个 Slave，有多对 Master-Slave，HA 采用同步双写方式，即只有主备都写成功，才向应用返回成功，这种模式的优
缺点如下:

  • 优点 :
    数据与服务都无单点故障，Master 宕机情况下，消息无延迟，服务可用性与数据可用性都非常高;

  • 缺点 :
    性能比异步复制模式略低(大约低10%左右)，发送单个消息的RT会略高，且目前版本在主节点宕机后，备机不能自动切换为主机。

四、RocketMQ – 双主双从（2m-2s）集群介绍和工作流程说明

1、RocketMQ – 双主双从（2m-2s）集群介绍总体架构：消息高可用采用 2m-2s（同步双写）方式。

在这里插入图片描述

2、RocketMQ – 双主双从（2m-2s）集群工作流程说明

  • 1）启动 NameServer，NameServer 起来后监听端口，等待 Broker、Producer、Consumer 连上来，相当于一个路由控制中心。

  • 2）Broker 启动，跟所有的 NameServer 保持长连接，定时发送心跳包。心跳包中包含当前 Broker信息(IP+端口等)以及存储所有 Topic 信息。注册成功后，NameServer 集群中就有 Topic 跟 Broker 的映射关系。

  • 3）收发消息前，先创建 Topic，创建Topic时需要指定该 Topic 要存储在哪些 Broker 上，也可以在发送消息时自动创建 Topic。

  • 4） Producer 发送消息，启动时先跟 NameSErver 集群中的其中一台建立长连接，并从 NameServer 中获取当前发送的 Topic 存在哪些Broker 上，轮询从队列列表中选择一个队列，然后与队列所在的 Broker 建立长连接从而向 Broker 发消息。

  • 5） Consumer 跟 Producer 类似，跟其中一台 NameServer 建立长连接，获取当前订阅 Topic 存在哪些 Broker上，然后直接跟 Broker 建立连接通道，开始消费消息。

五、RocketMQ – 集群搭建1

1、RocketMQ–集群搭建–服务器环境

序号IP角色架构模式
1192.168.25.135nameserver、brokerserverMaster1、Slave2
2192.168.25.138nameserver、brokerserverMaster2、Slave1

2、RocketMQ–集群搭建–Host 添加信息

（在两个虚拟机上都要添加配置：192.168.25.135 和 192.168.25.138）


vim /etc/hosts
配置如下:

# nameserver
192.168.25.135 rocketmq-nameserver1
192.168.25.138 rocketmq-nameserver2

# broker
192.168.25.135 rocketmq-master1
192.168.25.135 rocketmq-slave2
192.168.25.138 rocketmq-master2
192.168.25.138 rocketmq-slave1

# 配置完成后,重启网卡
systemctl restart network

3、RocketMQ–集群搭建–防火墙配置

（在两个虚拟机上都要添加配置：192.168.25.135 和 192.168.25.138）

1）宿主机需要远程访问虚拟机的 rocketmq 服务和 web 服务，需要开放相关端口号，简单粗暴的方式是直接关闭防火墙。


# 关闭防火墙
systemctl stop firewalld.service 

# 查看防火墙状态
firewall -cmd --state 

# 禁止 firewall 开机启动
sysemctl disable firewalld.service

2）或者为了安全，只开放特定的端口号，RocketMQ 默认使用3个端口：9876，10911，11011.如果防火墙没有关闭，那么防火墙就必须开放这几个端口。

  • nameserver 默认使用 9876 端口
  • master 默认使用 10911 端口
  • slave 默认使用 11011 端口

执行以下命令


# 开放 nameserver 默认使用 9876 端口
firewall -cmd --remove-port=9876/tcp --permanent

# 开放 master 默认使用 10911 端口
firewall -cmd --remove-port=10911/tcp --permanent

# 开放 slave 默认使用 11011 端口
firewall -cmd --remove-port=11011/tcp --permanent

# 重启防火墙
firewall -cmd --reload

4、RocketMQ–集群搭建–环境变量配置

（在两个虚拟机上都要添加配置：192.168.25.135 和 192.168.25.138）


vim /etc/profile

# 在profile文件的末尾加入如下命令

#set rocketmq
ROCKETMQ_HOME=/usr/local/rocketmq/rocketmq-all-4.5.1-bin-release
PATH=$PATH: $ROCKETMQ_HOME/bin
export ROCKETMQ_HOME PATH


# 输入: wq! 保存并退出，并使得配置立刻生效:
source /etc/profile

5、RocketMQ–集群搭建–创建消息存储路径

（在两个虚拟机上都要添加配置：192.168.25.135 和 192.168.25.138）


mkdir /usr/loca1/rocketmq/store
mkdir /usr/loca1/rocketmq/store/commitlog
mkdir /usr/local/rocketmq/store/consumequeue
mkdir /usr/local/rocketmq/store/index

六、RocketMQ – 集群搭建2

1、RocketMQ–集群搭建2–broker 配置文件

修改 服务器 192.168.25.135 上的 broker 配置文件 配置 master1


vim /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-a.properties

# 修改配置如下

# 所属集群名字
brokerclusterName=rocketmq-cluster

# broker 名字，注意此处不同的配置文件填写的不一样
brokerName=broker-a

# 0 表示 Master, >0 表示 slave
brokerid=0

# nameserver 地址，分号分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876

# 在发送消息时，自动创建服务器不存在的 topic，默认创建的队列数
defaultTopicQueueNums=4

# 是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true

# 是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autocreatesubscriptionGroup=true

# Broker 对外服务的监听端口
listenPort=10911

# 删除文件时间点，默认凌晨4点
deletewhen=04

# 文件保留时间，默认48小时
fileReservedTime=120

# commitLog 每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824

# ConsumeQueue 每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000

# destroyMapedFileIntervalForcibly=120000
# redeleteHangedFileInterval=120000
# 检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88

# 存储路径
storePathRootDir=/usr/local/rocketmq/store

# commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/commitlog

# 消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue

# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/index

# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/checkpoint

# abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort

# 限制的消息大小
maxMessageSize=65536

# flushCommitLogLeastPages=4
# flushConsumeQueueLeastPages=2
# flushCommitLogThoroughInterval=10000
# flushConsumeQueueThoroughInterval=60000
# Broker 的角色
#- ASYNC MASTER异步复制Master
#- SYNC MASTER同步双写Master
#- SLAVE
brokerRole=SYNC_MASTER

# 刷盘方式
#- ASYNC FLUSH 异步刷盘
#- SYNC FLUSH 同步刷盘
flushDiskType=SYNC_FLUSH

# checkTransactionMessageEnable=false
# 发消息线程池数量
# sendMessageThreadPoolNums=128
# 拉消息线程池数量
# pullMessageThreadPoolNums=128

2、RocketMQ–集群搭建2–broker 配置文件

修改 服务器 192.168.25.135 上的 broker 配置文件 配置 slave2



vim /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-b-s.properties

# 修改配置如下

# 所属集群名字
brokerclusterName=rocketmq-cluster

# broker 名字，注意此处不同的配置文件填写的不一样
brokerName=broker-b

# 0 表示 Master, >0 表示 slave
brokerid=1

# nameserver 地址，分号分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876

# 在发送消息时，自动创建服务器不存在的 topic，默认创建的队列数
defaultTopicQueueNums=4

# 是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true

# 是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autocreatesubscriptionGroup=true

# Broker 对外服务的监听端口
listenPort=11011

# 删除文件时间点，默认凌晨4点
deletewhen=04

# 文件保留时间，默认48小时
fileReservedTime=120

# commitLog 每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824

# ConsumeQueue 每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000

# destroyMapedFileIntervalForcibly=120000
# redeleteHangedFileInterval=120000
# 检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88

# 存储路径
storePathRootDir=/usr/local/rocketmq/store

# commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/commitlog

# 消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue

# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/index

# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/checkpoint

# abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort

# 限制的消息大小
maxMessageSize=65536

# flushCommitLogLeastPages=4
# flushConsumeQueueLeastPages=2
# flushCommitLogThoroughInterval=10000
# flushConsumeQueueThoroughInterval=60000
# Broker 的角色
#- ASYNC MASTER异步复制Master
#- SYNC MASTER同步双写Master
#- SLAVE
brokerRole=SLAVE

# 刷盘方式
#- ASYNC FLUSH 异步刷盘
#- SYNC FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH

# checkTransactionMessageEnable=false
# 发消息线程池数量
# sendMessageThreadPoolNums=128
# 拉消息线程池数量
# pullMessageThreadPoolNums=128

3、RocketMQ–集群搭建2–broker 配置文件

修改 服务器 192.168.25.138 上的 broker 配置文件 配置 master2


vim /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-b.properties

# 修改配置如下

# 所属集群名字
brokerclusterName=rocketmq-cluster

# broker 名字，注意此处不同的配置文件填写的不一样
brokerName=broker-b

# 0 表示 Master, >0 表示 slave
brokerid=0

# nameserver 地址，分号分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876

# 在发送消息时，自动创建服务器不存在的 topic，默认创建的队列数
defaultTopicQueueNums=4

# 是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true

# 是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autocreatesubscriptionGroup=true

# Broker 对外服务的监听端口
listenPort=10911

# 删除文件时间点，默认凌晨4点
deletewhen=04

# 文件保留时间，默认48小时
fileReservedTime=120

# commitLog 每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824

# ConsumeQueue 每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000

# destroyMapedFileIntervalForcibly=120000
# redeleteHangedFileInterval=120000
# 检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88

# 存储路径
storePathRootDir=/usr/local/rocketmq/store

# commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/commitlog

# 消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue

# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/index

# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/checkpoint

# abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort

# 限制的消息大小
maxMessageSize=65536

# flushCommitLogLeastPages=4
# flushConsumeQueueLeastPages=2
# flushCommitLogThoroughInterval=10000
# flushConsumeQueueThoroughInterval=60000
# Broker 的角色
#- ASYNC MASTER异步复制Master
#- SYNC MASTER同步双写Master
#- SLAVE
brokerRole=SYNC_MASTER

# 刷盘方式
#- ASYNC FLUSH 异步刷盘
#- SYNC FLUSH 同步刷盘
flushDiskType=SYNC_FLUSH

# checkTransactionMessageEnable=false
# 发消息线程池数量
# sendMessageThreadPoolNums=128
# 拉消息线程池数量
# pullMessageThreadPoolNums=128

4、RocketMQ–集群搭建2–broker 配置文件

修改 服务器 192.168.25.138 上的 broker 配置文件 配置 slave1


vim /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-a-s.properties

# 修改配置如下

# 所属集群名字
brokerclusterName=rocketmq-cluster

# broker 名字，注意此处不同的配置文件填写的不一样
brokerName=broker-a

# 0 表示 Master, >0 表示 slave
brokerid=1

# nameserver 地址，分号分割
namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876

# 在发送消息时，自动创建服务器不存在的 topic，默认创建的队列数
defaultTopicQueueNums=4

# 是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true

# 是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autocreatesubscriptionGroup=true

# Broker 对外服务的监听端口
listenPort=11011

# 删除文件时间点，默认凌晨4点
deletewhen=04

# 文件保留时间，默认48小时
fileReservedTime=120

# commitLog 每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824

# ConsumeQueue 每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000

# destroyMapedFileIntervalForcibly=120000
# redeleteHangedFileInterval=120000
# 检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88

# 存储路径
storePathRootDir=/usr/local/rocketmq/store

# commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/commitlog

# 消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue

# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/index

# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/checkpoint

# abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort

# 限制的消息大小
maxMessageSize=65536

# flushCommitLogLeastPages=4
# flushConsumeQueueLeastPages=2
# flushCommitLogThoroughInterval=10000
# flushConsumeQueueThoroughInterval=60000
# Broker 的角色
#- ASYNC MASTER异步复制Master
#- SYNC MASTER同步双写Master
#- SLAVE
brokerRole=SLAVE

# 刷盘方式
#- ASYNC FLUSH 异步刷盘
#- SYNC FLUSH 同步刷盘
flushDiskType=ASYNC_FLUSH

# checkTransactionMessageEnable=false
# 发消息线程池数量
# sendMessageThreadPoolNums=128
# 拉消息线程池数量
# pullMessageThreadPoolNums=128

5、RocketMQ–集群搭建2–broker 配置文件 注意事项：


# 1）进入 broker 配置文件 目录：

cd /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/

# 2）注意配置端口号，不要冲突

- nameserver 默认使用 9876 端口
- master 默认使用 10911 端口
- slave 默认使用 11011 端口

# 3）注意修改的 broker 配置文件名和端口号（同一虚拟机服务器端口号不能重复） 

192.168.25.135 rocketmq-master1  vim broker-a.properties 端口：10911
192.168.25.135 rocketmq-slave2   vim broker-b-s.properties 端口：11011

192.168.25.138 rocketmq-master2  vim broker-b.properties 端口：10911
192.168.25.138 rocketmq-slave1   vim broker-a-s.properties  端口：11011

七、RocketMQ – 集群搭建3

1、RocketMQ–集群搭建3–修改启动脚本文件

（注意：在两个虚拟机上都要修改配置：192.168.25.135 和 192.168.25.138）


# 1)修改 runbroker.sh

vi /usr/1oca1/rocketmq/rocketmq-all-4.5.1-bin-release/bin/runbrokeF.sh

# 需要根据内存大小进行适当的对JVM参数进行调整:

# 开发环境配置 JVM Configuration
JAVA_OPT="${JAVA_OPT} -server -xms256m -Xmx256m -Xmn128m"

# 2) 修改 runserver.sh

vim /usr/loca1/rocketmq/rocketmq-all-4.5.1-bin-release/bin/runserver.sh

JAVA_OPT="${JAVA_OPT} -server -xms256m -xmx256m -Xmn128m-XX:Metaspacesize=128m-
XX:MaxMetaspacesize=320m"

2、RocketMQ–集群搭建3–服务启动


# 1)启动 NameServe 集群

# 分别在 192.168.25.135 和 192.168.25.138 启动 NameServer

# 切换目录
cd /usr/loca1/rocketmq/rocketmq-all-4.5.1-bin-release/bin/

# 启动 NameServe 
nohup sh mqnamesrv &

# 查看启动结果
jps 


# 2)启动 Broker 集群--# 在 192.168.25.135 上启动 master1 和 slave2

# master1  切换目录 
cd /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/bin/

# 启动 master1
nohup sh mqbroker -c /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-a.properties &

# slave2:  切换目录
cd /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/bin/

# 启动 slave2
nohup sh mqbroker -c /usr/loca1/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-b-s.properties &

# 查看启动结果
jps 


# 3)启动 Broker 集群--# 在 192.168.25.138 上启动 master2 和 slave1

# master2  切换目录 
cd /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/bin/

# 启动 master2
nohup sh mqbroker -c /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-b.properties &

# slave1:  切换目录
cd /usr/local/rocketmq/rocketmq-all-4.5.1-bin-release/bin/

# 启动 slave1
nohup sh mqbroker -c /usr/loca1/rocketmq/rocketmq-all-4.5.1-bin-release/conf/2m-2s-sync/broker-a-s.properties &

# 查看启动结果
jps

3、RocketMQ–集群搭建3–查看进程状态和查看日志


# 1）启动后通过 jps 查看启动进程
jps 

# 2）查看日志

# 查看 nameServer 日志 
tail -500f ~/logs/rocketmqlogs/namesrv.log 

# 查看 broker 日志 
tail -500f ~/logs/rocketmqlogs/broker.log

八、RocketMQ – 双主双从集群搭建小结

1、总体架构

2、集群搭建工作流程

3、服务器环境

4、Host 添加信息

5、防火墙配置

6、环境变量配置

7、创建消息存储路径

8、broker 配置文件

9、修改启动脚本文件

10、服务启动

11、查看进程状态

12、查看日志。

上一节关联链接请点击：

# 全面解剖 消息中间件 RocketMQ-（1）

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1687501.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

数字人实训室解决方案

数字人实训室解决方案

前言 近年来，政策层面的积极推动为数字人产业铺设了坚实的基石。2021年，“十四五”规划将虚拟数字技术纳入其中，强调技术创新引领行业应用的革新，加速数字人在各领域的实际应用。紧接着的《“十四五”数字经济发展规划》进一步明确…
阅读更多...
CVE-2024-1561 Gradio component_server存在任意文件读取漏洞

CVE-2024-1561 Gradio component_server存在任意文件读取漏洞

声明： 本文仅用于技术交流，请勿用于非法用途 由于传播、利用此文所提供的信息而造成的任何直接或者间接的后果及损失，均由使用者本人负责，文章作者不为此承担任何责任。 简介 Gradio是一个用于构建快速原型和部署机器学习模型的…
阅读更多...
集成环境 ClassNotFound 分析与排查

集成环境 ClassNotFound 分析与排查

项目场景： 最近项目在集成环境，经常会报 ClassNotFound 异常， 而在开发环境通过IDEA查看项目，类是不缺的 原因分析： 经过排查，发现是项目中引用的 API jar包更新了，但是集成环境却没有成功更…
阅读更多...
ATA-2081高压放大器的结构组成及原理是什么

ATA-2081高压放大器的结构组成及原理是什么

高压放大器是一种电子设备，用于将低电压信号增强到高电压水平，以满足特定应用的需求。它们在各种领域中都有广泛的用途，包括医学成像、科学研究、通信系统和声学应用。下面西安安泰电子来为大家介绍高压放大器的结构组成和工作原理。 高压放大…
阅读更多...
kafka Kerberos集群环境部署验证

kafka Kerberos集群环境部署验证

背景 公司需要对kafka环境进行安全验证，目前考虑到的方案有Kerberos和SSL和SASL_SSL，最终考虑到安全和功能的丰富度，我们最终选择了SASL_SSL方案。处于知识积累的角度，记录一下kafka keberos安装部署的步骤。 机器规划 目前测试环境公搭建了三台kafka主机服务，现在将详细…
阅读更多...
国家开放大学Java语言程序设计实验2:分支、循环和跳转语句的使用

国家开放大学Java语言程序设计实验2:分支、循环和跳转语句的使用

作业答案 联系QQ:1603277115 实验目的 通过本实验，了解和掌握分支、循环和跳转语句的使用及常见问题处理。 问题描述 杂物店正在做促销活动，很多商品都在进行特价促销，针对特价商品的购买数量做了限制，具体的促销办法是&#…
阅读更多...
基于物理的AlGaN/GaN高电子迁移率晶体管的紧凑直流和交流模型

基于物理的AlGaN/GaN高电子迁移率晶体管的紧凑直流和交流模型

来源：A Physics-Based Compact Direct-Current and Alternating-Current Model for AlGaN/GaN High Electron obility Transistors（中国物理快报 07年） 摘要 一套针对 AlGaN/GaN 高电子迁移率晶体管 (HEMT) 的直流和小信号特性的分析模型被…
阅读更多...
2024年商业管理与文化传播国际学术会议（ICBMCC 2024)

2024年商业管理与文化传播国际学术会议（ICBMCC 2024)

2024年商业管理与文化传播国际学术会议（ICBMCC 2024) 2024 International Conference on Business Management and Cultural Communication 一、【会议简介】 2024年商业管理与文化传播国际学术会议（ICBMCC 2024）是一次汇集全球商业管理领域…
阅读更多...
Java与GO语言对比分析

Java与GO语言对比分析

你是不是总听到go与java种种对比，其中在高并发的服务器端应用场景会有人推荐你使用go而不是 java。 那我们就从两者运行原理和基本并发设计来对比分析，看看到底怎么回事。 运行原理对比 java java 中 jdk 已经帮我们屏蔽操作系统区别。 只要我们下载并…
阅读更多...
【MySQL数据库】CRUD 增 删 改 查 超详解，有这一篇就够了！

【MySQL数据库】CRUD 增 删 改 查 超详解，有这一篇就够了！

​ ​ 🔥个人主页： 中草药 🔥专栏：【MySQL】探秘：数据库世界的瑞士军刀 目录 ⚗️一.CRUD 🧪二.新增（Create） 🧫1.基本操作 🧬2.使用SELECT插入 &#x…
阅读更多...
【虚拟机软件】 VMware Workstation Pro 17 新建 Linux 虚拟机教程（CentOS 7 版本）

【虚拟机软件】 VMware Workstation Pro 17 新建 Linux 虚拟机教程（CentOS 7 版本）

文章目录 下载安装 VMware Workstation Pro 17 软件下载 Linux 的 ISO 映像文件Linux版本选择 新建虚拟机准备配置新建安装 后续设置文章导航 我是一名立志把细节说清楚的博主，欢迎【关注】🎉 ~ 原创不易， 如果有帮助 ，记得【点赞…
阅读更多...
css动画之hamburgers

css动画之hamburgers

动效1 代码如下&#xff1a; <!DOCTYPE html> <html><head><meta charset"utf-8"><title></title></head><body><div><label class"hamburger"><input type"checkbox"><…
阅读更多...
Redis主从、哨兵、集群讲解

Redis主从、哨兵、集群讲解

一、Redis主从 大家在面试中可能经常会被问到Redis的高可用问题。Redis高可用回答包括两个层面&#xff0c;一个就是数据不能丢失&#xff0c;或者说尽量减少丢失 ;另外一个就是保证Redis服务不中断 。 对于尽量减少数据丢失&#xff0c;可以通过AOF和RDB保证。 对于保证服务…
阅读更多...
捷报频传 | 北京讯通喜获中国信通院2023“Zero Trust Ready SDP解决方案”证书

捷报频传 | 北京讯通喜获中国信通院2023“Zero Trust Ready SDP解决方案”证书

中国信息通信研究院&#xff08;以下简称“中国信通院”&#xff09;算网融合团队联合各生态伙伴&#xff0c;共同发起“Zero Trust Ready”项目&#xff0c;推动零信任&#xff08;Zero Trust&#xff09;技术与产业发展。该项目旨在从垂直行业的网络安全需求出发&#xff0c;…
阅读更多...
『大模型笔记』从头开始代码构建GPT！

『大模型笔记』从头开始代码构建GPT！

从头开始代码构建GPT！ 文章目录 一. 从头开始代码构建GPT！二. 参考文献一. 从头开始代码构建GPT！ 我们构建了一个生成式预训练Transformer (GPT)，遵循论文《Attention is All You Need》和OpenAI的GPT-2 / GPT-3的方法。我们讨论了与ChatGPT的联系，ChatGPT已经风靡全球。我…
阅读更多...
牛马真的沉默了，入职第一天就干活

牛马真的沉默了，入职第一天就干活

入职第一天就干活的&#xff0c;就问还有谁&#xff0c;搬来一台N手电脑&#xff0c;第一分钟开机&#xff0c;第二分钟派活&#xff0c;第三分钟干活&#xff0c;巴适。。。。。。 打开代码发现问题不断 读取配置文件居然读取两个配置文件&#xff0c;一个读一点&#xff0c;…
阅读更多...
掌握Go语言中的net/http包：编写高性能Web服务

掌握Go语言中的net/http包：编写高性能Web服务

掌握Go语言中的net/http包&#xff1a;编写高性能Web服务 引言HTTP服务器构建基础服务器设置路由与处理函数中间件使用高级配置&#xff08;如TLS/SSL&#xff09; HTTP客户端开发创建与使用HTTP客户端处理响应 高级客户端特性 处理JSON与表单数据接收与解析JSON接收与解析表单…
阅读更多...
Langchain：数据连接封装、缓存封装和LCEL学习和探索

Langchain：数据连接封装、缓存封装和LCEL学习和探索

&#x1f335; 目录 &#x1f335; &#x1f60b; 数据连接封装 &#x1f354; 文档加载器&#xff1a;Document Loaders 文档处理器&#xff1a;TextSplitter 向量数据库与向量检索 总结 &#x1f349; 缓存封装&#xff1a;Memory &#x1f3d6;️ 对话上下文&#xf…
阅读更多...
Docker | 基础指令

Docker | 基础指令

环境&#xff1a;centos8 参考&#xff1a; 安装 Docker | Docker 从入门到实践https://vuepress.mirror.docker-practice.com/install/ 安装Docker 卸载旧版本&#xff0c;安装依赖包&#xff0c;添加yum软件源&#xff0c;更新 yum 软件源缓存&#xff0c;安装 docker-ce…
阅读更多...
保研笔试复习——nju

保研笔试复习——nju

文章目录 一、单选计算机网络计算机组成原理数字逻辑电路数据结构操作系统微机系统 多选题计算机网络计算机系统结构操作系统 免责声明&#xff1a;题目源自于网络&#xff0c;侵删。 就在今天2024-5-18&#xff0c;考的题下面的只有一道AVL的原题&#xff0c;其他都不是原题&a…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023